fix: ssh transport econnreset (#272)

IBM · Apr 30, 2020 · d5e71c1 · d5e71c1
1 parent 9e72857
commit d5e71c1
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 0 deletions.
diff --git a/lib/transports/sshTransport.js b/lib/transports/sshTransport.js
@@ -34,6 +34,7 @@ function sshCall(config, xmlIn, done) {
       console.log('SSH CLIENT ERROR: ', error);
     }
     client.end();
+    client.destroy();
     done(error, null);
   });
 
@@ -79,6 +80,7 @@ function sshCall(config, xmlIn, done) {
           return;
         }
         client.end();
+        client.destroy();
         done(null, xmlOut);
       });
 

diff --git a/test/functional/checkObjectExists.js b/test/functional/checkObjectExists.js
@@ -31,13 +31,15 @@ function checkObjectExistsSSH(config, object = {}, callback) {
           if (config.verbose) { console.log(`Command exited abnormally with code: ${checkLibCode}`); }
           const libError = new Error(`${lib} lib was not found!\nCreate it by running: ${createLib}`);
           client.end();
+          client.destroy();
           callback(libError, false);
           return;
         }
         client.exec(checkObjectCommand, (checkObjectError, checkObjectStream) => {
           if (config.verbose) { console.log(`executing ${checkObjectCommand}`); }
           if (checkObjectError) {
             client.end();
+            client.destroy();
             callback(checkLibError, false);
             return;
           }
@@ -47,12 +49,14 @@ function checkObjectExistsSSH(config, object = {}, callback) {
           checkObjectStream.on('exit', (checkObjectCode) => {
             if (checkObjectCode !== 0) {
               client.end();
+              client.destroy();
               console.log(`Command exited abnormally with code: ${checkObjectCode}`);
               const objectError = new Error(`${object.name} was not found!\nCreate it by running: ${object.createObject}`);
               callback(objectError);
               return;
             }
             client.end();
+            client.destroy();
             callback(null, true);
           });
         });