|
|
| 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: |