libaitrpc/src/srv.c - diff

Return to srv.c CVS log

Up to [ELWIX - Embedded LightWeight unIX -] / libaitrpc / src

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 {