wbtiger
/
foundationdb
mirror of https://github.com/apple/foundationdb.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

fix: do not increase numIncompatibleConnections if the connect was already incompatible

This commit is contained in:
Evan Tschannen 2018-07-28 08:50:54 -07:00
parent 7552a07997
commit fa3b61508c
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
fdbrpc/FlowTransport.actor.cpp
View File

@ -674,7 +674,7 @@ ACTOR static Future<Void> connectionReader(
TraceEvent("ConnectedOutgoing").detail("PeerAddr", NetworkAddress( p->canonicalRemoteIp, p->canonicalRemotePort ) ).suppressFor(1.0);
peer->compatible = compatible;
peer->incompatibleProtocolVersionNewer = incompatibleProtocolVersionNewer;
if (!compatible)
if (initiallyCompatible && !compatible)
peer->transport->numIncompatibleConnections++;
ASSERT( p->canonicalRemotePort == peerAddress.port );
} else {
@ -684,7 +684,7 @@ ACTOR static Future<Void> connectionReader(
peer = transport->getPeer(peerAddress);
peer->compatible = compatible;
peer->incompatibleProtocolVersionNewer = incompatibleProtocolVersionNewer;
if (!compatible)
if (initiallyCompatible && !compatible)
peer->transport->numIncompatibleConnections++;
onConnected.send( peer );
Void _ = wait( delay(0) ); // Check for cancellation