From e98b651676eb7a2cd893ac996433365ac5b38ac9 Mon Sep 17 00:00:00 2001
From: Anton Tananaev <anton.tananaev@gmail.com>
Date: Fri, 23 Oct 2015 14:56:25 +1300
Subject: Remove channel closing test

---
 test/org/traccar/ChannelClosingTest.java     | 122 ---------------------------
 test/org/traccar/helper/DateBuilderTest.java |   2 +-
 2 files changed, 1 insertion(+), 123 deletions(-)
 delete mode 100644 test/org/traccar/ChannelClosingTest.java

(limited to 'test')

diff --git a/test/org/traccar/ChannelClosingTest.java b/test/org/traccar/ChannelClosingTest.java
deleted file mode 100644
index 0b138235f..000000000
--- a/test/org/traccar/ChannelClosingTest.java
+++ /dev/null
@@ -1,122 +0,0 @@
-package org.traccar;
-
-import org.jboss.netty.bootstrap.ConnectionlessBootstrap;
-import org.jboss.netty.bootstrap.ServerBootstrap;
-import org.jboss.netty.channel.*;
-import org.junit.Assert;
-import org.junit.BeforeClass;
-import org.junit.Test;
-import org.traccar.database.IdentityManager;
-import org.traccar.helper.ChannelBufferTools;
-import org.traccar.model.Device;
-import org.traccar.protocol.GatorProtocol;
-import org.traccar.protocol.GatorProtocolDecoder;
-
-import java.net.*;
-import java.util.concurrent.CyclicBarrier;
-
-public class ChannelClosingTest {
-
-    @BeforeClass
-    public static void init() {
-        Context.init(new IdentityManager() {
-
-            private Device createDevice() {
-                return null;
-            }
-
-            @Override
-            public Device getDeviceById(long id) {
-                return createDevice();
-            }
-
-            @Override
-            public Device getDeviceByUniqueId(String imei) {
-                return createDevice();
-            }
-
-        });
-    }
-
-    static class ExceptionWaiter implements ChannelUpstreamHandler {
-        final CyclicBarrier barrier = new CyclicBarrier(2);
-        Channel channel;
-
-        @Override
-        public void handleUpstream(ChannelHandlerContext ctx, ChannelEvent e) throws Exception {
-            ctx.sendUpstream(e);
-            if (e instanceof ExceptionEvent) {
-                channel = e.getChannel();
-                barrier.await();
-            }
-        }
-
-        void waitFor() throws Exception {
-            barrier.await();
-        }
-
-        Channel channel() {
-            return channel;
-        }
-    }
-
-    @Test
-    public void testUDP() throws Exception {
-        final ExceptionWaiter exception = new ExceptionWaiter();
-
-        TrackerServer udpServer = new TrackerServer(new ConnectionlessBootstrap(), "gator") {
-            @Override
-            protected void addSpecificHandlers(ChannelPipeline pipeline) {
-                pipeline.addLast("objectDecoder", new GatorProtocolDecoder(new GatorProtocol()));
-                pipeline.addLast("exceptionWaiter", exception);
-            }
-        };
-        final int PORT = 50522;
-        udpServer.setPort(PORT);
-        try {
-            udpServer.start();
-            Assert.assertFalse(udpServer.getChannelGroup().isEmpty());
-            try (DatagramSocket socket = new DatagramSocket()) {
-                socket.connect(InetAddress.getLocalHost(), PORT);
-                byte[] data = ChannelBufferTools.convertHexString("242400");
-                socket.send(new DatagramPacket(data, data.length));
-            }
-            exception.waitFor();
-            Assert.assertFalse(udpServer.getChannelGroup().isEmpty());
-            Assert.assertTrue(exception.channel().isBound());
-            Assert.assertTrue(exception.channel().isOpen());
-        } finally {
-            udpServer.stop();
-        }
-    }
-
-    @Test
-    public void testTCP() throws Exception {
-        final ExceptionWaiter exception = new ExceptionWaiter();
-        TrackerServer tcpServer = new TrackerServer(new ServerBootstrap(), "gator") {
-            @Override
-            protected void addSpecificHandlers(ChannelPipeline pipeline) {
-                pipeline.addLast("objectDecoder", new GatorProtocolDecoder(new GatorProtocol()));
-                pipeline.addLast("exceptionWaiter", exception);
-            }
-        };
-        final int PORT = 50522;
-        tcpServer.setPort(PORT);
-        try {
-            tcpServer.start();
-            try (Socket socket = new Socket()) {
-                socket.connect(new InetSocketAddress(InetAddress.getLocalHost(), PORT));
-
-                byte[] data = ChannelBufferTools.convertHexString("242400");
-                socket.getOutputStream().write(data);
-
-                exception.waitFor();
-                Assert.assertFalse(exception.channel().isBound());
-                Assert.assertFalse(exception.channel().isOpen());
-                Assert.assertFalse(exception.channel().isConnected());
-            }
-        } finally {
-            tcpServer.stop();
-        }
-    }
-}
diff --git a/test/org/traccar/helper/DateBuilderTest.java b/test/org/traccar/helper/DateBuilderTest.java
index 8e474e059..74936208b 100644
--- a/test/org/traccar/helper/DateBuilderTest.java
+++ b/test/org/traccar/helper/DateBuilderTest.java
@@ -17,7 +17,7 @@ public class DateBuilderTest {
         dateFormat.setTimeZone(TimeZone.getTimeZone("UTC"));
 
         DateBuilder dateBuilder = new DateBuilder()
-                .setDate(2015, 10, 20).setTime(01, 21, 11);
+                .setDate(2015, 10, 20).setTime(1, 21, 11);
 
         Assert.assertEquals(dateFormat.parse("2015-10-20 01:21:11"), dateBuilder.getDate());
 
-- 
cgit v1.2.3