search for: rerr_streamio

..._COUNT; 284 r = deflate(&tx_strm, Z_INSERT_ONLY); 285 if (r != Z_OK || tx_strm.avail_in != 0) { 286 rprintf(FERROR, "deflate on token returned %d (%d bytes left)\n", 287 r, tx_strm.avail_in); 288 exit_cleanup(RERR_STREAMIO); 289 } MAX_DATA_COUNT is 16383 and toklen may be 16384. So, when deflate()'s outputs data length is bigger than input, then above code will fail. Normally output data length is smaller than input, but it is not true to already compressed data. --yasuoka Yasuoka Masahiko(yasuoka...

...ient), kludge_around_eof is True and we + just exit. + */ + + if (kludge_around_eof) + exit_cleanup (0); + else { + rprintf (FERROR, + "%s: connection unexpectedly closed " + "(%.0f bytes read so far)\n", + RSYNC_NAME, (double)stats.total_read); + + exit_cleanup (RERR_STREAMIO); + } +} -/* + +static void die_from_readerr (int err) +{ + /* this prevents us trying to write errors on a dead socket */ + io_multiplexing_close(); + + rprintf(FERROR, "%s: read error: %s\n", + RSYNC_NAME, strerror (err)); + exit_cleanup(RERR_STREAMIO); +} + + +/*! * Read from...

....pos = 0; + } + + /* File ended, flush */ + if (token != -2) + flush = ZSTD_e_flush; + + r = ZSTD_compressStream2(zstd_cctx, &zstd_out_buff, &zstd_in_buff, flush); + if (ZSTD_isError(r)) { + rprintf(FERROR, "ZSTD_compressStream returned %d\n", r); + exit_cleanup(RERR_STREAMIO); + } + + /* + * Nothing is sent if the buffer isn't full so avoid smaller + * transfers. If a file is finished then we flush the internal + * state and send a smaller buffer so that the remote side can + * finish the file. + */ + if (zstd_out_buff.pos == zstd_out_buff.size...

...that cannot support them; or an option was speciifed that is supported by the client and not by the server. +dit(bf(RERR_STARTCLIENT 5)) Error starting client-server protocol + dit(bf(RERR_SOCKETIO 10)) Error in socket IO dit(bf(RERR_FILEIO 11)) Error in file IO dit(bf(RERR_STREAMIO 12)) Error in rsync protocol data stream @@ -1126,6 +1128,7 @@ dit(bf(RERR_SIGNAL 20)) Received SIGUSR1 or SIGINT dit(bf(RERR_WAITCHILD 21)) Some error returned by waitpid() dit(bf(RERR_MALLOC 22)) Error allocating core memory buffers +dit(bf(RERR_PARTIAL 23...

...r_update(&m, (uchar *)map_ptr(buf, i, CHUNK_SIZE), CHUNK_SIZE); /* Prior to version 27 an incorrect MD4 checksum was computed * by failing to call mdfour_tail() for block sizes that @@ -362,9 +362,9 @@ void file_checksum(const char *fname, const STRUCT_STAT *st_p, char *sum) exit_cleanup(RERR_STREAMIO); } - for (i = 0; i + CSUM_CHUNK <= len; i += CSUM_CHUNK) { + for (i = 0; i + CHUNK_SIZE <= len; i += CHUNK_SIZE) { XXH_errorcode const updateResult = - XXH64_update(state, (uchar *)map_ptr(buf, i, CSUM_CHUNK), CSUM_CHUNK); + XXH64_update(state, (uchar *)map_ptr(buf, i, CHUNK_SIZE)...

I'm working on trying to get rsync 2.5.6pre1 available for people to test more widely. I'm out of time for today, and I'm stuck on a problem that some machines on build.samba.org are showing on the 'chgrp' test. I can reproduce this on my home redhat 7.3 system too. It appears to be a timing problem because when I do strace -F -f on it the problem goes away. Everything seems

...x_strm, Z_NO_FLUSH); > n = AVAIL_OUT_SIZE(CHUNK_SIZE) - rx_strm.avail_out; > if (r != Z_OK) { > rprintf(FERROR, "inflate returned %d (%d bytes)\n", r, n); > exit_cleanup(RERR_STREAMIO); > } > if (rx_strm.avail_in == 0) > recv_state = r_inflated; > if (n != 0) { > *data = dbuf; > return n; >...

...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: case MSG_ERROR: case MSG_LOG: @@ -637,6 +645,16 @@ static int read_unbuffered(int fd, char } read_loop(fd, buffer, remaining); bufferIdx = 0; + break; + case MSG_SUCCESS: +...

...maining); 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); } @@ -561,7 +561,7 @@ } while (len) { - int n = MIN(len, IO_BUFFER_SIZE-io_buffer_count); + int n = MIN((ssize_t)len, IO_BUFFER_SIZE-io_buffer_count); if (n > 0) { memcpy(io_buffer+io_buffer_count, buf, n); buf += n; diff -ru rsync-2.4.6/match.c rsync-2.4.6-fixed/match...

https://bugzilla.samba.org/show_bug.cgi?id=5811 Summary: rsync error: error allocating core memory buffers (code 22) at io.c(635) Product: rsync Version: 3.0.4 Platform: x64 OS/Version: Linux Status: NEW Severity: blocker Priority: P3 Component: core AssignedTo: wayned@samba.org

Hi, I'm having a problem rsyncing one file (since I signed it). It seems that the content of a file is able to cause problems in the protocol. building file list ... 28820 files to consider apt/packages/avifile/ apt/packages/avifile/avifile-0.7.34-1.dag.rh90.i386.rpm rsync: error writing 4 unbuffered bytes - exiting: Broken pipe rsync error: error in rsync protocol data stream (code

...f (cleanup_fname) do_unlink(cleanup_fname); if (code) { diff -rupNP rsync-2.6.2/errcode.h rsync-2.6.2-fnameconv.clean/errcode.h --- rsync-2.6.2/errcode.h 2003-12-15 10:04:14.000000000 +0200 +++ rsync-2.6.2-fnameconv.clean/errcode.h 2004-05-29 21:17:08.000000000 +0300 @@ -34,6 +34,7 @@ #define RERR_STREAMIO 12 /* error in rsync protocol data stream */ #define RERR_MESSAGEIO 13 /* errors with program diagnostics */ #define RERR_IPC 14 /* error in IPC code */ +#define RERR_FNAMECONV 15 /* error in filename conversion */ #define RERR_SIGNAL 20 /* status return...

...c int strwicmp( char *psz1, char *psz2 ); diff --exclude='*.o' -b --context rsync-2.5.6.orig/log.c rsync-2.5.6/log.c *** rsync-2.5.6.orig/log.c 2002-12-24 00:42:04.000000000 -0700 --- rsync-2.5.6/log.c 2003-04-28 09:32:31.000000000 -0600 *************** *** 49,54 **** --- 49,56 ---- { RERR_STREAMIO , "error in rsync protocol data stream" }, { RERR_MESSAGEIO , "errors with program diagnostics" }, { RERR_IPC , "error in IPC code" }, + { RERR_PRESCRIPT , "error running pre-transfer script" }, + { RERR_POSTSCRIPT , "error running...

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

...NEW/io.c Thu Jan 1 00:00:00 1970 @@ -316,8 +316,8 @@ } if (remaining > sizeof(line) - 1) { - rprintf(FERROR, "multiplexing overflow %d\n\n", - remaining); + rprintf(FERROR, "multiplexing overflow %lu\n\n", + (unsigned long int) remaining); exit_cleanup(RERR_STREAMIO); } --- OLD/log.c Thu Jan 1 00:00:00 1970 +++ NEW/log.c Thu Jan 1 00:00:00 1970 @@ -582,5 +582,6 @@ if (!verbose) return; +file=file; rprintf(FINFO, "%s\n", fname); } --- OLD/popt/popt.c Thu Jan 1 00:00:00 1970 +++ NEW/popt/popt.c Thu Jan 1 00:00:00 1970 @@ -1058,6 +1058...

...t_in = (Bytef *) buf->m_len; + tx_strm.avail_in = buf->m_len; tx_strm.next_out = (Bytef *) obuf; tx_strm.avail_out = MAX_DATA_COUNT; r = deflate(&tx_strm, Z_INSERT_ONLY); if (r != Z_OK || tx_strm.avail_in != 0) { @@ -287,8 +299,9 @@ r, tx_strm.avail_in); exit_cleanup(RERR_STREAMIO); } } + return data_read; } /* tells us what the receiver is in the middle of doing */ @@ -477,16 +490,17 @@ /* * transmit a verbatim buffer of length n followed by a token * If token == -1 then we have reached EOF * If n == 0 then don't send a buffer + * Returns number of d...