version 1.16.2.1, 2013/07/15 14:16:52
|
version 1.16.2.2, 2013/07/15 14:22:00
|
Line 561 closeBLOBClient(sched_task_t *task)
|
Line 561 closeBLOBClient(sched_task_t *task)
|
static void * |
static void * |
toutBLOB(sched_task_t *task) |
toutBLOB(sched_task_t *task) |
{ |
{ |
rpc_cli_t *c = TASK_DATA(task); | rpc_cli_t *c = TASK_ARG(task); |
|
|
rpc_srv_unregisterBLOB((rpc_srv_t*) c->cli_parent, (uint32_t) TASK_ARG(task)); | rpc_srv_unregisterBLOB((rpc_srv_t*) c->cli_parent, (uint32_t) TASK_DATA(task)); |
|
|
return NULL; |
return NULL; |
} |
} |
Line 650 rxBLOB(sched_task_t *task)
|
Line 650 rxBLOB(sched_task_t *task)
|
blob.hdr_ret = htonl(rpc_srv_recvBLOB(c, b)); |
blob.hdr_ret = htonl(rpc_srv_recvBLOB(c, b)); |
rpc_srv_blobUnmap(b); |
rpc_srv_blobUnmap(b); |
|
|
schedTimer(TASK_ROOT(task), toutBLOB, | schedTimer(TASK_ROOT(task), toutBLOB, TASK_ARG(task), ts, |
(void*) (intptr_t) ntohl(blob.hdr_var), ts, | (void*) (intptr_t) ntohl(blob.hdr_var), ntohl(blob.hdr_len)); |
TASK_ARG(task), ntohl(blob.hdr_len)); | |
} else { |
} else { |
blob.hdr_cmd = error; |
blob.hdr_cmd = error; |
blob.hdr_ret = RPC_ERROR(-1); |
blob.hdr_ret = RPC_ERROR(-1); |
Line 664 rxBLOB(sched_task_t *task)
|
Line 663 rxBLOB(sched_task_t *task)
|
blob.hdr_ret = RPC_ERROR(-1); |
blob.hdr_ret = RPC_ERROR(-1); |
} |
} |
|
|
schedCancelby(TASK_ROOT(task), taskTIMER, CRITERIA_ARG, | schedCancelby(TASK_ROOT(task), taskTIMER, CRITERIA_DATA, |
(void*) (intptr_t) ntohl(blob.hdr_var), NULL); |
(void*) (intptr_t) ntohl(blob.hdr_var), NULL); |
break; |
break; |
default: |
default: |