TW-53436 fix one more hanging

Continue read data even if channel is closed. Remote side can close it
when all data were send, but not yet read by us.

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 cdb92adf5a705a0cdca23dd3b39b47effd2e5f9e..3fffd9bd61518de598610bc845bb7f69409571e4 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
@@ -181,7 +181,7 @@ public class JSchClient {
         throw new IOException("Connection failed");
       }
 
-      Copy copyThread = new Copy(channel, input);
+      Copy copyThread = new Copy(input);
       if (timeoutSeconds != null) {
         new Timer(copyThread, timeoutSeconds * 1000).start();
       }
@@ -246,12 +246,10 @@ public class JSchClient {
 
 
   private class Copy extends Thread {
-    private final ChannelExec myChannel;
     private final InputStream myInput;
     private final AtomicLong myTimestamp = new AtomicLong(System.nanoTime());
     private volatile Exception myError;
-    Copy(@NotNull ChannelExec channel, @NotNull InputStream input) {
-      myChannel = channel;
+    Copy(@NotNull InputStream input) {
       myInput = input;
       setName("Copy");
     }
@@ -261,7 +259,7 @@ public class JSchClient {
       byte[] buffer = new byte[BUF_SIZE];
       int count;
       try {
-        while (myChannel.isConnected() && !myChannel.isClosed() && (count = myInput.read(buffer)) != -1) {
+        while ((count = myInput.read(buffer)) != -1) {
           System.out.write(buffer, 0, count);
           myTimestamp.set(System.nanoTime());
           if (System.out.checkError()) {