Displaying 5 results from an estimated 5 matches for "io_start_buffering_in".
2003 Jan 03
0
[Fwd: Re: rsync windows -> unix still hanging :(]
...bufferIdx = 0;
309a331
> }
330c352,354
<
---
> if (remaining == 0) {
> io_flush();
> }
347,348d370
< io_flush();
<
534c556
< void io_start_buffering(int fd)
---
> void io_start_buffering_out(int fd)
542a565,569
> void io_start_buffering_in(int fd)
> {
> multiplex_in_fd = fd;
> }
>
729c756
< io_start_buffering(fd);
---
> io_start_buffering_out(fd);
Index: main.c
===================================================================
RCS file: /cvsroot/rsync/main.c,v
retrieving revision 1.156
diff -r1.156 main...
2003 Jan 03
1
[Fwd: Re: rsync windows -> unix still hanging :(]
...================================
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]);
--- 423,4...
2002 Dec 09
2
Rsync performance increase through buffering
...uffer + total, N-total);
total += ret;
}
@@ -531,7 +553,7 @@
static char *io_buffer;
static int io_buffer_count;
-void io_start_buffering(int fd)
+void io_start_buffering_out(int fd)
{
if (io_buffer) return;
multiplex_out_fd = fd;
@@ -540,6 +562,11 @@
io_buffer_count = 0;
}
+void io_start_buffering_in(int fd)
+{
+ multiplex_in_fd = fd;
+}
+
/**
* Write an message to a multiplexed stream. If this fails then rsync
* exits.
@@ -726,7 +753,7 @@
{
multiplex_out_fd = fd;
io_flush();
- io_start_buffering(fd);
+ io_start_buffering_out(fd);
io_multiplexing_out = 1;
}
diff -bur rsync/main.c...
2006 Sep 18
1
code 23 error.
...(dir));
exit_cleanup(RERR_FILESELECT);
}
argc--;
argv++;
if (argc == 0 && (recurse || list_only)) {
argc = 1;
argv--;
argv[0] = ".";
}
flist = send_file_list(f_out,argc,argv);
if (!flist || flist->count == 0) {
exit_cleanup(0);
}
the_file_list = flist;
io_start_buffering_in();
io_start_buffering_out();
send_files(flist,f_out,f_in);
io_flush(FULL_FLUSH);
handle_stats(f_out);
if (protocol_version >= 24)
read_final_goodbye(f_in, f_out);
io_flush(FULL_FLUSH);
exit_cleanup(0);
}
**************************snip**********************************
***********...
2023 Jul 03
0
[PATCH] Add option --log-after to log after moving file into place
...dout_format;
+extern char *logfile_name;
extern char *logfile_format;
+extern char *logafter_name;
+extern int log_after_transfer;
extern char *filesfrom_host;
extern char *partial_dir;
extern char *rsync_path;
@@ -1053,6 +1056,10 @@ static int do_recv(int f_in, int f_out, char *local_name)
io_start_buffering_in(f_in);
io_start_multiplex_out(f_out);
+ /* Reopen log file for --log-after */
+ if (log_after_transfer)
+ logfile_name = logafter_name;
+
recv_files(f_in, f_out, local_name);
io_flush(FULL_FLUSH);
handle_stats(f_in);
diff --git a/options.c b/options.c
index fd674754..4ab83650 1006...