|
version 1.1.2.1, 2015/06/24 22:53:42
|
version 1.3, 2020/06/25 19:11:00
|
|
Line 1
|
Line 1
|
| #include <stdio.h> |
#include <stdio.h> |
| |
#include <string.h> |
| |
#include <errno.h> |
| |
#include <unistd.h> |
| #include <sys/time.h> |
#include <sys/time.h> |
| #include <pthread.h> |
#include <pthread.h> |
| #include <aitrpc.h> | #include <aitrpc_cli.h> |
| #include "rc.h" |
#include "rc.h" |
| |
|
| |
|
|
Line 57 int main(int argc, char **argv)
|
Line 60 int main(int argc, char **argv)
|
| printf("\n\n2 pass>>> RPC ping without reply!!!\n\n"); |
printf("\n\n2 pass>>> RPC ping without reply!!!\n\n"); |
| for (i = 0; i < 10; i++) { |
for (i = 0; i < 10; i++) { |
| gettimeofday(&before, NULL); |
gettimeofday(&before, NULL); |
| if (rpc_cli_execCall(cli, RPC_NOREPLY, CALL_SRVPING, NULL, &arr)) { | if (rpc_cli_execCall(cli, RPC_NOREPLY, CALL_SRVPING, NULL, &arr) == -1) { |
| 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_closeBLOBClient(&cli2); |
| rpc_cli_closeClient(&cli); |
rpc_cli_closeClient(&cli); |
|
Line 158 int main(int argc, char **argv)
|
Line 161 int main(int argc, char **argv)
|
| |
|
| valz = ait_allocVars(1); |
valz = ait_allocVars(1); |
| v = ait_getVars(&valz, 0); |
v = ait_getVars(&valz, 0); |
| |
printf("cli_id=%d\n", cli->cli_id); |
| AIT_SET_I32(v, (cli->cli_id == SOCK_STREAM || cli->cli_id == SOCK_EXT) ? 5000000 : 5000); |
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) { |
if (rpc_cli_execCall(cli, RPC_REPLY, RC_big, valz, &arr) < 0) { |
| printf("error:: \"big\" errno=%d %s\n", rpc_GetErrno(), rpc_GetError()); |
printf("error:: \"big\" errno=%d %s\n", rpc_GetErrno(), rpc_GetError()); |