diff --git a/router/java/src/net/i2p/router/peermanager/ProfileManagerImpl.java b/router/java/src/net/i2p/router/peermanager/ProfileManagerImpl.java index 056cef70d..1d4a39cb4 100644 --- a/router/java/src/net/i2p/router/peermanager/ProfileManagerImpl.java +++ b/router/java/src/net/i2p/router/peermanager/ProfileManagerImpl.java @@ -43,7 +43,8 @@ public class ProfileManagerImpl implements ProfileManager { * Non-blocking. Will not update the profile if we can't get the lock. */ public void messageFailed(Hash peer, String transport) { - PeerProfile data = getProfileNonblocking(peer); + // do not create profile if it didn't exist + PeerProfile data = _context.profileOrganizer().getProfileNonblocking(peer); if (data == null) return; data.setLastSendFailed(_context.clock().now()); } @@ -53,7 +54,8 @@ public class ProfileManagerImpl implements ProfileManager { * Non-blocking. Will not update the profile if we can't get the lock. */ public void messageFailed(Hash peer) { - PeerProfile data = getProfileNonblocking(peer); + // do not create profile if it didn't exist + PeerProfile data = _context.profileOrganizer().getProfileNonblocking(peer); if (data == null) return; data.setLastSendFailed(_context.clock().now()); } @@ -61,7 +63,9 @@ public class ProfileManagerImpl implements ProfileManager { /** * Note that there was some sort of communication error talking with the peer * + * @deprecated unused */ + @Deprecated public void commErrorOccurred(Hash peer) { if (_log.shouldLog(Log.INFO)) _log.info("Comm error occurred for peer " + peer.toBase64(), new Exception("Comm error")); @@ -200,7 +204,8 @@ public class ProfileManagerImpl implements ProfileManager { * Non-blocking. Will not update the profile if we can't get the lock. */ public void dbLookupFailed(Hash peer) { - PeerProfile data = getProfileNonblocking(peer); + // do not create profile if it didn't exist + PeerProfile data = _context.profileOrganizer().getProfileNonblocking(peer); if (data == null) return; if (!data.getIsExpandedDB()) data.expandDBProfile();