version 1.9, 2012/07/22 20:44:13
|
version 1.10, 2012/11/13 09:22:10
|
Line 53 int main(int argc, char **argv)
|
Line 53 int main(int argc, char **argv)
|
return 127; |
return 127; |
} |
} |
gettimeofday(&after, NULL); |
gettimeofday(&after, NULL); |
io_freeVars(&arr); | rpc_cli_freeCall(&arr); |
printf("RPC ping #%d --- %f\n", i, (after.tv_sec - before.tv_sec) + |
printf("RPC ping #%d --- %f\n", i, (after.tv_sec - before.tv_sec) + |
(after.tv_usec - before.tv_usec) / 1.e6); |
(after.tv_usec - before.tv_usec) / 1.e6); |
} |
} |
Line 127 int main(int argc, char **argv)
|
Line 127 int main(int argc, char **argv)
|
printf("+++++++ BLOB=%s", mem); |
printf("+++++++ BLOB=%s", mem); |
io_free(mem); |
io_free(mem); |
} |
} |
io_freeVars(&arr); | rpc_cli_freeCall(&arr); |
} |
} |
} |
} |
io_freeVars(&valz); |
io_freeVars(&valz); |
Line 148 int main(int argc, char **argv)
|
Line 148 int main(int argc, char **argv)
|
printf("0) 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); |
io_freeVars(&valz); |
if (arr) |
if (arr) |
io_freeVars(&arr); | rpc_cli_freeCall(&arr); |
rpc_cli_closeBLOBClient(&cli2); |
rpc_cli_closeBLOBClient(&cli2); |
rpc_cli_closeClient(&cli); |
rpc_cli_closeClient(&cli); |
return 3; |
return 3; |
Line 160 int main(int argc, char **argv)
|
Line 160 int main(int argc, char **argv)
|
v = io_array(arr, 0, ait_val_t*); |
v = io_array(arr, 0, ait_val_t*); |
printf("ret_val0:: %p %s len=%d type=%d\n", |
printf("ret_val0:: %p %s len=%d type=%d\n", |
v, AIT_GET_BUF(v), AIT_LEN(v), AIT_TYPE(v)); |
v, AIT_GET_BUF(v), AIT_LEN(v), AIT_TYPE(v)); |
io_freeVars(&arr); | rpc_cli_freeCall(&arr); |
} |
} |
|
|
valz = io_allocVars(1); |
valz = io_allocVars(1); |
Line 171 int main(int argc, char **argv)
|
Line 171 int main(int argc, char **argv)
|
printf("1) 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); |
io_freeVars(&valz); |
if (arr) |
if (arr) |
io_freeVars(&arr); | rpc_cli_freeCall(&arr); |
rpc_cli_closeBLOBClient(&cli2); |
rpc_cli_closeBLOBClient(&cli2); |
rpc_cli_closeClient(&cli); |
rpc_cli_closeClient(&cli); |
return 3; |
return 3; |
Line 183 int main(int argc, char **argv)
|
Line 183 int main(int argc, char **argv)
|
v = io_array(arr, 0, ait_val_t*); |
v = io_array(arr, 0, ait_val_t*); |
printf("ret_val0:: %p %s len=%d type=%d\n", |
printf("ret_val0:: %p %s len=%d type=%d\n", |
v, AIT_GET_BUF(v), AIT_LEN(v), AIT_TYPE(v)); |
v, AIT_GET_BUF(v), AIT_LEN(v), AIT_TYPE(v)); |
io_freeVars(&arr); | rpc_cli_freeCall(&arr); |
} |
} |
|
|
|
|
Line 196 int main(int argc, char **argv)
|
Line 196 int main(int argc, char **argv)
|
printf("return=%d registeredClient\n", (arr ? io_arraySize(arr) : 0)); |
printf("return=%d registeredClient\n", (arr ? io_arraySize(arr) : 0)); |
for (i = 0; i < (arr ? io_arraySize(arr) : 0); i++) |
for (i = 0; i < (arr ? io_arraySize(arr) : 0); i++) |
printf("registeredClient(%d)=%s\n", i, AIT_GET_STR(io_array(arr, i, ait_val_t*))); |
printf("registeredClient(%d)=%s\n", i, AIT_GET_STR(io_array(arr, i, ait_val_t*))); |
io_freeVars(&arr); | rpc_cli_freeCall(&arr); |
|
|
if (rpc_cli_execCall(cli, RPC_REPLY, CALL_BLOBCLIENTS, NULL, &arr) < 0) { |
if (rpc_cli_execCall(cli, RPC_REPLY, 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()); |
Line 207 int main(int argc, char **argv)
|
Line 207 int main(int argc, char **argv)
|
printf("return=%d registeredBLOBClient\n", (arr ? io_arraySize(arr) : 0)); |
printf("return=%d registeredBLOBClient\n", (arr ? io_arraySize(arr) : 0)); |
for (i = 0; i < (arr ? io_arraySize(arr) : 0); i++) |
for (i = 0; i < (arr ? io_arraySize(arr) : 0); i++) |
printf("registeredBLOBClient(%d)=%s\n", i, AIT_GET_STR(io_array(arr, i, ait_val_t*))); |
printf("registeredBLOBClient(%d)=%s\n", i, AIT_GET_STR(io_array(arr, i, ait_val_t*))); |
io_freeVars(&arr); | rpc_cli_freeCall(&arr); |
|
|
if (rpc_cli_execCall(cli, RPC_REPLY, CALL_BLOBVARS, NULL, &arr) < 0) { |
if (rpc_cli_execCall(cli, RPC_REPLY, 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()); |
Line 217 int main(int argc, char **argv)
|
Line 217 int main(int argc, char **argv)
|
} |
} |
for (i = 0; i < (arr ? io_arraySize(arr) : 0); i++) |
for (i = 0; i < (arr ? io_arraySize(arr) : 0); i++) |
printf("registeredBLOBVars(%d)=%s\n", i, AIT_GET_STR(io_array(arr, i, ait_val_t*))); |
printf("registeredBLOBVars(%d)=%s\n", i, AIT_GET_STR(io_array(arr, i, ait_val_t*))); |
io_freeVars(&arr); | rpc_cli_freeCall(&arr); |
|
|
if (rpc_cli_execCall(cli, RPC_REPLY, CALL_SRVCALLS, NULL, &arr) < 0) { |
if (rpc_cli_execCall(cli, RPC_REPLY, 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()); |
Line 227 int main(int argc, char **argv)
|
Line 227 int main(int argc, char **argv)
|
} |
} |
for (i = 0; i < (arr ? io_arraySize(arr) : 0); i++) |
for (i = 0; i < (arr ? io_arraySize(arr) : 0); i++) |
printf("registeredCall(%d)=%s\n", i, AIT_GET_STR(io_array(arr, i, ait_val_t*))); |
printf("registeredCall(%d)=%s\n", i, AIT_GET_STR(io_array(arr, i, ait_val_t*))); |
io_freeVars(&arr); | rpc_cli_freeCall(&arr); |
|
|
if (rpc_cli_execCall(cli, RPC_REPLY, CALL_SRVSESSIONS, NULL, &arr) < 0) { |
if (rpc_cli_execCall(cli, RPC_REPLY, 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()); |
Line 239 int main(int argc, char **argv)
|
Line 239 int main(int argc, char **argv)
|
printf("session(%d:%d:%d) clients=%d\n", (uint8_t) AIT_GET_U8(io_array(arr, 0, ait_val_t*)), |
printf("session(%d:%d:%d) clients=%d\n", (uint8_t) AIT_GET_U8(io_array(arr, 0, ait_val_t*)), |
(uint32_t) AIT_GET_U32(io_array(arr, 1, ait_val_t*)), |
(uint32_t) AIT_GET_U32(io_array(arr, 1, ait_val_t*)), |
AIT_GET_U8(io_array(arr, 2, ait_val_t*)), AIT_GET_I32(io_array(arr, 3, ait_val_t*))); |
AIT_GET_U8(io_array(arr, 2, ait_val_t*)), AIT_GET_I32(io_array(arr, 3, ait_val_t*))); |
io_freeVars(&arr); | rpc_cli_freeCall(&arr); |
|
|
if (argc > 1) |
if (argc > 1) |
rpc_cli_execCall(cli, RPC_NOREPLY, CALL_SRVSHUTDOWN, NULL, NULL); |
rpc_cli_execCall(cli, RPC_NOREPLY, CALL_SRVSHUTDOWN, NULL, NULL); |