libaitrpc/src/srv.c - diff

Return to srv.c CVS log

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

version 1.13.4.1, 2013/01/17 16:33:57	version 1.13.4.2, 2013/01/17 17:01:51
Line 438 rxUDPPacket(sched_task_t *task)	Line 438 rxUDPPacket(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;
socklen_t salen = sizeof(sockaddr_t);
int len, rlen, noreply;	int len, rlen, noreply;
u_short crc, off = 0;	u_short crc, off = 0;
u_char buf[USHRT_MAX + 1];	u_char buf[USHRT_MAX + 1];
struct tagRPCCall rpc = (struct tagRPCCall) buf;	struct tagRPCCall rpc = (struct tagRPCCall) buf;
sockaddr_t sa;	sockaddr_t sa;
	socklen_t salen;
struct timespec ts = { DEF_RPC_TIMEOUT, 0 };	struct timespec ts = { DEF_RPC_TIMEOUT, 0 };

/* receive connect packet */	/* receive connect packet */
	salen = sa.ss.ss_len = sizeof(sockaddr_t);
rlen = recvfrom(TASK_FD(task), buf, sizeof buf, 0, &sa.sa, &salen);	rlen = recvfrom(TASK_FD(task), buf, sizeof buf, 0, &sa.sa, &salen);
if (rlen < 1)	if (rlen < 1)
goto end;	goto end;