libaitrpc/src/srv.c - diff

Return to srv.c CVS log

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

version 1.27.2.4, 2015/07/19 23:40:40	version 1.27.2.5, 2015/07/22 12:49:10
Line 1379 rpc_srv_endBLOBServer(rpc_srv_t * __restrict srv)	Line 1379 rpc_srv_endBLOBServer(rpc_srv_t * __restrict srv)

srv->srv_blob.kill = 1;	srv->srv_blob.kill = 1;

schedEnd(&srv->srv_blob.root);

if (srv->srv_blob.server.cli_sa.sa.sa_family == AF_LOCAL)	if (srv->srv_blob.server.cli_sa.sa.sa_family == AF_LOCAL)
unlink(srv->srv_blob.server.cli_sa.sun.sun_path);	unlink(srv->srv_blob.server.cli_sa.sun.sun_path);

	schedEnd(&srv->srv_blob.root);
}	}

/*	/*
Line 1607 rpc_srv_endServer(rpc_srv_t ** __restrict psrv)	Line 1607 rpc_srv_endServer(rpc_srv_t ** __restrict psrv)
/* if send kill to blob server */	/* if send kill to blob server */
rpc_srv_endBLOBServer(*psrv);	rpc_srv_endBLOBServer(*psrv);
/* wait for BLOB server done */	/* wait for BLOB server done */
while ((*psrv)->srv_blob.root)	while ((&(psrv)->srv_blob.root))
usleep(1000);	usleep(1000);

(*psrv)->srv_kill = 1;	(*psrv)->srv_kill = 1;
sleep(RPC_SCHED_POLLING);	sleep(RPC_SCHED_POLLING);

schedEnd(&(*psrv)->srv_root);

if ((*psrv)->srv_server.cli_sa.sa.sa_family == AF_LOCAL)	if ((*psrv)->srv_server.cli_sa.sa.sa_family == AF_LOCAL)
unlink((*psrv)->srv_server.cli_sa.sun.sun_path);	unlink((*psrv)->srv_server.cli_sa.sun.sun_path);

	schedEnd(&(*psrv)->srv_root);

pthread_mutex_destroy(&(*psrv)->srv_funcs.mtx);	pthread_mutex_destroy(&(*psrv)->srv_funcs.mtx);
e_free(*psrv);	e_free(*psrv);