X-Git-Url: https://mattmccutchen.net/rsync/rsync.git/blobdiff_plain/20f90d5e8a58fa8992993b444897d435af4a7896..82ad07c4182f744c07b96a15df4572e559ed7dc8:/hlink.c

diff --git a/hlink.c b/hlink.c
index 65ddd158..d4808fc9 100644
--- a/hlink.c
+++ b/hlink.c
@@ -24,8 +24,12 @@
 #include "rsync.h"
 
 extern int verbose;
+extern int dry_run;
+extern int do_xfers;
 extern int link_dest;
 extern int make_backups;
+extern int flist_extra_ndx;
+extern int remove_source_files;
 extern int stdout_format_has_i;
 extern char *basis_dir[];
 extern struct file_list *the_file_list;
@@ -36,65 +40,73 @@ extern struct file_list *the_file_list;
 #define FINISHED_LINK (-2)
 
 #define FPTR(i) (the_file_list->files[i])
-#define LINKED(p1,p2) (FPTR(p1)->F_DEV == FPTR(p2)->F_DEV \
-		    && FPTR(p1)->F_INODE == FPTR(p2)->F_INODE)
+#define LINKED(i1,i2) ((i1)->dev == (i2)->dev && (i1)->ino == (i2)->ino)
 
 static int hlink_compare(int *int1, int *int2)
 {
 	struct file_struct *f1 = FPTR(*int1);
 	struct file_struct *f2 = FPTR(*int2);
+	struct idev *i1 = F_IDEV(f1);
+	struct idev *i2 = F_IDEV(f2);
 
-	if (f1->F_DEV != f2->F_DEV)
-		return (int) (f1->F_DEV > f2->F_DEV ? 1 : -1);
+	if (i1->dev != i2->dev)
+		return (int)(i1->dev > i2->dev ? 1 : -1);
 
-	if (f1->F_INODE != f2->F_INODE)
-		return (int) (f1->F_INODE > f2->F_INODE ? 1 : -1);
+	if (i1->ino != i2->ino)
+		return (int)(i1->ino > i2->ino ? 1 : -1);
 
 	return f_name_cmp(f1, f2);
 }
 
-static int *hlink_list;
-static int hlink_count;
+static int32 *hlink_list;
+static int32 hlink_count;
 
 /* Analyze the data in the hlink_list[], remove items that aren't multiply
  * linked, and replace the dev+inode data with the hlindex+next linked list. */
 static void link_idev_data(void)
 {
-	int cur, from, to, start;
+	int32 from, to, start;
+	struct file_struct *file, *file_next;
+	struct idev *idev, *idev_next;
+	struct hlist *hl;
 
 	alloc_pool_t hlink_pool;
 	alloc_pool_t idev_pool = the_file_list->hlink_pool;
 
-	hlink_pool = pool_create(128 * 1024, sizeof (struct hlink),
-	    out_of_memory, POOL_INTERN);
+	hlink_pool = pool_create(128 * 1024, sizeof (struct hlist), out_of_memory, POOL_INTERN);
 
 	for (from = to = 0; from < hlink_count; from++) {
 		start = from;
-		while (1) {
-			cur = hlink_list[from];
-			if (from == hlink_count-1
-			    || !LINKED(cur, hlink_list[from+1]))
+		for (file = FPTR(hlink_list[from]), idev = F_IDEV(file);
+		     from < hlink_count-1;
+		     file = file_next, idev = idev_next)
+		{
+			file_next = FPTR(hlink_list[from+1]);
+			idev_next = F_IDEV(file_next);
+			if (!LINKED(idev, idev_next))
 				break;
-			pool_free(idev_pool, 0, FPTR(cur)->link_u.idev);
-			FPTR(cur)->link_u.links = pool_talloc(hlink_pool,
-			    struct hlink, 1, "hlink_list");
-
-			FPTR(cur)->F_HLINDEX = to;
-			FPTR(cur)->F_NEXT = hlink_list[++from];
+			pool_free(idev_pool, 0, idev);
+			hl = pool_talloc(hlink_pool, struct hlist, 1,
+					 "hlink_list");
+			hl->hlindex = to;
+			hl->next = hlink_list[++from];
+			hl->dest_used = 0;
+			F_HLIST(file) = hl;
 		}
-		pool_free(idev_pool, 0, FPTR(cur)->link_u.idev);
+		pool_free(idev_pool, 0, idev);
 		if (from > start) {
 			int head = hlink_list[start];
-			FPTR(cur)->link_u.links = pool_talloc(hlink_pool,
-			    struct hlink, 1, "hlink_list");
-
-			FPTR(head)->flags |= FLAG_HLINK_TOL;
-			FPTR(cur)->F_HLINDEX = to;
-			FPTR(cur)->F_NEXT = head;
-			FPTR(cur)->flags |= FLAG_HLINK_EOL;
+			hl = pool_talloc(hlink_pool, struct hlist, 1,
+					 "hlink_list");
+			FPTR(head)->flags |= FLAG_HLINK_FIRST;
+			hl->hlindex = to;
+			hl->next = head;
+			hl->dest_used = 0;
 			hlink_list[to++] = head;
+			file->flags |= FLAG_HLINK_LAST;
+			F_HLIST(file) = hl;
 		} else
-			FPTR(cur)->link_u.links = NULL;
+			file->flags &= ~FLAG_HLINK_INFO;
 	}
 
 	if (!to) {
@@ -104,7 +116,7 @@ static void link_idev_data(void)
 		hlink_pool = NULL;
 	} else {
 		hlink_count = to;
-		hlink_list = realloc_array(hlink_list, int, hlink_count);
+		hlink_list = realloc_array(hlink_list, int32, hlink_count);
 		if (!hlink_list)
 			out_of_memory("init_hard_links");
 	}
@@ -121,12 +133,12 @@ void init_hard_links(void)
 	if (hlink_list)
 		free(hlink_list);
 
-	if (!(hlink_list = new_array(int, the_file_list->count)))
+	if (!(hlink_list = new_array(int32, the_file_list->count)))
 		out_of_memory("init_hard_links");
 
 	hlink_count = 0;
 	for (i = 0; i < the_file_list->count; i++) {
-		if (FPTR(i)->link_u.idev)
+		if (IS_HLINKED(FPTR(i)))
 			hlink_list[hlink_count++] = i;
 	}
 
@@ -177,19 +189,28 @@ int hard_link_check(struct file_struct *file, int ndx, char *fname,
 {
 #ifdef SUPPORT_HARD_LINKS
 	int head;
-	if (skip && !(file->flags & FLAG_HLINK_EOL))
-		head = hlink_list[file->F_HLINDEX] = file->F_NEXT;
+	struct hlist *hl = F_HLIST(file);
+
+	if (skip && !(file->flags & FLAG_HLINK_LAST))
+		head = hlink_list[hl->hlindex] = hl->next;
 	else
-		head = hlink_list[file->F_HLINDEX];
+		head = hlink_list[hl->hlindex];
 	if (ndx != head) {
 		struct file_struct *head_file = FPTR(head);
+		struct hlist *hf_hl = F_HLIST(head_file);
 		if (!stdout_format_has_i && verbose > 1) {
 			rprintf(FINFO, "\"%s\" is a hard link\n",
 				f_name(file, NULL));
 		}
-		if (head_file->F_HLINDEX == FINISHED_LINK) {
+		if (hf_hl->hlindex == FINISHED_LINK) {
 			STRUCT_STAT st2, st3;
-			char *toname = f_name(head_file, NULL);
+			char toname[MAXPATHLEN];
+			int ldu = hf_hl->dest_used;
+			if (ldu) {
+				pathjoin(toname, MAXPATHLEN, basis_dir[ldu-1],
+					 f_name(head_file, NULL));
+			} else
+				f_name(head_file, toname);
 			if (link_stat(toname, &st2, 0) < 0) {
 				rsyserr(FERROR, errno, "stat %s failed",
 					full_fname(toname));
@@ -208,8 +229,10 @@ int hard_link_check(struct file_struct *file, int ndx, char *fname,
 							continue;
 						statret = 1;
 						st = &st3;
-						if (verbose < 2 || !stdout_format_has_i)
-							itemizing = code = 0;
+						if (verbose < 2 || !stdout_format_has_i) {
+							itemizing = 0;
+							code = FNONE;
+						}
 						break;
 					}
 					if (!unchanged_file(cmpbuf, file, &st3))
@@ -222,9 +245,14 @@ int hard_link_check(struct file_struct *file, int ndx, char *fname,
 			}
 			maybe_hard_link(file, ndx, fname, statret, st,
 					toname, &st2, itemizing, code);
-			file->F_HLINDEX = FINISHED_LINK;
+			if (remove_source_files == 1 && do_xfers) {
+				char numbuf[4];
+				SIVAL(numbuf, 0, ndx);
+				send_msg(MSG_SUCCESS, numbuf, 4);
+			}
+			hl->hlindex = FINISHED_LINK;
 		} else
-			file->F_HLINDEX = SKIPPED_LINK;
+			hl->hlindex = SKIPPED_LINK;
 		return 1;
 	}
 #endif
@@ -253,7 +281,7 @@ int hard_link_one(struct file_struct *file, int ndx, char *fname,
 			ITEM_LOCAL_CHANGE | ITEM_XNAME_FOLLOWS, 0,
 			terse ? "" : toname);
 	}
-	if (code && verbose && !terse)
+	if (code != FNONE && verbose && !terse)
 		rprintf(code, "%s => %s\n", fname, toname);
 	return 0;
 }
@@ -261,33 +289,43 @@ int hard_link_one(struct file_struct *file, int ndx, char *fname,
 
 
 void hard_link_cluster(struct file_struct *file, int master, int itemizing,
-		       enum logcode code)
+		       enum logcode code, int dest_used)
 {
 #ifdef SUPPORT_HARD_LINKS
 	char hlink1[MAXPATHLEN];
 	char *hlink2;
 	STRUCT_STAT st1, st2;
 	int statret, ndx = master;
+	struct hlist *hl = F_HLIST(file);
 
-	file->F_HLINDEX = FINISHED_LINK;
+	hl->hlindex = FINISHED_LINK;
+	if (dry_run)
+		hl->dest_used = dest_used + 1;
 	if (link_stat(f_name(file, hlink1), &st1, 0) < 0)
 		return;
-	if (!(file->flags & FLAG_HLINK_TOL)) {
-		while (!(file->flags & FLAG_HLINK_EOL)) {
-			ndx = file->F_NEXT;
+	if (!(file->flags & FLAG_HLINK_FIRST)) {
+		while (!(file->flags & FLAG_HLINK_LAST)) {
+			ndx = hl->next;
 			file = FPTR(ndx);
+			hl = F_HLIST(file);
 		}
 	}
 	do {
-		ndx = file->F_NEXT;
+		ndx = hl->next;
 		file = FPTR(ndx);
-		if (file->F_HLINDEX != SKIPPED_LINK)
+		hl = F_HLIST(file);
+		if (hl->hlindex != SKIPPED_LINK)
 			continue;
 		hlink2 = f_name(file, NULL);
 		statret = link_stat(hlink2, &st2, 0);
 		maybe_hard_link(file, ndx, hlink2, statret, &st2,
 				hlink1, &st1, itemizing, code);
-		file->F_HLINDEX = FINISHED_LINK;
-	} while (!(file->flags & FLAG_HLINK_EOL));
+		if (remove_source_files == 1 && do_xfers) {
+			char numbuf[4];
+			SIVAL(numbuf, 0, ndx);
+			send_msg(MSG_SUCCESS, numbuf, 4);
+		}
+		hl->hlindex = FINISHED_LINK;
+	} while (!(file->flags & FLAG_HLINK_LAST));
 #endif
 }