--- libaitrpc/example/tsrv.c 2010/06/28 15:18:43 1.1.1.1.2.2 +++ libaitrpc/example/tsrv.c 2010/07/07 12:29:50 1.1.1.1.2.4 @@ -4,15 +4,31 @@ int aaa(rpc_func_t *f, int in, rpc_val_t *iv) { + rpc_blob_t *b; + RPC_CALLBACK_CHK_NUM_ARGS(f, in); printf("%s(%d): Piuk! %s\n", __func__, __LINE__, f->func_name); + + b = rpc_srv_registerBLOB(f->func_parent, BUFSIZ); + if (!b) + return -1; + if (rpc_srv_blobMap(f->func_parent, b) == -1) { + rpc_srv_blobFree(f->func_parent, b); + return -1; + } + + memset(b->blob_data, 0, b->blob_len); + strcpy(b->blob_data, "AAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAa dsfsfsfnskjfnk\n"); + + rpc_srv_blobUnmap(b); return 0; } int BBB(rpc_func_t *f, int in, rpc_val_t *iv) { rpc_val_t *v; + rpc_blob_t *b; RPC_CALLBACK_CHK_NUM_ARGS(f, in); @@ -24,6 +40,20 @@ int BBB(rpc_func_t *f, int in, rpc_val_t *iv) RPC_SET_BUF(&v[0], "00!oo", 6); RPC_SET_I8(&v[1], 65); RPC_SET_STR(&v[2], "Oho boho i cheburashka"); + + b = rpc_srv_registerBLOB(f->func_parent, 128); + if (!b) + return -1; + if (rpc_srv_blobMap(f->func_parent, b) == -1) { + rpc_srv_blobFree(f->func_parent, b); + return -1; + } + + printf("data=%p blen=%d\n", b->blob_data, b->blob_len); + memset(b->blob_data, 0, b->blob_len); + strcpy(b->blob_data, "Hello Worldzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzz mzdnfdskf\naddfs\n"); + + rpc_srv_blobUnmap(b); return 33; } @@ -31,6 +61,8 @@ int main() { rpc_srv_t *srv; rpc_func_t *f; + pthread_t tid[2]; + int ret; srv = rpc_srv_initServer(100, 2, 1, 2, "0.0.0.0", 11111); if (!srv) { @@ -56,10 +88,8 @@ int main() if (!fork()) { setsid(); - if (rpc_srv_execServer(srv) == -1) { - printf("error:: errno=%d %s\n", rpc_GetErrno(), rpc_GetError()); - return 2; - } + pthread_create(&tid[1], NULL, rpc_srv_execBLOBServer, srv); + rpc_srv_execServer(srv); } rpc_srv_endBLOBServer(srv);