--- libaitrpc/example/tcli.c 2010/06/18 15:47:33 1.1.1.1.2.2 +++ libaitrpc/example/tcli.c 2010/06/28 17:10:39 1.1.1.1.2.4 @@ -5,19 +5,32 @@ int main() { - rpc_cli_t *cli; + rpc_cli_t *cli, *cli2; int c, i, ret; rpc_val_t valz[3], *v = NULL; + char *blob43 = malloc(512); cli = rpc_cli_openClient(100, 2, 2, "127.0.0.1", 11111); if (!cli) { printf("error:: errno=%d %s\n", rpc_GetErrno(), rpc_GetError()); return 1; } + cli2 = rpc_cli_openBLOBClient(cli, 0); + if (!cli2) { + printf("error:: errno=%d %s\n", rpc_GetErrno(), rpc_GetError()); + return 1; + } + strlcpy(blob43, "aaaaaaaaaaaaaaa cddddddddddddddd zzzzzzzzzzzzzzzzzzzzz !!!!\n\n\n675675676...\n", 512); + RPC_SET_I32(&(valz[0]), 12345678); RPC_SET_STR(&(valz[1]), "gniah_blah SHMINK!"); - RPC_SET_U16(&(valz[2]), 123); + RPC_SET_BLOB(&(valz[2]), 19750310, 512); + if (rpc_cli_sendBLOB(cli2, &valz[2], blob43) == -1) { + printf("!!!!! blob error:: errno=%d %s\n", rpc_GetErrno(), rpc_GetError()); + return 2; + } + // for (i = 0; i < 1000000; i++) if ((ret = rpc_cli_execCall(cli, NULL, "BBB", 3, valz, &c, &v)) < 0) { printf("error:: errno=%d %s\n", rpc_GetErrno(), rpc_GetError()); @@ -40,6 +53,7 @@ int main() RPC_FREE_VAL(&valz[0]); RPC_FREE_VAL(&valz[1]); RPC_FREE_VAL(&valz[2]); + free(blob43); if (rpc_cli_execCall(cli, NULL, "aaa", 0, NULL, &c, &v) < 0) { printf("error:: errno=%d %s\n", rpc_GetErrno(), rpc_GetError()); @@ -50,9 +64,19 @@ int main() printf("error:: errno=%d %s\n", rpc_GetErrno(), rpc_GetError()); return 4; } + printf("return=%d registeredClient\n", c); for (i = 0; i < c; i++) - printf("registeredClient(%d)=%s\n", i, RPC_GET_STR(&*v)); + printf("registeredClient(%d)=%s\n", i, RPC_GET_STR(&v[i])); rpc_cli_freeVals(c, v); + if (rpc_cli_execCall(cli, NULL, CALL_BLOBCLIENTS, 0, NULL, &c, &v) < 0) { + printf("error:: errno=%d %s\n", rpc_GetErrno(), rpc_GetError()); + return 4; + } + printf("return=%d registeredBLOBClient\n", c); + for (i = 0; i < c; i++) + printf("registeredBLOBClient(%d)=%s\n", i, RPC_GET_STR(&*v)); + rpc_cli_freeVals(c, v); + if (rpc_cli_execCall(cli, NULL, CALL_SRVCALLS, 0, NULL, &c, &v) < 0) { printf("error:: errno=%d %s\n", rpc_GetErrno(), rpc_GetError()); return 5; @@ -69,8 +93,9 @@ 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); return 0; }