--- libaitrpc/example/tcli.c	2010/06/18 01:48:06	1.1
+++ libaitrpc/example/tcli.c	2011/05/02 23:12:07	1.2
@@ -1,43 +1,76 @@
 #include <stdio.h>
+#include <pthread.h>
 #include <aitrpc.h>
 
 //rpc_val_t valz[3];
 
 int main()
 {
-	rpc_cli_t *cli;
+	rpc_cli_t *cli, *cli2;
 	int c, i, ret;
-	rpc_val_t valz[3], *v = NULL;
+	rpc_val_t tval, valz[3], *v = NULL;
+	char *mem, *blob43 = malloc(512);
 
 	cli = rpc_cli_openClient(100, 2, 2, "127.0.0.1", 11111);
 	if (!cli) {
 		printf("error:: errno=%d %s\n", rpc_GetErrno(), rpc_GetError());
 		return 1;
 	}
+	cli2 = rpc_cli_openBLOBClient(cli, 0);
+	if (!cli2) {
+		printf("error:: errno=%d %s\n", rpc_GetErrno(), rpc_GetError());
+		return 1;
+	}
 
+	memset(blob43, 0, 512);
+	strlcpy(blob43, "aaaaaaaaaaaaaaa cddddddddddddddd zzzzzzzzzzzzzzzzzzzzz !!!!\n\n\n675675676...\n", 512);
+
 	RPC_SET_I32(&(valz[0]), 12345678);
 	RPC_SET_STR(&(valz[1]), "gniah_blah SHMINK!");
-	RPC_SET_U16(&(valz[2]), 123);
+	RPC_SET_BLOB(&(valz[2]), 0, 512);
+	if (rpc_cli_sendBLOB(cli2, &valz[2], blob43) == -1) {
+		printf("!!!!! blob error:: errno=%d %s\n", rpc_GetErrno(), rpc_GetError());
+		return 2;
+	} else
+		printf("Get BLOB = %x\n", RPC_GET_BLOB(&valz[2]));
+
+	/* test case for unknown blob ... 
+	RPC_SET_BLOB(&tval, 0x554C1BC7, BUFSIZ);
+	printf("test not found blob=%d\n", rpc_cli_getBLOB(cli2, &tval, (void**) &mem));
+	if (mem)
+		free(mem);
+	*/
+
 //	for (i = 0; i < 1000000; i++)
 		if ((ret = rpc_cli_execCall(cli, NULL, "BBB", 3, valz, &c, &v)) < 0) {
 			printf("error:: errno=%d %s\n", rpc_GetErrno(), rpc_GetError());
 			return 2;
 		} else {
 			printf("ret=%d\n", ret);
-			printf("ret_val0:: %p %s len=%d type=%d\n", 
-					&v[0], RPC_GET_BUF(&v[0]), RPC_LEN_VAL(&v[0]), RPC_TYPE_VAL(&v[0]));
-			printf("ret_val1:: %d len=%d type=%d\n", 
-					RPC_GET_I8(&v[1]), RPC_LEN_VAL(&v[1]), RPC_TYPE_VAL(&v[1]));
-			printf("ret_val2:: is_empty? %d %s len=%d type=%d\n", 
-					RPC_EMPTY_VAL(&v[2]), RPC_GET_STR(&v[2]), RPC_LEN_VAL(&v[2]), RPC_TYPE_VAL(&v[2]));
-			RPC_FREE_VAL(&v[0]);
-			RPC_FREE_VAL(&v[1]);
-			RPC_FREE_VAL(&v[2]);
-			rpc_cli_freeVals(c, v);
+			if (c && v) {
+				printf("ret_val0:: %p %s len=%d type=%d\n", 
+						&v[0], RPC_GET_BUF(&v[0]), RPC_LEN_VAL(&v[0]), RPC_TYPE_VAL(&v[0]));
+				printf("ret_val1:: %d len=%d type=%d\n", 
+						RPC_GET_I8(&v[1]), RPC_LEN_VAL(&v[1]), RPC_TYPE_VAL(&v[1]));
+				printf("ret_val2:: is_empty? %d %s len=%d type=%d\n", 
+						RPC_EMPTY_VAL(&v[2]), RPC_GET_STR(&v[2]), RPC_LEN_VAL(&v[2]), RPC_TYPE_VAL(&v[2]));
+				printf("ret_val3:: %X %d\n", RPC_GET_BLOB(&v[3]), RPC_LEN_VAL(&v[3]));
+				printf("test found blob=%d\n", rpc_cli_getBLOB(cli2, &v[3], (void**) &mem));
+				if (mem) {
+					printf("BLOB=%s", mem);
+					free(mem);
+				}
+				RPC_FREE_VAL(&v[0]);
+				RPC_FREE_VAL(&v[1]);
+				RPC_FREE_VAL(&v[2]);
+				RPC_FREE_VAL(&v[3]);
+				rpc_cli_freeVals(c, v);
+			}
 		}
 	RPC_FREE_VAL(&valz[0]);
 	RPC_FREE_VAL(&valz[1]);
 	RPC_FREE_VAL(&valz[2]);
+	free(blob43);
 
 	if (rpc_cli_execCall(cli, NULL, "aaa", 0, NULL, &c, &v) < 0) {
 		printf("error:: errno=%d %s\n", rpc_GetErrno(), rpc_GetError());
@@ -48,9 +81,26 @@ int main()
 		printf("error:: errno=%d %s\n", rpc_GetErrno(), rpc_GetError());
 		return 4;
 	}
+	printf("return=%d registeredClient\n", c);
 	for (i = 0; i < c; i++)
-		printf("registeredClient(%d)=%s\n", i, RPC_GET_STR(&*v));
+		printf("registeredClient(%d)=%s\n", i, RPC_GET_STR(&v[i]));
 	rpc_cli_freeVals(c, v);
+	if (rpc_cli_execCall(cli, NULL, CALL_BLOBCLIENTS, 0, NULL, &c, &v) < 0) {
+		printf("error:: errno=%d %s\n", rpc_GetErrno(), rpc_GetError());
+		return 4;
+	}
+	printf("return=%d registeredBLOBClient\n", c);
+	for (i = 0; i < c; i++)
+		printf("registeredBLOBClient(%d)=%s\n", i, RPC_GET_STR(&*v));
+	rpc_cli_freeVals(c, v);
+
+	if (rpc_cli_execCall(cli, NULL, CALL_BLOBVARS, 0, NULL, &c, &v) < 0) {
+		printf("error:: errno=%d %s\n", rpc_GetErrno(), rpc_GetError());
+		return 5;
+	}
+	for (i = 0; i < c; i++)
+		printf("registeredBLOBVars(%d)=%0X\n", i, RPC_GET_U32(&v[i]));
+	rpc_cli_freeVals(c, v);
 	if (rpc_cli_execCall(cli, NULL, CALL_SRVCALLS, 0, NULL, &c, &v) < 0) {
 		printf("error:: errno=%d %s\n", rpc_GetErrno(), rpc_GetError());
 		return 5;
@@ -67,6 +117,9 @@ int main()
 			RPC_GET_U32(&v[2]), RPC_GET_I32(&v[3]));
 	rpc_cli_freeVals(c, v);
 
+	rpc_cli_execCall(cli, NULL, CALL_SRVSHUTDOWN, 0, NULL, 0, NULL);
+
+	rpc_cli_closeBLOBClient(cli2);
 	rpc_cli_closeClient(cli);
 	return 0;
 }