version 1.14, 2013/08/23 13:53:15
|
version 1.18, 2015/07/02 22:28:13
|
Line 1
|
Line 1
|
#include <stdio.h> |
#include <stdio.h> |
|
#include <string.h> |
|
#include <errno.h> |
#include <pthread.h> |
#include <pthread.h> |
#include <aitrpc.h> |
#include <aitrpc.h> |
#include "rc.h" |
#include "rc.h" |
Line 29 int aaa(rpc_cli_t *cli, struct tagRPCCall *rpc, array_
|
Line 31 int aaa(rpc_cli_t *cli, struct tagRPCCall *rpc, array_
|
|
|
rpc_srv_blobUnmap(b); |
rpc_srv_blobUnmap(b); |
*/ |
*/ |
|
|
|
RPC_SET_ERRNO(rpc, EAGAIN); |
return 0; |
return 0; |
} |
} |
|
|
Line 99 int xYz(rpc_cli_t *cli, struct tagRPCCall *rpc, array_
|
Line 103 int xYz(rpc_cli_t *cli, struct tagRPCCall *rpc, array_
|
|
|
int big(rpc_cli_t *cli, struct tagRPCCall *rpc, array_t *iv) |
int big(rpc_cli_t *cli, struct tagRPCCall *rpc, array_t *iv) |
{ |
{ |
RPC_CALLBACK_CHECK_INPUT(cli); |
|
ait_val_t *v; |
ait_val_t *v; |
|
|
|
RPC_CALLBACK_CHECK_INPUT(cli); |
|
|
printf("Ok lets fun... %d\n", array_Size(iv)); |
printf("Ok lets fun... %d\n", array_Size(iv)); |
|
|
|
mpool_dump(NULL, ">>> %s(%d) ", __func__, __LINE__); |
v = ait_getVars(&RPC_RETVARS(cli), 0); |
v = ait_getVars(&RPC_RETVARS(cli), 0); |
AIT_SET_BUFSIZ(v, '*', 500000); | AIT_SET_BUFSIZ(v, '*', AIT_GET_I32(array(iv, 0, ait_val_t*))); |
| mpool_dump(NULL, ">>> %s(%d) ", __func__, __LINE__); |
return 0; |
return 0; |
} |
} |
|
|
Line 114 int main(int argc, char **argv)
|
Line 121 int main(int argc, char **argv)
|
rpc_func_t *f; |
rpc_func_t *f; |
int ret; |
int ret; |
|
|
if (argc > 1) | if (argc > 1) { |
srv = rpc_srv_initServer(2, 3, 1024 * 10, "0.0.0.0", 11111, SOCK_DGRAM); | if (argc > 2) |
else | 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); |
srv = rpc_srv_initServer(2, 2, 1024 * 10, "0.0.0.0", 11111, 0); |
if (!srv) { |
if (!srv) { |
printf("error:: errno=%d %s\n", rpc_GetErrno(), rpc_GetError()); |
printf("error:: errno=%d %s\n", rpc_GetErrno(), rpc_GetError()); |
Line 140 int main(int argc, char **argv)
|
Line 150 int main(int argc, char **argv)
|
rpc_register_srvServices(srv); |
rpc_register_srvServices(srv); |
rpc_register_blobServices(srv); |
rpc_register_blobServices(srv); |
|
|
|
mpool_dump(NULL, NULL); |
|
|
rpc_srv_execBLOBServer(srv); |
rpc_srv_execBLOBServer(srv); |
rpc_srv_loopServer(srv); |
rpc_srv_loopServer(srv); |
|
|
rpc_srv_endBLOBServer(srv); |
rpc_srv_endBLOBServer(srv); |
rpc_srv_endServer(&srv); |
rpc_srv_endServer(&srv); |
|
mpool_dump(NULL, NULL); |
return 0; |
return 0; |
} |
} |