version 1.17.4.7, 2013/08/21 13:02:33
|
version 1.17.4.8, 2013/08/21 15:28:16
|
Line 67 static sched_task_func_t cbProto[SOCK_RAW + 1][4] = {
|
Line 67 static sched_task_func_t cbProto[SOCK_RAW + 1][4] = {
|
}; |
}; |
|
|
|
|
static inline u_char * | ait_val_t * |
getBuffer(rpc_cli_t * __restrict c) | rpc_getBufVar(rpc_cli_t * __restrict c) |
{ |
{ |
|
return array(c->cli_buf, RPC_ISNEXTBUF(c), ait_val_t*); |
|
} |
|
|
|
u_char * |
|
rpc_getBuffer(rpc_cli_t * __restrict c) |
|
{ |
u_char *b = NULL; |
u_char *b = NULL; |
|
|
assert(c); |
assert(c); |
Line 83 getBuffer(rpc_cli_t * __restrict c)
|
Line 89 getBuffer(rpc_cli_t * __restrict c)
|
return b; |
return b; |
} |
} |
|
|
static inline struct tagRPCCall * | struct tagRPCCall * |
getHeader(rpc_cli_t * __restrict c) | rpc_getHeader(rpc_cli_t * __restrict c) |
{ |
{ |
assert(c); |
assert(c); |
|
|
Line 255 execCall(sched_task_t *task)
|
Line 261 execCall(sched_task_t *task)
|
rpc_srv_t *s = c->cli_parent; |
rpc_srv_t *s = c->cli_parent; |
rpc_func_t *f = NULL; |
rpc_func_t *f = NULL; |
array_t *arr = NULL; |
array_t *arr = NULL; |
u_char *buf = getBuffer(c); | u_char *buf = rpc_getBuffer(c); |
struct tagRPCCall *rpc = getHeader(c); | struct tagRPCCall *rpc = rpc_getHeader(c); |
int argc = ntohs(rpc->call_argc); |
int argc = ntohs(rpc->call_argc); |
|
|
/* Go decapsulate variables ... */ |
/* Go decapsulate variables ... */ |
Line 530 rxUDPPacket(sched_task_t *task)
|
Line 536 rxUDPPacket(sched_task_t *task)
|
RPC_SET_NEXTBUF(c); |
RPC_SET_NEXTBUF(c); |
} |
} |
|
|
rpc = getHeader(c); | rpc = rpc_getHeader(c); |
memcpy(rpc, &rpcbuf, sizeof(struct tagRPCCall)); |
memcpy(rpc, &rpcbuf, sizeof(struct tagRPCCall)); |
memcpy(getBuffer(c), buf, len); | memcpy(rpc_getBuffer(c), buf, len); |
|
|
c->cli_sock = TASK_FD(task); |
c->cli_sock = TASK_FD(task); |
memcpy(&c->cli_sa, sa, sizeof c->cli_sa); |
memcpy(&c->cli_sa, sa, sizeof c->cli_sa); |