libaitrpc/src/srv.c - diff

Return to srv.c CVS log

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

version 1.30.2.4, 2024/02/26 11:01:01	version 1.30.2.6, 2024/02/26 13:30:59
Line 291 execCall(sched_task_t *task)	Line 291 execCall(sched_task_t *task)
if (TASK_VAL(task)) {	if (TASK_VAL(task)) {
/* without reply */	/* without reply */
ait_freeVars(&c->cli_vars);	ait_freeVars(&c->cli_vars);
} else {	} else if (rpc->call_io & RPC_REQ) {
/* reply */	/* reply */
rpc->call_argc = (u_char) array_Size(RPC_RETVARS(c));	rpc->call_argc = (u_char) array_Size(RPC_RETVARS(c));
}	}
Line 1383 rpc_srv_initBLOBServer(rpc_srv_t * __restrict srv, u_s	Line 1383 rpc_srv_initBLOBServer(rpc_srv_t * __restrict srv, u_s
close(srv->srv_blob.server.cli_sock);	close(srv->srv_blob.server.cli_sock);
AIT_FREE_VAL(&srv->srv_blob.dir);	AIT_FREE_VAL(&srv->srv_blob.dir);
return -1;	return -1;
} else	}
schedSignalDispatch(srv->srv_blob.root, 42);

return 0;	return 0;
}	}
Line 1459 rpc_srv_loopBLOBServer(rpc_srv_t * __restrict srv)	Line 1458 rpc_srv_loopBLOBServer(rpc_srv_t * __restrict srv)
schedPolling(srv->srv_blob.root, &ts, NULL);	schedPolling(srv->srv_blob.root, &ts, NULL);
/* main rpc loop */	/* main rpc loop */
schedRun(srv->srv_blob.root, &srv->srv_blob.kill);	schedRun(srv->srv_blob.root, &srv->srv_blob.kill);
schedSignalDispatch(srv->srv_blob.root, 0);

/* 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) {