version 1.30.2.10, 2024/02/26 18:25:32
|
version 1.30.2.11, 2024/03/20 16:53:08
|
Line 147 _allocClient(rpc_srv_t * __restrict srv, sockaddr_t *
|
Line 147 _allocClient(rpc_srv_t * __restrict srv, sockaddr_t *
|
|
|
/* alloc empty buffer */ |
/* alloc empty buffer */ |
AIT_SET_BUFSIZ(&c->cli_buf, 0, srv->srv_netbuf); |
AIT_SET_BUFSIZ(&c->cli_buf, 0, srv->srv_netbuf); |
|
if (!AIT_GET_BUF(&c->cli_buf)) { |
|
array_Del(srv->srv_clients, n, 0); |
|
e_free(c); |
|
c = NULL; |
|
} |
} |
} |
|
|
return c; |
return c; |
Line 308 rxPacket(sched_task_t *task)
|
Line 313 rxPacket(sched_task_t *task)
|
{ |
{ |
rpc_cli_t *c = TASK_ARG(task); |
rpc_cli_t *c = TASK_ARG(task); |
rpc_srv_t *s = c->cli_parent; |
rpc_srv_t *s = c->cli_parent; |
int len, noreply = 0, rlen = AIT_LEN(&c->cli_buf); | int len, noreply = 0, rlen; |
#if 0 |
#if 0 |
u_short crc; |
u_short crc; |
#endif |
#endif |
Line 998 rxEXTPacket(sched_task_t *task)
|
Line 1003 rxEXTPacket(sched_task_t *task)
|
{ |
{ |
rpc_srv_t *srv = TASK_ARG(task); |
rpc_srv_t *srv = TASK_ARG(task); |
rpc_cli_t *c = NULL; |
rpc_cli_t *c = NULL; |
int len, noreply = 0, rlen = AIT_LEN(&c->cli_buf); | int len, noreply = 0, rlen; |
struct tagRPCCall *rpc; |
struct tagRPCCall *rpc; |
struct timespec ts = { DEF_RPC_TIMEOUT, 0 }; |
struct timespec ts = { DEF_RPC_TIMEOUT, 0 }; |
sockaddr_t sa; |
sockaddr_t sa; |