Skip to content

L
liblongpath-rsync
Commit 417099fa authored by Wayne Davison's avatar Wayne Davison
Browse files
Options

Periodically call maybe_flush_socket().

parent 626bec8e
Hide whitespace changes
Inline Side-by-side
Showing with 5 additions and 1 deletion
generator.c
View file @ 417099fa
...@@ -1205,6 +1205,8 @@ void generate_files(int f_out, struct file_list *flist, char *local_name) ...@@ -1205,6 +1205,8 @@ void generate_files(int f_out, struct file_list *flist, char *local_name)
if (allowed_lull && !(i % lull_mod)) if (allowed_lull && !(i % lull_mod))
maybe_send_keepalive(); maybe_send_keepalive();
else if (!(i % 50))
maybe_flush_socket();
} }
recv_generator(NULL, NULL, 0, 0, 0, code, -1); recv_generator(NULL, NULL, 0, 0, 0, code, -1);
if (delete_during) if (delete_during)
...@@ -1278,8 +1280,10 @@ void generate_files(int f_out, struct file_list *flist, char *local_name) ...@@ -1278,8 +1280,10 @@ void generate_files(int f_out, struct file_list *flist, char *local_name)
continue; continue;
recv_generator(f_name(file), file, i, itemizing, recv_generator(f_name(file), file, i, itemizing,
maybe_PERMS_REPORT, code, -1); maybe_PERMS_REPORT, code, -1);
if (allowed_lull && !(j++ % lull_mod)) if (allowed_lull && !(++j % lull_mod))
maybe_send_keepalive(); maybe_send_keepalive();
else if (!(j % 50))
maybe_flush_socket();
} }
} }
recv_generator(NULL, NULL, 0, 0, 0, code, -1); recv_generator(NULL, NULL, 0, 0, 0, code, -1);
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment