libaitrpc/src/srv.c - diff

Return to srv.c CVS log

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

version 1.10.2.2, 2012/07/22 18:39:27	version 1.11.2.1, 2012/08/29 14:04:04
Line 421 rxBLOB(sched_task_t *task)	Line 421 rxBLOB(sched_task_t *task)
}	}
break;	break;
case unset:	case unset:
if (rpc_srv_unregisterBLOB(s, blob.hdr_var) == -1) {	if (rpc_srv_unregisterBLOB(s, ntohl(blob.hdr_var)) == -1) {
blob.hdr_cmd = error;	blob.hdr_cmd = error;
blob.hdr_ret = RPC_ERROR(-1);	blob.hdr_ret = RPC_ERROR(-1);
}	}
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);
	int n = 1;

/* 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 474 acceptBLOBClients(sched_task_t *task)	Line 475 acceptBLOBClients(sched_task_t *task)
AIT_FREE_VAL(&c->cli_buf);	AIT_FREE_VAL(&c->cli_buf);
io_arrayDel(srv->srv_blob.clients, i, 42);	io_arrayDel(srv->srv_blob.clients, i, 42);
goto end;	goto end;
} else	} else {
	setsockopt(c->cli_sock, IPPROTO_TCP, TCP_NOPUSH, &n, sizeof n);
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);
	}

schedRead(TASK_ROOT(task), rxBLOB, c, c->cli_sock, NULL, 0);	schedRead(TASK_ROOT(task), rxBLOB, c, c->cli_sock, NULL, 0);
end:	end: