From 6d04217600f2145ee80d5d62231b8ade34f2e5ff Mon Sep 17 00:00:00 2001
From: Dietmar Maurer <dietmar@proxmox.com>
Date: Tue, 25 Sep 2012 09:27:24 +0200
Subject: [PATCH] pass timeout to qmp open_connection

---
 PVE/QMPClient.pm | 8 +++++---
 1 file changed, 5 insertions(+), 3 deletions(-)

diff --git a/PVE/QMPClient.pm b/PVE/QMPClient.pm
index d026f4d4..9829986a 100755
--- a/PVE/QMPClient.pm
+++ b/PVE/QMPClient.pm
@@ -114,10 +114,12 @@ my $close_connection = sub {
 };
 
 my $open_connection = sub {
-    my ($self, $vmid) = @_;
+    my ($self, $vmid, $timeout) = @_;
 
     my $sname = PVE::QemuServer::qmp_socket($vmid);
 
+    $timeout = 1 if !$timeout;
+
     my $fh;
     my $starttime = [gettimeofday];
     my $count = 0;
@@ -129,7 +131,7 @@ my $open_connection = sub {
 	    die "unable to connect to VM $vmid socket - $!\n";
 	}
 	my $elapsed = tv_interval($starttime, [gettimeofday]);
-	if ($elapsed > 1) {
+	if ($elapsed >= $timeout) {
 	    die "unable to connect to VM $vmid socket - timeout after $count retries\n";
 	}
 	usleep(100000);
@@ -204,7 +206,7 @@ sub queue_execute {
 	next if !scalar(@{$self->{queue}->{$vmid}}); # no commands for the VM
 
 	eval {
-	    my $fh = &$open_connection($self, $vmid);
+	    my $fh = &$open_connection($self, $vmid, $timeout);
 	    my $cmd = { execute => 'qmp_capabilities', arguments => {} };
 	    unshift @{$self->{queue}->{$vmid}}, $cmd;
 	    $self->{mux}->set_timeout($fh, $timeout);