mirror/rsync
1
0
Fork 0
mirror of https://github.com/RsyncProject/rsync.git synced 2026-04-25 16:49:42 -04:00
Code Issues Packages Projects Releases Wiki Activity

standard input on server may be nonblocking

Browse Source
This commit is contained in:
Paul Mackerras
1996-06-28 07:06:34 +00:00
parent 43a481dc55
commit 7f28dbee65
1 changed files with 10 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

13
io.c
View File

@@ -103,8 +103,15 @@ static int readfd(int fd,char *buffer,int N)
read_buffer_p += ret;
read_buffer_len -= ret;
} else {
if ((ret = read(fd,buffer + total,N - total)) == -1)
return -1;
while ((ret = read(fd,buffer + total,N - total)) == -1) {
fd_set fds;
if (errno != EAGAIN && errno != EWOULDBLOCK)
return -1;
FD_ZERO(&fds);
FD_SET(fd, &fds);
select(fd+1, &fds, NULL, NULL, NULL);
}
}
if (ret <= 0)
@@ -194,7 +201,7 @@ static int writefd(int fd,char *buf,int len)
FD_SET(fd,&fds);
tv.tv_sec = BLOCKING_TIMEOUT;
tv.tv_usec = 0;
select(16,NULL,&fds,NULL,&tv);
select(fd+1,NULL,&fds,NULL,&tv);
} else {
total += ret;
}