version 1.26.2.8, 2015/06/29 22:29:26
|
version 1.26.2.10, 2015/06/30 14:11:55
|
Line 70 static void *rxEXTPacket(sched_task_t *);
|
Line 70 static void *rxEXTPacket(sched_task_t *);
|
static void *txEXTPacket(sched_task_t *); |
static void *txEXTPacket(sched_task_t *); |
|
|
static sched_task_func_t cbProto[SOCK_MAX_SUPPORT][4] = { |
static sched_task_func_t cbProto[SOCK_MAX_SUPPORT][4] = { |
{ acceptClients, closeClient, rxPacket, txPacket }, /* SOCK_STREAM */ | { acceptClients, closeClient, rxPacket, txPacket }, /* SOCK_STREAM */ |
{ acceptClients, closeClient, rxPacket, txPacket }, /* SOCK_STREAM */ | { acceptClients, closeClient, rxPacket, txPacket }, /* SOCK_STREAM */ |
{ rxUDPPacket, freeClient, rxUDPPacket, txUDPPacket }, /* SOCK_DGRAM */ | { rxUDPPacket, freeClient, NULL /*rxUDPPacket*/, txUDPPacket }, /* SOCK_DGRAM */ |
{ rxRAWPacket, freeClient, rxRAWPacket, txRAWPacket }, /* SOCK_RAW */ | { rxRAWPacket, freeClient, NULL /*rxRAWPacket*/, txRAWPacket }, /* SOCK_RAW */ |
{ rxBPFPacket, freeClient, rxBPFPacket, txBPFPacket }, /* SOCK_BPF */ | { rxBPFPacket, freeClient, NULL /*rxBPFPacket*/, txBPFPacket }, /* SOCK_BPF */ |
{ rxEXTPacket, freeClient, rxEXTPacket, txEXTPacket } /* SOCK_EXT */ | { rxEXTPacket, freeClient, NULL /*rxEXTPacket*/, txEXTPacket } /* SOCK_EXT */ |
}; |
}; |
|
|
/* Global Signal Argument when kqueue support disabled */ |
/* Global Signal Argument when kqueue support disabled */ |
Line 313 rxPacket(sched_task_t *task)
|
Line 313 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 *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 322 rxPacket(sched_task_t *task)
|
Line 323 rxPacket(sched_task_t *task)
|
TASK_ARG(task), ts, TASK_ARG(task), 0); |
TASK_ARG(task), ts, TASK_ARG(task), 0); |
#endif |
#endif |
|
|
|
/* prepare rx */ |
|
len = recv(TASK_FD(task), b, sizeof b, MSG_PEEK); |
|
if (len == sizeof b) |
|
rlen = ntohl(((struct tagRPCCall*) 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) { |
/* close connection */ |
/* close connection */ |
Line 613 txRAWPacket(sched_task_t *task)
|
Line 619 txRAWPacket(sched_task_t *task)
|
RPC_RETVARS(c)); |
RPC_RETVARS(c)); |
if (ret == -1) { |
if (ret == -1) { |
rpc_SetErr(EBADRPC, "Prepare RPC packet failed"); |
rpc_SetErr(EBADRPC, "Prepare RPC packet failed"); |
|
|
rpc->call_argc ^= rpc->call_argc; |
rpc->call_argc ^= rpc->call_argc; |
rpc->call_rep.ret = RPC_ERROR(-1); |
rpc->call_rep.ret = RPC_ERROR(-1); |
rpc->call_rep.eno = RPC_ERROR(rpc_Errno); |
rpc->call_rep.eno = RPC_ERROR(rpc_Errno); |