libaitrpc/example/tcli.c - diff

Return to tcli.c CVS log

Up to [ELWIX - Embedded LightWeight unIX -] / libaitrpc / example

Diff for /libaitrpc/example/tcli.c between versions 1.15 and 1.18

version 1.15, 2013/08/22 15:31:09	version 1.18, 2013/11/14 21:44:13
Line 1	Line 1
#include <stdio.h>	#include <stdio.h>
	#include <sys/time.h>
#include <pthread.h>	#include <pthread.h>
#include <aitrpc.h>	#include <aitrpc.h>
#include "rc.h"	#include "rc.h"
Line 19 int main(int argc, char **argv)	Line 20 int main(int argc, char **argv)
if (argc > 1)	if (argc > 1)
cli = rpc_cli_openClient(2, 1024 * 10, "127.0.0.1", 11111, SOCK_DGRAM);	cli = rpc_cli_openClient(2, 1024 * 10, "127.0.0.1", 11111, SOCK_DGRAM);
else	else
	// cli = rpc_cli_openClient(2, 1024 * 10, "93.123.104.1", 11111, 0);
cli = rpc_cli_openClient(2, 1024 * 10, "127.0.0.1", 11111, 0);	cli = rpc_cli_openClient(2, 1024 * 10, "127.0.0.1", 11111, 0);
if (!cli) {	if (!cli) {
printf("error:: errno=%d %s\n", rpc_GetErrno(), rpc_GetError());	printf("error:: errno=%d %s\n", rpc_GetErrno(), rpc_GetError());
Line 34 int main(int argc, char **argv)	Line 36 int main(int argc, char **argv)
return 1;	return 1;
}	}

	//#if 0
printf("\n\n1 pass>>> RPC ping\n\n");	printf("\n\n1 pass>>> RPC ping\n\n");
for (i = 0; i < 100000; i++) {	for (i = 0; i < 1000; i++) {
gettimeofday(&before, NULL);	gettimeofday(&before, NULL);
if ((ret = rpc_cli_ping(cli)) == -1) {	if ((ret = rpc_cli_ping(cli)) == -1) {
printf("error:: errno=%d %s\n", rpc_GetErrno(), rpc_GetError());	printf("error:: errno=%d %s\n", rpc_GetErrno(), rpc_GetError());
Line 48 int main(int argc, char **argv)	Line 51 int main(int argc, char **argv)
printf("RPC ping seq[0x%04x] #%d --- %f\n", ret, i,	printf("RPC ping seq[0x%04x] #%d --- %f\n", ret, i,
(after.tv_sec - before.tv_sec) + (after.tv_usec - before.tv_usec) / 1.e6);	(after.tv_sec - before.tv_sec) + (after.tv_usec - before.tv_usec) / 1.e6);
}	}
	//#if 0
printf("\n\n2 pass>>> RPC ping without reply!!!\n\n");	printf("\n\n2 pass>>> RPC ping without reply!!!\n\n");
for (i = 0; i < 10000; 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)) {
printf("error:: errno=%d %s\n", rpc_GetErrno(), rpc_GetError());	printf("error:: errno=%d %s\n", rpc_GetErrno(), rpc_GetError());
Line 79 int main(int argc, char **argv)	Line 83 int main(int argc, char **argv)
(after.tv_sec - before.tv_sec) + (after.tv_usec - before.tv_usec) / 1.e6);	(after.tv_sec - before.tv_sec) + (after.tv_usec - before.tv_usec) / 1.e6);
}	}
#endif	#endif
	//#endif

memset(blob43, 0, 512);	memset(blob43, 0, 512);
strlcpy(blob43, "aaaaaaaaaaaaaaa cddddddddddddddd zzzzzzzzzzzzzzzzzzzzz !!!!\n\n\n675675676...\n", 512);	strlcpy(blob43, "aaaaaaaaaaaaaaa cddddddddddddddd zzzzzzzzzzzzzzzzzzzzz !!!!\n\n\n675675676...\n", 512);
Line 148 int main(int argc, char **argv)	Line 153 int main(int argc, char **argv)
return 3;	return 3;
}	}
printf("return=%d aaa arr=%p\n", arr ? array_Size(arr) : 42424242, arr);	printf("return=%d aaa arr=%p\n", arr ? array_Size(arr) : 42424242, arr);

	if (rpc_cli_execCall(cli, RPC_REPLY, RC_big, NULL, &arr) < 0) {
	printf("error:: \"big\" errno=%d %s\n", rpc_GetErrno(), rpc_GetError());
	} else
	printf("return=%d big arr=%p\n", arr ? array_Size(arr) : 42424242, arr);
	ait_freeVars(&arr);


valz = ait_allocVars(1);	valz = ait_allocVars(1);

FreeBSD-CVSweb <freebsd-cvsweb@FreeBSD.org>

Removed from v.1.15
changed lines
	Added in v.1.18