--- libaitrpc/example/tsrv.c 2011/08/19 06:58:31 1.2.4.3 +++ libaitrpc/example/tsrv.c 2011/08/19 09:20:46 1.2.4.5 @@ -3,6 +3,9 @@ #include +#define sTYPE SOCK_STREAM + + int aaa(rpc_func_t *f, int in, rpc_val_t *iv) { rpc_blob_t *b; @@ -49,8 +52,8 @@ int BBB(rpc_func_t *f, int in, rpc_val_t *iv) rpc_srv_unregisterBLOB(f->func_parent, RPC_GET_BLOB(&iv[2])); - rpc_srv_declValsCall(f, 4); - rpc_srv_getValsCall(f, &v); + rpc_srv_allocVars(f, 4); + rpc_srv_getVars(f, &v); RPC_SET_BUF(&v[0], "00!oo", 6); RPC_SET_I8(&v[1], 65); RPC_SET_STR(&v[2], "Oho boho i cheburashka"); @@ -82,13 +85,13 @@ int main() pthread_t tid[2]; int ret; - srv = rpc_srv_initServer(100, 2, 1, SOCK_STREAM, AF_INET, "0.0.0.0", 11111); + srv = rpc_srv_initServer(100, 2, 1, sTYPE, AF_INET, "0.0.0.0", 11111); if (!srv) { printf("error:: errno=%d %s\n", rpc_GetErrno(), rpc_GetError()); return 1; } - if (rpc_srv_initBLOBServer(srv, SOCK_STREAM, 0, "/tmp")) { + if (rpc_srv_initBLOBServer(srv, sTYPE, 0, "/tmp")) { printf("error:: errno=%d %s\n", rpc_GetErrno(), rpc_GetError()); return 1; }