diff --git a/server/netty/src/com/riiablo/net/reliable/TestClient.java b/server/netty/src/com/riiablo/net/reliable/TestClient.java index 79762404..e02ebec7 100644 --- a/server/netty/src/com/riiablo/net/reliable/TestClient.java +++ b/server/netty/src/com/riiablo/net/reliable/TestClient.java @@ -61,12 +61,11 @@ public class TestClient extends ApplicationAdapter implements PacketProcessor { ChannelFuture f = b.connect("localhost", TestServer.PORT).sync(); sendPacket(); - f.channel().closeFuture().sync(); } catch (Throwable t) { Gdx.app.error(TAG, t.getMessage(), t); + Gdx.app.exit(); } finally { group.shutdownGracefully(); - Gdx.app.exit(); } } diff --git a/server/netty/src/com/riiablo/net/reliable/TestServer.java b/server/netty/src/com/riiablo/net/reliable/TestServer.java index 5efa4d9e..77ae5944 100644 --- a/server/netty/src/com/riiablo/net/reliable/TestServer.java +++ b/server/netty/src/com/riiablo/net/reliable/TestServer.java @@ -62,12 +62,11 @@ public class TestServer extends ApplicationAdapter implements PacketProcessor { ; ChannelFuture f = b.bind(PORT).sync(); - f.channel().closeFuture().sync(); } catch (Throwable t) { Gdx.app.error(TAG, t.getMessage(), t); + Gdx.app.exit(); } finally { group.shutdownGracefully(); - Gdx.app.exit(); } } diff --git a/server/netty/src/com/riiablo/net/tcp/TestClient.java b/server/netty/src/com/riiablo/net/tcp/TestClient.java index 2e1d7143..7a5c2800 100644 --- a/server/netty/src/com/riiablo/net/tcp/TestClient.java +++ b/server/netty/src/com/riiablo/net/tcp/TestClient.java @@ -63,12 +63,11 @@ public class TestClient extends ApplicationAdapter implements PacketProcessor { ChannelFuture f = b.connect("localhost", TestServer.PORT).sync(); sendPacket(); - f.channel().closeFuture().sync(); } catch (Throwable t) { Gdx.app.error(TAG, t.getMessage(), t); + Gdx.app.exit(); } finally { workerGroup.shutdownGracefully(); - Gdx.app.exit(); } } diff --git a/server/netty/src/com/riiablo/net/tcp/TestServer.java b/server/netty/src/com/riiablo/net/tcp/TestServer.java index f3470cf0..62df357f 100644 --- a/server/netty/src/com/riiablo/net/tcp/TestServer.java +++ b/server/netty/src/com/riiablo/net/tcp/TestServer.java @@ -62,10 +62,10 @@ public class TestServer extends ApplicationAdapter implements PacketProcessor { f.channel().closeFuture().sync(); } catch (Throwable t) { Gdx.app.error(TAG, t.getMessage(), t); + Gdx.app.exit(); } finally { workerGroup.shutdownGracefully(); bossGroup.shutdownGracefully(); - Gdx.app.exit(); } }