57 lines
		
	
	
	
		
			2.1 KiB
		
	
	
	
		
			Perl
		
	
	
	
	
	
			
		
		
	
	
			57 lines
		
	
	
	
		
			2.1 KiB
		
	
	
	
		
			Perl
		
	
	
	
	
	
| package Nix::CopyClosure;
 | ||
| 
 | ||
| use strict;
 | ||
| use Nix::Config;
 | ||
| use Nix::Store;
 | ||
| use List::Util qw(sum);
 | ||
| 
 | ||
| 
 | ||
| sub copyTo {
 | ||
|     my ($sshHost, $sshOpts, $storePaths, $compressor, $decompressor,
 | ||
|         $includeOutputs, $dryRun, $sign, $progressViewer, $useSubstitutes) = @_;
 | ||
| 
 | ||
|     # Get the closure of this path.
 | ||
|     my @closure = reverse(topoSortPaths(computeFSClosure(0, $includeOutputs,
 | ||
|         map { followLinksToStorePath $_ } @{$storePaths})));
 | ||
| 
 | ||
|     # Optionally use substitutes on the remote host.
 | ||
|     if (!$dryRun && $useSubstitutes) {
 | ||
|         system "ssh $sshHost @{$sshOpts} nix-store -r --ignore-unknown @closure";
 | ||
|         # Ignore exit status because this is just an optimisation.
 | ||
|     }
 | ||
| 
 | ||
|     # Ask the remote host which paths are invalid.  Because of limits
 | ||
|     # to the command line length, do this in chunks.  Eventually,
 | ||
|     # we'll want to use ‘--from-stdin’, but we can't rely on the
 | ||
|     # target having this option yet.
 | ||
|     my @missing = ();
 | ||
|     my $missingSize = 0;
 | ||
|     while (scalar(@closure) > 0) {
 | ||
|         my @ps = splice(@closure, 0, 1500);
 | ||
|         open(READ, "set -f; ssh $sshHost @{$sshOpts} nix-store --check-validity --print-invalid @ps|");
 | ||
|         while (<READ>) {
 | ||
|             chomp;
 | ||
|             push @missing, $_;
 | ||
|             my ($deriver, $narHash, $time, $narSize, $refs) = queryPathInfo($_, 1);
 | ||
|             $missingSize += $narSize;
 | ||
|         }
 | ||
|         close READ or die;
 | ||
|     }
 | ||
| 
 | ||
|     $compressor = "$compressor |" if $compressor ne "";
 | ||
|     $decompressor = "$decompressor |" if $decompressor ne "";
 | ||
|     $progressViewer = "$progressViewer -s $missingSize |" if $progressViewer ne "";
 | ||
| 
 | ||
|     # Export the store paths and import them on the remote machine.
 | ||
|     if (scalar @missing > 0) {
 | ||
|         print STDERR "copying ", scalar @missing, " missing paths to ‘$sshHost’...\n";
 | ||
|         unless ($dryRun) {
 | ||
|             open SSH, "| $progressViewer $compressor ssh $sshHost @{$sshOpts} '$decompressor nix-store --import' > /dev/null" or die;
 | ||
|             exportPaths(fileno(SSH), $sign, @missing);
 | ||
|             close SSH or die "copying store paths to remote machine `$sshHost' failed: $?";
 | ||
|         }
 | ||
|     }
 | ||
| }
 | ||
| 
 | ||
| 
 | ||
| 1;
 |