--- libaitrpc/example/tsrv.c 2013/07/16 12:38:50 1.11.4.2 +++ libaitrpc/example/tsrv.c 2013/11/11 22:48:53 1.16 @@ -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,25 +99,27 @@ int xYz(rpc_cli_t *cli, struct tagRPCCall *rpc, array_ return 0; } -void -sig(int s) +int big(rpc_cli_t *cli, struct tagRPCCall *rpc, array_t *iv) { - switch (s) { - case SIGINT: - rpc_srv_endBLOBServer(srv); - rpc_srv_endServer(&srv); - break; - } -} + RPC_CALLBACK_CHECK_INPUT(cli); + ait_val_t *v; + printf("Ok lets fun... %d\n", array_Size(iv)); -int main() + v = ait_getVars(&RPC_RETVARS(cli), 0); + AIT_SET_BUFSIZ(v, '*', 5000000); + 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; @@ -131,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);