--- libaitrpc/example/tcli.c 2013/11/11 22:48:53 1.17 +++ libaitrpc/example/tcli.c 2015/06/25 22:39:05 1.19.2.1 @@ -17,11 +17,14 @@ int main(int argc, char **argv) // printf("MM model=%d\n", elwix_mm_inuse()); // getchar(); - if (argc > 1) - cli = rpc_cli_openClient(2, 1024 * 10, "127.0.0.1", 11111, SOCK_DGRAM); - else - cli = rpc_cli_openClient(2, 1024 * 10, "93.123.104.1", 11111, 0); -// cli = rpc_cli_openClient(2, 1024 * 10, "127.0.0.1", 11111, 0); + if (argc > 1) { + if (argc > 2) + cli = rpc_cli_openClient(2, 1024 * 10, "127.0.0.1", 0, SOCK_RAW); + else + cli = rpc_cli_openClient(2, 1024 * 10, "127.0.0.1", 11111, SOCK_DGRAM); + } else +// cli = rpc_cli_openClient(2, 1024 * 10, "93.123.104.1", 11111, 0); + cli = rpc_cli_openClient(2, 1024 * 10, "127.0.0.1", 11111, 0); if (!cli) { printf("error:: errno=%d %s\n", rpc_GetErrno(), rpc_GetError()); e_free(blob43); @@ -154,11 +157,16 @@ int main(int argc, char **argv) } printf("return=%d aaa arr=%p\n", arr ? array_Size(arr) : 42424242, arr); - if (rpc_cli_execCall(cli, RPC_REPLY, RC_big, NULL, &arr) < 0) { + valz = ait_allocVars(1); + v = ait_getVars(&valz, 0); + printf("cli_id=%d\n", cli->cli_id); + AIT_SET_I32(v, (cli->cli_id == SOCK_STREAM || cli->cli_id == SOCK_EXT) ? 50000 : 5000); + if (rpc_cli_execCall(cli, RPC_REPLY, RC_big, valz, &arr) < 0) { printf("error:: \"big\" errno=%d %s\n", rpc_GetErrno(), rpc_GetError()); } else printf("return=%d big arr=%p\n", arr ? array_Size(arr) : 42424242, arr); ait_freeVars(&arr); + ait_freeVars(&valz); valz = ait_allocVars(1);