diff options
author | FreeArtMan <dos21h@gmail.com> | 2017-11-22 21:42:17 +0000 |
---|---|---|
committer | FreeArtMan <dos21h@gmail.com> | 2017-11-22 21:42:17 +0000 |
commit | afb3657fa2cbc6bd9e5901d6c5590b09d15c2d89 (patch) | |
tree | 62d707d0c48bf4350700aec627b4b5ac49f9731c /agni.c | |
parent | de98f9c8e8468ed046dfc7208daea24e14707009 (diff) | |
download | agni-afb3657fa2cbc6bd9e5901d6c5590b09d15c2d89.tar.gz agni-afb3657fa2cbc6bd9e5901d6c5590b09d15c2d89.zip |
Added todo file size max 1MB and 64 todo's per user
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]; |