cx.h File Reference

---

Detailed Description

Interrogating-CSCF - Cx operations.

Author:

Dragos Vingarzan vingarzan -at- fokus dot fraunhofer dot de

Definition in file cx.h.

#include "../../sr_module.h"
#include "../cdp/cdp_load.h"

Go to the source code of this file.

Functions
void	CxAnswerHandler (AAAMessage *response, void *param)
	Handler for incoming Diameter responses.
void	CxFailureHandler (int is_timeout, void *param, AAAMessage *ans)
	Handler for Diameter Failures.
AAAMessage *	CxRequestHandler (AAAMessage *request, void *param)
	Handler for Diameter incoming requests Not used now as here there are no expected incoming requests.
AAAMessage *	Cx_UAR (struct sip_msg *msg, str private_identity, str public_identity, str visited_network_id, int authorization_type, str realm)
	Sends an UAR and returns the UAA.
AAAMessage *	Cx_LIR (struct sip_msg *msg, str public_identity, str realm)
	Sends an LIR and returns the LIA.

---

Function Documentation

void CxAnswerHandler	(	AAAMessage *	response,
		void *	param
	)

Handler for incoming Diameter responses.

Not used now as all answers are handled by transactional callbacks.

Parameters:

	response	- the diameter response
	param	- generic parameter - here the AAATransaction

Definition at line 81 of file cx.c.

References _message_t::commandCode.

{
    AAATransaction *t;
    t = (AAATransaction*)param;
    
    if (!param){
        LOG(L_ERR,"ERR:CxAnswerHandler: Answer received but no transaction\n");
        return;
    }

    switch(response->commandCode){
        default:
            LOG(L_ERR,"ERR:CxAnswerHandler: Unkown Command Code %d\n",
                response->commandCode);
    }
    return;
}

void CxFailureHandler	(	int	is_timeout,
		void *	param,
		AAAMessage *	ans
	)

Handler for Diameter Failures.

Not used now as all answers are handled by transactional callbacks.

Parameters:

	is_tiemout	- if this is a time-out
	param	- generic parameter - here the AAATransaction
	ans	- the Diameter answer if available, NULL if not

Definition at line 106 of file cx.c.

References cdp_binds::AAADropTransaction, cdpb, and _AAATransaction::command_code.

{
    AAATransaction *t;
    t = (AAATransaction*)param;
    /* filter only failures */
//  if (!is_timeout) return;
    if (!param){
        LOG(L_ERR,"ERR:CxFailureHandler: NULL transaction parameter received\n");
        return;
    }
    switch(t->command_code){
        default:
        LOG(L_ERR,"ERR:CxFailureHandler: Unkown Command Code %d\n",
            t->command_code);
    }
    cdpb.AAADropTransaction(t);
    return;
}

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 131 of file cx.c.

{
    LOG(L_INFO,"INF:CxSIRequestHandler: NOT IMPLEMENTED\n");
    return 0;   
}

AAAMessage* Cx_UAR	(	struct sip_msg *	msg,
		str	private_identity,
		str	public_identity,
		str	visited_network_id,
		int	authorization_type,
		str	realm
	)

Sends an UAR and returns the UAA.

Parameters:

	msg	- the SIP message
	private_identity	- the username
	public_identity	- the public identity
	visited_network_id	- id of the roaming network
	authorization_type	- if registration or de-registration
	realm	- Realm

Returns:

the UAA message received or NULL on error

Definition at line 149 of file cx.c.

References cdp_binds::AAACreateRequest, cdp_binds::AAACreateSession, cdp_binds::AAADropSession, cdp_binds::AAAFreeMessage, cdp_binds::AAASendRecvMessage, cdp_binds::AAASendRecvMessageToPeer, AVP_IMS_UAR_REGISTRATION, cdpb, Cx_add_auth_session_state(), Cx_add_authorization_type(), Cx_add_destination_realm(), Cx_add_public_identity(), Cx_add_user_name(), Cx_add_vendor_specific_appid(), Cx_add_visited_network_id(), Flag_Proxyable, icscf_forced_hss_peer_str, IMS_Cx, IMS_UAR, and IMS_vendor_id_3GPP.

Referenced by I_UAR().

{
    AAAMessage *uar=0;
    AAASessionId sessId={0,0};
    AAAMessage *uaa=0;
    
    sessId = cdpb.AAACreateSession();

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

    if (!Cx_add_destination_realm(uar,realm)) goto error;
        
    if (!Cx_add_vendor_specific_appid(uar,IMS_vendor_id_3GPP,IMS_Cx,0/*IMS_Cx*/)) goto error;
    if (!Cx_add_auth_session_state(uar,1)) goto error;

    if (!Cx_add_user_name(uar,private_identity)) goto error;
    if (!Cx_add_public_identity(uar,public_identity)) goto error;
    if (!Cx_add_visited_network_id(uar,visited_network_id)) goto error;
    if (authorization_type!=AVP_IMS_UAR_REGISTRATION)
        if (!Cx_add_authorization_type(uar,authorization_type)) goto error;

    #ifdef WITH_IMS_PM
        ims_pm_diameter_request(uar);
    #endif              
    if (icscf_forced_hss_peer_str.len)
        uaa = cdpb.AAASendRecvMessageToPeer(uar,&icscf_forced_hss_peer_str);
    else 
        uaa = cdpb.AAASendRecvMessage(uar); 
    #ifdef WITH_IMS_PM
        ims_pm_diameter_answer(uaa);
    #endif              

    cdpb.AAADropSession(&sessId);
    
    return uaa;
    
error:
    //free stuff
    if (sessId.s) cdpb.AAADropSession(&sessId);
    if (uar) cdpb.AAAFreeMessage(&uar);
    return 0;
}   

AAAMessage* Cx_LIR	(	struct sip_msg *	msg,
		str	public_identity,
		str	realm
	)

Sends an LIR and returns the LIA.

Parameters:

	msg	- the SIP message
	public_identity	- the public identity
	realm	- Realm

Returns:

the LIA message received or NULL on error

Definition at line 203 of file cx.c.

References cdp_binds::AAACreateRequest, cdp_binds::AAACreateSession, cdp_binds::AAADropSession, cdp_binds::AAAFreeMessage, cdp_binds::AAASendRecvMessage, cdp_binds::AAASendRecvMessageToPeer, cdpb, Cx_add_auth_session_state(), Cx_add_destination_realm(), Cx_add_public_identity(), Cx_add_vendor_specific_appid(), Flag_Proxyable, icscf_forced_hss_peer_str, IMS_Cx, IMS_LIR, and IMS_vendor_id_3GPP.

Referenced by I_LIR().

{
    AAAMessage *lir=0,*lia=0;
    AAASessionId sessId={0,0};
    
    sessId = cdpb.AAACreateSession();

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

    if (!Cx_add_destination_realm(lir,realm)) goto error;
    
    if (!Cx_add_vendor_specific_appid(lir,IMS_vendor_id_3GPP,IMS_Cx,0/*IMS_Cx*/)) goto error;
    if (!Cx_add_auth_session_state(lir,1)) goto error;      

    if (!Cx_add_public_identity(lir,public_identity)) goto error;
            
    #ifdef WITH_IMS_PM
        ims_pm_diameter_request(lir);
    #endif              
    if (icscf_forced_hss_peer_str.len)
        lia = cdpb.AAASendRecvMessageToPeer(lir,&icscf_forced_hss_peer_str);
    else 
        lia = cdpb.AAASendRecvMessage(lir);
    #ifdef WITH_IMS_PM
        ims_pm_diameter_answer(lia);
    #endif              


    cdpb.AAADropSession(&sessId);
    
    return lia;
    
error:
    //free stuff
    if (sessId.s) cdpb.AAADropSession(&sessId);
    if (lir) cdpb.AAAFreeMessage(&lir);
    return 0;
}   

---