version 1.30.2.7, 2024/02/26 16:56:22
|
version 1.30.2.9, 2024/02/26 18:07:32
|
Line 87 rpc_freeCli(rpc_cli_t * __restrict c)
|
Line 87 rpc_freeCli(rpc_cli_t * __restrict c)
|
{ |
{ |
rpc_srv_t *s = c->cli_parent; |
rpc_srv_t *s = c->cli_parent; |
|
|
schedCancelby(s->srv_root, taskMAX, CRITERIA_ARG, c, NULL); | if (s->srv_proto == SOCK_STREAM) |
| schedCancelby(s->srv_root, taskMAX, CRITERIA_ARG, c, NULL); |
|
|
/* free buffer */ |
/* free buffer */ |
AIT_FREE_VAL(&c->cli_buf); |
AIT_FREE_VAL(&c->cli_buf); |
Line 311 rpc_srv_Return(sched_root_task_t *root, rpc_cli_t *c)
|
Line 312 rpc_srv_Return(sched_root_task_t *root, rpc_cli_t *c)
|
|
|
if (!RPC_CHK_NOREPLY(rpc)) { |
if (!RPC_CHK_NOREPLY(rpc)) { |
rpc->call_argc = (u_char) array_Size(RPC_RETVARS(c)); |
rpc->call_argc = (u_char) array_Size(RPC_RETVARS(c)); |
schedWrite(root, cbProto[s->srv_proto][CB_TXPACKET], c, c->cli_sock, NULL, 0); | schedWrite(root, cbProto[s->srv_proto][CB_TXPACKET], c, c->cli_sock, rpc, 0); |
} |
} |
|
|
return rpc->call_argc; |
return rpc->call_argc; |
Line 575 rxUDPPacket(sched_task_t *task)
|
Line 576 rxUDPPacket(sched_task_t *task)
|
|
|
c = _allocClient(srv, &sa); |
c = _allocClient(srv, &sa); |
if (!c) { |
if (!c) { |
EVERBOSE(1, "RPC client quota exceeded! Connection will be shutdown!\n"); | EVERBOSE(1, "RPC client quota exceeded!"); |
usleep(2000); /* blocked client delay */ |
usleep(2000); /* blocked client delay */ |
goto end; |
goto end; |
} else { |
} else { |