From 06b66f31f5479913d42d0fc363050e16e0812877 Mon Sep 17 00:00:00 2001
From: Greg Wilkins <gregw@webtide.com>
Date: Mon, 28 Nov 2011 11:54:08 +1100
Subject: [PATCH] test NIO assumptions

---
 .../org/eclipse/jetty/io/nio/NIOTest.java     | 133 ++++++++++++++++++
 1 file changed, 133 insertions(+)
 create mode 100644 jetty-io/src/test/java/org/eclipse/jetty/io/nio/NIOTest.java

diff --git a/jetty-io/src/test/java/org/eclipse/jetty/io/nio/NIOTest.java b/jetty-io/src/test/java/org/eclipse/jetty/io/nio/NIOTest.java
new file mode 100644
index 00000000000..e62027ffbf5
--- /dev/null
+++ b/jetty-io/src/test/java/org/eclipse/jetty/io/nio/NIOTest.java
@@ -0,0 +1,133 @@
+// ========================================================================
+// Copyright (c) 2004-2009 Mort Bay Consulting Pty. Ltd.
+// ------------------------------------------------------------------------
+// All rights reserved. This program and the accompanying materials
+// are made available under the terms of the Eclipse Public License v1.0
+// and Apache License v2.0 which accompanies this distribution.
+// The Eclipse Public License is available at
+// http://www.eclipse.org/legal/epl-v10.html
+// The Apache License v2.0 is available at
+// http://www.opensource.org/licenses/apache2.0.php
+// You may elect to redistribute this code under either of these licenses.
+// ========================================================================
+
+package org.eclipse.jetty.io.nio;
+
+import static junit.framework.Assert.assertEquals;
+import static junit.framework.Assert.assertFalse;
+import static junit.framework.Assert.assertTrue;
+
+import java.net.ServerSocket;
+import java.net.Socket;
+import java.nio.ByteBuffer;
+import java.nio.channels.SelectionKey;
+import java.nio.channels.Selector;
+import java.nio.channels.SocketChannel;
+
+import junit.framework.Assert;
+
+import org.junit.Test;
+
+/**
+ *
+ */
+public class NIOTest
+{
+    @Test
+    public void testSelector() throws Exception
+    {
+        ServerSocket acceptor = new ServerSocket(0);
+        
+        Selector selector = Selector.open();
+        
+        // Create client server socket pair
+        SocketChannel client = SocketChannel.open(acceptor.getLocalSocketAddress());
+        Socket server = acceptor.accept();
+        server.setTcpNoDelay(true);
+        
+        // Make the client non blocking and register it with selector for reads
+        client.configureBlocking(false);
+        SelectionKey key = client.register(selector,SelectionKey.OP_READ);
+        
+        // assert it is not selected
+        assertTrue(key.isValid());
+        assertFalse(key.isReadable());
+        assertEquals(0,key.readyOps());
+        
+        // try selecting and assert nothing selected
+        int selected = selector.selectNow();
+        assertEquals(0,selected);
+        assertEquals(0,selector.selectedKeys().size());
+        assertTrue(key.isValid());
+        assertFalse(key.isReadable());
+        assertEquals(0,key.readyOps());
+        
+        // Write a byte from server to client
+        server.getOutputStream().write(42);
+        server.getOutputStream().flush();
+        
+        // select again and assert selection found for read
+        selected = selector.selectNow();
+        assertEquals(1,selected);
+        assertEquals(1,selector.selectedKeys().size());
+        assertTrue(key.isValid());
+        assertTrue(key.isReadable());
+        assertEquals(1,key.readyOps());
+
+        // select again and see that it is not reselect, but stays selected
+        selected = selector.selectNow();
+        assertEquals(0,selected);
+        assertEquals(1,selector.selectedKeys().size());
+        assertTrue(key.isValid());
+        assertTrue(key.isReadable());
+        assertEquals(1,key.readyOps());
+        
+        // read the byte
+        ByteBuffer buf = ByteBuffer.allocate(1024);
+        int len=client.read(buf);
+        assertEquals(1,len);
+        buf.flip();
+        assertEquals(42,buf.get());
+        buf.clear();
+        
+        // But this does not change the key
+        assertTrue(key.isValid());
+        assertTrue(key.isReadable());
+        assertEquals(1,key.readyOps());
+        
+        // Even if we select again ?
+        selected = selector.selectNow();
+        assertEquals(0,selected);
+        assertEquals(1,selector.selectedKeys().size());
+        assertTrue(key.isValid());
+        assertTrue(key.isReadable());
+        assertEquals(1,key.readyOps());
+        
+        // Unless we remove the key from the select set
+        // and then it is still flagged as isReadable()
+        selector.selectedKeys().clear();
+        assertEquals(0,selector.selectedKeys().size());
+        assertTrue(key.isValid());
+        assertTrue(key.isReadable());
+        assertEquals(1,key.readyOps());
+        
+        // Now if we select again - it is still flagged as readable!!!
+        selected = selector.selectNow();
+        assertEquals(0,selected);
+        assertEquals(0,selector.selectedKeys().size());
+        assertTrue(key.isValid());
+        assertTrue(key.isReadable());
+        assertEquals(1,key.readyOps());
+        
+        // Only when it is selected for something else does that state change.
+        key.interestOps(SelectionKey.OP_READ|SelectionKey.OP_WRITE);
+        selected = selector.selectNow();
+        assertEquals(1,selected);
+        assertEquals(1,selector.selectedKeys().size());
+        assertTrue(key.isValid());
+        assertTrue(key.isWritable());
+        assertFalse(key.isReadable());
+        assertEquals(SelectionKey.OP_WRITE,key.readyOps());
+    }
+
+}