search for: read_loop

...tatic 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 + version is 24 or less. */ +int kludge_around_eof = False; + + static int io_error_fd = -1; static void read_loop(int fd, char *buf, int len); @@ -106,9 +113,46 @@ static void read_error_fd(void) } -static int no_flush; +static void whine_about_eof (void) +{ + /** + It's almost always an error to get an EOF when we're trying + to read from the network, because the protocol is + self-termi...

...n 12 18:29:18 2002 @@ -1,3 +1,4 @@ +/* Converted by prj_src:unix_c_to_vms_c.tpu AND PRJ_SRC:IO.TPU on 12-JAN-2002 18:29:18.32 OPENVMS_AXP */ /* -*- c-file-style: "linux" -*- Copyright (C) 1996-2001 by Andrew Tridgell @@ -49,7 +50,7 @@ static int io_error_fd = -1; -static void read_loop(int fd, char *buf, int len); +static void read_loop(int fd, void *buf, int len); static void check_timeout(void) { @@ -163,9 +164,11 @@ * give a better explanation. We can tell whether the connection has * started by looking e.g. at whether the remote version is known yet. */ -static...

...not delete in a directory prior to receiving an I/O error for that directory (or not receiving it, as the case may be). $ gstack 22366 #0 0x0000000000a24ad3 in __select_nocancel () from /lib64/libc.so.6 #1 0x00007fa36509b660 in read_timeout () from /proc/22366/exe #2 0x00007fa36509bb86 in read_loop () from /proc/22366/exe #3 0x00007fa36509a241 in readfd_unbuffered () from /proc/22366/exe #4 0x00007fa36509bd33 in readfd () from /proc/22366/exe #5 0x00007fa36509c956 in read_ndx () from /proc/22366/exe #6 0x00007fa36507cc20 in read_ndx_and_attrs () from /proc/22366/exe #7 0x00007fa365085ede...

...= flags; + file->flags = flags & LIVE_FLAGS; file->length = read_longint(f); if (!(flags & SAME_TIME)) modtime = (time_t)read_int(f); Index: io.c --- io.c 16 Jan 2004 16:31:47 -0000 1.119 +++ io.c 17 Jan 2004 05:04:54 -0000 @@ -222,6 +222,14 @@ static void read_msg_fd(void) read_loop(fd, buf, 4); redo_list_add(IVAL(buf,0)); break; + case MSG_SUCCESS: + if (len != 4) { + rprintf(FERROR, "invalid message %d:%d\n", tag, len); + exit_cleanup(RERR_STREAMIO); + } + read_loop(fd, buf, 4); + io_multiplex_write(MSG_SUCCESS, buf, 4); + break; case MSG_INFO: c...

...1000227ea in main (argc=2, argv=0x100100390) at main.c:1504 Stack trace on the iMac for the child rsync process (gdb) bt #0 0x00007fff87a86e52 in select$DARWIN_EXTSN () #1 0x000000010002eaad in read_timeout (fd=5, buf=0x7fff5fbfc420 "6", len=4) at io.c:654 #2 0x000000010002f7c5 in read_loop (fd=5, buf=0x7fff5fbfc420 "6", len=4) at io.c:989 #3 0x000000010002f989 in readfd_unbuffered (fd=5, buf=0x7fff5fbfd8a0 "", len=1) at io.c:1026 #4 0x000000010002ffae in readfd (fd=5, buffer=0x7fff5fbfd8a0 "", N=1) at io.c:1157 #5 0x00000001000319c8 in read_ndx...

...fferSz = 2 * IO_BUFFER_SIZE; + buffer = malloc(bufferSz); + if (!buffer) out_of_memory("read_unbuffered"); + } + remaining = read_timeout(fd, buffer, bufferSz); + bufferIdx = 0; + } + while (ret == 0) { if (remaining) { len = MIN(len, remaining); - read_loop(fd, buf, len); + memcpy(buf, buffer + bufferIdx, len); + bufferIdx += len; remaining -= len; ret = len; - continue; + break; } read_loop(fd, line, 4); @@ -305,8 +319,16 @@ remaining = tag & 0xFFFFFF; tag = tag >> 24; - if (tag == MPLEX_BASE) + if (tag ==...

...* IO_BUFFER_SIZE; > buffer = malloc(bufferSz); > if (!buffer) out_of_memory("read_unbuffered"); > } > remaining = read_timeout(fd, buffer, bufferSz); > bufferIdx = 0; > } > 296c309,310 < read_loop(fd, buf, len); --- > memcpy(buf, buffer + bufferIdx, len); > bufferIdx += len; 299c313 < continue; --- > break; 308c322,329 < if (tag == MPLEX_BASE) --- > if (tag == MPLEX_BASE) { > if (!buffer || remai...

.../0/oudeserver/20071225/tree /var/lib/vservers/oudeserver/ /backup/0/oudeserver/laatste/tree # gdb -p 3712 (gdb) bt #0 0x00002ba78dcf3b63 in select () from /lib/libc.so.6 #1 0x0000000000423ee1 in read_timeout (fd=5, buf=0x7fff1d3ac5c0 "\001", len=4) at io.c:653 #2 0x00000000004243e2 in read_loop (fd=5, buf=0x7fff1d3ac5c0 "\001", len=4) at io.c:985 #3 0x00000000004244d5 in readfd_unbuffered (fd=5, buf=0x7fff1d3adc70 "", len=1) at io.c:1022 #4 0x0000000000424a93 in readfd (fd=5, buffer=0x7fff1d3adc70 "", N=1) at io.c:1144 #5 0x0000000000425b20 in read_ndx (f=...

..._client (argc=1, argv=0x56f74) at main.c:731 #10 0x1e098 in main (argc=2, argv=0x56f70) at main.c:841 Backtrace #2 on client (child): #0 0xef5b7904 in _poll () #1 0xef5d3d40 in _select () #2 0x24644 in read_timeout (fd=4, buf=0xefffe680 "", len=4) at io.c:191 #3 0x24788 in read_loop (fd=4, buf=0xefffe680 "", len=4) at io.c:242 #4 0x24824 in read_unbuffered (fd=4, buf=0xefffe680 "", len=4) at io.c:268 #5 0x24950 in readfd (fd=4, buffer=0xefffe680 "", N=4) at io.c:316 #6 0x24998 in read_int (f=4) at io.c:329 #7 0x18eec in recv_files (f_i...

...c "h\002", len=620) at io.c:1074 #14 0x080692e9 in mplex_write (code=Variable "code" is not available. ) at io.c:1169 #15 0x0806937b in io_flush (flush_it_all=-4) at io.c:1191 #16 0x0806943b in read_timeout (fd=8, buf=0xbfeccd7c "", len=4) at io.c:481 #17 0x080699d6 in read_loop (fd=8, buf=0xbfeccd7c "", len=4) at io.c:735 #18 0x08069a22 in read_msg_fd () at io.c:246 #19 0x08069e4d in get_redo_num (itemizing=1, code=FLOG) at io.c:406 #20 0x0804f9eb in generate_files (f_out=0, flist=0x82d8730, local_name=0x0) at generator.c:1613 #21 0x08058bb1 in do_recv (f_in=0,...

...ave Dykstra diff -ru rsync-2.4.6/io.c rsync-2.4.6-fixed/io.c --- rsync-2.4.6/io.c Mon Jan 28 19:16:47 2002 +++ rsync-2.4.6-fixed/io.c Mon Jan 28 19:15:05 2002 @@ -275,7 +275,7 @@ while (ret == 0) { if (remaining) { - len = MIN(len, remaining); + len = MIN((ssize_t)len, remaining); read_loop(fd, buf, len); remaining -= len; ret = len; @@ -453,7 +453,7 @@ } if (ret <= 0) { - rprintf(FERROR,"erroring writing %d bytes - exiting\n", len); + rprintf(FERROR,"erroring writing %lu bytes - exiting\n", len); exit_cleanup(RERR_STREAMIO); }...

...c:921 #9 0x4004e853 in __libc_start_main () from /lib/libc.so.6 If I then detach and attach to process number 2 (7284) on the linux box, then single step until it emerges from select I get this back trace: #0 read_timeout (fd=5, buf=0x8186b31 "", len=1251) at io.c:204 #1 0x8056b8b in read_loop (fd=5, buf=0x8186018 "\213E??@\030\002", len=4092) at io.c:253 #2 0x8056c05 in read_unbuffered (fd=5, buf=0x8186018 "\213E??@\030\002", len=4128) at io.c:279 #3 0x8056d4a in readfd (fd=5, buffer=0x817f038 "MZ\220", N=32768) at io.c:329 #4 0x8056dfb in read_buf (f=5,...

...+ push es + mov ax,cs + add ax,1000h + mov es,ax + mov word [menu_seg],ax + xor eax,eax + mov cx,4000h + mov di,0 + rep stosd + pop es +.read: + call skipspace + jz .eof + jc .read + cmp al,'#' + je .nextline + or al,20h ; convert to lower case + mov di,configbuf + stosb +.read_loop: + call getc + jc .eof + cmp al,' ' + jbe .done + or al,20h ; convert to lower case + stosb + jmp .read_loop +.done: + call ungetc + + xor ax,ax + stosb +%ifdef DEBUG + mov ax,2 + mov bx, configbuf + int 22h + + mov ax,2 + mov bx, msg_crlf + int 22h +%endif + push si + pus...

...+ push es + mov ax,cs + add ax,1000h + mov es,ax + mov word [menu_seg],ax + xor eax,eax + mov cx,4000h + mov di,0 + rep stosd + pop es +.read: + call skipspace + jz .eof + jc .read + cmp al,'#' + je .nextline + or al,20h ; convert to lower case + mov di,configbuf + stosb +.read_loop: + call getc + jc .eof + cmp al,' ' + jbe .done + or al,20h ; convert to lower case + stosb + jmp .read_loop +.done: + call ungetc + + xor ax,ax + stosb +%ifdef DEBUG + mov ax,2 + mov bx, configbuf + int 22h + + mov ax,2 + mov bx, msg_crlf + int 22h +%endif + push si + pus...

Hi guys: First post for me on this list. THE PROBLEM =========== I have several linux servers (ranging from Redhat 7.3 to FC3) that use Rsync (version 2.6.8 and 2.6.7, read on for reasons) to backup their data. A typical rsync backup script looks like this: ------------------------------------------------------------------------------------------ #!/bin/sh RSYNC_PASSWORD=<PASSWORD> rsync

People of cygwin & rsync, I recently attempted to get cygwin and rsync working to solve a backup/mirroring need in my computer life. Well, as you might guess, I ran into a little but of trouble. Strangely enough, rsync seemed to be regularly hanging when I attempted to do a "get" (sycronize a remote to a local dir). Well, considering I want to automate this, that was not going

Hello, I'm running HP-UX 11i on an rp74xx. It's 64-bit. C compiler is as follows: B3901BA B.11.11.03 HP C/ANSI C Developer's Bundle for HP-UX 11.i (S800) B3913DB C.03.30.02 HP aC++ Compiler (S800) /usr/bin/cc: LINT B.11.11.02 CXREF B.11.11.02 HP92453-01 B.11.11.02 HP C Compiler $ Sep 8 2000 23:13:51 $ I have successfully compiled rsync 2.6.2 and it