diff --git a/router/java/src/net/i2p/router/transport/udp/OutboundEstablishState.java b/router/java/src/net/i2p/router/transport/udp/OutboundEstablishState.java index b50f60da0dffc3e2c211935e9654a12c0b3ef612..7919d534f9a3e37f6a9b180bdd8385be2d361625 100644 --- a/router/java/src/net/i2p/router/transport/udp/OutboundEstablishState.java +++ b/router/java/src/net/i2p/router/transport/udp/OutboundEstablishState.java @@ -257,6 +257,9 @@ class OutboundEstablishState { if (m.getType() == DatabaseStoreMessage.MESSAGE_TYPE) { DatabaseStoreMessage dsm = (DatabaseStoreMessage) m; if (dsm.getKey().equals(_context.routerHash())) { + // version 2 sends our RI in handshake + if (getVersion() > 1) + return; _isFirstMessageOurDSM = true; } } @@ -609,8 +612,8 @@ class OutboundEstablishState { } _confirmedSentCount++; _nextSend = _lastSend + delay; - if (_log.shouldLog(Log.DEBUG)) - _log.debug("Send confirm packets, nextSend in " + delay); + if (_log.shouldDebug()) + _log.debug("Send confirm packets, nextSend in " + delay + " on " + this); if (_currentState == OutboundState.OB_STATE_UNKNOWN || _currentState == OutboundState.OB_STATE_PENDING_INTRO || _currentState == OutboundState.OB_STATE_INTRODUCED ||