cx.c File Reference

---

Detailed Description

Serving-CSCF - Cx Operations.

Author:

Dragos Vingarzan vingarzan -at- fokus dot fraunhofer dot de

Definition in file cx.c.

#include "cx.h"
#include "../tm/tm_load.h"
#include "cx_avp.h"
#include "sip.h"
#include "registrar_storage.h"
#include "registrar_parser.h"
#include "registration.h"
#include "ims_pm_scscf.h"

Go to the source code of this file.

Functions
int	CxAnswerHandler (AAAMessage *response, AAATransaction *t)
	Handler for incoming Diameter answers.
int	CxFailureHandler (AAATransaction *t, int reason)
	Handler for incoming Diameter failures This is not used as all diameter failures are handled transactionaly.
AAAMessage *	CxRequestHandler (AAAMessage *request, void *param)
	Handler for Diameter incoming requests Not used now as here there are no expected incoming requests.
AAAMessage *	Cx_MAR (struct sip_msg *msg, str public_identity, str private_identity, unsigned int count, str algorithm, str authorization, str server_name, str realm)
	Create and send a Multimedia-Authentication-Request and returns the Answer received for it.
AAAMessage *	Cx_SAR (struct sip_msg *msg, str public_identity, str private_identity, str server_name, str realm, int assignment_type, int data_available)
	Create and send a Server-Assignment-Request and returns the Answer received for it.
AAAMessage *	Cx_RTA (AAAMessage *rtr)
	Process a Registration Termination Request and return the Answer for it.
AAAMessage *	Cx_PPA (AAAMessage *ppr)
	Process a Push Profile Request and return the Answer for it.
Variables
tm_binds	tmb
	Structure with pointers to tm funcs.
cdp_binds	cdpb
	Structure with pointers to cdp funcs.
str	scscf_forced_hss_peer_str
	FQDN of the forced Diameter Peer (HSS).
int	r_hash_size
	records tables parameters
r_hash_slot *	registrar
	the contacts
static str	s_empty = {0,0}
str	auth_scheme_types []

---

Function Documentation

int CxAnswerHandler	(	AAAMessage *	response,
		AAATransaction *	t
	)

Handler for incoming Diameter answers.

This is not used as all diameter answers are handled transactionaly

Parameters:

	response	- received response
	t	- transaction

Returns:

1

Definition at line 81 of file cx.c.

References _message_t::commandCode, and M_NAME.

{
    #ifdef WITH_IMS_PM
        ims_pm_diameter_answer(response);
    #endif      
    switch(response->commandCode){
        default:
            LOG(L_ERR,"ERR:"M_NAME":CxAnswerHandler: Unkown Command Code %d\n",
                response->commandCode);
    }
    return 1;
}

int CxFailureHandler	(	AAATransaction *	t,
		int	reason
	)

Handler for incoming Diameter failures This is not used as all diameter failures are handled transactionaly.

Parameters:

	t	- transaction
	reason	- failure reason

Returns:

1

Definition at line 101 of file cx.c.

References _AAATransaction::command_code, _AAATransaction::hash, _AAATransaction::label, and M_NAME.

{
    LOG(L_INFO,"INF:"M_NAME":AAAFailureHandler:  SIP transaction %u %u Reason %d\n",
        t->hash,t->label,reason);
    switch(t->command_code){
        default:
        LOG(L_ERR,"ERR:"M_NAME":CxFailureHandler: Unkown Command Code %d\n",
            t->command_code);
    }
    return 0;
}

AAAMessage* CxRequestHandler	(	AAAMessage *	request,
		void *	param
	)

Handler for Diameter incoming requests Not used now as here there are no expected incoming requests.

Parameters:

	request	- the received request
	param	- generic pointer

Returns:

the answer to this request

Definition at line 119 of file cx.c.

References _message_t::applicationId, _message_t::commandCode, Cx_PPA(), Cx_RTA(), IMS_Cx, IMS_PPR, IMS_RTR, is_req, and M_NAME.

{
    if (is_req(request)){       
        LOG(L_INFO,"INFO:"M_NAME":CxRequestHandler(): We have received a request\n");
        #ifdef WITH_IMS_PM
            ims_pm_diameter_request(request);
        #endif      
        switch(request->applicationId){
            case IMS_Cx:
                switch(request->commandCode){               
                    case IMS_RTR:
                        LOG(L_INFO,"INFO:"M_NAME":CxRequestHandler():- Received an IMS_RTR \n");
                        return Cx_RTA(request);
                        break;
                    case IMS_PPR:
                        LOG(L_INFO,"INFO:"M_NAME":CxRequestHandler(): - Received an IMS_PPR \n");
                        return Cx_PPA(request);
                        break;
                    default :
                        LOG(L_ERR,"ERR:"M_NAME":CxRequestHandler(): - Received unknown request for Cx command %d\n",request->commandCode);
                        break;  
                }
                break;
            default:
                LOG(L_ERR,"ERR:"M_NAME":CxRequestHandler(): - Received unknown request for app %d command %d\n",
                    request->applicationId,
                    request->commandCode);
                break;              
        }                   
    }
    return 0;       
}

AAAMessage* Cx_MAR	(	struct sip_msg *	msg,
		str	public_identity,
		str	private_identity,
		unsigned int	count,
		str	algorithm,
		str	authorization,
		str	server_name,
		str	realm
	)

Create and send a Multimedia-Authentication-Request and returns the Answer received for it.

This function retrieves authentication vectors from the HSS.

Parameters:

	msg	- the SIP message to send for public_identity - the public identity of the user
	private_identity	- the private identity of the user
	count	- how many authentication vectors to ask for
	algorithm	- for which algorithm
	authorization	- the authorization value
	server_name	- local name of the S-CSCF to save on the HSS
	realm	- Realm of the user

Returns:

the MAA

Definition at line 169 of file cx.c.

References cdp_binds::AAACreateRequest, cdp_binds::AAACreateSession, cdp_binds::AAACreateTransaction, cdp_binds::AAADropSession, cdp_binds::AAADropTransaction, cdp_binds::AAAFreeMessage, cdp_binds::AAASendRecvMessage, cdp_binds::AAASendRecvMessageToPeer, _AAATransaction::application_id, _message_t::applicationId, AUTH_HTTP_DIGEST_MD5, auth_scheme_types, cdpb, _AAATransaction::command_code, _message_t::commandCode, Cx_add_auth_session_state(), Cx_add_destination_realm(), Cx_add_public_identity(), Cx_add_server_name(), Cx_add_sip_auth_data_item_request(), Cx_add_sip_number_auth_items(), Cx_add_user_name(), Cx_add_vendor_specific_appid(), Flag_Proxyable, _AAATransaction::hash, IMS_Cx, IMS_MAR, IMS_vendor_id_3GPP, _AAATransaction::label, M_NAME, s_empty, scscf_forced_hss_peer_str, and tmb.

Referenced by S_MAR().

{
    AAAMessage *mar=0,*maa=0;
    AAASessionId sessId={0,0};
    AAATransaction *trans=0;
    unsigned int hash=0,label=0;    
    
    sessId = cdpb.AAACreateSession();
    trans=cdpb.AAACreateTransaction(IMS_Cx,IMS_MAR);

    mar = cdpb.AAACreateRequest(IMS_Cx,IMS_MAR,Flag_Proxyable,&sessId);
    if (!mar) goto error;

    if (!Cx_add_destination_realm(mar,realm)) goto error;
        
    if (!Cx_add_vendor_specific_appid(mar,IMS_vendor_id_3GPP,IMS_Cx,0 /*IMS_Cx*/)) goto error;
    if (!Cx_add_auth_session_state(mar,1)) goto error;      
        
    if (!Cx_add_public_identity(mar,public_identity)) goto error;
    if (!Cx_add_user_name(mar,private_identity)) goto error;
    if (!Cx_add_sip_number_auth_items(mar, count)) goto error;
    if (algorithm.len==auth_scheme_types[AUTH_HTTP_DIGEST_MD5].len &&
        strncasecmp(algorithm.s,auth_scheme_types[AUTH_HTTP_DIGEST_MD5].s,algorithm.len)==0) {
        if (!Cx_add_sip_auth_data_item_request(mar, algorithm, authorization, private_identity, realm, 
            msg->first_line.u.request.method, server_name)) goto error;
    }else{
        if (!Cx_add_sip_auth_data_item_request(mar, algorithm, authorization, private_identity, realm, 
            msg->first_line.u.request.method, s_empty)) goto error;     
    }
    if (!Cx_add_server_name(mar,server_name)) goto error;
    //TODO - add the realm also - and don't add when sending if added here 
        
    if (tmb.t_get_trans_ident(msg,&hash,&label)<0){ 
        LOG(L_ERR,"INF:"M_NAME":Cx_MAR: SIP message without transaction... very strange\n");
        return 0;
    }

    trans->hash=hash;
    trans->label=label;
    trans->application_id=mar->applicationId;
    trans->command_code=mar->commandCode;
    
    #ifdef WITH_IMS_PM
        ims_pm_diameter_request(mar);
    #endif              
    if (scscf_forced_hss_peer_str.len)
        maa = cdpb.AAASendRecvMessageToPeer(mar,&scscf_forced_hss_peer_str);
    else 
        maa = cdpb.AAASendRecvMessage(mar);
    #ifdef WITH_IMS_PM
        ims_pm_diameter_answer(maa);
    #endif          
    
    cdpb.AAADropSession(&sessId);
    cdpb.AAADropTransaction(trans);
    
    return maa;
    
error:
    //free stuff
    if (trans) cdpb.AAADropTransaction(trans);
    if (sessId.s) cdpb.AAADropSession(&sessId);
    if (mar) cdpb.AAAFreeMessage(&mar);
    return 0;   
}

AAAMessage* Cx_SAR	(	struct sip_msg *	msg,
		str	public_identity,
		str	private_identity,
		str	server_name,
		str	realm,
		int	assignment_type,
		int	data_available
	)

Create and send a Server-Assignment-Request and returns the Answer received for it.

This function performs the Server Assignment operation.

Parameters:

	msg	- the SIP message to send for public_identity - the public identity of the user
	server_name	- local name of the S-CSCF to save on the HSS
	realm	- Realm of the user
	assignment_type	- type of the assignment
	data_available	- if the data is already available

Returns:

the SAA

Definition at line 248 of file cx.c.

References cdp_binds::AAACreateRequest, cdp_binds::AAACreateSession, cdp_binds::AAACreateTransaction, cdp_binds::AAADropSession, cdp_binds::AAADropTransaction, cdp_binds::AAAFreeMessage, cdp_binds::AAASendRecvMessage, cdp_binds::AAASendRecvMessageToPeer, _AAATransaction::application_id, _message_t::applicationId, cdpb, _AAATransaction::command_code, _message_t::commandCode, Cx_add_auth_session_state(), Cx_add_destination_realm(), Cx_add_public_identity(), Cx_add_server_assignment_type(), Cx_add_server_name(), Cx_add_user_name(), Cx_add_userdata_available(), Cx_add_vendor_specific_appid(), Flag_Proxyable, _AAATransaction::hash, IMS_Cx, IMS_SAR, IMS_vendor_id_3GPP, _AAATransaction::label, scscf_forced_hss_peer_str, and tmb.

Referenced by SAR().

{
    AAAMessage *sar=0,*saa=0;
    AAASessionId sessId={0,0};
    AAATransaction *trans=0;
//  struct cell* t;
    unsigned int hash=0,label=0;    
    
    sessId = cdpb.AAACreateSession();
    trans=cdpb.AAACreateTransaction(IMS_Cx,IMS_SAR);

    sar = cdpb.AAACreateRequest(IMS_Cx,IMS_SAR,Flag_Proxyable,&sessId);
    if (!sar) goto error;

    if (!Cx_add_destination_realm(sar,realm)) goto error;
        
    if (!Cx_add_vendor_specific_appid(sar,IMS_vendor_id_3GPP,IMS_Cx,0 /*IMS_Cx*/)) goto error;
    if (!Cx_add_auth_session_state(sar,1)) goto error;      
        
    if (!Cx_add_public_identity(sar,public_identity)) goto error;
    if (!Cx_add_server_name(sar,server_name)) goto error;
    if (private_identity.len)
        if (!Cx_add_user_name(sar,private_identity)) goto error;
    if (!Cx_add_server_assignment_type(sar,assignment_type)) goto error;
    if (!Cx_add_userdata_available(sar,data_available)) goto error;
    
    if (msg&&tmb.t_get_trans_ident(msg,&hash,&label)<0){    
        // it's ok cause we can call this async with a message
        //LOG(L_ERR,"INF:"M_NAME":Cx_MAR: SIP message without transaction... very strange\n");
        //return 0;
    }

    trans->hash=hash;
    trans->label=label;
    trans->application_id=sar->applicationId;
    trans->command_code=sar->commandCode;
    
    #ifdef WITH_IMS_PM
        ims_pm_diameter_request(sar);
    #endif              
    if (scscf_forced_hss_peer_str.len)
        saa = cdpb.AAASendRecvMessageToPeer(sar,&scscf_forced_hss_peer_str);
    else 
        saa = cdpb.AAASendRecvMessage(sar);
    #ifdef WITH_IMS_PM
        ims_pm_diameter_answer(saa);
    #endif              
    
    cdpb.AAADropSession(&sessId);
    cdpb.AAADropTransaction(trans);
    
    return saa;
    
error:
    //free stuff
    if (trans) cdpb.AAADropTransaction(trans);
    if (sessId.s)   cdpb.AAADropSession(&sessId);
    if (sar) cdpb.AAAFreeMessage(&sar);
    return 0;   
}

AAAMessage* Cx_RTA

(

AAAMessage *

rtr

)

Process a Registration Termination Request and return the Answer for it.

Parameters:

rtr

- the RTR Diameter request

Returns:

the RTA Diameter answer

Definition at line 315 of file cx.c.

References cdp_binds::AAACreateResponse, cdp_binds::AAAGetNextAVP, AVP_IMS_Public_Identity, cdpb, Cx_add_auth_session_state(), Cx_add_result_code(), Cx_add_vendor_specific_appid(), Cx_get_next_public_identity(), Cx_get_user_name(), avp::data, DIAMETER_SUCCESS, IMS_Cx, IMS_vendor_id_3GPP, r_private_expire(), and r_public_expire().

Referenced by CxRequestHandler().

{   
    AAAMessage  *rta_msg;
    AAA_AVP* avp;
    str public_id;
    str private_id;
    
    rta_msg = cdpb.AAACreateResponse(rtr);//session ID?
    if (!rta_msg) return 0;

    avp = Cx_get_next_public_identity(rtr,0,AVP_IMS_Public_Identity,IMS_vendor_id_3GPP,__FUNCTION__);   
    if(avp==0){
        private_id=Cx_get_user_name(rtr);   
        r_private_expire(private_id);            
    }else{
        public_id=avp->data;
        r_public_expire(public_id);
        while(cdpb.AAAGetNextAVP(avp) && (avp=Cx_get_next_public_identity(rtr,cdpb.AAAGetNextAVP(avp),AVP_IMS_Public_Identity,IMS_vendor_id_3GPP,__FUNCTION__))!=0){
            public_id=avp->data;
            r_public_expire(public_id);
        }       
    }
    Cx_add_vendor_specific_appid(rta_msg,IMS_vendor_id_3GPP,IMS_Cx,0 /*IMS_Cx*/);
    Cx_add_auth_session_state(rta_msg,1);       

    /* send an RTA back to the HSS */
    Cx_add_result_code(rta_msg,DIAMETER_SUCCESS);
    #ifdef WITH_IMS_PM
        ims_pm_diameter_answer(rta_msg);
    #endif      
    
    return rta_msg;
}

AAAMessage* Cx_PPA

(

AAAMessage *

ppr

)

Process a Push Profile Request and return the Answer for it.

Parameters:

ppr

- the PPR Diameter request

Returns:

the PPA Diameter answer

Definition at line 355 of file cx.c.

References cdp_binds::AAACreateResponse, cdpb, Cx_add_auth_session_state(), Cx_add_result_code(), Cx_add_vendor_specific_appid(), Cx_get_charging_info(), Cx_get_user_data(), DIAMETER_SUCCESS, _r_public::hash, if, IMS_Cx, IMS_vendor_id_3GPP, M_NAME, parse_user_data(), print_user_data(), ims_service_profile::public_identities, ims_service_profile::public_identities_cnt, ims_public_identity::public_identity, r_unlock(), ims_subscription::service_profiles, ims_subscription::service_profiles_cnt, and update_r_public().

Referenced by CxRequestHandler().

{
    AAAMessage  *ppa_msg;
    str ppr_data;
    ims_subscription *imss;
    int i,j;
    r_public *pu;
    str ccf1,ccf2,ecf1,ecf2;

    ppa_msg = cdpb.AAACreateResponse(ppr);
    if (!ppa_msg) return 0; 
    
    if((ppr_data=Cx_get_user_data(ppr)).len != 0){
        LOG(L_INFO,"INFO:"M_NAME":Cx_PPA(): Received a User_Data PPR!\n");
        imss=parse_user_data(ppr_data);
        print_user_data(L_ALERT,imss);
        
        for(i=0;i<imss->service_profiles_cnt;i++)
            for(j=0;j<imss->service_profiles[i].public_identities_cnt;j++){             
                pu = update_r_public(imss->service_profiles[i].public_identities[j].public_identity,
                    0,&imss,0,0,0,0);
                if (!pu) continue;
                r_unlock(pu->hash);
            }           
    }
    else{
        if (Cx_get_charging_info(ppr,&ccf1,&ccf2,&ecf1,&ecf2)){
            LOG(L_INFO,"INFO:"M_NAME":Cx_PPA(): Received a Charging Info PPR - NOT IMPLEMENTED\n");
            //TODO find all r_public that should be updated and update
        }
    }   
    Cx_add_vendor_specific_appid(ppa_msg,IMS_vendor_id_3GPP,IMS_Cx,0 /*IMS_Cx*/);
    Cx_add_auth_session_state(ppa_msg,1);       
    
    Cx_add_result_code(ppa_msg,DIAMETER_SUCCESS);
    #ifdef WITH_IMS_PM
        ims_pm_diameter_answer(ppa_msg);
    #endif          
    return ppa_msg;
}

---

Variable Documentation

struct tm_binds tmb

Structure with pointers to tm funcs.

Definition at line 257 of file mod.c.

struct cdp_binds cdpb

Structure with pointers to cdp funcs.

Definition at line 258 of file mod.c.

str scscf_forced_hss_peer_str

FQDN of the forced Diameter Peer (HSS).

Definition at line 166 of file mod.c.

Referenced by Cx_MAR(), Cx_SAR(), and mod_init().

int r_hash_size

records tables parameters

Definition at line 73 of file registrar_storage.c.

r_hash_slot* registrar

the contacts

Definition at line 72 of file registrar_storage.c.

str s_empty = {0,0} [static]

Definition at line 153 of file cx.c.

str auth_scheme_types[]

Definition at line 101 of file registration.c.

Referenced by Cx_MAR(), get_auth_scheme_type(), S_challenge(), and S_is_authorized().

---