worker.h

Go to the documentation of this file.

#ifndef __WORKER_H
#define __WORKER_H

#include "peer.h"
#include "diameter.h"
#include "utils.h"

typedef int (*worker_init_function)(int rank);

typedef struct _task_t {
    peer *p;            
    AAAMessage *msg;    
} task_t;

typedef struct {
    gen_lock_t *lock;   
    int start;          
    int end;            
    int max;            
    task_t *queue;      
    int empty;          
    int full;           
} task_queue_t;

typedef int (*cdp_cb_f)(peer *p,AAAMessage *msg,void* ptr);

typedef struct _cdp_cb_t{
    cdp_cb_f cb;                
    void **ptr;                 
    struct _cdp_cb_t *next;     
    struct _cdp_cb_t *prev;     
} cdp_cb_t;
    
typedef struct {
    cdp_cb_t *head; 
    cdp_cb_t *tail; 
} cdp_cb_list_t;

void worker_init();
void worker_destroy();

int cb_add(cdp_cb_f cb,void *ptr);
void cb_remove(cdp_cb_t *cb);

int put_task(peer *p,AAAMessage *msg);
task_t take_task();


void worker_poison_queue();

void worker_process(int id);



#endif

---