From b190a6af38f077b1754b4cb0cdd6c1f6e1494aba Mon Sep 17 00:00:00 2001 From: wangzhengquan <wangzhengquan85@126.com> Date: 星期五, 17 七月 2020 20:41:16 +0800 Subject: [PATCH] tmp --- queue/mod_socket.c | 19 ++++++++++++++++--- 1 files changed, 16 insertions(+), 3 deletions(-) diff --git a/queue/mod_socket.c b/queue/mod_socket.c index ba70580..7476921 100644 --- a/queue/mod_socket.c +++ b/queue/mod_socket.c @@ -1,6 +1,9 @@ #include "mod_socket.h" #include "shm_socket.h" #include "usg_common.h" +#include "logger_factory.h" +static Logger logger = LoggerFactory::getLogger(); + typedef struct mod_entry_t { int size; @@ -55,7 +58,7 @@ int mod_socket_bind(void * _socket, int port){ mod_socket_t * socket = (mod_socket_t *) _socket; - return shm_soket_bind(socket->shm_socket, port); + return shm_socket_bind(socket->shm_socket, port); } void * run_server_recv_client_msg(void *_socket) { @@ -118,9 +121,11 @@ if(socket->is_server ) { switch(socket->mod) { case REQ_REP: +logger.debug("mod_send before"); SemUtil::dec(socket->items); rv = shm_send(socket->client_socket, buf, size); SemUtil::inc(socket->slots); +logger.debug("mod_send after"); break; case SURVEY: case PUB_SUB: @@ -135,7 +140,10 @@ } else { - return shm_send(socket->shm_socket, buf, size); +logger.debug("mod_send before"); + rv = shm_send(socket->shm_socket, buf, size); +logger.debug("mod_send after"); + return rv; } return -1; @@ -149,12 +157,14 @@ if(socket->is_server ) { switch(socket->mod) { case REQ_REP: + logger.debug("REQ_REP mod_recv before"); SemUtil::dec(socket->slots); rv = socket->recvQueue->pop(entry); *buf = entry.buf; *size = entry.size; socket->client_socket = entry.client_socket; SemUtil::inc(socket->items); +logger.debug("REQ_REP mod_recv after"); break; case PUB_SUB: rv = 0; @@ -170,7 +180,10 @@ return rv; } else { - return shm_recv(socket->shm_socket, buf, size); +logger.debug("mod_recv before"); + rv = shm_recv(socket->shm_socket, buf, size); +logger.debug("mod_recv after"); + return rv; } return -1; -- Gitblit v1.8.0