diff options
| -rw-r--r-- | agni.c | 27 |
1 files changed, 2 insertions, 25 deletions
@@ -358,11 +358,6 @@ int th_start_client(void *data) PERM(); } - - - - - atomic_fetch_add(&cfg->running,1); printf("Start client\n"); printf("Server %d\n",cfg->tid); @@ -428,7 +423,6 @@ int th_start_client(void *data) ib = irc_buf_create(); if (ib == NULL) { - PNL(); PERM(); //return 0; } @@ -450,15 +444,12 @@ int th_start_client(void *data) PRINT("MQ_EVENT IN\n"); if (mq_ntf_read(mq, MQ_IN, in_buf, in_attr.mq_msgsize) == -1) { - PNL(); printf("Cant read input message \n"); } else { - //PNL(); in_buf[in_attr.mq_msgsize-1] = 0x0; PRINT("Recieve %s\n", in_buf); } - PNL(); break; default: printf("Unknown event type\n"); @@ -490,41 +481,31 @@ int th_start_client(void *data) memset(match_resp, 0, sizeof(tble_cmd_resp)); if (match_resp != NULL) { - //PNL(); match_resp->qid = mq_cmd_id(recv_cmd); //for now any type is ok, make time consistant, for this usage //match_cmd->type = QCMD_NONE - //PNL(); match_resp->resp = alloc_new_str_s(paramPtr, paramSz); - //PNL(); //check if command match int cmd_id = tbl_qcmd_resp(qtbl, match_resp); if (cmd_id > 0) { - PRINT("%d\n",cmd_id); tble_qcmd *cmd = tbl_qcmd_match_id(qtbl, cmd_id); - PNL(); if (cmd != NULL) { int buf_sz = TH_CONN_BUF_SZ>128?128:TH_CONN_BUF_SZ; - PNL(); char *resp_user = token_new_str(cmd->tok,0); char *sep = strchr(resp_user,'!'); resp_user[sep-resp_user] = 0x0; - PNL(); memset(cmd_buf, 0, buf_sz); - PNL(); //prepare response int fret = snprintf(cmd_buf, buf_sz,":%s PRIVMSG %s :%s \r\n",cfg->user,resp_user,match_resp->resp); - PRINT("cmd_buf %s \n", cmd_buf); write(conn, cmd_buf, fret); free(resp_user); - } } @@ -592,8 +573,6 @@ int th_start_client(void *data) memset(cmd_buf,0,128); char *uname = token_new_str(itok,0); char *msg = token_new_str(itok,3); - - PRINT("msg %s\n", msg); char *sep = strchr(uname,'!'); uname[sep-uname] = 0x0; @@ -621,9 +600,7 @@ int th_start_client(void *data) |TBL_PF_QCMD_TID |TBL_PF_QCMD_TIDX); } - - PRINT("msg %s\n", msg); - + //create command and send to mq mq_cmd *privcmd = mq_cmd_create(qcmd->cid,"PRIVMSG",strlen("PRIVMSG"),msg,strlen(msg)); char *bufPtr; @@ -637,7 +614,7 @@ int th_start_client(void *data) free(msg); free(uname); - printf("OUT<<Send %d\n", fret); + //printf("OUT<<Send %d\n", fret); } token_destroy(itok); |