I2P Address: [http://git.idk.i2p]

Skip to content
Snippets Groups Projects
Unverified Commit 5e6ec442 authored by zzz's avatar zzz
Browse files

SSU2: Fix PacketPusher NPE

parent cdf5bec1
No related branches found
No related tags found
No related merge requests found
...@@ -669,6 +669,7 @@ public class PeerState2 extends PeerState implements SSU2Payload.PayloadCallback ...@@ -669,6 +669,7 @@ public class PeerState2 extends PeerState implements SSU2Payload.PayloadCallback
if (_sessConfForReTX == null) if (_sessConfForReTX == null)
return null; return null;
UDPPacket[] rv = new UDPPacket[_sessConfForReTX.length]; UDPPacket[] rv = new UDPPacket[_sessConfForReTX.length];
InetAddress addr = getRemoteIPAddress();
for (int i = 0; i < rv.length; i++) { for (int i = 0; i < rv.length; i++) {
UDPPacket packet = UDPPacket.acquire(_context, false); UDPPacket packet = UDPPacket.acquire(_context, false);
rv[i] = packet; rv[i] = packet;
...@@ -677,7 +678,7 @@ public class PeerState2 extends PeerState implements SSU2Payload.PayloadCallback ...@@ -677,7 +678,7 @@ public class PeerState2 extends PeerState implements SSU2Payload.PayloadCallback
int off = pkt.getOffset(); int off = pkt.getOffset();
System.arraycopy(_sessConfForReTX[i], 0, data, off, _sessConfForReTX[i].length); System.arraycopy(_sessConfForReTX[i], 0, data, off, _sessConfForReTX[i].length);
pkt.setLength(_sessConfForReTX.length); pkt.setLength(_sessConfForReTX.length);
pkt.setAddress(_remoteIPAddress); pkt.setAddress(addr);
pkt.setPort(_remotePort); pkt.setPort(_remotePort);
packet.setMessageType(PacketBuilder2.TYPE_CONF); packet.setMessageType(PacketBuilder2.TYPE_CONF);
packet.setPriority(PacketBuilder2.PRIORITY_HIGH); packet.setPriority(PacketBuilder2.PRIORITY_HIGH);
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment