libaitrpc/src/srv.c - diff

Return to srv.c CVS log

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

version 1.26.2.1, 2015/06/24 22:27:58	version 1.26.2.4, 2015/06/24 23:02:28
Line 1478 rpc_srv_endBLOBServer(rpc_srv_t * __restrict srv)	Line 1478 rpc_srv_endBLOBServer(rpc_srv_t * __restrict srv)
srv->srv_blob.kill = 1;	srv->srv_blob.kill = 1;

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

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

/*	/*
Line 1579 rpc_srv_initServer(u_char InstID, int concurentClients	Line 1582 rpc_srv_initServer(u_char InstID, int concurentClients
rpc_SetErr(EINVAL, "Invalid parameters can`t init RPC server");	rpc_SetErr(EINVAL, "Invalid parameters can`t init RPC server");
return NULL;	return NULL;
}	}
	if (!Port && proto < SOCK_RAW)
	Port = RPC_DEFPORT;
if (!e_gethostbyname(csHost, Port, &sa))	if (!e_gethostbyname(csHost, Port, &sa))
return NULL;	return NULL;
if (!Port)
Port = RPC_DEFPORT;
if (!proto)	if (!proto)
proto = SOCK_STREAM;	proto = SOCK_STREAM;
if (netBuf < RPC_MIN_BUFSIZ)	if (netBuf < RPC_MIN_BUFSIZ)
Line 1700 rpc_srv_endServer(rpc_srv_t ** __restrict psrv)	Line 1703 rpc_srv_endServer(rpc_srv_t ** __restrict psrv)
sleep(RPC_SCHED_POLLING);	sleep(RPC_SCHED_POLLING);

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

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

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