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

SSU: Increase socket buffer size (ticket #2781)

Browse Source
This commit is contained in:
zzz
2020-10-21 12:44:27 +00:00
parent 0ace93cec7
commit 9ae5cbbc87
1 changed files with 9 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

9
router/java/src/net/i2p/router/transport/udp/UDPEndpoint.java
View File

@ -11,6 +11,7 @@ import java.util.concurrent.atomic.AtomicInteger;
import net.i2p.router.RouterContext; import net.i2p.router.RouterContext;
import net.i2p.router.transport.TransportUtil; import net.i2p.router.transport.TransportUtil;
import net.i2p.util.Log; import net.i2p.util.Log;
import net.i2p.util.SystemVersion;
/** /**
* Coordinate the low-level datagram socket, creating and managing the UDPSender and * Coordinate the low-level datagram socket, creating and managing the UDPSender and
@ -28,6 +29,8 @@ class UDPEndpoint implements SocketListener {
private final boolean _isIPv4, _isIPv6; private final boolean _isIPv4, _isIPv6;
private static final AtomicInteger _counter = new AtomicInteger(); private static final AtomicInteger _counter = new AtomicInteger();
private static final int MIN_SOCKET_BUFFER = 256*1024;
/** /**
* @param transport may be null for unit testing ONLY * @param transport may be null for unit testing ONLY
* @param listenPort -1 or the requested port, may not be honored * @param listenPort -1 or the requested port, may not be honored
@ -124,6 +127,12 @@ class UDPEndpoint implements SocketListener {
socket = new DatagramSocket(port); socket = new DatagramSocket(port);
else else
socket = new DatagramSocket(port, _bindAddress); socket = new DatagramSocket(port, _bindAddress);
if (!SystemVersion.isAndroid()) {
if (socket.getSendBufferSize() < MIN_SOCKET_BUFFER)
socket.setSendBufferSize(MIN_SOCKET_BUFFER);
if (socket.getReceiveBufferSize() < MIN_SOCKET_BUFFER)
socket.setReceiveBufferSize(MIN_SOCKET_BUFFER);
}
break; break;
} catch (SocketException se) { } catch (SocketException se) {
if (_log.shouldLog(Log.WARN)) if (_log.shouldLog(Log.WARN))