--- libaitrpc/src/srv.c 2012/05/11 12:53:35 1.8.2.5 +++ libaitrpc/src/srv.c 2012/05/11 13:23:12 1.8.2.6 @@ -3,7 +3,7 @@ * by Michael Pounov * * $Author: misho $ -* $Id: srv.c,v 1.8.2.5 2012/05/11 12:53:35 misho Exp $ +* $Id: srv.c,v 1.8.2.6 2012/05/11 13:23:12 misho Exp $ * ************************************************************************** The ELWIX and AITNET software is distributed under the following @@ -60,8 +60,6 @@ txPacket(sched_task_t *task) int ret, wlen = sizeof(struct tagRPCCall); array_t *arr = NULL; - ioTRACE(RPC_TRACE_LEVEL); - if (rpc->call_argc) { f = rpc_srv_getCall(s, ntohs(rpc->call_tag), ntohl(rpc->call_hash)); if (!f) { @@ -113,8 +111,6 @@ execCall(sched_task_t *task) struct tagRPCCall *rpc = (struct tagRPCCall*) buf; int argc = ntohs(rpc->call_argc); - ioTRACE(RPC_TRACE_LEVEL); - /* Go decapsulate variables ... */ if (argc) { arr = io_buffer2vars(buf + sizeof(struct tagRPCCall), @@ -171,8 +167,6 @@ rxPacket(sched_task_t *task) struct tagRPCCall *rpc; struct timespec ts; - ioTRACE(RPC_TRACE_LEVEL); - memset(buf, 0, TASK_DATLEN(task)); rlen = recv(TASK_FD(task), buf, TASK_DATLEN(task), 0); if (rlen == -1) { @@ -252,8 +246,6 @@ rpc_srv_dispatchCall(void *arg) sched_root_task_t *root; struct timespec ts = { DEF_RPC_TIMEOUT, 0 }; - ioTRACE(RPC_TRACE_LEVEL); - if (!arg) { rpc_SetErr(EINVAL, "Invalid parameter can`t procced RPC client"); return NULL; @@ -297,8 +289,6 @@ txBLOB(sched_task_t *task) struct tagBLOBHdr *blob = (struct tagBLOBHdr *) buf; int wlen = sizeof(struct tagBLOBHdr); - ioTRACE(RPC_TRACE_LEVEL); - /* calculate CRC */ blob->hdr_crc ^= blob->hdr_crc; blob->hdr_crc = htons(crcFletcher16((u_short*) buf, wlen / 2)); @@ -328,8 +318,6 @@ rxBLOB(sched_task_t *task) u_short crc; struct timespec ts; - ioTRACE(RPC_TRACE_LEVEL); - /* check for disable service at this moment? */ if (!s || s->srv_blob.state == disable) { usleep(100000); @@ -444,8 +432,6 @@ rpc_srv_dispatchVars(void *arg) u_char *buf; struct timespec ts = { DEF_RPC_TIMEOUT, 0 }; - ioTRACE(RPC_TRACE_LEVEL); - if (!arg) { rpc_SetErr(EINVAL, "Invalid parameter can`t procced BLOB"); return NULL; @@ -497,8 +483,6 @@ rpc_srv_initBLOBServer(rpc_srv_t * __restrict srv, u_s int n = 1; io_sockaddr_t sa; - ioTRACE(RPC_TRACE_LEVEL); - if (!srv) { rpc_SetErr(EINVAL, "Invalid parameters can`t init BLOB server"); return -1; @@ -601,8 +585,6 @@ rpc_srv_endBLOBServer(rpc_srv_t * __restrict srv) register int i; rpc_blob_t *f; - ioTRACE(RPC_TRACE_LEVEL); - if (!srv || srv->srv_blob.state == disable) return; else @@ -653,8 +635,6 @@ rpc_srv_loopBLOB(rpc_srv_t * __restrict srv) pthread_attr_t attr; struct pollfd pfd; - ioTRACE(RPC_TRACE_LEVEL); - if (!srv || srv->srv_blob.state == kill) { rpc_SetErr(EINVAL, "Invalid parameter can`t start BLOB server"); return -1; @@ -663,10 +643,9 @@ rpc_srv_loopBLOB(rpc_srv_t * __restrict srv) if (listen(srv->srv_blob.server.cli_sock, SOMAXCONN) == -1) { LOGERR; return -1; - }/* else + } else fcntl(srv->srv_blob.server.cli_sock, F_SETFL, fcntl(srv->srv_blob.server.cli_sock, F_GETFL) | O_NONBLOCK); - */ pthread_attr_init(&attr); pthread_attr_setdetachstate(&attr, PTHREAD_CREATE_DETACHED); @@ -737,8 +716,6 @@ rpc_srv_initServer(u_int regProgID, u_int regProcID, i struct hostent *host = NULL; io_sockaddr_t sa; - ioTRACE(RPC_TRACE_LEVEL); - if (!concurentClients || !regProgID || (family != AF_INET && family != AF_INET6 && family != AF_LOCAL)) { rpc_SetErr(EINVAL, "Error:: Invalid parameters can`t init RPC server ...\n"); @@ -866,8 +843,6 @@ rpc_srv_endServer(rpc_srv_t ** __restrict psrv) register int i; rpc_func_t *f; - ioTRACE(RPC_TRACE_LEVEL); - if (!psrv || !*psrv) { rpc_SetErr(EINVAL, "Error:: Can`t destroy server because parameter is null!\n"); return; @@ -918,8 +893,6 @@ rpc_srv_loopServer(rpc_srv_t * __restrict srv) pthread_attr_t attr; struct pollfd pfd; - ioTRACE(RPC_TRACE_LEVEL); - if (!srv) { rpc_SetErr(EINVAL, "Error:: Invalid parameter can`t start RPC server ...\n"); return -1; @@ -997,8 +970,6 @@ rpc_srv_execCall(rpc_func_t * __restrict call, struct void *dl; rpc_callback_t func; int ret; - - ioTRACE(RPC_TRACE_LEVEL); if (!call || !rpc || !call->func_parent) { rpc_SetErr(EINVAL, "Invalid parameter can`t exec function");