From cbb4a1942cd00edc77dbc2c4f93858104576d0d5 Mon Sep 17 00:00:00 2001 From: nathan Date: Mon, 20 Jul 2015 14:18:34 +0200 Subject: [PATCH] Updated Netty, passes all unit tests --- Dorkbox-Network/.classpath | 7 +- Dorkbox-Network/Dorkbox-Network.iml | 7 +- .../src/dorkbox/network/Broadcast.java | 2 +- .../src/dorkbox/network/Client.java | 167 +- ...nectionOptions.java => Configuration.java} | 38 +- .../src/dorkbox/network/Server.java | 213 +-- .../network/connection/Connection.java | 79 +- .../network/connection/ConnectionImpl.java | 461 ++++-- .../network/connection/ConnectionManager.java | 234 +-- .../dorkbox/network/connection/EndPoint.java | 438 +++--- .../network/connection/EndPointClient.java | 96 +- .../network/connection/EndPointServer.java | 26 +- .../KryoCryptoSerializationManager.java} | 1366 +++++++++-------- .../dorkbox/network/connection/KryoExtra.java | 167 ++ .../network/connection/PropertyStore.java | 208 +-- .../connection/RegisterRmiSystemListener.java | 16 + .../connection/RegistrationWrapper.java | 126 +- .../network/connection/idle/IdleBridge.java | 9 +- .../network/connection/idle/IdleSender.java | 41 +- .../local/RegistrationLocalHandler.java | 28 +- .../local/RegistrationLocalHandlerClient.java | 28 +- .../local/RegistrationLocalHandlerServer.java | 57 +- .../remote/RegistrationRemoteHandler.java | 205 +-- .../RegistrationRemoteHandlerClient.java | 4 +- .../RegistrationRemoteHandlerClientTCP.java | 112 +- .../RegistrationRemoteHandlerClientUDP.java | 4 +- .../RegistrationRemoteHandlerClientUDT.java | 4 +- .../RegistrationRemoteHandlerServer.java | 33 +- .../RegistrationRemoteHandlerServerTCP.java | 114 +- .../RegistrationRemoteHandlerServerUDP.java | 34 +- .../RegistrationRemoteHandlerServerUDT.java | 4 +- .../network/pipeline/ByteBufInput.java | 416 +++-- .../dorkbox/network/pipeline/KryoDecoder.java | 16 +- .../network/pipeline/KryoDecoderCrypto.java | 6 +- .../dorkbox/network/pipeline/KryoEncoder.java | 8 +- .../network/pipeline/KryoEncoderCrypto.java | 6 +- .../network/pipeline/udp/KryoDecoderUdp.java | 18 +- .../pipeline/udp/KryoDecoderUdpCrypto.java | 25 +- .../network/pipeline/udp/KryoEncoderUdp.java | 36 +- .../pipeline/udp/KryoEncoderUdpCrypto.java | 18 +- .../dorkbox/network/rmi/AsmCachedMethod.java | 9 +- .../src/dorkbox/network/rmi/CachedMethod.java | 13 +- .../src/dorkbox/network/rmi/InvokeMethod.java | 1 + .../network/rmi/InvokeMethodSerializer.java | 6 +- .../network/rmi/RemoteInvocationHandler.java | 19 +- .../network/rmi/RemoteObjectSerializer.java | 20 +- .../src/dorkbox/network/rmi/RemoteProxy.java | 14 + .../src/dorkbox/network/rmi/Rmi.java | 22 - .../src/dorkbox/network/rmi/RmiBridge.java | 454 ++---- .../rmi/RmiRegisterClassesCallback.java | 7 - .../dorkbox/network/rmi/RmiRegistration.java | 28 + .../network/rmi/SerializerRegistration.java | 7 - .../util/BinaryListReferenceResolver.java | 201 --- ...r.java => CryptoSerializationManager.java} | 4 +- .../{EndpointTool.java => EndPointTool.java} | 2 +- .../NullConnectionSerializationManager.java | 110 -- .../network/util/RMISerializationManager.java | 35 +- .../test/dorkbox/network/BaseTest.java | 64 +- ...DataTest.java => ChunkedDataIdleTest.java} | 59 +- .../test/dorkbox/network/ClientSendTest.java | 21 +- .../test/dorkbox/network/ConnectionTest.java | 96 +- .../dorkbox/network/DiscoverHostTest.java | 12 +- .../test/dorkbox/network/IdleTest.java | 88 +- .../test/dorkbox/network/LargeBufferTest.java | 130 +- .../test/dorkbox/network/ListenerTest.java | 24 +- .../dorkbox/network/MultipleServerTest.java | 40 +- .../dorkbox/network/MultipleThreadTest.java | 41 +- .../dorkbox/network/PingPongLocalTest.java | 4 +- .../test/dorkbox/network/PingPongTest.java | 32 +- .../test/dorkbox/network/PingTest.java | 54 +- .../test/dorkbox/network/ReconnectTest.java | 10 +- .../test/dorkbox/network/ReuseTest.java | 12 +- .../network/UnregisteredClassTest.java | 17 +- .../network/rmi/RmiSendObjectTest.java | 102 +- .../test/dorkbox/network/rmi/RmiTest.java | 323 ++-- 75 files changed, 3550 insertions(+), 3408 deletions(-) rename Dorkbox-Network/src/dorkbox/network/{ConnectionOptions.java => Configuration.java} (54%) rename Dorkbox-Network/src/dorkbox/network/{util/KryoConnectionSerializationManager.java => connection/KryoCryptoSerializationManager.java} (68%) create mode 100644 Dorkbox-Network/src/dorkbox/network/connection/KryoExtra.java create mode 100644 Dorkbox-Network/src/dorkbox/network/connection/RegisterRmiSystemListener.java create mode 100644 Dorkbox-Network/src/dorkbox/network/rmi/RemoteProxy.java delete mode 100644 Dorkbox-Network/src/dorkbox/network/rmi/Rmi.java delete mode 100644 Dorkbox-Network/src/dorkbox/network/rmi/RmiRegisterClassesCallback.java create mode 100644 Dorkbox-Network/src/dorkbox/network/rmi/RmiRegistration.java delete mode 100644 Dorkbox-Network/src/dorkbox/network/rmi/SerializerRegistration.java delete mode 100644 Dorkbox-Network/src/dorkbox/network/util/BinaryListReferenceResolver.java rename Dorkbox-Network/src/dorkbox/network/util/{ConnectionSerializationManager.java => CryptoSerializationManager.java} (94%) rename Dorkbox-Network/src/dorkbox/network/util/{EndpointTool.java => EndPointTool.java} (51%) delete mode 100644 Dorkbox-Network/src/dorkbox/network/util/NullConnectionSerializationManager.java rename Dorkbox-Network/test/dorkbox/network/{ChunkedDataTest.java => ChunkedDataIdleTest.java} (84%) diff --git a/Dorkbox-Network/.classpath b/Dorkbox-Network/.classpath index 08559f20..fc4ebd34 100644 --- a/Dorkbox-Network/.classpath +++ b/Dorkbox-Network/.classpath @@ -12,7 +12,6 @@ - @@ -22,8 +21,10 @@ - - + + + + diff --git a/Dorkbox-Network/Dorkbox-Network.iml b/Dorkbox-Network/Dorkbox-Network.iml index 175c848e..9252623e 100644 --- a/Dorkbox-Network/Dorkbox-Network.iml +++ b/Dorkbox-Network/Dorkbox-Network.iml @@ -22,7 +22,7 @@ - + @@ -32,12 +32,13 @@ - + + @@ -46,7 +47,6 @@ - @@ -59,6 +59,7 @@ +