version 1.1, 2010/06/18 01:48:06
|
version 1.1.1.1.2.1, 2010/06/18 13:36:01
|
Line 276 rpc_srv_initServer(u_int regProgID, u_int regProcID, i
|
Line 276 rpc_srv_initServer(u_int regProgID, u_int regProcID, i
|
} else |
} else |
memset(srv->srv_clients, 0, srv->srv_numcli * sizeof(rpc_cli_t)); |
memset(srv->srv_clients, 0, srv->srv_numcli * sizeof(rpc_cli_t)); |
|
|
|
rpc_srv_registerCall(srv, NULL, CALL_SRVSHUTDOWN, 0); |
rpc_srv_registerCall(srv, NULL, CALL_SRVCLIENTS, 0); |
rpc_srv_registerCall(srv, NULL, CALL_SRVCLIENTS, 0); |
rpc_srv_registerCall(srv, NULL, CALL_SRVCALLS, 0); |
rpc_srv_registerCall(srv, NULL, CALL_SRVCALLS, 0); |
rpc_srv_registerCall(srv, NULL, CALL_SRVSESSIONS, 0); |
rpc_srv_registerCall(srv, NULL, CALL_SRVSESSIONS, 0); |
|
|
|
pthread_mutex_init(&rpc_mtx, NULL); |
return srv; |
return srv; |
} |
} |
|
|
Line 299 rpc_srv_endServer(rpc_srv_t * __restrict srv)
|
Line 302 rpc_srv_endServer(rpc_srv_t * __restrict srv)
|
return; |
return; |
} |
} |
|
|
|
pthread_mutex_destroy(&rpc_mtx); |
|
|
while ((f = srv->srv_funcs)) { |
while ((f = srv->srv_funcs)) { |
srv->srv_funcs = f->func_next; |
srv->srv_funcs = f->func_next; |
free(f); |
free(f); |
Line 340 rpc_srv_execServer(rpc_srv_t * __restrict srv)
|
Line 345 rpc_srv_execServer(rpc_srv_t * __restrict srv)
|
return -1; |
return -1; |
} |
} |
|
|
while (42) { | while (!rpc_Kill) { |
for (c = srv->srv_clients, i = 0; i < srv->srv_numcli && c; i++, c++) |
for (c = srv->srv_clients, i = 0; i < srv->srv_numcli && c; i++, c++) |
if (!c->cli_sa.sa_family) |
if (!c->cli_sa.sa_family) |
break; |
break; |