search for: io_start_buff

...writeBufCnt = 0; > } > } while ( buf && len > 0 ); > return ret; Index: flist.c =================================================================== RCS file: /cvsroot/rsync/flist.c,v retrieving revision 1.127 diff -r1.127 flist.c 894c894 < io_start_buffering(f); --- > io_start_buffering_out(f); Index: io.c =================================================================== RCS file: /cvsroot/rsync/io.c,v retrieving revision 1.105 diff -r1.105 io.c 44,45c44,45 < static int multiplex_in_fd; < static int multiplex_out_fd; --- > st...

...= 0; + } + } while ( buf && len > 0 ); + return ret; } while (len>0) { diff -bur rsync/flist.c rsync-craig/flist.c --- rsync/flist.c Sat Jul 27 11:01:21 2002 +++ rsync-craig/flist.c Sun Dec 8 16:28:14 2002 @@ -889,7 +889,7 @@ flist = flist_new(); 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...

.../* finally we go to sleep until our parent kills us ! with a USR2 signal. We sleep for a short time as on ! some OSes a signal won't interrupt a sleep! */ ! while (msleep(20)) ! ; } close(recv_pipe[1]); close(error_pipe[1]); if (f_in != f_out) close(f_in); io_start_buffering(f_out); --- 445,465 ---- write_int(recv_pipe[1],1); close(recv_pipe[1]); io_flush(); ! do { ! status = read(cleanup_pipe[0], &tmp, 1); ! } while (status == -1 && errno == EINTR); ! if (status != 1) { ! rprintf(FERROR,"cleanup read returned %d in do_recv...

...quot;, 4) = 4 > [...] > > so it looks like sending the exclude list is quite inefficient and therefore > --file-from should definitely not use this code to do the same thing. Indeed, it definitely should be doing buffering! It looks like there's a function io_start_buffering() that should be called. I don't know why it isn't called until later, though, and there may be a good reason. It's getting called in send_file_list() and in do_recv(), both of which are called from client_run() in main.c after send_exclude_list(). Could you play with calling it...

...================================ RCS file: /cvsroot/rsync/main.c,v retrieving revision 1.156 diff -c -r1.156 main.c *** main.c 1 Aug 2002 20:46:59 -0000 1.156 --- main.c 31 Dec 2002 01:21:34 -0000 *************** *** 346,351 **** --- 346,353 ---- exit_cleanup(0); } + io_start_buffering_in(f_in); + io_start_buffering_out(f_out); send_files(flist,f_out,f_in); io_flush(); report(f_out); *************** *** 421,427 **** close(error_pipe[1]); if (f_in != f_out) close(f_in); ! io_start_buffering(f_out); io_set_error_fd(error_pipe[0]); -...

...fd_set w_fds, r_fds; int fd_count, count; struct timeval tv; +unsigned char * buf; + buf = (unsigned char *)buf1; err_list_push(); @@ -469,24 +480,26 @@ } -static char *io_buffer; +static unsigned char *io_buffer; static int io_buffer_count; void io_start_buffering(int fd) { if (io_buffer) return; multiplex_out_fd = fd; - io_buffer = (char *)malloc(IO_BUFFER_SIZE); + io_buffer = malloc(IO_BUFFER_SIZE); if (!io_buffer) out_of_memory("writefd"); io_buffer_count = 0; } /* write an message to a...

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

...olddir; char lastpath[MAXPATHLEN]=""; struct file_list *flist; int64 start_write; + char *in_fn; + extern int implicit_dirs; if (verbose && recurse && !am_server && f != -1) { rprintf(FINFO,"building file list ... "); @@ -711,10 +714,10 @@ io_start_buffering(f); } - for (i=0;i<argc;i++) { + while ((in_fn = (*ffunc)(opq)) != NULL) { char *fname = topsrcname; - strlcpy(fname,argv[i],MAXPATHLEN); + strlcpy(fname,in_fn,MAXPATHLEN); l = strlen(fname); if (l != 1 && fname[l-1] == '/') { @@ -738,8 +741,8 @@ conti...

...TAT st; char *p, *dir, *olddir; char lastpath[MAXPATHLEN] = ""; struct file_list *flist; int64 start_write; + char *in_fn; + extern int implicit_dirs; if (show_filelist_p() && f != -1) start_filelist_progress("building file list"); @@ -876,10 +879,10 @@ io_start_buffering(f); } - for (i = 0; i < argc; i++) { + while ((in_fn = (*ffunc)(opq)) != NULL) { char *fname = topsrcname; - strlcpy(fname, argv[i], MAXPATHLEN); + strlcpy(fname, in_fn, MAXPATHLEN); l = strlen(fname); if (l != 1 && fname[l - 1] == '/') { @@ -904,8 +907,8...