diff options
Diffstat (limited to 'agni.c')
| -rw-r--r-- | agni.c | 42 |
1 files changed, 21 insertions, 21 deletions
@@ -78,9 +78,9 @@ INPUT(string)->OUTPUT(string) */ tble_cmd_resp* cllbk_wrapper( void *(*call)(void *), tble_cmd_param *param) { - void *data_out = NULL; - tble_cmd_resp *resp = NULL; - char *data=NULL; + void *data_out = NULL; + tble_cmd_resp *resp = NULL; + char *data = NULL; if (call == NULL) { @@ -223,11 +223,11 @@ int th_start_client(void *data) int fret=-1; server_cfg *cfg = data; - mq_ntf_mdt *mq = cfg->mq; + mq_ntf_mdt *mq = cfg->mq; struct mq_attr out_attr, *ptr_out_attr=&out_attr; struct mq_attr in_attr, *ptr_in_attr=&in_attr; - char *out_buf = NULL; - char *in_buf = NULL; + char *out_buf = NULL; + char *in_buf = NULL; //network creation var int cret = -1; @@ -237,13 +237,13 @@ int th_start_client(void *data) char cmd_buf[TH_CONN_BUF_SZ]; //irc parsting - irc_buf *ib = NULL; + irc_buf *ib = NULL; irc_token *itok = NULL; - char *irc_line = NULL; + char *irc_line = NULL; //table to match response/request tble_qcmd *qcmd = NULL; - tbl_qcmd *qtbl = NULL; + tbl_qcmd *qtbl = NULL; //create response table qtbl = tbl_qcmd_c(100); @@ -254,9 +254,9 @@ int th_start_client(void *data) ////////////////////////////////////////////////////////////////////////////// //nbrpc - char *buf_nb = NULL; - rpc_request *req=NULL; - rpc_response *resp=NULL; + char *buf_nb = NULL; + rpc_request *req = NULL; + rpc_response *resp = NULL; netbyte_store *nb_req, *nb_resp; nb_resp = malloc(sizeof(netbyte_store)); @@ -697,10 +697,10 @@ int th_event_manager(void *data) { event_handler_cfg *cfg = data; atomic_fetch_add(&cfg->running,1); - mq_ntf_mdt *mq=NULL,*mq_cur=NULL; - int i_mq=0; //to iter trought mqueue + mq_ntf_mdt *mq= NULL,*mq_cur=NULL; + int i_mq = 0; //to iter trought mqueue char *out_buf = NULL; - char *in_buf = NULL; + char *in_buf = NULL; int run; int mq_event; @@ -782,9 +782,9 @@ int th_event_manager(void *data) ////////////////////////////////////////////////////////////////////////////// //nbrpc prepare variables - rpc_request *req=NULL; - rpc_response *resp=NULL; - netbyte_store *nb_req=NULL, *nb_resp=NULL; + rpc_request *req = NULL; + rpc_response *resp = NULL; + netbyte_store *nb_req = NULL, *nb_resp=NULL; char *buf_nb = NULL; nb_resp = malloc(sizeof(netbyte_store)); //not freed @@ -929,9 +929,9 @@ int main(int argc, char **argv) int i,j; int cnt_servers,cnt_running; - server_cfg *cfg_list; + server_cfg *cfg_list; event_handler_cfg *evhnd_cfg; - mq_ntf_mdt *mq_array; + mq_ntf_mdt *mq_array; /*set atomic variables to init value*/ atomic_store(&_glbl_id, 0); @@ -968,7 +968,7 @@ int main(int argc, char **argv) /* For each configuration create listener */ for (i=0;i<cnt_servers;i++) - { + { /*initialise server config*/ server_cfg *srvc = &cfg_list[i]; //irc_server_conf *isrvc = &server_list[i]; |