libaitrpc/src/srv.c - diff

Return to srv.c CVS log

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

version 1.16.2.6, 2013/07/16 12:35:25	version 1.17.4.1, 2013/08/20 23:37:43
Line 74 rpc_freeCli(rpc_cli_t * __restrict c)	Line 74 rpc_freeCli(rpc_cli_t * __restrict c)

schedCancelby(s->srv_root, taskMAX, CRITERIA_ARG, c, NULL);	schedCancelby(s->srv_root, taskMAX, CRITERIA_ARG, c, NULL);

/* free buffer */	/* free buffer(s) */
AIT_FREE_VAL(&c->cli_buf);	ait_freeVars(&c->cli_buf);

array_Del(s->srv_clients, c->cli_id, 0);	array_Del(s->srv_clients, c->cli_id, 0);
if (c)	if (c)
Line 127 _allocClient(rpc_srv_t * __restrict srv, sockaddr_t *	Line 127 _allocClient(rpc_srv_t * __restrict srv, sockaddr_t *
}	}

/* alloc empty buffer */	/* alloc empty buffer */
AIT_SET_BUFSIZ(&c->cli_buf, 0, srv->srv_netbuf);	c->cli_buf = ait_allocVars(1);
	if (!c->cli_buf) {
	rpc_SetErr(elwix_GetErrno(), "%s", elwix_GetError());
	array_Del(srv->srv_clients, n, 42);
	return NULL;
	} else
	AIT_SET_BUFSIZ(array(c->cli_buf, 0, ait_val_t*), 0, srv->srv_netbuf);
}	}

return c;	return c;
Line 665 flushBLOB(sched_task_t *task)	Line 671 flushBLOB(sched_task_t *task)
{	{
rpc_srv_t *srv = TASK_ARG(task);	rpc_srv_t *srv = TASK_ARG(task);
rpc_blob_t b, tmp;	rpc_blob_t b, tmp;

printf("!signal 99\n");

TAILQ_FOREACH_SAFE(b, &srv->srv_blob.blobs, blob_node, tmp) {	TAILQ_FOREACH_SAFE(b, &srv->srv_blob.blobs, blob_node, tmp) {
TAILQ_REMOVE(&srv->srv_blob.blobs, b, blob_node);	TAILQ_REMOVE(&srv->srv_blob.blobs, b, blob_node);