| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| #include "rsync.h" |
| #include <zlib.h> |
| #include <time.h> |
| |
| extern int eol_nulls; |
| extern int recurse; |
| extern int xfer_dirs; |
| extern int preserve_links; |
| extern int preserve_hard_links; |
| extern int preserve_devices; |
| extern int preserve_uid; |
| extern int preserve_gid; |
| extern int preserve_acls; |
| extern int preserve_xattrs; |
| extern int always_checksum; |
| extern int do_compression; |
| extern int inplace; |
| extern int append_mode; |
| extern int protocol_version; |
| extern char *batch_name; |
| #ifdef ICONV_OPTION |
| extern char *iconv_opt; |
| #endif |
| |
| extern filter_rule_list filter_list; |
| |
| int batch_stream_flags; |
| |
| static int tweaked_append; |
| static int tweaked_append_verify; |
| static int tweaked_iconv; |
| |
| static int *flag_ptr[] = { |
| &recurse, |
| &preserve_uid, |
| &preserve_gid, |
| &preserve_links, |
| &preserve_devices, |
| &preserve_hard_links, |
| &always_checksum, |
| &xfer_dirs, |
| &do_compression, |
| &tweaked_iconv, |
| &preserve_acls, |
| &preserve_xattrs, |
| &inplace, |
| &tweaked_append, |
| &tweaked_append_verify, |
| NULL |
| }; |
| |
| static char *flag_name[] = { |
| "--recurse (-r)", |
| "--owner (-o)", |
| "--group (-g)", |
| "--links (-l)", |
| "--devices (-D)", |
| "--hard-links (-H)", |
| "--checksum (-c)", |
| "--dirs (-d)", |
| "--compress (-z)", |
| "--iconv", |
| "--acls (-A)", |
| "--xattrs (-X)", |
| "--inplace", |
| "--append", |
| "--append-verify", |
| NULL |
| }; |
| |
| void write_stream_flags(int fd) |
| { |
| int i, flags; |
| |
| tweaked_append = append_mode == 1; |
| tweaked_append_verify = append_mode == 2; |
| #ifdef ICONV_OPTION |
| tweaked_iconv = iconv_opt != NULL; |
| #endif |
| |
| |
| |
| for (i = 0, flags = 0; flag_ptr[i]; i++) { |
| if (*flag_ptr[i]) |
| flags |= 1 << i; |
| } |
| write_int(fd, flags); |
| } |
| |
| void read_stream_flags(int fd) |
| { |
| batch_stream_flags = read_int(fd); |
| } |
| |
| void check_batch_flags(void) |
| { |
| int i; |
| |
| if (protocol_version < 29) |
| flag_ptr[7] = NULL; |
| else if (protocol_version < 30) |
| flag_ptr[9] = NULL; |
| tweaked_append = append_mode == 1; |
| tweaked_append_verify = append_mode == 2; |
| #ifdef ICONV_OPTION |
| tweaked_iconv = iconv_opt != NULL; |
| #endif |
| for (i = 0; flag_ptr[i]; i++) { |
| int set = batch_stream_flags & (1 << i) ? 1 : 0; |
| if (*flag_ptr[i] != set) { |
| if (i == 9) { |
| rprintf(FERROR, |
| "%s specify the --iconv option to use this batch file.\n", |
| set ? "Please" : "Do not"); |
| exit_cleanup(RERR_SYNTAX); |
| } |
| if (INFO_GTE(MISC, 1)) { |
| rprintf(FINFO, |
| "%sing the %s option to match the batchfile.\n", |
| set ? "Sett" : "Clear", flag_name[i]); |
| } |
| *flag_ptr[i] = set; |
| } |
| } |
| if (protocol_version < 29) { |
| if (recurse) |
| xfer_dirs |= 1; |
| else if (xfer_dirs < 2) |
| xfer_dirs = 0; |
| } |
| |
| if (tweaked_append) |
| append_mode = 1; |
| else if (tweaked_append_verify) |
| append_mode = 2; |
| } |
| |
| static int write_arg(int fd, char *arg) |
| { |
| char *x, *s; |
| int len, ret = 0; |
| |
| if (*arg == '-' && (x = strchr(arg, '=')) != NULL) { |
| if (write(fd, arg, x - arg + 1) != x - arg + 1) |
| ret = -1; |
| arg += x - arg + 1; |
| } |
| |
| if (strpbrk(arg, " \"'&;|[]()$#!*?^\\") != NULL) { |
| if (write(fd, "'", 1) != 1) |
| ret = -1; |
| for (s = arg; (x = strchr(s, '\'')) != NULL; s = x + 1) { |
| if (write(fd, s, x - s + 1) != x - s + 1 |
| || write(fd, "'", 1) != 1) |
| ret = -1; |
| } |
| len = strlen(s); |
| if (write(fd, s, len) != len |
| || write(fd, "'", 1) != 1) |
| ret = -1; |
| return ret; |
| } |
| |
| len = strlen(arg); |
| if (write(fd, arg, len) != len) |
| ret = -1; |
| |
| return ret; |
| } |
| |
| static void write_filter_rules(int fd) |
| { |
| filter_rule *ent; |
| |
| write_sbuf(fd, " <<'#E#'\n"); |
| for (ent = filter_list.head; ent; ent = ent->next) { |
| unsigned int plen; |
| char *p = get_rule_prefix(ent, "- ", 0, &plen); |
| write_buf(fd, p, plen); |
| write_sbuf(fd, ent->pattern); |
| if (ent->rflags & FILTRULE_DIRECTORY) |
| write_byte(fd, '/'); |
| write_byte(fd, eol_nulls ? 0 : '\n'); |
| } |
| if (eol_nulls) |
| write_sbuf(fd, ";\n"); |
| write_sbuf(fd, "#E#"); |
| } |
| |
| |
| |
| |
| |
| |
| void write_batch_shell_file(int argc, char *argv[], int file_arg_cnt) |
| { |
| int fd, i, len, err = 0; |
| char *p, filename[MAXPATHLEN]; |
| |
| stringjoin(filename, sizeof filename, |
| batch_name, ".sh", NULL); |
| fd = do_open(filename, O_WRONLY | O_CREAT | O_TRUNC, |
| S_IRUSR | S_IWUSR | S_IXUSR); |
| if (fd < 0) { |
| rsyserr(FERROR, errno, "Batch file %s open error", |
| filename); |
| exit_cleanup(RERR_FILESELECT); |
| } |
| |
| |
| if (write_arg(fd, argv[0]) < 0) |
| err = 1; |
| if (filter_list.head) { |
| if (protocol_version >= 29) |
| write_sbuf(fd, " --filter=._-"); |
| else |
| write_sbuf(fd, " --exclude-from=-"); |
| } |
| for (i = 1; i < argc - file_arg_cnt; i++) { |
| p = argv[i]; |
| if (strncmp(p, "--files-from", 12) == 0 |
| || strncmp(p, "--filter", 8) == 0 |
| || strncmp(p, "--include", 9) == 0 |
| || strncmp(p, "--exclude", 9) == 0) { |
| if (strchr(p, '=') == NULL) |
| i++; |
| continue; |
| } |
| if (strcmp(p, "-f") == 0) { |
| i++; |
| continue; |
| } |
| if (write(fd, " ", 1) != 1) |
| err = 1; |
| if (strncmp(p, "--write-batch", len = 13) == 0 |
| || strncmp(p, "--only-write-batch", len = 18) == 0) { |
| if (write(fd, "--read-batch", 12) != 12) |
| err = 1; |
| if (p[len] == '=') { |
| if (write(fd, "=", 1) != 1 |
| || write_arg(fd, p + len + 1) < 0) |
| err = 1; |
| } |
| } else { |
| if (write_arg(fd, p) < 0) |
| err = 1; |
| } |
| } |
| if (!(p = check_for_hostspec(argv[argc - 1], &p, &i))) |
| p = argv[argc - 1]; |
| if (write(fd, " ${1:-", 6) != 6 |
| || write_arg(fd, p) < 0) |
| err = 1; |
| write_byte(fd, '}'); |
| if (filter_list.head) |
| write_filter_rules(fd); |
| if (write(fd, "\n", 1) != 1 || close(fd) < 0 || err) { |
| rsyserr(FERROR, errno, "Batch file %s write error", |
| filename); |
| exit_cleanup(RERR_FILEIO); |
| } |
| } |