diff options
| author | FreeArtMan <dos21h@gmail.com> | 2017-09-19 13:49:04 +0100 |
|---|---|---|
| committer | FreeArtMan <dos21h@gmail.com> | 2017-09-19 13:49:04 +0100 |
| commit | c2f9ce9c4b65ee53cd0c070895833215185061f3 (patch) | |
| tree | 23ba9cde2a933448395d236ac4a87d22ee2d7282 /agni.c | |
| parent | fc6970fcd404305c3e16d2e90d6d0dec4b03c160 (diff) | |
| download | agni-c2f9ce9c4b65ee53cd0c070895833215185061f3.tar.gz agni-c2f9ce9c4b65ee53cd0c070895833215185061f3.zip | |
New line bug fix, /b 5
Diffstat (limited to 'agni.c')
| -rw-r--r-- | agni.c | 6 |
1 files changed, 4 insertions, 2 deletions
@@ -789,15 +789,17 @@ int th_event_manager(void *data) mq_cur = &mq[i_mq]; if (mq_event == 1) { + int bytes; //PRINT("MQ_EVENT OUT\n"); memset(out_buf, 0, out_attr.mq_msgsize); //will fail if some of queue have different buffer size param - if (mq_ntf_read(&mq[i_mq], MQ_OUT, out_buf, out_attr.mq_msgsize) == -1) + if ((bytes = mq_ntf_read(&mq[i_mq], MQ_OUT, out_buf, out_attr.mq_msgsize)) == -1) { printf("Cant read output message\n"); } else { out_buf[out_attr.mq_msgsize-1] = 0x0; + stats.cnt_ipc_rx += bytes; printf("Recieve %s\n", out_buf); } break; @@ -813,7 +815,7 @@ int th_event_manager(void *data) { rpc_req_unmarsh(nb_req, &req); PRINT("EVENT-REQ: %d-%s(%s)\n", req->id, req->method, req->params); - nb_print(nb_req); + //nb_print(nb_req); if (strncmp(req->method,":PRIVMSG",8)) { |