From: Thomas Lamprecht <t.lamprecht@proxmox.com>
Date: Thu, 3 Aug 2017 15:11:18 +0000 (+0200)
Subject: pvecm mtunnel: factor out run command
X-Git-Url: https://git.proxmox.com/?p=pve-cluster.git;a=commitdiff_plain;h=48178573ca55460bc5b2bd81c774fbe6cfb11755

pvecm mtunnel: factor out run command

Signed-off-by: Thomas Lamprecht <t.lamprecht@proxmox.com>
---

diff --git a/data/PVE/CLI/pvecm.pm b/data/PVE/CLI/pvecm.pm
index 799665a..7ca98f7 100755
--- a/data/PVE/CLI/pvecm.pm
+++ b/data/PVE/CLI/pvecm.pm
@@ -864,50 +864,7 @@ __PACKAGE__->register_method ({
 	    }
 	    my $port = PVE::Tools::next_migrate_port($family, $ip);
 
-	    # Wait for a client
-	    my $socket = IO::Socket::IP->new(
-		Listen => 1,
-		ReuseAddr => 1,
-		Family => $family,
-		Proto => &Socket::IPPROTO_TCP,
-		GetAddrInfoFlags => 0,
-		LocalAddr => $ip,
-		LocalPort => $port,
-	    ) or die "failed to open socket: $!\n";
-	    print "$ip\n$port\n";
-	    *STDOUT->flush();
-	    alarm 0;
-	    local $SIG{ALRM} = sub { die "timed out waiting for client\n" };
-	    alarm 30;
-	    my $client = $socket->accept;
-	    alarm 0;
-	    close($socket);
-
-	    # We want that the command talks over the TCP socket and takes
-	    # ownership of it, so that when it closes it the connection is
-	    # terminated, so we need to be able to close the socket. So we
-	    # can't really use PVE::Tools::run_command().
-	    my $pid = fork();
-	    die "fork failed: $!\n" if !defined($pid);
-	    if (!$pid) {
-		POSIX::dup2(fileno($client), 0);
-		POSIX::dup2(fileno($client), 1);
-		close($client);
-		exec {$cmd->[0]} @$cmd or do {
-		    warn "exec failed: $!\n";
-		    POSIX::_exit(1);
-		};
-	    }
-	    close($client);
-	    if (waitpid($pid, 0) != $pid) {
-		kill(9 => $pid);
-		1 while waitpid($pid, 0) != $pid;
-	    }
-	    if (my $sig = ($? & 127)) {
-		die "got signal $sig\n";
-	    } elsif (my $exitcode = ($? >> 8)) {
-		die "exit code $exitcode\n";
-	    }
+	    PVE::Tools::pipe_socket_to_command($cmd, $ip, $port);
 	    return undef;
 	}