X-Git-Url: https://mattmccutchen.net/rsync/rsync.git/blobdiff_plain/aae43eb38f8c49c8ac675f8269b06d11a72bd10e..16edf86595a5a990a942fa045dfb523dae1fe6cb:/compat.c diff --git a/compat.c b/compat.c index 293bbc6c..3f4bd45c 100644 --- a/compat.c +++ b/compat.c @@ -1,221 +1,195 @@ -/* - Copyright (C) Andrew Tridgell 1996 - Copyright (C) Paul Mackerras 1996 - - This program is free software; you can redistribute it and/or modify - it under the terms of the GNU General Public License as published by - the Free Software Foundation; either version 2 of the License, or - (at your option) any later version. - - This program is distributed in the hope that it will be useful, - but WITHOUT ANY WARRANTY; without even the implied warranty of - MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the - GNU General Public License for more details. - - You should have received a copy of the GNU General Public License - along with this program; if not, write to the Free Software - Foundation, Inc., 675 Mass Ave, Cambridge, MA 02139, USA. -*/ - -/* compatability routines for older rsync protocol versions */ +/* + * Compatibility routines for older rsync protocol versions. + * + * Copyright (C) Andrew Tridgell 1996 + * Copyright (C) Paul Mackerras 1996 + * Copyright (C) 2004-2007 Wayne Davison + * + * This program is free software; you can redistribute it and/or modify + * it under the terms of the GNU General Public License version 2 as + * published by the Free Software Foundation. + * + * This program is distributed in the hope that it will be useful, + * but WITHOUT ANY WARRANTY; without even the implied warranty of + * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the + * GNU General Public License for more details. + * + * You should have received a copy of the GNU General Public License along + * with this program; if not, write to the Free Software Foundation, Inc., + * 51 Franklin Street - Fifth Floor, Boston, MA 02110-1301, USA. + */ #include "rsync.h" -extern int am_server; - -extern int csum_length; +int remote_protocol = 0; +int file_extra_cnt = 0; /* count of file-list extras that everyone gets */ +int inc_recurse = 0; -extern int preserve_links; -extern int preserve_perms; -extern int preserve_devices; +extern int verbose; +extern int am_server; +extern int am_sender; +extern int local_server; +extern int inplace; +extern int recurse; +extern int allow_inc_recurse; +extern int fuzzy_basis; +extern int read_batch; +extern int max_delete; +extern int delay_updates; +extern int checksum_seed; +extern int basis_dir_cnt; +extern int prune_empty_dirs; +extern int protocol_version; extern int preserve_uid; extern int preserve_gid; -extern int preserve_times; -extern int always_checksum; -extern int checksum_seed; - - -extern int remote_version; - - void (*send_file_entry)(struct file_struct *file,int f) = NULL; - void (*receive_file_entry)(struct file_struct *file, - unsigned char flags,int f) = NULL; - - -void send_file_entry_v10(struct file_struct *file,int f) -{ - unsigned char flags; - static mode_t last_mode=0; - static dev_t last_rdev=0; - static uid_t last_uid=0; - static gid_t last_gid=0; - static char lastdir[MAXPATHLEN]=""; - char *p=NULL; - - if (f == -1) return; - - if (!file) { - write_byte(f,0); - return; - } - - flags = FILE_VALID; - - if (file->mode == last_mode) flags |= SAME_MODE; - if (file->rdev == last_rdev) flags |= SAME_RDEV; - if (file->uid == last_uid) flags |= SAME_UID; - if (file->gid == last_gid) flags |= SAME_GID; - - if (strncmp(file->name,lastdir,strlen(lastdir)) == 0) { - flags |= SAME_DIR; - p = file->name + strlen(lastdir); - } else { - p = file->name; - } - - write_byte(f,flags); - if (flags & SAME_DIR) - write_byte(f,strlen(p)); - else - write_int(f,strlen(p)); - write_buf(f,p,strlen(p)); - write_int(f,(int)file->modtime); - write_int(f,(int)file->length); - if (!(flags & SAME_MODE)) - write_int(f,(int)file->mode); - if (preserve_uid && !(flags & SAME_UID)) - write_int(f,(int)file->uid); - if (preserve_gid && !(flags & SAME_GID)) - write_int(f,(int)file->gid); - if (preserve_devices && IS_DEVICE(file->mode) && !(flags & SAME_RDEV)) - write_int(f,(int)file->rdev); - -#if SUPPORT_LINKS - if (preserve_links && S_ISLNK(file->mode)) { - write_int(f,strlen(file->link)); - write_buf(f,file->link,strlen(file->link)); - } -#endif - - if (always_checksum) { - write_buf(f,file->sum,csum_length); - } - - last_mode = file->mode; - last_rdev = file->rdev; - last_uid = file->uid; - last_gid = file->gid; - p = strrchr(file->name,'/'); - if (p) { - int l = (int)(p - file->name) + 1; - strncpy(lastdir,file->name,l); - lastdir[l] = 0; - } else { - strcpy(lastdir,""); - } -} - - - -void receive_file_entry_v10(struct file_struct *file, - unsigned char flags,int f) -{ - static mode_t last_mode=0; - static dev_t last_rdev=0; - static uid_t last_uid=0; - static gid_t last_gid=0; - static char lastdir[MAXPATHLEN]=""; - char *p=NULL; - int l1,l2; - - if (flags & SAME_DIR) { - l1 = read_byte(f); - l2 = strlen(lastdir); - } else { - l1 = read_int(f); - l2 = 0; - } - - file->name = (char *)malloc(l1+l2+1); - if (!file->name) out_of_memory("receive_file_entry"); - - strncpy(file->name,lastdir,l2); - read_buf(f,file->name+l2,l1); - file->name[l1+l2] = 0; - - file->modtime = (time_t)read_int(f); - file->length = (off_t)read_int(f); - file->mode = (flags & SAME_MODE) ? last_mode : (mode_t)read_int(f); - if (preserve_uid) - file->uid = (flags & SAME_UID) ? last_uid : (uid_t)read_int(f); - if (preserve_gid) - file->gid = (flags & SAME_GID) ? last_gid : (gid_t)read_int(f); - if (preserve_devices && IS_DEVICE(file->mode)) - file->rdev = (flags & SAME_RDEV) ? last_rdev : (dev_t)read_int(f); - -#if SUPPORT_LINKS - if (preserve_links && S_ISLNK(file->mode)) { - int l = read_int(f); - file->link = (char *)malloc(l+1); - if (!file->link) out_of_memory("receive_file_entry"); - read_buf(f,file->link,l); - file->link[l] = 0; - } -#endif - - if (always_checksum) - read_buf(f,file->sum,csum_length); - - last_mode = file->mode; - last_rdev = file->rdev; - last_uid = file->uid; - last_gid = file->gid; - p = strrchr(file->name,'/'); - if (p) { - int l = (int)(p - file->name) + 1; - strncpy(lastdir,file->name,l); - lastdir[l] = 0; - } else { - strcpy(lastdir,""); - } -} - - - +extern int preserve_acls; +extern int preserve_xattrs; +extern int preserve_hard_links; +extern int need_messages_from_generator; +extern int delete_mode, delete_before, delete_during, delete_after; +extern int delete_excluded; +extern int make_backups; +extern char *backup_dir, *backup_suffix; +extern char *partial_dir; +extern char *dest_option; +extern struct filter_list_struct filter_list; void setup_protocol(int f_out,int f_in) { - if (am_server) { - remote_version = read_int(f_in); - write_int(f_out,PROTOCOL_VERSION); - write_flush(f_out); - } else { - write_int(f_out,PROTOCOL_VERSION); - write_flush(f_out); - remote_version = read_int(f_in); - } - - if (remote_version < MIN_PROTOCOL_VERSION || - remote_version > MAX_PROTOCOL_VERSION) { - fprintf(FERROR,"protocol version mismatch - is your shell clean?\n"); - exit_cleanup(1); - } - - if (remote_version == 10) { - send_file_entry = send_file_entry_v10; - receive_file_entry = receive_file_entry_v10; - } else { - send_file_entry = send_file_entry_v11; - receive_file_entry = receive_file_entry_v11; - } - - if (remote_version >= 12) { - if (am_server) { - checksum_seed = time(NULL); - write_int(f_out,checksum_seed); - } else { - checksum_seed = read_int(f_in); - } - } + if (am_sender) + file_extra_cnt += PTR_EXTRA_LEN; + else + file_extra_cnt++; + if (preserve_uid) + preserve_uid = ++file_extra_cnt; + if (preserve_gid) + preserve_gid = ++file_extra_cnt; + if (preserve_acls && !am_sender) + preserve_acls = ++file_extra_cnt; + if (preserve_xattrs) + preserve_xattrs = ++file_extra_cnt; + + if (remote_protocol == 0) { + if (!read_batch) + write_int(f_out, protocol_version); + remote_protocol = read_int(f_in); + if (protocol_version > remote_protocol) + protocol_version = remote_protocol; + } + if (read_batch && remote_protocol > protocol_version) { + rprintf(FERROR, "The protocol version in the batch file is too new (%d > %d).\n", + remote_protocol, protocol_version); + exit_cleanup(RERR_PROTOCOL); + } + + if (verbose > 3) { + rprintf(FINFO, "(%s) Protocol versions: remote=%d, negotiated=%d\n", + am_server? "Server" : "Client", remote_protocol, protocol_version); + } + if (remote_protocol < MIN_PROTOCOL_VERSION + || remote_protocol > MAX_PROTOCOL_VERSION) { + rprintf(FERROR,"protocol version mismatch -- is your shell clean?\n"); + rprintf(FERROR,"(see the rsync man page for an explanation)\n"); + exit_cleanup(RERR_PROTOCOL); + } + if (remote_protocol < OLD_PROTOCOL_VERSION) { + rprintf(FINFO,"%s is very old version of rsync, upgrade recommended.\n", + am_server? "Client" : "Server"); + } + if (protocol_version < MIN_PROTOCOL_VERSION) { + rprintf(FERROR, "--protocol must be at least %d on the %s.\n", + MIN_PROTOCOL_VERSION, am_server? "Server" : "Client"); + exit_cleanup(RERR_PROTOCOL); + } + if (protocol_version > PROTOCOL_VERSION) { + rprintf(FERROR, "--protocol must be no more than %d on the %s.\n", + PROTOCOL_VERSION, am_server? "Server" : "Client"); + exit_cleanup(RERR_PROTOCOL); + } + + if (protocol_version < 30) { + if (max_delete == 0 && am_sender) { + rprintf(FERROR, + "--max-delete=0 requires protocol 30 or higher" + " (negotiated %d).\n", + protocol_version); + exit_cleanup(RERR_PROTOCOL); + } + if (preserve_acls) { + rprintf(FERROR, + "--acls requires protocol 30 or higher" + " (negotiated %d).\n", + protocol_version); + exit_cleanup(RERR_PROTOCOL); + } + if (preserve_xattrs) { + rprintf(FERROR, + "--xattrs requires protocol 30 or higher" + " (negotiated %d).\n", + protocol_version); + exit_cleanup(RERR_PROTOCOL); + } + } + + if (delete_mode && !(delete_before+delete_during+delete_after)) { + if (protocol_version < 30) + delete_before = 1; + else + delete_during = 1; + } + + if (protocol_version < 29) { + if (fuzzy_basis) { + rprintf(FERROR, + "--fuzzy requires protocol 29 or higher" + " (negotiated %d).\n", + protocol_version); + exit_cleanup(RERR_PROTOCOL); + } + + if (basis_dir_cnt && inplace) { + rprintf(FERROR, + "%s with --inplace requires protocol 29 or higher" + " (negotiated %d).\n", + dest_option, protocol_version); + exit_cleanup(RERR_PROTOCOL); + } + + if (basis_dir_cnt > 1) { + rprintf(FERROR, + "Using more than one %s option requires protocol" + " 29 or higher (negotiated %d).\n", + dest_option, protocol_version); + exit_cleanup(RERR_PROTOCOL); + } + + if (prune_empty_dirs) { + rprintf(FERROR, + "--prune-empty-dirs requires protocol 29 or higher" + " (negotiated %d).\n", + protocol_version); + exit_cleanup(RERR_PROTOCOL); + } + } else if (protocol_version >= 30) { + if (recurse && allow_inc_recurse && !preserve_hard_links + && !delete_before && !delete_after && !delay_updates + && !prune_empty_dirs) + inc_recurse = 1; + need_messages_from_generator = 1; + } + + if (partial_dir && *partial_dir != '/' && (!am_server || local_server)) { + int flags = MATCHFLG_NO_PREFIXES | MATCHFLG_DIRECTORY; + if (!am_sender || protocol_version >= 30) + flags |= MATCHFLG_PERISHABLE; + parse_rule(&filter_list, partial_dir, flags, 0); + } + + if (am_server) { + if (!checksum_seed) + checksum_seed = time(NULL); + write_int(f_out, checksum_seed); + } else { + checksum_seed = read_int(f_in); + } } -