Fix jsch client hanging

We need to ask for input stream before connecting because it initializes
the stream.

diff --git a/git-agent/src/jetbrains/buildServer/buildTriggers/vcs/git/agent/JSchClient.java b/git-agent/src/jetbrains/buildServer/buildTriggers/vcs/git/agent/JSchClient.java
index ca32e99bdc3f31656853b1497989e648bfc83553..8304e19f4327c795fe03beb65ed2f17cbe193149 100644 (file)
--- a/git-agent/src/jetbrains/buildServer/buildTriggers/vcs/git/agent/JSchClient.java
+++ b/git-agent/src/jetbrains/buildServer/buildTriggers/vcs/git/agent/JSchClient.java
@@ -29,6 +29,7 @@ import javax.security.auth.callback.Callback;
 import javax.security.auth.callback.CallbackHandler;
 import javax.security.auth.callback.UnsupportedCallbackException;
 import java.io.File;
+import java.io.IOException;
 import java.io.InputStream;
 import java.security.Security;
 import java.text.SimpleDateFormat;
@@ -168,12 +169,16 @@ public class JSchClient {
       channel.setCommand(myCommand);
       channel.setInputStream(System.in);
       channel.setErrStream(System.err);
+      InputStream input = channel.getInputStream();
       channel.connect();
 
-      InputStream input = channel.getInputStream();
+      if (!channel.isConnected()) {
+        throw new IOException("Connection failed");
+      }
+
       byte[] buffer = new byte[BUF_SIZE];
       int count;
-      while ((count = input.read(buffer)) != -1) {
+      while (channel.isConnected() && !channel.isClosed() && (count = input.read(buffer)) != -1) {
         System.out.write(buffer, 0, count);
       }
     } finally {