You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@mina.apache.org by jv...@apache.org on 2009/11/03 09:20:30 UTC
svn commit: r832339 - in
/mina/branches/3.0/core/src/test/java/org/apache/mina: impl/ session/
session/AbstractIoSessionTest.java transport/ transport/socket/
transport/socket/nio/ transport/socket/nio/NioAcceptorTest.java
Author: jvermillard
Date: Tue Nov 3 08:20:29 2009
New Revision: 832339
URL: http://svn.apache.org/viewvc?rev=832339&view=rev
Log: (empty)
Added:
mina/branches/3.0/core/src/test/java/org/apache/mina/session/
- copied from r829717, mina/branches/3.0/core/src/test/java/org/apache/mina/impl/
mina/branches/3.0/core/src/test/java/org/apache/mina/session/AbstractIoSessionTest.java
- copied, changed from r830467, mina/branches/3.0/core/src/test/java/org/apache/mina/impl/AbstractIoSessionTest.java
mina/branches/3.0/core/src/test/java/org/apache/mina/transport/
mina/branches/3.0/core/src/test/java/org/apache/mina/transport/socket/
mina/branches/3.0/core/src/test/java/org/apache/mina/transport/socket/nio/
mina/branches/3.0/core/src/test/java/org/apache/mina/transport/socket/nio/NioAcceptorTest.java (with props)
Removed:
mina/branches/3.0/core/src/test/java/org/apache/mina/impl/
Copied: mina/branches/3.0/core/src/test/java/org/apache/mina/session/AbstractIoSessionTest.java (from r830467, mina/branches/3.0/core/src/test/java/org/apache/mina/impl/AbstractIoSessionTest.java)
URL: http://svn.apache.org/viewvc/mina/branches/3.0/core/src/test/java/org/apache/mina/session/AbstractIoSessionTest.java?p2=mina/branches/3.0/core/src/test/java/org/apache/mina/session/AbstractIoSessionTest.java&p1=mina/branches/3.0/core/src/test/java/org/apache/mina/impl/AbstractIoSessionTest.java&r1=830467&r2=832339&rev=832339&view=diff
==============================================================================
--- mina/branches/3.0/core/src/test/java/org/apache/mina/impl/AbstractIoSessionTest.java (original)
+++ mina/branches/3.0/core/src/test/java/org/apache/mina/session/AbstractIoSessionTest.java Tue Nov 3 08:20:29 2009
@@ -1,94 +1,111 @@
-package org.apache.mina.impl;
+package org.apache.mina.session;
import java.net.SocketAddress;
import junit.framework.Assert;
import org.apache.mina.CloseFuture;
+import org.apache.mina.IoService;
import org.apache.mina.IoSessionConfig;
import org.apache.mina.session.AbstractIoSession;
import org.junit.Test;
public class AbstractIoSessionTest {
+ private final class DummySession extends AbstractIoSession {
+ private DummySession(IoService service) {
+ super(service);
+ }
+
+ @Override
+ public CloseFuture close(boolean immediately) {
+ return null;
+ }
+
+ @Override
+ public IoSessionConfig getConfig() {
+ return null;
+ }
+
+ @Override
+ public SocketAddress getLocalAddress() {
+ return null;
+ }
+
+ @Override
+ public SocketAddress getRemoteAddress() {
+ return null;
+ }
+
+ @Override
+ public boolean isClosing() {
+ return false;
+ }
+
+ @Override
+ public boolean isConnected() {
+ return false;
+ }
+
+ @Override
+ public boolean isReadSuspended() {
+ return false;
+ }
+
+ @Override
+ public boolean isWriteSuspended() {
+ return false;
+ }
+
+ @Override
+ public void resumeRead() {
+ }
+
+ @Override
+ public void resumeWrite() {
+ }
+
+ @Override
+ public void suspendRead() {
+ }
+
+ @Override
+ public void suspendWrite() {
+ }
+ }
+
@Test
public void testGetId() {
- AbstractIoSession aio = new AbstractIoSession(null) {
-
- @Override
- public CloseFuture close(boolean immediately) {
- return null;
- }
-
- @Override
- public IoSessionConfig getConfig() {
- return null;
- }
-
- @Override
- public SocketAddress getLocalAddress() {
- return null;
- }
-
- @Override
- public SocketAddress getRemoteAddress() {
- return null;
- }
-
- @Override
- public boolean isClosing() {
- return false;
- }
-
- @Override
- public boolean isConnected() {
- return false;
- }
-
- @Override
- public boolean isReadSuspended() {
- return false;
- }
-
- @Override
- public boolean isWriteSuspended() {
- return false;
- }
-
- @Override
- public void resumeRead() {
- }
-
- @Override
- public void resumeWrite() {
- }
-
- @Override
- public void suspendRead() {
- }
-
- @Override
- public void suspendWrite() {
- }
-
- };
+ Assert.assertNotSame((new DummySession(null)).getId(), (new DummySession(null)).getId());
- System.out.println("Session Id : "+aio.getId());
+ }
+
+ @Test
+ public void testCreationTime() {
+ long before = System.currentTimeMillis();
+ long creation = (new DummySession(null)).getCreationTime();
+ long after = System.currentTimeMillis();
+ Assert.assertTrue( creation <= after);
+ Assert.assertTrue( creation >= before);
+ }
+
+ @Test
+ public void testAttachment() {
+ AbstractIoSession aio = new DummySession(null);
String value = "value";
- Assert.assertNull( aio.getAttribute("test") );
- Assert.assertEquals(null,aio.setAttribute("test", value));
+ Assert.assertNull(aio.getAttribute("test"));
+ Assert.assertEquals(null, aio.setAttribute("test", value));
Assert.assertTrue(aio.containsAttribute("test"));
Assert.assertEquals(aio.getAttributeNames().size(), 1);
- Assert.assertEquals(value,aio.setAttribute("test", value));
+ Assert.assertEquals(value, aio.setAttribute("test", value));
Assert.assertEquals(aio.getAttributeNames().size(), 1);
Assert.assertTrue(aio.containsAttribute("test"));
- Assert.assertEquals(value,aio.getAttribute("test"));
- Assert.assertEquals(value,aio.removeAttribute("test"));
+ Assert.assertEquals(value, aio.getAttribute("test"));
+ Assert.assertEquals(value, aio.removeAttribute("test"));
Assert.assertEquals(aio.getAttributeNames().size(), 0);
Assert.assertFalse(aio.containsAttribute("test"));
-
+
Assert.assertEquals(null, aio.getAttribute("test"));
-
Assert.assertNull(aio.getService());
}
Added: mina/branches/3.0/core/src/test/java/org/apache/mina/transport/socket/nio/NioAcceptorTest.java
URL: http://svn.apache.org/viewvc/mina/branches/3.0/core/src/test/java/org/apache/mina/transport/socket/nio/NioAcceptorTest.java?rev=832339&view=auto
==============================================================================
--- mina/branches/3.0/core/src/test/java/org/apache/mina/transport/socket/nio/NioAcceptorTest.java (added)
+++ mina/branches/3.0/core/src/test/java/org/apache/mina/transport/socket/nio/NioAcceptorTest.java Tue Nov 3 08:20:29 2009
@@ -0,0 +1,61 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied. See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ *
+ */
+
+package org.apache.mina.transport.socket.nio;
+
+import java.io.IOException;
+import java.net.InetSocketAddress;
+
+import junit.framework.Assert;
+
+import org.junit.Test;
+
+
+/**
+ * A basic Acceptor test
+ * @author <a href="http://mina.apache.org">Apache MINA Project</a>
+ *
+ */
+public class NioAcceptorTest {
+
+ @Test
+ public void acceptorTest() {
+ NioSocketAcceptor acceptor = new NioSocketAcceptor();
+ try {
+ acceptor.bind(new InetSocketAddress(9999));
+ acceptor.unbind(new InetSocketAddress(9999));
+ acceptor.bind(new InetSocketAddress(9999));
+ } catch (IOException e) {
+ e.printStackTrace();
+ Assert.fail();
+ }
+ Exception ex = null;
+ try {
+ // try to bind an already bound port
+ acceptor.bind(new InetSocketAddress(9999));
+ Assert.fail();
+
+ } catch (IOException e) {
+ ex = e;
+ }
+ Assert.assertNotNull(ex);
+
+ }
+}
Propchange: mina/branches/3.0/core/src/test/java/org/apache/mina/transport/socket/nio/NioAcceptorTest.java
------------------------------------------------------------------------------
svn:mime-type = text/plain