libaitrpc/src/srv.c - diff

Return to srv.c CVS log

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

version 1.11.2.1, 2012/08/29 14:04:04	version 1.11.2.3, 2012/09/17 14:16:42
Line 446 acceptBLOBClients(sched_task_t *task)	Line 446 acceptBLOBClients(sched_task_t *task)
rpc_cli_t *c = NULL;	rpc_cli_t *c = NULL;
register int i;	register int i;
socklen_t salen = sizeof(io_sockaddr_t);	socklen_t salen = sizeof(io_sockaddr_t);
	#ifdef TCP_NOPUSH
int n = 1;	int n = 1;
	#endif

/* check free slots for connect */	/* check free slots for connect */
for (i = 0; i < io_arraySize(srv->srv_blob.clients) &&	for (i = 0; i < io_arraySize(srv->srv_blob.clients) &&
Line 476 acceptBLOBClients(sched_task_t *task)	Line 478 acceptBLOBClients(sched_task_t *task)
io_arrayDel(srv->srv_blob.clients, i, 42);	io_arrayDel(srv->srv_blob.clients, i, 42);
goto end;	goto end;
} else {	} else {
	#ifdef TCP_NOPUSH
setsockopt(c->cli_sock, IPPROTO_TCP, TCP_NOPUSH, &n, sizeof n);	setsockopt(c->cli_sock, IPPROTO_TCP, TCP_NOPUSH, &n, sizeof n);
	#endif
fcntl(c->cli_sock, F_SETFL, fcntl(c->cli_sock, F_GETFL) \| O_NONBLOCK);	fcntl(c->cli_sock, F_SETFL, fcntl(c->cli_sock, F_GETFL) \| O_NONBLOCK);
}	}

Line 705 rpc_srv_initServer(u_int regProgID, u_char regProcID,	Line 709 rpc_srv_initServer(u_int regProgID, u_char regProcID,
if (netBuf < RPC_MIN_BUFSIZ)	if (netBuf < RPC_MIN_BUFSIZ)
netBuf = BUFSIZ;	netBuf = BUFSIZ;
else	else
netBuf = io_align(netBuf, 1); /* align netBuf length */	netBuf = io_align(netBuf, 2); /* align netBuf length */

#ifdef HAVE_SRANDOMDEV	#ifdef HAVE_SRANDOMDEV
srandomdev();	srandomdev();