Add sync hardlink preserve support for local->NFS

azcopy/copy.go

@@ -144,6 +144,7 @@ func (c *Client) Copy(ctx context.Context, src, dest string, opts CopyOptions) (
 	}
 	jobID := common.NewJobID()
 	c.CurrentJobID = jobID
+
 	timeAtPrestart := time.Now()
 	common.AzcopyCurrentJobLogger = common.NewJobLogger(jobID, c.GetLogLevel(), common.LogPathFolder, "")
 	common.AzcopyCurrentJobLogger.OpenLog()
@@ -242,9 +243,10 @@ func (c *Client) Copy(ctx context.Context, src, dest string, opts CopyOptions) (
 }
 
 type transferExecutor struct {
-	opts *CookedTransferOptions
-	trp  *remoteProvider
-	tpt  *transferProgressTracker
+	opts       *CookedTransferOptions
+	trp        *remoteProvider
+	tpt        *transferProgressTracker
+	inodeStore *common.InodeStore
 }
 
 func newCopyTransferExecutor(ctx context.Context, jobID common.JobID, src, dst string, opts CopyOptions, uotm *common.UserOAuthTokenManager) (t *transferExecutor, err error) {
@@ -259,7 +261,12 @@ func newCopyTransferExecutor(ctx context.Context, jobID common.JobID, src, dst s
 		return nil, err
 	}
 
+	store, err := common.NewInodeStore(jobID)
+	if err != nil {
+		return nil, fmt.Errorf("failed to initialize inode store: %w", err)
+	}
+
 	progressTracker := newTransferProgressTracker(jobID, opts.Handler, cookedOpts.fromTo)
 
-	return &transferExecutor{opts: cookedOpts, trp: copyRemote, tpt: progressTracker}, nil
+	return &transferExecutor{opts: cookedOpts, trp: copyRemote, tpt: progressTracker, inodeStore: store}, nil
 }

azcopy/copyEnumerator.go

@@ -150,6 +150,7 @@ func (t *transferExecutor) initCopyEnumerator(ctx context.Context, logLevel comm
 
 		ExcludeContainers:    t.opts.excludeContainers,
 		IncrementEnumeration: t.tpt.incEnumeration,
+		InodeStore:           t.inodeStore,
 	})
 	if err != nil {
 		return nil, err

azcopy/output.go

@@ -156,6 +156,7 @@ Number of Copy Transfers Failed: %v
 Number of Deletions at Destination: %v
 Number of Symbolic Links Skipped: %v
 Number of Special Files Skipped: %v
+Number of Hardlinks Transferred: %v
 Number of Hardlinks Converted: %v
 Number of Hardlinks Skipped: %v
 Total Number of Bytes Transferred: %v
@@ -175,6 +176,7 @@ Final Job Status: %v%s%s
 		result.DeleteTransfersCompleted,
 		result.SkippedSymlinkCount,
 		result.SkippedSpecialFileCount,
+		result.HardlinksTransferCount,
 		result.HardlinksConvertedCount,
 		result.SkippedHardlinkCount,
 		result.TotalBytesTransferred,

azcopy/sync.go

@@ -132,6 +132,7 @@ func (c *Client) Sync(ctx context.Context, src, dest string, opts SyncOptions) (
 	}
 	jobID := common.NewJobID()
 	c.CurrentJobID = jobID
+
 	timeAtPrestart := time.Now()
 	common.AzcopyCurrentJobLogger = common.NewJobLogger(jobID, c.GetLogLevel(), common.LogPathFolder, "")
 	common.AzcopyCurrentJobLogger.OpenLog()
@@ -219,9 +220,10 @@ func (c *Client) Sync(ctx context.Context, src, dest string, opts SyncOptions) (
 }
 
 type syncer struct {
-	opts *cookedSyncOptions
-	srp  *remoteProvider
-	spt  *syncProgressTracker
+	opts       *cookedSyncOptions
+	srp        *remoteProvider
+	spt        *syncProgressTracker
+	inodeStore *common.InodeStore
 }
 
 func newSyncer(ctx context.Context, jobID common.JobID, src, dst string, opts SyncOptions, uotm *common.UserOAuthTokenManager) (s *syncer, err error) {
@@ -234,6 +236,10 @@ func newSyncer(ctx context.Context, jobID common.JobID, src, dst string, opts Sy
 	if err != nil {
 		return nil, err
 	}
+	store, err := common.NewInodeStore(jobID)
+	if err != nil {
+		return nil, fmt.Errorf("failed to initialize inode store: %w", err)
+	}
 	progressTracker := newSyncProgressTracker(jobID, opts.Handler)
-	return &syncer{opts: cookedOpts, srp: syncRemote, spt: progressTracker}, nil
+	return &syncer{opts: cookedOpts, srp: syncRemote, spt: progressTracker, inodeStore: store}, nil
 }