--- libaitrpc/example/tsrv.c 2013/09/05 00:43:04 1.15 +++ libaitrpc/example/tsrv.c 2015/07/02 22:28:13 1.18 @@ -1,4 +1,6 @@ #include +#include +#include #include #include #include "rc.h" @@ -101,13 +103,16 @@ int xYz(rpc_cli_t *cli, struct tagRPCCall *rpc, array_ int big(rpc_cli_t *cli, struct tagRPCCall *rpc, array_t *iv) { - RPC_CALLBACK_CHECK_INPUT(cli); ait_val_t *v; + RPC_CALLBACK_CHECK_INPUT(cli); + printf("Ok lets fun... %d\n", array_Size(iv)); + mpool_dump(NULL, ">>> %s(%d) ", __func__, __LINE__); v = ait_getVars(&RPC_RETVARS(cli), 0); - AIT_SET_BUFSIZ(v, '*', 500000); + AIT_SET_BUFSIZ(v, '*', AIT_GET_I32(array(iv, 0, ait_val_t*))); + mpool_dump(NULL, ">>> %s(%d) ", __func__, __LINE__); return 0; } @@ -116,9 +121,12 @@ int main(int argc, char **argv) rpc_func_t *f; int ret; - if (argc > 1) - srv = rpc_srv_initServer(2, 3, 1024 * 10, "0.0.0.0", 11111, SOCK_DGRAM); - else + if (argc > 1) { + 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); + } else srv = rpc_srv_initServer(2, 2, 1024 * 10, "0.0.0.0", 11111, 0); if (!srv) { printf("error:: errno=%d %s\n", rpc_GetErrno(), rpc_GetError()); @@ -142,10 +150,13 @@ int main(int argc, char **argv) rpc_register_srvServices(srv); rpc_register_blobServices(srv); + mpool_dump(NULL, NULL); + rpc_srv_execBLOBServer(srv); rpc_srv_loopServer(srv); rpc_srv_endBLOBServer(srv); rpc_srv_endServer(&srv); + mpool_dump(NULL, NULL); return 0; }