--- libaitrpc/example/tsrv.c 2013/03/07 23:10:50 1.10 +++ libaitrpc/example/tsrv.c 2013/09/05 00:43:04 1.15 @@ -4,6 +4,9 @@ #include "rc.h" +rpc_srv_t *srv; + + int aaa(rpc_cli_t *cli, struct tagRPCCall *rpc, array_t *iv) { // rpc_blob_t *b; @@ -26,6 +29,8 @@ int aaa(rpc_cli_t *cli, struct tagRPCCall *rpc, array_ rpc_srv_blobUnmap(b); */ + + RPC_SET_ERRNO(rpc, EAGAIN); return 0; } @@ -59,7 +64,7 @@ int BBB(rpc_cli_t *cli, struct tagRPCCall *rpc, array_ AIT_SET_STR(ait_getVars(&RPC_RETVARS(cli), 2), "Oho boho i cheburashka"); // return blob object - b = rpc_srv_registerBLOB(s, 128); + b = rpc_srv_registerBLOB(s, 128, 0); if (!b) return -1; else @@ -94,15 +99,27 @@ int xYz(rpc_cli_t *cli, struct tagRPCCall *rpc, array_ return 0; } +int big(rpc_cli_t *cli, struct tagRPCCall *rpc, array_t *iv) +{ + RPC_CALLBACK_CHECK_INPUT(cli); + ait_val_t *v; -int main() + printf("Ok lets fun... %d\n", array_Size(iv)); + + v = ait_getVars(&RPC_RETVARS(cli), 0); + AIT_SET_BUFSIZ(v, '*', 500000); + return 0; +} + +int main(int argc, char **argv) { - rpc_srv_t *srv; rpc_func_t *f; int ret; - srv = rpc_srv_initServer(100, 2, 3, 1024 * 10, "0.0.0.0", 11111, SOCK_DGRAM); -// srv = rpc_srv_initServer(100, 2, 2, 1024 * 10, "0.0.0.0", 11111, 0); + if (argc > 1) + srv = rpc_srv_initServer(2, 3, 1024 * 10, "0.0.0.0", 11111, SOCK_DGRAM); + else + srv = rpc_srv_initServer(2, 2, 1024 * 10, "0.0.0.0", 11111, 0); if (!srv) { printf("error:: errno=%d %s\n", rpc_GetErrno(), rpc_GetError()); return 1; @@ -118,6 +135,7 @@ int main() rpc_srv_registerCall(srv, 3, NULL); rpc_srv_registerCall(srv, RC_xYz, xYz); rpc_srv_registerCall(srv, RC_xxx, xxx); + rpc_srv_registerCall(srv, RC_big, big); rpc_srv_unregisterCall(srv, 4);