|
|
| version 1.27.2.6, 2015/07/22 15:07:10 | 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) { |