version 1.28, 2015/07/22 20:01:46
|
version 1.28.2.1, 2016/06/23 15:59:52
|
Line 312 rxPacket(sched_task_t *task)
|
Line 312 rxPacket(sched_task_t *task)
|
u_short crc; |
u_short crc; |
#endif |
#endif |
u_char *buf = AIT_GET_BUF(&c->cli_buf); |
u_char *buf = AIT_GET_BUF(&c->cli_buf); |
u_char b[sizeof(struct tagRPCCall)]; | struct tagRPCCall b, *rpc = (struct tagRPCCall*) buf; |
struct tagRPCCall *rpc = (struct tagRPCCall*) buf; | |
#ifdef TCP_SESSION_TIMEOUT |
#ifdef TCP_SESSION_TIMEOUT |
struct timespec ts = { DEF_RPC_TIMEOUT, 0 }; |
struct timespec ts = { DEF_RPC_TIMEOUT, 0 }; |
|
|
Line 323 rxPacket(sched_task_t *task)
|
Line 322 rxPacket(sched_task_t *task)
|
#endif |
#endif |
|
|
/* prepare rx */ |
/* prepare rx */ |
len = recv(TASK_FD(task), b, sizeof b, MSG_PEEK); | len = recv(TASK_FD(task), &b, sizeof b, MSG_PEEK); |
if (len == sizeof b) |
if (len == sizeof b) |
rlen = ntohl(((struct tagRPCCall*) b)->call_len); | rlen = ntohl(b.call_len); |
|
|
rlen = recv(TASK_FD(task), buf, rlen, 0); |
rlen = recv(TASK_FD(task), buf, rlen, 0); |
if (rlen == -1) { |
if (rlen == -1) { |