#define CSUM_CHUNK 64
int checksum_seed = 0;
-extern int remote_version;
+extern int protocol_version;
/*
a simple 32 bit checksum that can be upadted from either end
* are multiples of 64. This is fixed by calling mdfour_update()
* even when there are no more bytes.
*/
- if (len - i > 0 || remote_version >= 27) {
+ if (len - i > 0 || protocol_version >= 27) {
mdfour_update(&m, (uchar *)(buf1+i), (len-i));
}
if (len - i > 0) {
memcpy(tmpchunk, map_ptr(buf,i,len-i), len-i);
}
- if (len - i > 0 || remote_version >= 27) {
+ if (len - i > 0 || protocol_version >= 27) {
mdfour_update(&m, (uchar *)tmpchunk, (len-i));
}
void sum_end(char *sum)
{
- if (sumresidue || remote_version >= 27) {
+ if (sumresidue || protocol_version >= 27) {
mdfour_update(&md, (uchar *)sumrbuf, sumresidue);
}
void send_exclude_list(int f)
{
int i;
- extern int remote_version;
+ extern int protocol_version;
extern int list_only, recurse;
/* This is a complete hack - blame Rusty.
l = strlen(pattern);
if (l == 0) continue;
if (exclude_list[i]->include) {
- if (remote_version < 19) {
+ if (protocol_version < 19) {
rprintf(FERROR,"remote rsync does not support include syntax - aborting\n");
exit_cleanup(RERR_UNSUPPORTED);
}
extern int implied_dirs;
extern int copy_links;
extern int copy_unsafe_links;
-extern int remote_version;
+extern int protocol_version;
extern int io_error;
extern int sanitize_paths;
#if SUPPORT_HARD_LINKS
if (preserve_hard_links && S_ISREG(file->mode)) {
- if (remote_version < 26) {
+ if (protocol_version < 26) {
/* 32-bit dev_t and ino_t */
write_int(f, (int) file->dev);
write_int(f, (int) file->inode);
#endif
if (always_checksum) {
- if (remote_version < 21) {
+ if (protocol_version < 21) {
write_buf(f, file->sum, 2);
} else {
write_buf(f, file->sum, MD4_SUM_LENGTH);
}
#if SUPPORT_HARD_LINKS
if (preserve_hard_links && S_ISREG(file->mode)) {
- if (remote_version < 26) {
+ if (protocol_version < 26) {
file->dev = read_int(f);
file->inode = read_int(f);
} else {
file->sum = (char *) malloc(MD4_SUM_LENGTH);
if (!file->sum)
out_of_memory("md4 sum");
- if (remote_version < 21) {
+ if (protocol_version < 21) {
read_buf(f, file->sum, 2);
} else {
read_buf(f, file->sum, MD4_SUM_LENGTH);
extern int ignore_times;
extern int size_only;
extern int io_timeout;
-extern int remote_version;
+extern int protocol_version;
extern int always_checksum;
extern int modify_window;
extern char *compare_dest;
}
}
file_checksum(fname,sum,st->st_size);
- if (remote_version < 21) {
+ if (protocol_version < 21) {
return (memcmp(sum,file->sum,2) == 0);
} else {
return (memcmp(sum,file->sum,MD4_SUM_LENGTH) == 0);
write_int(f, sum->count);
write_int(f, sum->blength);
- if (remote_version >= 27)
+ if (protocol_version >= 27)
write_int(f, sum->s2length);
write_int(f, sum->remainder);
}
blength = MAX(blength, BLOCK_SIZE);
}
- if (remote_version < 27) {
+ if (protocol_version < 27) {
s2length = csum_length;
} else if (csum_length == SUM_LENGTH) {
s2length = SUM_LENGTH;
{
unsigned char buf[128];
uint32 M[16];
- extern int remote_version;
+ extern int protocol_version;
/*
* Count total number of bits, modulo 2^64
* of bits modulo 2^64, which was fixed starting with
* protocol version 27.
*/
- if (remote_version >= 27) {
+ if (protocol_version >= 27) {
copy4(buf+60, m->totalN2);
}
copy64(M, buf);
* of bits modulo 2^64, which was fixed starting with
* protocol version 27.
*/
- if (remote_version >= 27) {
+ if (protocol_version >= 27) {
copy4(buf+124, m->totalN2);
}
copy64(M, buf);
extern int am_sender;
extern int am_daemon;
extern int verbose;
+extern int protocol_version;
/* there's probably never more than at most 2 outstanding child processes,
* but set it higher just in case.
{
time_t t = time(NULL);
extern int do_stats;
- extern int remote_version;
int send_stats;
if (do_stats && verbose > 1) {
if (f == -1 || !am_sender) return;
}
- send_stats = verbose || (remote_version >= 20);
+ send_stats = verbose || protocol_version >= 20;
if (am_server) {
if (am_sender && send_stats) {
int64 w;
char *dir = argv[0];
extern int relative_paths;
extern int recurse;
- extern int remote_version;
if (verbose > 2)
rprintf(FINFO,"server_sender starting pid=%d\n",(int)getpid());
send_files(flist,f_out,f_in);
io_flush();
report(f_out);
- if (remote_version >= 24) {
+ if (protocol_version >= 24) {
/* final goodbye message */
read_int(f_in);
}
extern int delete_after;
extern int recurse;
extern int delete_mode;
- extern int remote_version;
if (preserve_hard_links)
init_hard_links(flist);
read_int(recv_pipe[0]);
close(recv_pipe[0]);
- if (remote_version >= 24) {
+ if (protocol_version >= 24) {
/* send a final goodbye message */
write_int(f_out, -1);
}
void start_server(int f_in, int f_out, int argc, char *argv[])
{
extern int cvs_exclude;
- extern int remote_version;
extern int read_batch;
setup_protocol(f_out, f_in);
set_nonblocking(f_in);
set_nonblocking(f_out);
- if (remote_version >= 23)
+ if (protocol_version >= 23)
io_start_multiplex_out(f_out);
if (am_sender) {
struct file_list *flist = NULL;
int status = 0, status2 = 0;
char *local_name = NULL;
- extern int remote_version;
extern pid_t cleanup_child_pid;
extern int write_batch;
extern int read_batch;
setup_protocol(f_out,f_in);
- if (remote_version >= 23)
+ if (protocol_version >= 23)
io_start_multiplex_in(f_in);
if (am_sender) {
rprintf(FINFO,"file list sent\n");
send_files(flist,f_out,f_in);
- if (remote_version >= 24) {
+ if (protocol_version >= 24) {
/* final goodbye message */
read_int(f_in);
}
extern int verbose;
extern int recurse;
extern int delete_mode;
-extern int remote_version;
+extern int protocol_version;
extern int csum_length;
extern struct stats stats;
extern int dry_run;
if (!S_ISDIR(flist->files[j]->mode) ||
!(flist->files[j]->flags & FLAG_DELETE)) continue;
- if (remote_version < 19 &&
+ if (protocol_version < 19 &&
delete_already_done(flist, j)) continue;
name = strdup(f_name(flist->files[j]));
for (i=local_file_list->count-1;i>=0;i--) {
if (max_delete && deletion_count > max_delete) break;
if (!local_file_list->files[i]->basename) continue;
- if (remote_version < 19 &&
+ if (protocol_version < 19 &&
S_ISDIR(local_file_list->files[i]->mode))
add_delete_entry(local_file_list->files[i]);
if (-1 == flist_find(flist,local_file_list->files[i])) {
void read_sum_head(int f, struct sum_struct *sum)
{
- extern int remote_version;
+ extern int protocol_version;
sum->count = read_int(f);
sum->blength = read_int(f);
- if (remote_version < 27)
- {
+ if (protocol_version < 27)
sum->s2length = csum_length;
- } else {
+ else
sum->s2length = read_int(f);
- }
sum->remainder = read_int(f);
}