Author: markt
Date: Wed Oct 9 09:41:31 2013
New Revision: 1530545
URL: http://svn.apache.org/r1530545
Log:
Use the constant for the buffer sizes (makes it easier to experiment with
performance impacts of different buffer sizes)
Modified:
tomcat/trunk/java/org/apache/tomcat/websocket/WsRemoteEndpointImplBase.java
Modified:
tomcat/trunk/java/org/apache/tomcat/websocket/WsRemoteEndpointImplBase.java
URL:
http://svn.apache.org/viewvc/tomcat/trunk/java/org/apache/tomcat/websocket/WsRemoteEndpointImplBase.java?rev=1530545&r1=1530544&r2=1530545&view=diff
==============================================================================
--- tomcat/trunk/java/org/apache/tomcat/websocket/WsRemoteEndpointImplBase.java
(original)
+++ tomcat/trunk/java/org/apache/tomcat/websocket/WsRemoteEndpointImplBase.java
Wed Oct 9 09:41:31 2013
@@ -73,9 +73,9 @@ public abstract class WsRemoteEndpointIm
// Max size of WebSocket header is 14 bytes
private final ByteBuffer headerBuffer = ByteBuffer.allocate(14);
- private final ByteBuffer outputBuffer = ByteBuffer.allocate(8192);
+ private final ByteBuffer outputBuffer =
ByteBuffer.allocate(Constants.DEFAULT_BUFFER_SIZE);
private final CharsetEncoder encoder = new Utf8Encoder();
- private final ByteBuffer encoderBuffer = ByteBuffer.allocate(8192);
+ private final ByteBuffer encoderBuffer =
ByteBuffer.allocate(Constants.DEFAULT_BUFFER_SIZE);
private final AtomicBoolean batchingAllowed = new AtomicBoolean(false);
private volatile long sendTimeout = -1;
private WsSession wsSession;
@@ -743,7 +743,7 @@ public abstract class WsRemoteEndpointIm
private static class WsOutputStream extends OutputStream {
private final WsRemoteEndpointImplBase endpoint;
- private final ByteBuffer buffer = ByteBuffer.allocate(8192);
+ private final ByteBuffer buffer =
ByteBuffer.allocate(Constants.DEFAULT_BUFFER_SIZE);
private final Object closeLock = new Object();
private volatile boolean closed = false;
@@ -826,7 +826,7 @@ public abstract class WsRemoteEndpointIm
private static class WsWriter extends Writer {
private final WsRemoteEndpointImplBase endpoint;
- private final CharBuffer buffer = CharBuffer.allocate(8192);
+ private final CharBuffer buffer =
CharBuffer.allocate(Constants.DEFAULT_BUFFER_SIZE);
private final Object closeLock = new Object();
private volatile boolean closed = false;
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
