Displaying 4 results from an estimated 4 matches for "io_multiplexing_in".
2001 Aug 22
1
@RSYNC EXIT / @RSYNC EOF
...; you can redistribute it and/or modify
it under the terms of the GNU General Public License as published by
@@ -28,18 +29,24 @@
/* if no timeout is specified then use a 60 second select timeout */
#define SELECT_TIMEOUT 60
-extern int bwlimit;
-
static int io_multiplexing_out;
static int io_multiplexing_in;
static int multiplex_in_fd;
static int multiplex_out_fd;
static time_t last_io;
-static int eof_error=1;
+static int no_flush;
+
+extern int bwlimit;
extern int verbose;
extern int io_timeout;
extern struct stats stats;
+
+/** Ignore EOF errors while reading a module listing if the remote...
2002 Dec 09
2
Rsync performance increase through buffering
...if (f != -1) {
- io_start_buffering(f);
+ io_start_buffering_out(f);
}
for (i = 0; i < argc; i++) {
diff -bur rsync/io.c rsync-craig/io.c
--- rsync/io.c Wed Apr 10 19:11:50 2002
+++ rsync-craig/io.c Sun Dec 8 17:54:23 2002
@@ -41,8 +41,8 @@
static int io_multiplexing_out;
static int io_multiplexing_in;
-static int multiplex_in_fd;
-static int multiplex_out_fd;
+static int multiplex_in_fd = -1;
+static int multiplex_out_fd = -1;
static time_t last_io;
static int no_flush;
@@ -286,17 +286,31 @@
static size_t remaining;
int tag, ret = 0;
char line[1024];
+ static char *buffer;
+...
2003 Jan 03
0
[Fwd: Re: rsync windows -> unix still hanging :(]
...4,45
< static int multiplex_in_fd;
< static int multiplex_out_fd;
---
> static int multiplex_in_fd = -1;
> static int multiplex_out_fd = -1;
288a289,291
> static char *buffer;
> static size_t bufferIdx = 0;
> static size_t bufferSz;
290c293
< if (!io_multiplexing_in || fd != multiplex_in_fd)
---
> if (fd != multiplex_in_fd)
292a296,305
> if (!io_multiplexing_in && remaining == 0) {
> if (!buffer) {
> bufferSz = 2 * IO_BUFFER_SIZE;
> buffer = malloc(bufferSz);
> if (!buffer) out_of_...
2002 Jan 13
0
rsynd-2.5.1 / io.c patches
...,11 +258,11 @@
*
* Never returns <= 0.
*/
-static int read_unbuffered(int fd, char *buf, int len)
+static int read_unbuffered(int fd, void *buf, int len)
{
static int remaining;
int tag, ret=0;
- char line[1024];
+ unsigned char line[1024];
if (!io_multiplexing_in || fd != multiplex_in_fd)
return read_timeout(fd, buf, len);
@@ -305,10 +310,12 @@
/* do a buffered read from fd. don't return until all N bytes
have been read. If all N can't be read then exit with an error */
-static void readfd (int fd, char *buffer, int N)
+stat...