libaitrpc/src/srv.c - diff

Return to srv.c CVS log

Up to [ELWIX - Embedded LightWeight unIX -] / libaitrpc / src

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);