--- libaitrpc/example/tcli.c 2013/08/23 00:09:50 1.15.2.1 +++ libaitrpc/example/tcli.c 2015/05/18 15:09:59 1.19 @@ -1,4 +1,5 @@ #include +#include #include #include #include "rc.h" @@ -16,9 +17,13 @@ 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 + 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()); @@ -34,8 +39,9 @@ int main(int argc, char **argv) return 1; } +//#if 0 printf("\n\n1 pass>>> RPC ping\n\n"); - for (i = 0; i < 100000; i++) { + for (i = 0; i < 1000; i++) { gettimeofday(&before, NULL); if ((ret = rpc_cli_ping(cli)) == -1) { printf("error:: errno=%d %s\n", rpc_GetErrno(), rpc_GetError()); @@ -48,8 +54,9 @@ int main(int argc, char **argv) printf("RPC ping seq[0x%04x] #%d --- %f\n", ret, i, (after.tv_sec - before.tv_sec) + (after.tv_usec - before.tv_usec) / 1.e6); } +//#if 0 printf("\n\n2 pass>>> RPC ping without reply!!!\n\n"); - for (i = 0; i < 10000; i++) { + for (i = 0; i < 10; i++) { gettimeofday(&before, NULL); if (rpc_cli_execCall(cli, RPC_NOREPLY, CALL_SRVPING, NULL, &arr)) { printf("error:: errno=%d %s\n", rpc_GetErrno(), rpc_GetError()); @@ -79,6 +86,7 @@ int main(int argc, char **argv) (after.tv_sec - before.tv_sec) + (after.tv_usec - before.tv_usec) / 1.e6); } #endif +//#endif memset(blob43, 0, 512); strlcpy(blob43, "aaaaaaaaaaaaaaa cddddddddddddddd zzzzzzzzzzzzzzzzzzzzz !!!!\n\n\n675675676...\n", 512); @@ -149,12 +157,15 @@ 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); + AIT_SET_I32(v, (cli->cli_id == SOCK_STREAM || cli->cli_id == SOCK_EXT) ? 5000000 : 5000); + if (rpc_cli_execCall(cli, RPC_REPLY, RC_big, valz, &arr) < 0) { printf("error:: \"big\" errno=%d %s\n", rpc_GetErrno(), rpc_GetError()); - return 3; - } - printf("return=%d big arr=%p\n", arr ? array_Size(arr) : 42424242, arr); + } else + printf("return=%d big arr=%p\n", arr ? array_Size(arr) : 42424242, arr); ait_freeVars(&arr); + ait_freeVars(&valz); valz = ait_allocVars(1);