extern int inplace;
extern int batch_fd;
extern int write_batch;
+extern int file_old_total;
extern struct stats stats;
extern struct file_list *cur_flist, *first_flist, *dir_flist;
{
struct sum_struct *s;
int32 i;
- int lull_mod = allowed_lull * 5;
+ int lull_mod = protocol_version >= 31 ? 0 : allowed_lull * 5;
OFF_T offset = 0;
if (!(s = new(struct sum_struct)))
s->sums[i].len = s->blength;
offset += s->sums[i].len;
- if (allowed_lull && !(i % lull_mod))
- maybe_send_keepalive();
+ if (lull_mod && !(i % lull_mod))
+ maybe_send_keepalive(time(NULL), True);
if (DEBUG_GTE(DELTASUM, 3)) {
rprintf(FINFO,
end_progress(0);
}
if (inc_recurse && first_flist) {
+ file_old_total -= first_flist->used;
flist_free(first_flist);
if (first_flist) {
+ if (first_flist == cur_flist)
+ file_old_total = cur_flist->used;
write_ndx(f_out, NDX_DONE);
continue;
}
rsyserr(FERROR_XFER, errno, "fstat failed");
free_sums(s);
close(fd);
- exit_cleanup(RERR_PROTOCOL);
+ exit_cleanup(RERR_FILEIO);
}
if (st.st_size) {