-void send_file_entry(struct file_struct *file,int f,unsigned base_flags)
-{
- unsigned char flags;
- static time_t last_time;
- static mode_t last_mode;
- static dev_t last_rdev;
- static uid_t last_uid;
- static gid_t last_gid;
- static char lastname[MAXPATHLEN];
- char *fname;
- int l1,l2;
-
- if (f == -1) return;
-
- if (!file) {
- write_byte(f,0);
- return;
- }
-
- fname = f_name(file);
-
- flags = base_flags;
-
- 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 (file->modtime == last_time) flags |= SAME_TIME;
-
- for (l1=0;lastname[l1] && (fname[l1] == lastname[l1]) && (l1 < 255);l1++) ;
- l2 = strlen(fname) - l1;
-
- if (l1 > 0) flags |= SAME_NAME;
- if (l2 > 255) flags |= LONG_NAME;
-
- /* we must make sure we don't send a zero flags byte or the other
- end will terminate the flist transfer */
- if (flags == 0 && !S_ISDIR(file->mode)) flags |= FLAG_DELETE;
- if (flags == 0) flags |= LONG_NAME;
-
- write_byte(f,flags);
- if (flags & SAME_NAME)
- write_byte(f,l1);
- if (flags & LONG_NAME)
- write_int(f,l2);
- else
- write_byte(f,l2);
- write_buf(f,fname+l1,l2);
-
- write_longint(f,file->length);
- if (!(flags & SAME_TIME))
- write_int(f,(int)file->modtime);
- if (!(flags & SAME_MODE))
- write_int(f,(int)file->mode);
- if (preserve_uid && !(flags & SAME_UID)) {
- add_uid(file->uid);
- write_int(f,(int)file->uid);
- }
- if (preserve_gid && !(flags & SAME_GID)) {
- add_gid(file->gid);
- write_int(f,(int)file->gid);
- }
- if (preserve_devices && IS_DEVICE(file->mode) && !(flags & SAME_RDEV))
- write_int(f,(int)file->rdev);
+ if (!flist->files)
+ out_of_memory("flist_expand");
+}
+
+void send_file_entry(struct file_struct *file, int f, unsigned short base_flags)
+{
+ unsigned short flags;
+ static time_t modtime;
+ static mode_t mode;
+ static DEV64_T rdev, rdev_high;
+ static DEV64_T dev;
+ static uid_t uid;
+ static gid_t gid;
+ static char lastname[MAXPATHLEN];
+ char *fname, fbuf[MAXPATHLEN];
+ int l1, l2;
+
+ if (f == -1)
+ return;
+
+ if (!file) {
+ write_byte(f, 0);
+ modtime = 0, mode = 0;
+ rdev = 0, rdev_high = 0, dev = 0;
+ uid = 0, gid = 0;
+ *lastname = '\0';
+ return;
+ }
+
+ io_write_phase = "send_file_entry";
+
+ fname = f_name_to(file, fbuf);
+
+ flags = base_flags;
+
+ if (file->mode == mode)
+ flags |= XMIT_SAME_MODE;
+ else
+ mode = file->mode;
+ if (preserve_devices) {
+ if (protocol_version < 28) {
+ if (IS_DEVICE(mode)) {
+ if (file->u.rdev == rdev) {
+ /* Set both flags to simplify the test
+ * when writing the data. */
+ flags |= XMIT_SAME_RDEV_pre28
+ | XMIT_SAME_HIGH_RDEV;
+ } else
+ rdev = file->u.rdev;
+ } else
+ rdev = 0;
+ } else if (IS_DEVICE(mode)) {
+ if ((file->u.rdev & ~0xFF) == rdev_high)
+ flags |= XMIT_SAME_HIGH_RDEV;
+ else {
+ rdev = file->u.rdev;
+ rdev_high = rdev & ~0xFF;
+ }
+ }
+ }
+ if (file->uid == uid)
+ flags |= XMIT_SAME_UID;
+ else
+ uid = file->uid;
+ if (file->gid == gid)
+ flags |= XMIT_SAME_GID;
+ else
+ gid = file->gid;
+ if (file->modtime == modtime)
+ flags |= XMIT_SAME_TIME;
+ else
+ modtime = file->modtime;
+
+#if SUPPORT_HARD_LINKS
+ if (file->link_u.idev) {
+ if (file->F_DEV == dev) {
+ if (protocol_version >= 28)
+ flags |= XMIT_SAME_DEV;
+ } else
+ dev = file->F_DEV;
+ flags |= XMIT_HAS_IDEV_DATA;
+ }
+#endif
+
+ for (l1 = 0;
+ lastname[l1] && (fname[l1] == lastname[l1]) && (l1 < 255);
+ l1++) {}
+ l2 = strlen(fname+l1);
+
+ if (l1 > 0)
+ flags |= XMIT_SAME_NAME;
+ if (l2 > 255)
+ flags |= XMIT_LONG_NAME;
+
+ /* We must make sure we don't send a zero flag byte or the
+ * other end will terminate the flist transfer. Note that
+ * the use of XMIT_TOP_DIR on a non-dir has no meaning, so
+ * it's harmless way to add a bit to the first flag byte. */
+ if (protocol_version >= 28) {
+ if (!flags && !S_ISDIR(mode))
+ flags |= XMIT_TOP_DIR;
+ if ((flags & 0xFF00) || !flags) {
+ flags |= XMIT_EXTENDED_FLAGS;
+ write_byte(f, flags);
+ write_byte(f, flags >> 8);
+ } else
+ write_byte(f, flags);
+ } else {
+ if (!(flags & 0xFF) && !S_ISDIR(mode))
+ flags |= XMIT_TOP_DIR;
+ if (!(flags & 0xFF))
+ flags |= XMIT_LONG_NAME;
+ write_byte(f, flags);
+ }
+ if (flags & XMIT_SAME_NAME)
+ write_byte(f, l1);
+ if (flags & XMIT_LONG_NAME)
+ write_int(f, l2);
+ else
+ write_byte(f, l2);
+ write_buf(f, fname + l1, l2);
+
+ write_longint(f, file->length);
+ if (!(flags & XMIT_SAME_TIME))
+ write_int(f, modtime);
+ if (!(flags & XMIT_SAME_MODE))
+ write_int(f, to_wire_mode(mode));
+ if (preserve_uid && !(flags & XMIT_SAME_UID)) {
+ if (!numeric_ids)
+ add_uid(uid);
+ write_int(f, uid);
+ }
+ if (preserve_gid && !(flags & XMIT_SAME_GID)) {
+ if (!numeric_ids)
+ add_gid(gid);
+ write_int(f, gid);
+ }
+ if (preserve_devices && IS_DEVICE(mode)) {
+ /* If XMIT_SAME_HIGH_RDEV is off, XMIT_SAME_RDEV_pre28 is
+ * also off. */
+ if (!(flags & XMIT_SAME_HIGH_RDEV))
+ write_int(f, rdev);
+ else if (protocol_version >= 28)
+ write_byte(f, rdev);
+ }
+
+#if SUPPORT_LINKS
+ if (preserve_links && S_ISLNK(mode)) {
+ int len = strlen(file->u.link);
+ write_int(f, len);
+ write_buf(f, file->u.link, len);
+ }
+#endif
+
+#if SUPPORT_HARD_LINKS
+ if (flags & XMIT_HAS_IDEV_DATA) {
+ if (protocol_version < 26) {
+ /* 32-bit dev_t and ino_t */
+ write_int(f, dev);
+ write_int(f, file->F_INODE);
+ } else {
+ /* 64-bit dev_t and ino_t */
+ if (!(flags & XMIT_SAME_DEV))
+ write_longint(f, dev);
+ write_longint(f, file->F_INODE);
+ }
+ }
+#endif
+
+ if (always_checksum) {
+ char *sum;
+ if (S_ISREG(mode))
+ sum = file->u.sum;
+ else if (protocol_version < 28) {
+ /* Prior to 28, we sent a useless set of nulls. */
+ sum = empty_sum;
+ } else
+ sum = NULL;
+ if (sum) {
+ write_buf(f, sum, protocol_version < 21? 2
+ : MD4_SUM_LENGTH);
+ }
+ }
+
+ strlcpy(lastname, fname, MAXPATHLEN);
+
+ io_write_phase = "unknown";
+}
+
+
+
+void receive_file_entry(struct file_struct **fptr, unsigned short flags, int f)
+{
+ static time_t modtime;
+ static mode_t mode;
+ static DEV64_T rdev, rdev_high;
+ static DEV64_T dev;
+ static uid_t uid;
+ static gid_t gid;
+ static char lastname[MAXPATHLEN], *lastdir;
+ static int lastdir_len = -1;
+ char thisname[MAXPATHLEN];
+ unsigned int l1 = 0, l2 = 0;
+ int alloc_len, basename_len, dirname_len, linkname_len, sum_len;
+ int file_struct_len, idev_len;
+ OFF_T file_length;
+ char *basename, *dirname, *bp;
+ struct file_struct *file;
+
+ if (!fptr) {
+ modtime = 0, mode = 0;
+ rdev = 0, rdev_high = 0, dev = 0;
+ uid = 0, gid = 0;
+ *lastname = '\0';
+ return;
+ }
+
+ if (flags & XMIT_SAME_NAME)
+ l1 = read_byte(f);
+
+ if (flags & XMIT_LONG_NAME)
+ l2 = read_int(f);
+ else
+ l2 = read_byte(f);
+
+ if (l2 >= MAXPATHLEN - l1) {
+ rprintf(FERROR,
+ "overflow: flags=0x%x l1=%d l2=%d lastname=%s\n",
+ flags, l1, l2, lastname);
+ overflow("receive_file_entry");
+ }
+
+ strlcpy(thisname, lastname, l1 + 1);
+ read_sbuf(f, &thisname[l1], l2);
+ thisname[l1 + l2] = 0;
+
+ strlcpy(lastname, thisname, MAXPATHLEN);
+
+ clean_fname(thisname);
+
+ if (sanitize_paths)
+ sanitize_path(thisname, NULL);
+
+ if ((basename = strrchr(thisname, '/')) != NULL) {
+ dirname_len = ++basename - thisname; /* counts future '\0' */
+ if (lastdir_len == dirname_len - 1
+ && strncmp(thisname, lastdir, lastdir_len) == 0) {
+ dirname = lastdir;
+ dirname_len = 0; /* indicates no copy is needed */
+ } else
+ dirname = thisname;
+ } else {
+ basename = thisname;
+ dirname = NULL;
+ dirname_len = 0;
+ }
+ basename_len = strlen(basename) + 1; /* count the '\0' */
+
+ file_length = read_longint(f);
+ if (!(flags & XMIT_SAME_TIME))
+ modtime = (time_t)read_int(f);
+ if (!(flags & XMIT_SAME_MODE))
+ mode = from_wire_mode(read_int(f));
+
+ if (preserve_uid && !(flags & XMIT_SAME_UID))
+ uid = (uid_t)read_int(f);
+ if (preserve_gid && !(flags & XMIT_SAME_GID))
+ gid = (gid_t)read_int(f);
+
+ if (preserve_devices) {
+ if (protocol_version < 28) {
+ if (IS_DEVICE(mode)) {
+ if (!(flags & XMIT_SAME_RDEV_pre28))
+ rdev = (DEV64_T)read_int(f);
+ } else
+ rdev = 0;
+ } else if (IS_DEVICE(mode)) {
+ if (!(flags & XMIT_SAME_HIGH_RDEV)) {
+ rdev = (DEV64_T)read_int(f);
+ rdev_high = rdev & ~0xFF;
+ } else
+ rdev = rdev_high | (DEV64_T)read_byte(f);
+ }
+ }