version 1.1.1.1, 2010/06/18 01:48:06
|
version 1.1.1.1.2.1, 2010/06/18 13:36:01
|
Line 22 rpcServerClients(rpc_srv_t * __restrict srv, rpc_func_
|
Line 22 rpcServerClients(rpc_srv_t * __restrict srv, rpc_func_
|
struct sockaddr_in *s; |
struct sockaddr_in *s; |
struct sockaddr_in6 *s6; |
struct sockaddr_in6 *s6; |
|
|
if (!srv || !call) { | RPC_CALLBACK_CHECK_INPUT(srv, call); |
rpc_SetErr(EINVAL, "Error:: invalid parameters ...\n"); | |
return -1; | |
} | |
if (rpc_srv_declValsCall(call, srv->srv_numcli) == -1) |
if (rpc_srv_declValsCall(call, srv->srv_numcli) == -1) |
return -1; |
return -1; |
else |
else |
Line 61 rpcServerCalls(rpc_srv_t * __restrict srv, rpc_func_t
|
Line 59 rpcServerCalls(rpc_srv_t * __restrict srv, rpc_func_t
|
register int i; |
register int i; |
char str[MAXPATHLEN]; |
char str[MAXPATHLEN]; |
|
|
if (!srv || !call) { | RPC_CALLBACK_CHECK_INPUT(srv, call); |
rpc_SetErr(EINVAL, "Error:: invalid parameters ...\n"); | |
return -1; | |
} | |
|
|
for (i = 0, f = srv->srv_funcs; f; i++, f = f->func_next); |
for (i = 0, f = srv->srv_funcs; f; i++, f = f->func_next); |
|
|
Line 91 rpcServerSessions(rpc_srv_t * __restrict srv, rpc_func
|
Line 86 rpcServerSessions(rpc_srv_t * __restrict srv, rpc_func
|
{ |
{ |
rpc_val_t *vals = NULL; |
rpc_val_t *vals = NULL; |
|
|
if (!srv || !call) { | RPC_CALLBACK_CHECK_INPUT(srv, call); |
rpc_SetErr(EINVAL, "Error:: invalid parameters ...\n"); | |
return -1; | |
} | |
|
|
if (rpc_srv_declValsCall(call, 4) == -1) |
if (rpc_srv_declValsCall(call, 4) == -1) |
return -1; |
return -1; |
Line 107 rpcServerSessions(rpc_srv_t * __restrict srv, rpc_func
|
Line 99 rpcServerSessions(rpc_srv_t * __restrict srv, rpc_func
|
RPC_SET_U32(&vals[1], srv->srv_session.sess_program); |
RPC_SET_U32(&vals[1], srv->srv_session.sess_program); |
RPC_SET_U32(&vals[2], srv->srv_session.sess_process); |
RPC_SET_U32(&vals[2], srv->srv_session.sess_process); |
RPC_SET_I32(&vals[3], srv->srv_numcli); |
RPC_SET_I32(&vals[3], srv->srv_numcli); |
|
|
|
return 0; |
|
} |
|
|
|
int |
|
rpcServerShutdown(rpc_srv_t * __restrict srv, rpc_func_t *call, int ic, rpc_val_t *iv) |
|
{ |
|
RPC_CALLBACK_CHECK_INPUT(srv, call); |
|
|
|
pthread_mutex_lock(&rpc_mtx); |
|
rpc_Kill = 1; |
|
pthread_mutex_unlock(&rpc_mtx); |
|
|
return 0; |
return 0; |
} |
} |