--- libaitrpc/example/tsrv_un.c 2015/06/28 21:40:45 1.1.2.5 +++ libaitrpc/example/tsrv_un.c 2024/03/20 17:32:30 1.3 @@ -1,4 +1,6 @@ #include +#include +#include #include #include #include @@ -108,27 +110,13 @@ 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; } -static void -sig(int s) -{ - switch (s) { - case SIGINT: - unlink("/tmp/libaitrpc-0.sock"); - unlink("/tmp/libaitrpc-1.sock.blob"); - unlink("/tmp/libaitrpc.sock-11111"); - unlink("/tmp/libaitrpc.sock-11111.blob"); - _exit(0); - break; - } -} - int main(int argc, char **argv) { rpc_func_t *f; @@ -146,13 +134,13 @@ int main(int argc, char **argv) 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; } - signal(SIGINT, sig); - rpc_srv_registerCall(srv, RC_aaa, aaa); rpc_srv_registerCall(srv, RC_BBB, BBB); rpc_srv_registerCall(srv, 3, NULL); @@ -165,13 +153,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; }