version 1.9.2.24, 2012/05/17 15:18:48
|
version 1.9.2.25, 2012/05/17 15:48:45
|
Line 602 rpc_srv_endBLOBServer(rpc_srv_t * __restrict srv)
|
Line 602 rpc_srv_endBLOBServer(rpc_srv_t * __restrict srv)
|
if (!srv) |
if (!srv) |
return; |
return; |
|
|
if (srv->srv_blob.tid) { |
|
pthread_cancel(srv->srv_blob.tid); |
|
pthread_join(srv->srv_blob.tid, NULL); |
|
} |
|
|
|
/* close all clients connections & server socket */ |
/* close all clients connections & server socket */ |
for (i = 0; i < io_arraySize(srv->srv_blob.clients); i++) { |
for (i = 0; i < io_arraySize(srv->srv_blob.clients); i++) { |
c = io_array(srv->srv_blob.clients, i, rpc_cli_t*); |
c = io_array(srv->srv_blob.clients, i, rpc_cli_t*); |
Line 620 rpc_srv_endBLOBServer(rpc_srv_t * __restrict srv)
|
Line 615 rpc_srv_endBLOBServer(rpc_srv_t * __restrict srv)
|
io_arrayDel(srv->srv_blob.clients, i, 42); |
io_arrayDel(srv->srv_blob.clients, i, 42); |
} |
} |
io_arrayDestroy(&srv->srv_blob.clients); |
io_arrayDestroy(&srv->srv_blob.clients); |
|
|
|
srv->srv_blob.kill = 1; |
|
if (srv->srv_blob.tid) |
|
pthread_cancel(srv->srv_blob.tid); |
|
|
close(srv->srv_blob.server.cli_sock); |
close(srv->srv_blob.server.cli_sock); |
|
|