--- libaitrpc/example/tsrv.c 2013/07/15 15:10:37 1.11.4.1 +++ libaitrpc/example/tsrv.c 2013/08/23 00:09:50 1.13.2.1 @@ -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; @@ -59,7 +62,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, 0, cli); + b = rpc_srv_registerBLOB(s, 128, 0); if (!b) return -1; else @@ -94,15 +97,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(2, 3, 1024 * 10, "0.0.0.0", 11111, SOCK_DGRAM); -// srv = rpc_srv_initServer(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 +133,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);