--- libaitrpc/example/tsrv.c 2013/07/16 13:04:20 1.12 +++ libaitrpc/example/tsrv.c 2013/09/05 00:43:04 1.15 @@ -29,6 +29,8 @@ int aaa(rpc_cli_t *cli, struct tagRPCCall *rpc, array_ rpc_srv_blobUnmap(b); */ + + RPC_SET_ERRNO(rpc, EAGAIN); return 0; } @@ -97,13 +99,27 @@ int xYz(rpc_cli_t *cli, struct tagRPCCall *rpc, array_ return 0; } -int main() +int big(rpc_cli_t *cli, struct tagRPCCall *rpc, array_t *iv) { + RPC_CALLBACK_CHECK_INPUT(cli); + ait_val_t *v; + + 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_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; @@ -119,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);