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; |