FABN-1058 NodeSDK handler close peer

Have the handler close the peer connection on error. Change-Id: Ic43a2e16ad3e4ad792fb61b954fa121c39a445b4 Signed-off-by: Bret Harrison <beharrison@nc.rr.com>
hyperledger · Dec 15, 2018 · 866f023 · 866f023
1 parent 284ff10
commit 866f023
Show file tree

Hide file tree

Showing 3 changed files with 13 additions and 0 deletions.
diff --git a/fabric-client/lib/Channel.js b/fabric-client/lib/Channel.js
@@ -1258,6 +1258,13 @@ const Channel = class {
 				return results;
 			}
 		} else {
+			if (response instanceof Error) {
+				if (response.connectFailed) {
+					logger.error(' Unable to get discovery results from peer %s', target_peer.getUrl());
+					// close this peer down so that next time a new connection will be used
+					target_peer.close();
+				}
+			}
 			throw new Error('Discovery has failed to return results');
 		}
 	}

diff --git a/fabric-client/lib/impl/DiscoveryEndorsementHandler.js b/fabric-client/lib/impl/DiscoveryEndorsementHandler.js
@@ -279,6 +279,7 @@ class DiscoveryEndorsementHandler extends api.EndorsementHandler {
 								error = new Error(caught_error.toString());
 								// if this peer failed to connect then close it
 								if (error.connectFailed) {
+									logger.warn('%s - connect fail to peer - %s', peer.getUrl());
 									peer.close();
 								}
 							} else {

diff --git a/test/unit/remote.js b/test/unit/remote.js
@@ -156,6 +156,11 @@ test('\n\n ** Remote node tests **\n\n', async (t) => {
 	} catch (error) {
 		if (error.toString().includes(peer.getUrl())) {
 			t.pass('Successfully got the waitForReady URL address error');
+			if (error.connectFailed) {
+				t.pass('Successfully got the connection failed set in the error');
+			} else {
+				t.fail('Failed to get the connection failed set in the error');
+			}
 		} else {
 			t.fail('Failed to get the waitForReady URL address error');
 		}