version 1.7, 2012/03/29 01:34:16
|
version 1.7.4.2, 2012/05/16 14:08:52
|
Line 55 int BBB(rpc_func_t *f, int in, array_t *iv)
|
Line 55 int BBB(rpc_func_t *f, int in, array_t *iv)
|
rpc_srv_unregisterBLOB(f->func_parent, AIT_GET_BLOB(io_array(iv, 2, ait_val_t*))); |
rpc_srv_unregisterBLOB(f->func_parent, AIT_GET_BLOB(io_array(iv, 2, ait_val_t*))); |
|
|
|
|
rpc_srv_getVars(f, &arr); | v = io_array(f->func_vars, 0, ait_val_t*); |
v = io_array(arr, 0, ait_val_t*); | |
AIT_SET_BUF(v, "00!oo", 6); |
AIT_SET_BUF(v, "00!oo", 6); |
v = io_array(arr, 1, ait_val_t*); | v = io_array(f->func_vars, 1, ait_val_t*); |
AIT_SET_I8(v, 65); |
AIT_SET_I8(v, 65); |
v = io_array(arr, 2, ait_val_t*); | v = io_array(f->func_vars, 2, ait_val_t*); |
AIT_SET_STR(v, "Oho boho i cheburashka"); |
AIT_SET_STR(v, "Oho boho i cheburashka"); |
|
|
// return blob object |
// return blob object |
Line 82 int BBB(rpc_func_t *f, int in, array_t *iv)
|
Line 81 int BBB(rpc_func_t *f, int in, array_t *iv)
|
|
|
int xxx(rpc_func_t *f, int in, array_t *iv) |
int xxx(rpc_func_t *f, int in, array_t *iv) |
{ |
{ |
array_t *arr; |
|
ait_val_t *v; |
ait_val_t *v; |
|
|
RPC_CALLBACK_CHECK_INPUT(f); |
RPC_CALLBACK_CHECK_INPUT(f); |
Line 92 int xxx(rpc_func_t *f, int in, array_t *iv)
|
Line 90 int xxx(rpc_func_t *f, int in, array_t *iv)
|
AIT_GET_BUF(io_array(iv, 0, ait_val_t*))); |
AIT_GET_BUF(io_array(iv, 0, ait_val_t*))); |
fflush(stdout); |
fflush(stdout); |
|
|
rpc_srv_getVars(f, &arr); | v = io_array(f->func_vars, 0, ait_val_t*); |
v = io_array(arr, 0, ait_val_t*); | |
AIT_SET_DATA(v, "00!oo", 6); |
AIT_SET_DATA(v, "00!oo", 6); |
io_arraySet(arr, 0, v); | io_arraySet(f->func_vars, 0, v); |
v = io_array(arr, 1, ait_val_t*); | v = io_array(f->func_vars, 1, ait_val_t*); |
AIT_SET_I8(v, 65); |
AIT_SET_I8(v, 65); |
|
io_arraySet(f->func_vars, 1, v); |
return 111; |
return 111; |
} |
} |
|
|
io_enableDEBUG = 7; | int xYz(rpc_func_t *f, int in, array_t *iv) |
| { |
| return 0; |
| } |
|
|
|
|
int main() |
int main() |
{ |
{ |
rpc_srv_t *srv; |
rpc_srv_t *srv; |
rpc_func_t *f; |
rpc_func_t *f; |
int ret; |
int ret; |
|
|
srv = rpc_srv_initServer(100, 2, 1, 1024 * 10, AF_INET, "0.0.0.0", 11111); | srv = rpc_srv_initServer(100, 2, 2, 1024 * 10, "0.0.0.0", 11111); |
// srv = rpc_srv_initServer(100, 2, 1, AF_LOCAL, "0.0.0.0", 11111); | // srv = rpc_srv_initServer(100, 2, 1, 1024 * 10, "0.0.0.0", 11111); |
if (!srv) { |
if (!srv) { |
printf("error:: errno=%d %s\n", rpc_GetErrno(), rpc_GetError()); |
printf("error:: errno=%d %s\n", rpc_GetErrno(), rpc_GetError()); |
return 1; |
return 1; |
Line 121 int main()
|
Line 123 int main()
|
return 1; |
return 1; |
} |
} |
|
|
rpc_srv_registerCall(srv, NULL, "aaa", 0); | rpc_srv_registerCall(srv, 1, aaa, 0); |
rpc_srv_registerCall(srv, NULL, "BBB", 4); | rpc_srv_registerCall(srv, 2, BBB, 4); |
rpc_srv_registerCall(srv, NULL, "dummy", 1); | rpc_srv_registerCall(srv, 3, NULL, 1); |
rpc_srv_registerCall(srv, NULL, "xYz", 2); | rpc_srv_registerCall(srv, 4, xYz, 2); |
rpc_srv_registerCall(srv, NULL, "xxx", 2); | rpc_srv_registerCall(srv, 5, xxx, 2); |
|
|
/* dump register functions */ | rpc_srv_unregisterCall(srv, 4); |
/* | |
for (f = srv->srv_funcs; f; f = f->func_next) | |
printf("0.func::name=%s args=%d\n", AIT_GET_STR(&f->func_name), io_arraySize(f->func_vars)); | |
*/ | |
|
|
rpc_srv_unregisterCall(srv, NULL, "dummy"); | rpc_srv_loopServer(srv); |
|
|
/* dump register functions */ |
|
/* |
|
for (f = srv->srv_funcs; f; f = f->func_next) |
|
printf("1.func::name=%s args=%d\n", AIT_GET_STR(&f->func_name), io_arraySize(f->func_vars)); |
|
*/ |
|
|
|
// if (!fork()) { |
|
///////// setsid(); |
|
|
|
rpc_srv_loopServer(srv); |
|
//// rpc_srv_execServer(srv, &ret); |
|
// } |
|
|
|
rpc_srv_endBLOBServer(srv); |
rpc_srv_endBLOBServer(srv); |
rpc_srv_endServer(&srv); |
rpc_srv_endServer(&srv); |
|
|
return 0; |
return 0; |
} |
} |