--- libaitrpc/src/srv.c 2013/08/20 23:37:43 1.17.4.1 +++ libaitrpc/src/srv.c 2013/08/22 11:55:45 1.17.6.1 @@ -3,7 +3,7 @@ * by Michael Pounov * * $Author: misho $ -* $Id: srv.c,v 1.17.4.1 2013/08/20 23:37:43 misho Exp $ +* $Id: srv.c,v 1.17.6.1 2013/08/22 11:55:45 misho Exp $ * ************************************************************************** The ELWIX and AITNET software is distributed under the following @@ -74,8 +74,8 @@ rpc_freeCli(rpc_cli_t * __restrict c) schedCancelby(s->srv_root, taskMAX, CRITERIA_ARG, c, NULL); - /* free buffer(s) */ - ait_freeVars(&c->cli_buf); + /* free buffer */ + AIT_FREE_VAL(&c->cli_buf); array_Del(s->srv_clients, c->cli_id, 0); if (c) @@ -127,13 +127,7 @@ _allocClient(rpc_srv_t * __restrict srv, sockaddr_t * } /* alloc empty buffer */ - c->cli_buf = ait_allocVars(1); - if (!c->cli_buf) { - rpc_SetErr(elwix_GetErrno(), "%s", elwix_GetError()); - array_Del(srv->srv_clients, n, 42); - return NULL; - } else - AIT_SET_BUFSIZ(array(c->cli_buf, 0, ait_val_t*), 0, srv->srv_netbuf); + AIT_SET_BUFSIZ(&c->cli_buf, 0, srv->srv_netbuf); } return c; @@ -197,7 +191,7 @@ txPacket(sched_task_t *task) } } - rpc->call_len = htons(wlen); + rpc->call_len = htonl(wlen); #if 0 /* calculate CRC */ @@ -309,7 +303,7 @@ rxPacket(sched_task_t *task) } else rpc = (struct tagRPCCall*) (buf + off); - len = ntohs(rpc->call_len); + len = ntohl(rpc->call_len); rlen -= len; /* check RPC packet lengths */ @@ -428,7 +422,7 @@ txUDPPacket(sched_task_t *task) } } - rpc->call_len = htons(wlen); + rpc->call_len = htonl(wlen); /* calculate CRC */ rpc->call_crc ^= rpc->call_crc; @@ -486,7 +480,7 @@ rxUDPPacket(sched_task_t *task) } else rpc = (struct tagRPCCall*) (AIT_GET_BUF(&c->cli_buf) + off); - len = ntohs(rpc->call_len); + len = ntohl(rpc->call_len); rlen -= len; /* check RPC packet lengths */