libaitrpc/src/srv.c - diff

Return to srv.c CVS log

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

Diff for /libaitrpc/src/srv.c between versions 1.9.2.18 and 1.9.2.20

version 1.9.2.18, 2012/05/17 08:42:32	version 1.9.2.20, 2012/05/17 11:01:30
Line 52 closeClient(sched_task_t *task)	Line 52 closeClient(sched_task_t *task)
rpc_cli_t *c = TASK_ARG(task);	rpc_cli_t *c = TASK_ARG(task);
rpc_srv_t *s = c->cli_parent;	rpc_srv_t *s = c->cli_parent;

schedCancelby(s->srv_root, taskMAX, CRITERIA_ARG, TASK_ARG(task), NULL);	schedCancelby(TASK_ROOT(task), taskMAX, CRITERIA_ARG, TASK_ARG(task), NULL);

/* close client socket */	/* close client socket */
if (TASK_VAL(task))	if (TASK_VAL(task))
Line 294 closeBLOBClient(sched_task_t *task)	Line 294 closeBLOBClient(sched_task_t *task)
rpc_cli_t *c = TASK_ARG(task);	rpc_cli_t *c = TASK_ARG(task);
rpc_srv_t *s = c->cli_parent;	rpc_srv_t *s = c->cli_parent;

schedCancelby(s->srv_blob.root, taskMAX, CRITERIA_ARG, TASK_ARG(task), NULL);	schedCancelby(TASK_ROOT(task), taskMAX, CRITERIA_ARG, TASK_ARG(task), NULL);

/* close client socket */	/* close client socket */
if (TASK_VAL(task))	if (TASK_VAL(task))
Line 592 rpc_srv_endBLOBServer(rpc_srv_t * __restrict srv)	Line 592 rpc_srv_endBLOBServer(rpc_srv_t * __restrict srv)
if (!srv)	if (!srv)
return;	return;

	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 599 rpc_srv_endBLOBServer(rpc_srv_t * __restrict srv)	Line 602 rpc_srv_endBLOBServer(rpc_srv_t * __restrict srv)
shutdown(c->cli_sock, SHUT_RDWR);	shutdown(c->cli_sock, SHUT_RDWR);
close(c->cli_sock);	close(c->cli_sock);

io_arrayDel(srv->srv_blob.clients, i, 42);	schedCancelby(srv->srv_blob.root, taskMAX, CRITERIA_ARG, c, NULL);
	AIT_FREE_VAL(&c->cli_buf);
}	}
	io_arrayDel(srv->srv_blob.clients, i, 42);
}	}
io_arrayDestroy(&srv->srv_blob.clients);	io_arrayDestroy(&srv->srv_blob.clients);

Line 616 rpc_srv_endBLOBServer(rpc_srv_t * __restrict srv)	Line 621 rpc_srv_endBLOBServer(rpc_srv_t * __restrict srv)

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

srv->srv_blob.kill = 1;
}	}

/*	/*
Line 648 rpc_srv_loopBLOBServer(rpc_srv_t * __restrict srv)	Line 651 rpc_srv_loopBLOBServer(rpc_srv_t * __restrict srv)
return -1;	return -1;
}	}

#if 0
for (c = srv->srv_blob.clients, i = 0; i < srv->srv_numcli && c; i++, c++)
if (!c->cli_sa.sa.sa_family)
break;
if (i >= srv->srv_numcli) {
#ifdef HAVE_PTHREAD_YIELD
pthread_yield();
#endif
usleep(1000000);
continue;
}

c->cli_sock = accept(srv->srv_blob.server.cli_sock, &c->cli_sa.sa, &salen);
if (c->cli_sock == -1) {
LOGERR;
continue;
} else
c->cli_parent = srv;
}
#endif

/* main rpc loop */	/* main rpc loop */
schedRun(srv->srv_blob.root, &srv->srv_blob.kill);	schedRun(srv->srv_blob.root, &srv->srv_blob.kill);
return 0;	return 0;
Line 815 rpc_srv_endServer(rpc_srv_t ** __restrict psrv)	Line 797 rpc_srv_endServer(rpc_srv_t ** __restrict psrv)
shutdown(c->cli_sock, SHUT_RDWR);	shutdown(c->cli_sock, SHUT_RDWR);
close(c->cli_sock);	close(c->cli_sock);

io_arrayDel((*psrv)->srv_clients, i, 42);	schedCancelby((*psrv)->srv_root, taskMAX, CRITERIA_ARG, c, NULL);
	AIT_FREE_VAL(&c->cli_buf);
}	}
	io_arrayDel((*psrv)->srv_clients, i, 42);
}	}
io_arrayDestroy(&(*psrv)->srv_clients);	io_arrayDestroy(&(*psrv)->srv_clients);

FreeBSD-CVSweb <freebsd-cvsweb@FreeBSD.org>

Removed from v.1.9.2.18
changed lines
	Added in v.1.9.2.20