From 29a58cb0301ac404de74d4fe23f9a2c97d65aba5 Mon Sep 17 00:00:00 2001
From: zzz <zzz@mail.i2p>
Date: Wed, 22 Apr 2009 18:53:57 +0000
Subject: [PATCH] * NTCP: Hopefully prevent this:   
 java.lang.IllegalStateException: Unable to serialize the message
 (net.i2p.data.i2np.DatabaseStoreMessage): Invalid key type 	at
 net.i2p.data.i2np.I2NPMessageImpl.toByteArray(I2NPMessageImpl.java:238) 
 at
 net.i2p.router.transport.ntcp.NTCPConnection.bufferedPrepare(NTCPConnection.java:668)
 	at
 net.i2p.router.transport.ntcp.NTCPConnection.send(NTCPConnection.java:295) 
 at
 net.i2p.router.transport.ntcp.NTCPConnection.enqueueFloodfillMessage(NTCPConnection.java:412)
 	at
 net.i2p.router.transport.ntcp.NTCPConnection.enqueueInfoMessage(NTCPConnection.java:373)
 	at
 net.i2p.router.transport.ntcp.NTCPTransport.outboundMessageReady(NTCPTransport.java:179)
 	at net.i2p.router.transport.TransportImpl.send(TransportImpl.java:339)
       ...

---
 .../java/src/net/i2p/router/transport/ntcp/NTCPConnection.java  | 2 ++
 1 file changed, 2 insertions(+)

diff --git a/router/java/src/net/i2p/router/transport/ntcp/NTCPConnection.java b/router/java/src/net/i2p/router/transport/ntcp/NTCPConnection.java
index 95152c6a07..3acabafdc4 100644
--- a/router/java/src/net/i2p/router/transport/ntcp/NTCPConnection.java
+++ b/router/java/src/net/i2p/router/transport/ntcp/NTCPConnection.java
@@ -398,6 +398,8 @@ public class NTCPConnection implements FIFOBandwidthLimiter.CompleteListener {
                 continue;
             
             RouterInfo info = fac.lookupRouterInfoLocally(peer);
+            if (info == null)
+                continue;
 
             OutNetMessage infoMsg = new OutNetMessage(_context);
             infoMsg.setExpiration(_context.clock().now()+10*1000);
-- 
GitLab