idk/i2p.i2p
1
0
Fork 0
forked from I2P_Developers/i2p.i2p
Code Issues 2 Pull Requests Actions 2 Packages Projects Releases Wiki Activity

NTCP: Avoid Java 8/9 bootclasspath issue

Browse Source
This commit is contained in:
zzz
2019-01-10 14:17:18 +00:00
parent 0d330caf9a
commit e02a0dfc5b
1 changed files with 3 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
router/java/src/net/i2p/router/transport/ntcp/EventPumper.java
View File

@@ -5,6 +5,7 @@ import java.net.InetAddress;
import java.net.Inet6Address; import java.net.Inet6Address;
import java.net.InetSocketAddress; import java.net.InetSocketAddress;
import java.nio.ByteBuffer; import java.nio.ByteBuffer;
import java.nio.Buffer;
import java.nio.channels.CancelledKeyException; import java.nio.channels.CancelledKeyException;
import java.nio.channels.ClosedChannelException; import java.nio.channels.ClosedChannelException;
import java.nio.channels.ClosedSelectorException; import java.nio.channels.ClosedSelectorException;
@@ -650,7 +651,8 @@ class EventPumper implements Runnable {
// go around again if we filled the buffer (so we can read more) // go around again if we filled the buffer (so we can read more)
boolean keepReading = !buf.hasRemaining(); boolean keepReading = !buf.hasRemaining();
// ZERO COPY. The buffer will be returned in Reader.processRead() // ZERO COPY. The buffer will be returned in Reader.processRead()
buf.flip(); // not ByteBuffer to avoid Java 8/9 issues with flip()
((Buffer)buf).flip();
FIFOBandwidthLimiter.Request req = _context.bandwidthLimiter().requestInbound(read, "NTCP read"); //con, buf); FIFOBandwidthLimiter.Request req = _context.bandwidthLimiter().requestInbound(read, "NTCP read"); //con, buf);
if (req.getPendingRequested() > 0) { if (req.getPendingRequested() > 0) {
// rare since we generally don't throttle inbound // rare since we generally don't throttle inbound