|
|
| version 1.30.2.9, 2024/02/26 18:07:32 | version 1.30.2.10, 2024/02/26 18:25:32 |
|---|---|
| Line 303 execCall(sched_task_t *task) | Line 303 execCall(sched_task_t *task) |
| taskExit(task, NULL); | taskExit(task, NULL); |
| } | } |
| int | |
| rpc_srv_Return(sched_root_task_t *root, rpc_cli_t *c) | |
| { | |
| rpc_srv_t *s = c->cli_parent; | |
| u_char *buf = AIT_GET_BUF(&c->cli_buf); | |
| struct tagRPCCall *rpc = (struct tagRPCCall*) buf; | |
| if (!RPC_CHK_NOREPLY(rpc)) { | |
| rpc->call_argc = (u_char) array_Size(RPC_RETVARS(c)); | |
| schedWrite(root, cbProto[s->srv_proto][CB_TXPACKET], c, c->cli_sock, rpc, 0); | |
| } | |
| return rpc->call_argc; | |
| } | |
| static void * | static void * |
| rxPacket(sched_task_t *task) | rxPacket(sched_task_t *task) |
| { | { |
| Line 1981 rpc_srv_initServerExt(u_char InstID, int netBuf, int f | Line 1966 rpc_srv_initServerExt(u_char InstID, int netBuf, int f |
| rpc_register_srvPing(srv); | rpc_register_srvPing(srv); |
| return srv; | return srv; |
| } | |
| /* | |
| * rpc_srv_Return() - Prepare IPC return answer to RPC client | |
| * | |
| * @c = RPC client | |
| * return: number of arguments in response | |
| */ | |
| int | |
| rpc_srv_Return(rpc_cli_t *c) | |
| { | |
| rpc_srv_t *s = c->cli_parent; | |
| u_char *buf = AIT_GET_BUF(&c->cli_buf); | |
| struct tagRPCCall *rpc = (struct tagRPCCall*) buf; | |
| if (!RPC_CHK_NOREPLY(rpc)) { | |
| rpc->call_argc = (u_char) array_Size(RPC_RETVARS(c)); | |
| schedWrite(s->srv_root, cbProto[s->srv_proto][CB_TXPACKET], c, c->cli_sock, rpc, 0); | |
| } else | |
| rpc->call_argc ^= rpc->call_argc; | |
| return rpc->call_argc; | |
| } | } |