svn commit: r1530545 - /tomcat/trunk/java/org/apache/tomcat/websocket/WsRemoteEndpointImplBase.java

[markt]

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: dev-unsubscr...@tomcat.apache.org
For additional commands, e-mail: dev-h...@tomcat.apache.org