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()); |