--- libaitrpc/example/tsrv_un.c 2015/06/24 22:53:42 1.1.2.1 +++ libaitrpc/example/tsrv_un.c 2015/06/28 21:40:45 1.1.2.5 @@ -108,11 +108,27 @@ 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__); 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__); 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; @@ -135,6 +151,8 @@ int main(int argc, char **argv) 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); @@ -147,10 +165,13 @@ int main(int argc, char **argv) rpc_register_srvServices(srv); rpc_register_blobServices(srv); + mpool_xdump(NULL); + rpc_srv_execBLOBServer(srv); rpc_srv_loopServer(srv); rpc_srv_endBLOBServer(srv); rpc_srv_endServer(&srv); + mpool_xdump(NULL); return 0; }