api_process.c

Go to the documentation of this file.

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


handler_list *handlers = 0; 
gen_lock_t *handlers_lock;  
int api_callback(peer *p,AAAMessage *msg,void* ptr)
{
    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;
}

---