--- libaitrpc/example/tsrv.c 2015/06/29 22:29:25 1.17.2.2 +++ libaitrpc/example/tsrv.c 2024/03/20 17:20:13 1.18.8.3 @@ -1,4 +1,6 @@ #include +#include +#include #include #include #include "rc.h" @@ -107,10 +109,10 @@ int big(rpc_cli_t *cli, struct tagRPCCall *rpc, array_ printf("Ok lets fun... %d\n", array_Size(iv)); - mpool_xdump(">>> %s(%d) ", __func__, __LINE__); + mpool_dump(NULL, ">>> %s(%d) ", __func__, __LINE__); v = ait_getVars(&RPC_RETVARS(cli), 0); AIT_SET_BUFSIZ(v, '*', AIT_GET_I32(array(iv, 0, ait_val_t*))); - mpool_xdump(">>> %s(%d) ", __func__, __LINE__); + mpool_dump(NULL, ">>> %s(%d) ", __func__, __LINE__); return 0; } @@ -123,14 +125,16 @@ int main(int argc, char **argv) if (argc > 2) srv = rpc_srv_initServer(2, 3, 1024 * 10, "0.0.0.0", 0, SOCK_RAW); else - srv = rpc_srv_initServer(2, 5, 1024 * 10, "0.0.0.0", 11111, SOCK_DGRAM); + srv = rpc_srv_initServer(2, 5, 1024 * 10, "0.0.0.0", 11112, SOCK_DGRAM); } else - srv = rpc_srv_initServer(2, 2, 1024 * 10, "0.0.0.0", 11111, 0); + srv = rpc_srv_initServer(2, 2, 1024 * 10, "0.0.0.0", 11112, 0); if (!srv) { printf("error:: errno=%d %s\n", rpc_GetErrno(), rpc_GetError()); return 1; } + rpc_srv_DispatchSignal(srv, 42); + if (rpc_srv_initBLOBServer(srv, 0, "/tmp")) { printf("error:: errno=%d %s\n", rpc_GetErrno(), rpc_GetError()); return 1; @@ -148,13 +152,14 @@ int main(int argc, char **argv) rpc_register_srvServices(srv); rpc_register_blobServices(srv); - mpool_xdump(NULL); + mpool_dump(NULL, NULL); rpc_srv_execBLOBServer(srv); rpc_srv_loopServer(srv); + rpc_srv_DispatchSignal(srv, 0); rpc_srv_endBLOBServer(srv); rpc_srv_endServer(&srv); - mpool_xdump(NULL); + mpool_dump(NULL, NULL); return 0; }