aboutsummaryrefslogtreecommitdiffstats
path: root/agni.c
diff options
context:
space:
mode:
authorFreeArtMan <dos21h@gmail.com>2017-11-22 21:42:17 +0000
committerFreeArtMan <dos21h@gmail.com>2017-11-22 21:42:17 +0000
commitafb3657fa2cbc6bd9e5901d6c5590b09d15c2d89 (patch)
tree62d707d0c48bf4350700aec627b4b5ac49f9731c /agni.c
parentde98f9c8e8468ed046dfc7208daea24e14707009 (diff)
downloadagni-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.c42
1 files changed, 21 insertions, 21 deletions
diff --git a/agni.c b/agni.c
index 520ef45..e4be388 100644
--- a/agni.c
+++ b/agni.c
@@ -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];