version 1.16.2.3, 2013/07/15 14:54:40
|
version 1.16.2.5, 2013/07/16 08:25:55
|
Line 629 rxBLOB(sched_task_t *task)
|
Line 629 rxBLOB(sched_task_t *task)
|
break; |
break; |
case set: |
case set: |
if ((b = rpc_srv_registerBLOB(s, ntohl(blob.hdr_len), |
if ((b = rpc_srv_registerBLOB(s, ntohl(blob.hdr_len), |
ntohl(blob.hdr_ret), task))) { | ntohl(blob.hdr_ret), c))) { |
/* set new BLOB variable for reply :) */ |
/* set new BLOB variable for reply :) */ |
blob.hdr_var = htonl(b->blob_var); |
blob.hdr_var = htonl(b->blob_var); |
|
|
Line 646 rxBLOB(sched_task_t *task)
|
Line 646 rxBLOB(sched_task_t *task)
|
blob.hdr_cmd = error; |
blob.hdr_cmd = error; |
blob.hdr_ret = RPC_ERROR(-1); |
blob.hdr_ret = RPC_ERROR(-1); |
} |
} |
|
|
schedCancelby(TASK_ROOT(task), taskTIMER, CRITERIA_DATA, |
|
(void*) (intptr_t) ntohl(blob.hdr_var), NULL); |
|
break; |
break; |
default: |
default: |
rpc_SetErr(EPROCUNAVAIL, "Unsupported BLOB command %d", blob.hdr_cmd); |
rpc_SetErr(EPROCUNAVAIL, "Unsupported BLOB command %d", blob.hdr_cmd); |
Line 892 rpc_srv_loopBLOBServer(rpc_srv_t * __restrict srv)
|
Line 889 rpc_srv_loopBLOBServer(rpc_srv_t * __restrict srv)
|
/* detach blobs */ |
/* detach blobs */ |
TAILQ_FOREACH_SAFE(b, &srv->srv_blob.blobs, blob_node, tmp) { |
TAILQ_FOREACH_SAFE(b, &srv->srv_blob.blobs, blob_node, tmp) { |
TAILQ_REMOVE(&srv->srv_blob.blobs, b, blob_node); |
TAILQ_REMOVE(&srv->srv_blob.blobs, b, blob_node); |
|
|
|
rpc_srv_unregisterBLOB(srv, b->blob_var); |
|
|
rpc_srv_blobFree(srv, b); |
rpc_srv_blobFree(srv, b); |
e_free(b); |
e_free(b); |