version 1.6.2.3, 2012/03/28 11:36:42
|
version 1.7, 2012/03/29 01:34:16
|
Line 17 int main()
|
Line 17 int main()
|
// cli = rpc_cli_openClient(100, 2, AF_LOCAL, "0.0.0.0", 11111); |
// cli = rpc_cli_openClient(100, 2, AF_LOCAL, "0.0.0.0", 11111); |
if (!cli) { |
if (!cli) { |
printf("error:: errno=%d %s\n", rpc_GetErrno(), rpc_GetError()); |
printf("error:: errno=%d %s\n", rpc_GetErrno(), rpc_GetError()); |
|
free(blob43); |
return 1; |
return 1; |
} |
} |
|
|
cli2 = rpc_cli_openBLOBClient(cli, 0); |
cli2 = rpc_cli_openBLOBClient(cli, 0); |
if (!cli2) { |
if (!cli2) { |
printf("error:: errno=%d %s\n", rpc_GetErrno(), rpc_GetError()); |
printf("error:: errno=%d %s\n", rpc_GetErrno(), rpc_GetError()); |
|
rpc_cli_closeClient(cli); |
|
free(blob43); |
return 1; |
return 1; |
} |
} |
|
|
Line 38 int main()
|
Line 41 int main()
|
AIT_NEW_BLOB(v, 512); |
AIT_NEW_BLOB(v, 512); |
if (rpc_cli_sendBLOB(cli2, v, blob43) == -1) { |
if (rpc_cli_sendBLOB(cli2, v, blob43) == -1) { |
printf("!!!!! blob error:: errno=%d %s\n", rpc_GetErrno(), rpc_GetError()); |
printf("!!!!! blob error:: errno=%d %s\n", rpc_GetErrno(), rpc_GetError()); |
|
io_freeVars(&valz); |
|
rpc_cli_closeBLOBClient(cli2); |
|
rpc_cli_closeClient(cli); |
|
free(blob43); |
return 2; |
return 2; |
} else |
} else |
printf("Get BLOB = %x\n", AIT_GET_BLOB(v)); |
printf("Get BLOB = %x\n", AIT_GET_BLOB(v)); |
Line 52 int main()
|
Line 59 int main()
|
// for (i = 0; i < 1000000; i++) |
// for (i = 0; i < 1000000; i++) |
if ((ret = rpc_cli_execCall(cli, RPC_REPLY, NULL, "BBB", valz, &arr)) < 0) { |
if ((ret = rpc_cli_execCall(cli, RPC_REPLY, NULL, "BBB", valz, &arr)) < 0) { |
printf("error:: errno=%d %s\n", rpc_GetErrno(), rpc_GetError()); |
printf("error:: errno=%d %s\n", rpc_GetErrno(), rpc_GetError()); |
|
io_freeVars(&valz); |
|
rpc_cli_closeBLOBClient(cli2); |
|
rpc_cli_closeClient(cli); |
|
free(blob43); |
return 2; |
return 2; |
} else { |
} else { |
printf("ret=%d\n", ret); |
printf("ret=%d\n", ret); |
Line 91 int main()
|
Line 102 int main()
|
AIT_SET_DATA(v, "1234567890", 11); |
AIT_SET_DATA(v, "1234567890", 11); |
io_arraySet(valz, 0, v); |
io_arraySet(valz, 0, v); |
if (rpc_cli_execCall(cli, RPC_NOREPLY, NULL, "xxx", valz, &arr) < 0) { |
if (rpc_cli_execCall(cli, RPC_NOREPLY, NULL, "xxx", valz, &arr) < 0) { |
printf("error:: \"xxx\" errno=%d %s\n", rpc_GetErrno(), rpc_GetError()); | printf("0) error:: \"xxx\" errno=%d %s\n", rpc_GetErrno(), rpc_GetError()); |
| io_freeVars(&valz); |
| if (arr) |
| io_freeVars(&arr); |
| rpc_cli_closeBLOBClient(cli2); |
| rpc_cli_closeClient(cli); |
return 3; |
return 3; |
} |
} |
printf("return=%d xxx arr=%p\n", arr ? io_arraySize(arr) : 42424242, arr); | printf("0) return=%d xxx arr=%p\n", arr ? io_arraySize(arr) : 42424242, arr); |
io_freeVars(&valz); |
io_freeVars(&valz); |
if (arr) { |
if (arr) { |
printf("...REPLY --- "); |
printf("...REPLY --- "); |
Line 109 int main()
|
Line 125 int main()
|
AIT_SET_DATA(v, "0987654321", 11); |
AIT_SET_DATA(v, "0987654321", 11); |
io_arraySet(valz, 0, v); |
io_arraySet(valz, 0, v); |
if (rpc_cli_execCall(cli, RPC_REPLY, NULL, "xxx", valz, &arr) < 0) { |
if (rpc_cli_execCall(cli, RPC_REPLY, NULL, "xxx", valz, &arr) < 0) { |
printf("error:: \"xxx\" errno=%d %s\n", rpc_GetErrno(), rpc_GetError()); | printf("1) error:: \"xxx\" errno=%d %s\n", rpc_GetErrno(), rpc_GetError()); |
| io_freeVars(&valz); |
| if (arr) |
| io_freeVars(&arr); |
| rpc_cli_closeBLOBClient(cli2); |
| rpc_cli_closeClient(cli); |
return 3; |
return 3; |
} |
} |
printf("return=%d xxx arr=%p\n", arr ? io_arraySize(arr) : 42424242, arr); | printf("1) return=%d xxx arr=%p\n", arr ? io_arraySize(arr) : 42424242, arr); |
io_freeVars(&valz); |
io_freeVars(&valz); |
if (arr) { |
if (arr) { |
printf("@REPLY --- "); |
printf("@REPLY --- "); |
Line 125 int main()
|
Line 146 int main()
|
|
|
if (rpc_cli_execCall(cli, RPC_REPLY, NULL, CALL_SRVCLIENTS, NULL, &arr) < 0) { |
if (rpc_cli_execCall(cli, RPC_REPLY, NULL, CALL_SRVCLIENTS, NULL, &arr) < 0) { |
printf("error:: errno=%d %s\n", rpc_GetErrno(), rpc_GetError()); |
printf("error:: errno=%d %s\n", rpc_GetErrno(), rpc_GetError()); |
|
rpc_cli_closeBLOBClient(cli2); |
|
rpc_cli_closeClient(cli); |
return 4; |
return 4; |
} |
} |
printf("return=%d registeredClient\n", (arr ? io_arraySize(arr) : 0)); |
printf("return=%d registeredClient\n", (arr ? io_arraySize(arr) : 0)); |
Line 134 int main()
|
Line 157 int main()
|
|
|
if (rpc_cli_execCall(cli, RPC_REPLY, NULL, CALL_BLOBCLIENTS, NULL, &arr) < 0) { |
if (rpc_cli_execCall(cli, RPC_REPLY, NULL, CALL_BLOBCLIENTS, NULL, &arr) < 0) { |
printf("error:: errno=%d %s\n", rpc_GetErrno(), rpc_GetError()); |
printf("error:: errno=%d %s\n", rpc_GetErrno(), rpc_GetError()); |
|
rpc_cli_closeBLOBClient(cli2); |
|
rpc_cli_closeClient(cli); |
return 4; |
return 4; |
} |
} |
printf("return=%d registeredBLOBClient\n", (arr ? io_arraySize(arr) : 0)); |
printf("return=%d registeredBLOBClient\n", (arr ? io_arraySize(arr) : 0)); |
Line 143 int main()
|
Line 168 int main()
|
|
|
if (rpc_cli_execCall(cli, RPC_REPLY, NULL, CALL_BLOBVARS, NULL, &arr) < 0) { |
if (rpc_cli_execCall(cli, RPC_REPLY, NULL, CALL_BLOBVARS, NULL, &arr) < 0) { |
printf("error:: errno=%d %s\n", rpc_GetErrno(), rpc_GetError()); |
printf("error:: errno=%d %s\n", rpc_GetErrno(), rpc_GetError()); |
|
rpc_cli_closeBLOBClient(cli2); |
|
rpc_cli_closeClient(cli); |
return 5; |
return 5; |
} |
} |
for (i = 0; i < (arr ? io_arraySize(arr) : 0); i++) |
for (i = 0; i < (arr ? io_arraySize(arr) : 0); i++) |
Line 151 int main()
|
Line 178 int main()
|
|
|
if (rpc_cli_execCall(cli, RPC_REPLY, NULL, CALL_SRVCALLS, NULL, &arr) < 0) { |
if (rpc_cli_execCall(cli, RPC_REPLY, NULL, CALL_SRVCALLS, NULL, &arr) < 0) { |
printf("error:: errno=%d %s\n", rpc_GetErrno(), rpc_GetError()); |
printf("error:: errno=%d %s\n", rpc_GetErrno(), rpc_GetError()); |
|
rpc_cli_closeBLOBClient(cli2); |
|
rpc_cli_closeClient(cli); |
return 5; |
return 5; |
} |
} |
for (i = 0; i < (arr ? io_arraySize(arr) : 0); i++) |
for (i = 0; i < (arr ? io_arraySize(arr) : 0); i++) |
Line 159 int main()
|
Line 188 int main()
|
|
|
if (rpc_cli_execCall(cli, RPC_REPLY, NULL, CALL_SRVSESSIONS, NULL, &arr) < 0) { |
if (rpc_cli_execCall(cli, RPC_REPLY, NULL, CALL_SRVSESSIONS, NULL, &arr) < 0) { |
printf("error:: errno=%d %s\n", rpc_GetErrno(), rpc_GetError()); |
printf("error:: errno=%d %s\n", rpc_GetErrno(), rpc_GetError()); |
|
rpc_cli_closeBLOBClient(cli2); |
|
rpc_cli_closeClient(cli); |
return 6; |
return 6; |
} |
} |
printf("c=%d v=%p\n", io_arraySize(arr), arr); |
printf("c=%d v=%p\n", io_arraySize(arr), arr); |