# HG changeset patch
# User alanb
# Date 1520406924 0
# Node ID 4affaea00c05ab1bf1d68f7a212a332701cd1a3c
# Parent  ac95c7a7613272af731fbf38aba22a8a2c8b9626
8199015: (se) SocketChannelImpl.translateXXXOps access channel state without synchronization
Reviewed-by: bpb

diff -r ac95c7a76132 -r 4affaea00c05 src/java.base/share/classes/sun/nio/ch/SelChImpl.java
--- a/src/java.base/share/classes/sun/nio/ch/SelChImpl.java	Wed Mar 07 07:13:55 2018 +0000
+++ b/src/java.base/share/classes/sun/nio/ch/SelChImpl.java	Wed Mar 07 07:15:24 2018 +0000
@@ -63,8 +63,6 @@
 
     void translateAndSetInterestOps(int ops, SelectionKeyImpl sk);
 
-    int validOps();
-
     void kill() throws IOException;
 
 }
diff -r ac95c7a76132 -r 4affaea00c05 src/java.base/share/classes/sun/nio/ch/SocketChannelImpl.java
--- a/src/java.base/share/classes/sun/nio/ch/SocketChannelImpl.java	Wed Mar 07 07:13:55 2018 +0000
+++ b/src/java.base/share/classes/sun/nio/ch/SocketChannelImpl.java	Wed Mar 07 07:15:24 2018 +0000
@@ -96,7 +96,7 @@
     private static final int ST_CLOSING = 3;
     private static final int ST_KILLPENDING = 4;
     private static final int ST_KILLED = 5;
-    private int state;
+    private volatile int state;  // need stateLock to change
 
     // IDs of native threads doing reads and writes, for signalling
     private long readerThread;
@@ -574,16 +574,12 @@
 
     @Override
     public boolean isConnected() {
-        synchronized (stateLock) {
-            return (state == ST_CONNECTED);
-        }
+        return (state == ST_CONNECTED);
     }
 
     @Override
     public boolean isConnectionPending() {
-        synchronized (stateLock) {
-            return (state == ST_CONNECTIONPENDING);
-        }
+        return (state == ST_CONNECTIONPENDING);
     }
 
     /**
@@ -604,12 +600,13 @@
         }
         synchronized (stateLock) {
             ensureOpen();
+            int state = this.state;
             if (state == ST_CONNECTED)
                 throw new AlreadyConnectedException();
             if (state == ST_CONNECTIONPENDING)
                 throw new ConnectionPendingException();
             assert state == ST_UNCONNECTED;
-            state = ST_CONNECTIONPENDING;
+            this.state = ST_CONNECTIONPENDING;
 
             if (localAddress == null)
                 NetHooks.beforeTcpConnect(fd, isa.getAddress(), isa.getPort());
@@ -985,20 +982,17 @@
             return (newOps & ~oldOps) != 0;
         }
 
+        boolean connected = isConnected();
         if (((ops & Net.POLLIN) != 0) &&
-            ((intOps & SelectionKey.OP_READ) != 0) &&
-            (state == ST_CONNECTED))
+            ((intOps & SelectionKey.OP_READ) != 0) && connected)
             newOps |= SelectionKey.OP_READ;
 
         if (((ops & Net.POLLCONN) != 0) &&
-            ((intOps & SelectionKey.OP_CONNECT) != 0) &&
-            ((state == ST_UNCONNECTED) || (state == ST_CONNECTIONPENDING))) {
+            ((intOps & SelectionKey.OP_CONNECT) != 0) && isConnectionPending())
             newOps |= SelectionKey.OP_CONNECT;
-        }
 
         if (((ops & Net.POLLOUT) != 0) &&
-            ((intOps & SelectionKey.OP_WRITE) != 0) &&
-            (state == ST_CONNECTED))
+            ((intOps & SelectionKey.OP_WRITE) != 0) && connected)
             newOps |= SelectionKey.OP_WRITE;
 
         sk.nioReadyOps(newOps);