We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent fe465fe commit d887779Copy full SHA for d887779
java/libraries/net/src/processing/net/Client.java
@@ -219,7 +219,15 @@ public void dispose() {
219
220
@Override
221
public void run() {
222
- byte[] readBuffer = new byte[2048]; // Ethernet MTU = 1500 B
+ byte[] readBuffer;
223
+ { // make the read buffer same size as socket receive buffer so that
224
+ // we don't waste cycles calling listeners when there is more data waiting
225
+ int readBufferSize = 2 << 16; // 64 KB (default socket receive buffer size)
226
+ try {
227
+ readBufferSize = socket.getReceiveBufferSize();
228
+ } catch (SocketException ignore) { }
229
+ readBuffer = new byte[readBufferSize];
230
+ }
231
while (Thread.currentThread() == thread) {
232
try {
233
while (input != null) {
0 commit comments