| FazBrowse GitHub Viewer | Trending | | Home |
| Tools: [Download Repo ZIP] [Original HTTPS Page] |
1 parent 2c4d783 commit 759408e
1 file changed
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
@@ -219,7 +219,15 @@ public void dispose() { | |||
| 219 | 219 | ||
| 220 | 220 | @Override | |
| 221 | 221 | public void run() { | |
| 222 | - byte[] readBuffer = new byte[2048]; // Ethernet MTU = 1500 B | ||
| 222 | + 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 | + } | ||
| 223 | 231 | while (Thread.currentThread() == thread) { | |
| 224 | 232 | try { | |
| 225 | 233 | while (input != null) { | |
| Back | FazBrowse Home | New Git URL |
0 commit comments