--- libaitrpc/example/tcli.c 2010/07/08 07:16:35 1.1.1.1.2.7 +++ libaitrpc/example/tcli.c 2011/08/19 09:24:41 1.2.4.2 @@ -1,7 +1,9 @@ #include +#include #include //rpc_val_t valz[3]; +#define sTYPE SOCK_DGRAM int main() { @@ -10,12 +12,13 @@ int main() rpc_val_t tval, valz[3], *v = NULL; char *mem, *blob43 = malloc(512); - cli = rpc_cli_openClient(100, 2, 2, "127.0.0.1", 11111); + cli = rpc_cli_openClient(100, 2, sTYPE, AF_INET, "127.0.0.1", 11111); +// cli = rpc_cli_openClient(100, 2, sTYPE, AF_LOCAL, "0.0.0.0", 11111); if (!cli) { printf("error:: errno=%d %s\n", rpc_GetErrno(), rpc_GetError()); return 1; } - cli2 = rpc_cli_openBLOBClient(cli, 0); + cli2 = rpc_cli_openBLOBClient(cli, sTYPE, 0); if (!cli2) { printf("error:: errno=%d %s\n", rpc_GetErrno(), rpc_GetError()); return 1; @@ -33,10 +36,12 @@ int main() } else printf("Get BLOB = %x\n", RPC_GET_BLOB(&valz[2])); + /* test case for unknown blob ... RPC_SET_BLOB(&tval, 0x554C1BC7, BUFSIZ); - printf("test not found blob=%d\n", rpc_cli_recvBLOB(cli2, &tval, (void**) &mem)); + printf("test not found blob=%d\n", rpc_cli_getBLOB(cli2, &tval, (void**) &mem)); if (mem) free(mem); + */ // for (i = 0; i < 1000000; i++) if ((ret = rpc_cli_execCall(cli, NULL, "BBB", 3, valz, &c, &v)) < 0) { @@ -51,8 +56,8 @@ int main() RPC_GET_I8(&v[1]), RPC_LEN_VAL(&v[1]), RPC_TYPE_VAL(&v[1])); printf("ret_val2:: is_empty? %d %s len=%d type=%d\n", RPC_EMPTY_VAL(&v[2]), RPC_GET_STR(&v[2]), RPC_LEN_VAL(&v[2]), RPC_TYPE_VAL(&v[2])); - printf("test found blob=%d %X\n", rpc_cli_recvBLOB(cli2, &v[3], (void**) &mem), - RPC_GET_BLOB(&v[3])); + printf("ret_val3:: %X %d\n", RPC_GET_BLOB(&v[3]), RPC_LEN_VAL(&v[3])); + printf("test found blob=%d\n", rpc_cli_getBLOB(cli2, &v[3], (void**) &mem)); if (mem) { printf("BLOB=%s", mem); free(mem); @@ -114,7 +119,7 @@ int main() RPC_GET_U32(&v[2]), RPC_GET_I32(&v[3])); rpc_cli_freeVals(c, v); -// rpc_cli_execCall(cli, NULL, CALL_SRVSHUTDOWN, 0, NULL, 0, NULL); + rpc_cli_execCall(cli, NULL, CALL_SRVSHUTDOWN, 0, NULL, 0, NULL); rpc_cli_closeBLOBClient(cli2); rpc_cli_closeClient(cli);