libaitrpc/src/srv.c - diff

Return to srv.c CVS log

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

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;