api_process.c File Reference

---

Detailed Description

CDiameterPeer API processor.

Author:

Dragos Vingarzan vingarzan -at- fokus dot fraunhofer dot de

Definition in file api_process.c.

#include "api_process.h"
#include "transaction.h"
#include "receiver.h"

Go to the source code of this file.

Functions
int	api_callback (peer *p, AAAMessage *msg, void *ptr)
	This callback is added as an internal message listener and used to process transaction requests.
Variables
handler_list *	handlers = 0
	list of handlers
gen_lock_t *	handlers_lock
	lock for list of handlers

---

Function Documentation

int api_callback	(	peer *	p,
		AAAMessage *	msg,
		void *	ptr
	)

This callback is added as an internal message listener and used to process transaction requests.

• first it calls all the registered handlers for requests and responses
• then it calls the transactio handler

  Parameters:

  	p	- peer that this message came from
  	msg	- the diameter message
  	ptr	- not used anymore

  Returns:

  1 always

Definition at line 73 of file api_process.c.

References _cdp_trans_t::ans, _cdp_trans_t::auto_drop, _cdp_trans_t::cb, free_trans(), handler_t::handler, handlers, handlers_lock, handler_list_t::head, is_req, handler_t::next, handler_t::param, peer_send_msg(), _cdp_trans_t::ptr, REQUEST_HANDLER, handler_t::requestHandler, RESPONSE_HANDLER, handler_t::responseHandler, take_trans(), and handler_t::type.

Referenced by diameter_peer_init().

{
    cdp_trans_t *t;
    int auto_drop;  
    handler *h;
    enum handler_types type;
    AAAMessage *rsp;
    if (is_req(msg)) type = REQUEST_HANDLER;
    else type=RESPONSE_HANDLER;

    lock_get(handlers_lock);
        for(h=handlers->head;h;h=h->next){
            if (h->type==type){
                if (h->type == REQUEST_HANDLER) {                   
                    rsp = (h->handler.requestHandler)(msg,h->param);
                    if (rsp) peer_send_msg(p,rsp);
                }
                else (h->handler.responseHandler)(msg,h->param);
            }
        }       
    lock_release(handlers_lock);
    
    if (!is_req(msg)){      
        /* take care of transactional callback if any */
        t = take_trans(msg);
        if (t){
            t->ans = msg;
            auto_drop = t->auto_drop;
            if (t->cb){
                (t->cb)(0,*(t->ptr),msg);
            }
            if (auto_drop) free_trans(t);
        }
    }
    return 1;
}

---

Variable Documentation

handler_list* handlers = 0

list of handlers

Definition at line 60 of file api_process.c.

Referenced by AAAAddRequestHandler(), AAAAddResponseHandler(), api_callback(), diameter_peer_destroy(), and diameter_peer_init().

gen_lock_t* handlers_lock

lock for list of handlers

Definition at line 61 of file api_process.c.

Referenced by AAAAddRequestHandler(), AAAAddResponseHandler(), api_callback(), diameter_peer_destroy(), and diameter_peer_init().

---