--- libaitrpc/example/tsrv.c 2013/08/22 12:01:36 1.12.6.1 +++ libaitrpc/example/tsrv.c 2015/06/28 21:27:47 1.17.2.1 @@ -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,14 +99,30 @@ int xYz(rpc_cli_t *cli, struct tagRPCCall *rpc, array_ return 0; } +int big(rpc_cli_t *cli, struct tagRPCCall *rpc, array_t *iv) +{ + ait_val_t *v; + + RPC_CALLBACK_CHECK_INPUT(cli); + + printf("Ok lets fun... %d\n", array_Size(iv)); + + v = ait_getVars(&RPC_RETVARS(cli), 0); + AIT_SET_BUFSIZ(v, '*', AIT_GET_I32(array(iv, 0, ait_val_t*))); + return 0; +} + int main(int argc, char **argv) { rpc_func_t *f; int ret; - if (argc > 1) - srv = rpc_srv_initServer(2, 3, 1024 * 10, "0.0.0.0", 11111, SOCK_DGRAM); - else + if (argc > 1) { + if (argc > 2) + srv = rpc_srv_initServer(2, 3, 1024 * 10, "0.0.0.0", 0, SOCK_RAW); + else + srv = rpc_srv_initServer(2, 5, 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()); @@ -121,6 +139,7 @@ int main(int argc, char **argv) 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);