libaitrpc/src/srv.c - diff

Return to srv.c CVS log

Up to [ELWIX - Embedded LightWeight unIX -] / libaitrpc / src

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);