libaitrpc/src/blob.c - diff

Return to blob.c CVS log

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

version 1.6, 2012/03/29 01:34:16	version 1.6.2.1, 2012/05/11 09:18:13
Line 247 rpc_srv_recvBLOB(rpc_cli_t * __restrict cli, rpc_blob_	Line 247 rpc_srv_recvBLOB(rpc_cli_t * __restrict cli, rpc_blob_
{	{
int ret, len;	int ret, len;
uint8_t *pos;	uint8_t *pos;
fd_set fds;	struct pollfd pfd;
struct timeval tv = { DEF_RPC_TIMEOUT, 0 };

if (!cli \|\| !blob \|\| !blob->blob_data) {	if (!cli \|\| !blob \|\| !blob->blob_data) {
rpc_SetErr(EINVAL, "Invalid arguments");	rpc_SetErr(EINVAL, "Invalid arguments");
return -1;	return -1;
} else	}
tv.tv_sec = ((rpc_sess_t*) cli->cli_parent)->sess_timeout;

	pfd.fd = cli->cli_sock;
	pfd.events = POLLIN \| POLLPRI;
for (ret = blob->blob_len, pos = blob->blob_data; ret > 0; ret -= len, pos += len) {	for (ret = blob->blob_len, pos = blob->blob_data; ret > 0; ret -= len, pos += len) {
FD_ZERO(&fds);	if ((len = poll(&pfd, 1, ((rpc_sess_t) cli->cli_parent)->sess_timeout 1000)) == -1 \|\|
FD_SET(cli->cli_sock, &fds);	pfd.revents & (POLLERR \| POLLHUP \| POLLNVAL)) {
len = select(cli->cli_sock + 1, &fds, NULL, NULL, &tv);
if (len < 1) {
LOGERR;	LOGERR;
return -1;	return -1;
}	}