Author: markt
Date: Fri Mar 15 21:08:34 2013
New Revision: 1457118
URL: http://svn.apache.org/r1457118
Log:
Update comment. Make state volatile
Modified:
tomcat/trunk/java/org/apache/tomcat/websocket/WsSession.java
Modified: tomcat/trunk/java/org/apache/tomcat/websocket/WsSession.java
URL:
http://svn.apache.org/viewvc/tomcat/trunk/java/org/apache/tomcat/websocket/WsSession.java?rev=1457118&r1=1457117&r2=1457118&view=diff
==============================================================================
--- tomcat/trunk/java/org/apache/tomcat/websocket/WsSession.java (original)
+++ tomcat/trunk/java/org/apache/tomcat/websocket/WsSession.java Fri Mar 15
21:08:34 2013
@@ -70,7 +70,7 @@ public class WsSession implements Sessio
private MessageHandler textMessageHandler = null;
private MessageHandler binaryMessageHandler = null;
private MessageHandler.Whole<PongMessage> pongMessageHandler = null;
- private State state = State.OPEN;
+ private volatile State state = State.OPEN;
private final Object stateLock = new Object();
private final Map<String,Object> userProperties = new
ConcurrentHashMap<>();
private volatile int maxBinaryMessageBufferSize =
@@ -292,7 +292,7 @@ public class WsSession implements Sessio
@Override
public void close(CloseReason closeReason) throws IOException {
- // Double-checked locking. OK because open is volatile
+ // Double-checked locking. OK because state is volatile
if (state != State.OPEN) {
return;
}
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
