libaitrpc/src/srv.c - diff

Return to srv.c CVS log

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

version 1.6.2.2, 2012/03/12 15:04:38	version 1.6.2.3, 2012/03/12 15:07:58
Line 784 rpc_srv_loopServer(rpc_srv_t * __restrict srv)	Line 784 rpc_srv_loopServer(rpc_srv_t * __restrict srv)
return -1;	return -1;
}	}

	tv.tv_sec = srv->srv_session.sess_timeout;

/* activate BLOB server worker if srv->srv_blob.state == enable */	/* activate BLOB server worker if srv->srv_blob.state == enable */
rpc_srv_execBLOBServer(srv);	rpc_srv_execBLOBServer(srv);

Line 795 rpc_srv_loopServer(rpc_srv_t * __restrict srv)	Line 797 rpc_srv_loopServer(rpc_srv_t * __restrict srv)
pthread_attr_init(&attr);	pthread_attr_init(&attr);
pthread_attr_setdetachstate(&attr, PTHREAD_CREATE_DETACHED);	pthread_attr_setdetachstate(&attr, PTHREAD_CREATE_DETACHED);

	/* main rpc loop */
while (srv->srv_kill != kill) {	while (srv->srv_kill != 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.sa_family)	if (!c->cli_sa.sa.sa_family)
Line 826 rpc_srv_loopServer(rpc_srv_t * __restrict srv)	Line 829 rpc_srv_loopServer(rpc_srv_t * __restrict srv)
} else	} else
c->cli_parent = srv;	c->cli_parent = srv;

	/* spawn rpc client dispatcher */
if (pthread_create(&c->cli_tid, &attr, rpc_srv_dispatchCall, c)) {	if (pthread_create(&c->cli_tid, &attr, rpc_srv_dispatchCall, c)) {
LOGERR;	LOGERR;
continue;	continue;