version 1.26.2.4, 2015/06/24 23:02:28
|
version 1.26.2.5, 2015/06/25 22:39:05
|
Line 212 txPacket(sched_task_t *task)
|
Line 212 txPacket(sched_task_t *task)
|
/* Go Encapsulate variables */ |
/* Go Encapsulate variables */ |
ret = ait_vars2buffer(buf + wlen, AIT_LEN(&c->cli_buf) - wlen, |
ret = ait_vars2buffer(buf + wlen, AIT_LEN(&c->cli_buf) - wlen, |
RPC_RETVARS(c)); |
RPC_RETVARS(c)); |
/* Free return values */ |
|
ait_freeVars(&c->cli_vars); |
|
if (ret == -1) { |
if (ret == -1) { |
rpc_SetErr(EBADRPC, "Prepare RPC packet failed"); |
rpc_SetErr(EBADRPC, "Prepare RPC packet failed"); |
|
|
Line 225 txPacket(sched_task_t *task)
|
Line 223 txPacket(sched_task_t *task)
|
} |
} |
} |
} |
|
|
|
/* Free return values */ |
|
ait_freeVars(&c->cli_vars); |
|
|
rpc->call_len = htonl(wlen); |
rpc->call_len = htonl(wlen); |
rpc->call_io = RPC_ACK; |
rpc->call_io = RPC_ACK; |
|
|
Line 303 execCall(sched_task_t *task)
|
Line 304 execCall(sched_task_t *task)
|
rpc->call_rep.eno = RPC_ERROR(rpc_Errno); |
rpc->call_rep.eno = RPC_ERROR(rpc_Errno); |
} |
} |
rpc->call_argc ^= rpc->call_argc; |
rpc->call_argc ^= rpc->call_argc; |
|
ait_freeVars(&c->cli_vars); |
} else { |
} else { |
rpc->call_rep.eno ^= rpc->call_rep.eno; |
rpc->call_rep.eno ^= rpc->call_rep.eno; |
if (argc) { |
if (argc) { |
Line 501 txUDPPacket(sched_task_t *task)
|
Line 503 txUDPPacket(sched_task_t *task)
|
/* Go Encapsulate variables */ |
/* Go Encapsulate variables */ |
ret = ait_vars2buffer(buf + wlen, AIT_LEN(&c->cli_buf) - wlen, |
ret = ait_vars2buffer(buf + wlen, AIT_LEN(&c->cli_buf) - wlen, |
RPC_RETVARS(c)); |
RPC_RETVARS(c)); |
/* Free return values */ |
|
ait_freeVars(&c->cli_vars); |
|
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; |
Line 513 txUDPPacket(sched_task_t *task)
|
Line 513 txUDPPacket(sched_task_t *task)
|
} |
} |
} |
} |
|
|
|
/* Free return values */ |
|
ait_freeVars(&c->cli_vars); |
|
|
rpc->call_len = htonl(wlen); |
rpc->call_len = htonl(wlen); |
rpc->call_io = RPC_ACK; |
rpc->call_io = RPC_ACK; |
|
|
Line 693 txRAWPacket(sched_task_t *task)
|
Line 696 txRAWPacket(sched_task_t *task)
|
/* Go Encapsulate variables */ |
/* Go Encapsulate variables */ |
ret = ait_vars2buffer(buf + wlen, AIT_LEN(&c->cli_buf) - wlen, |
ret = ait_vars2buffer(buf + wlen, AIT_LEN(&c->cli_buf) - wlen, |
RPC_RETVARS(c)); |
RPC_RETVARS(c)); |
/* Free return values */ |
|
ait_freeVars(&c->cli_vars); |
|
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; |
Line 705 txRAWPacket(sched_task_t *task)
|
Line 706 txRAWPacket(sched_task_t *task)
|
} |
} |
} |
} |
|
|
|
/* Free return values */ |
|
ait_freeVars(&c->cli_vars); |
|
|
rpc->call_len = htonl(wlen); |
rpc->call_len = htonl(wlen); |
rpc->call_io = RPC_ACK; |
rpc->call_io = RPC_ACK; |
|
|
Line 866 txBPFPacket(sched_task_t *task)
|
Line 870 txBPFPacket(sched_task_t *task)
|
/* Go Encapsulate variables */ |
/* Go Encapsulate variables */ |
ret = ait_vars2buffer(buf + wlen, AIT_LEN(&c->cli_buf) - wlen, |
ret = ait_vars2buffer(buf + wlen, AIT_LEN(&c->cli_buf) - wlen, |
RPC_RETVARS(c)); |
RPC_RETVARS(c)); |
/* Free return values */ |
|
ait_freeVars(&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; |
Line 878 txBPFPacket(sched_task_t *task)
|
Line 880 txBPFPacket(sched_task_t *task)
|
} |
} |
} |
} |
|
|
|
/* Free return values */ |
|
ait_freeVars(&RPC_RETVARS(c)); |
|
|
rpc->call_len = htonl(wlen); |
rpc->call_len = htonl(wlen); |
rpc->call_io = RPC_ACK; |
rpc->call_io = RPC_ACK; |
|
|
Line 1036 txEXTPacket(sched_task_t *task)
|
Line 1041 txEXTPacket(sched_task_t *task)
|
/* Go Encapsulate variables */ |
/* Go Encapsulate variables */ |
ret = ait_vars2buffer(buf + wlen, AIT_LEN(&c->cli_buf) - wlen, |
ret = ait_vars2buffer(buf + wlen, AIT_LEN(&c->cli_buf) - wlen, |
RPC_RETVARS(c)); |
RPC_RETVARS(c)); |
/* Free return values */ |
|
ait_freeVars(&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; |
Line 1047 txEXTPacket(sched_task_t *task)
|
Line 1050 txEXTPacket(sched_task_t *task)
|
wlen += ret; |
wlen += ret; |
} |
} |
} |
} |
|
|
|
/* Free return values */ |
|
ait_freeVars(&RPC_RETVARS(c)); |
|
|
rpc->call_len = htonl(wlen); |
rpc->call_len = htonl(wlen); |
rpc->call_io = RPC_ACK; |
rpc->call_io = RPC_ACK; |