Removed legacy code that wasn't being used.

[openflowjava.git] / third-party / openflow-codec / src / test / java / org / openflow / codec / io / OFMessageAsyncStreamTest.java

diff --git a/third-party/openflow-codec/src/test/java/org/openflow/codec/io/OFMessageAsyncStreamTest.java b/third-party/openflow-codec/src/test/java/org/openflow/codec/io/OFMessageAsyncStreamTest.java
deleted file mode 100644 (file)
index bea7f2c..0000000
--- a/third-party/openflow-codec/src/test/java/org/openflow/codec/io/OFMessageAsyncStreamTest.java
+++ /dev/null
@@ -1,75 +0,0 @@
-package org.openflow.codec.io;
-
-import org.openflow.codec.io.OFMessageAsyncStream;
-import org.openflow.codec.protocol.*;
-import org.openflow.codec.protocol.factory.OFPBasicFactoryImpl;
-
-import java.util.*;
-import java.nio.channels.*;
-import java.net.InetSocketAddress;
-
-import org.junit.Assert;
-
-import org.junit.Test;
-
-/**
- * @author Rob Sherwood (rob.sherwood@stanford.edu)
- *
- */
-public class OFMessageAsyncStreamTest
-{
-       @Test
-       public void testMarshalling() throws Exception
-       {
-               OFPMessage h = new OFPHello();
-
-               ServerSocketChannel serverSC = ServerSocketChannel.open();
-               serverSC.socket().bind(new java.net.InetSocketAddress(0));
-               serverSC.configureBlocking(false);
-
-               SocketChannel client = SocketChannel.open(new InetSocketAddress(
-                               "localhost", serverSC.socket().getLocalPort()));
-               SocketChannel server = null;
-               int i = 0;
-               // added to make sure server connection in at most 5 attempts
-               while (i < 5)
-               {
-                       server = serverSC.accept();
-                       if (null != server)
-                       {
-                               break;
-                       }
-                       Thread.sleep(100);
-                       i++;
-               }
-               // added checks, to be on safer side
-               if (null == client || null == server)
-               {
-                       /*
-                        * if either client or server is null, no connection can be made. No
-                        * point of continuing with null client or server, because it will
-                        * result in null exception. So we can pass the test and return.
-                        */
-                       Assert.assertTrue(true);
-                       return;
-               }
-
-               OFMessageAsyncStream clientStream = new OFMessageAsyncStream(client,
-                               new OFPBasicFactoryImpl());
-               OFMessageAsyncStream serverStream = new OFMessageAsyncStream(server,
-                               new OFPBasicFactoryImpl());
-
-               clientStream.write(h);
-               while (clientStream.needsFlush())
-               {
-                       clientStream.flush();
-               }
-               List<OFPMessage> l = serverStream.read();
-               Assert.assertEquals(l.size(), 1);
-               OFPMessage m = l.get(0);
-               Assert.assertEquals(m.getLength(), h.getLength());
-               Assert.assertEquals(m.getVersion(), h.getVersion());
-               Assert.assertEquals(m.getType(), h.getType());
-               Assert.assertEquals(m.getType(), h.getType());
-       }
-}