From e788d74139782c65d52a7bd307a04acdfc8185f0 Mon Sep 17 00:00:00 2001 From: Mikko Kortelainen Date: Mon, 24 Jun 2024 16:03:08 +0300 Subject: [PATCH] net_01 restructuring (#204) * re-structure networking code from rlp_03 package to net_01 package * apply spotless --- README.adoc | 8 ++++---- .../channel/buffer/BufferContainer.java | 2 +- .../channel/buffer/BufferContainerImpl.java | 2 +- .../channel/buffer/BufferContainerStub.java | 2 +- .../channel/buffer/BufferLease.java | 2 +- .../channel/buffer/BufferLeaseImpl.java | 2 +- .../channel/buffer/BufferLeasePool.java | 2 +- .../channel/buffer/BufferLeaseStub.java | 2 +- .../channel/buffer}/access/Access.java | 2 +- .../channel/buffer}/access/Lease.java | 2 +- .../channel/buffer/writable/Writeable.java | 2 +- .../channel/buffer/writable/WriteableAccess.java | 6 +++--- .../channel/buffer/writable/WriteableClosure.java | 4 ++-- .../buffer/writable/WriteableInvalidation.java | 2 +- .../channel/buffer/writable/WriteableLeaseful.java | 4 ++-- .../channel/buffer/writable/WriteableStub.java | 2 +- .../channel/buffer/writable/Writeables.java | 2 +- .../{rlp_03 => net_01}/channel/context/Clock.java | 4 ++-- .../channel/context/ClockFactory.java | 2 +- .../channel/context/ConnectContext.java | 6 +++--- .../channel/context/ConnectContextFactory.java | 10 +++++----- .../{rlp_03 => net_01}/channel/context/Context.java | 2 +- .../{rlp_03 => net_01}/channel/context/Egress.java | 4 ++-- .../channel/context/EgressImpl.java | 6 +++--- .../channel/context/EndOfStreamException.java | 2 +- .../channel/context/EstablishedContext.java | 6 +++--- .../channel/context/EstablishedContextImpl.java | 6 +++--- .../channel/context/EstablishedContextStub.java | 4 ++-- .../{rlp_03 => net_01}/channel/context/Ingress.java | 2 +- .../channel/context/IngressImpl.java | 6 +++--- .../channel/context/InterestOps.java | 2 +- .../channel/context/InterestOpsImpl.java | 2 +- .../channel/context/ListenContext.java | 8 ++++---- .../channel/context/ListenContextFactory.java | 6 +++--- .../channel/socket/EncryptionInfo.java | 4 ++-- .../channel/socket/EncryptionInfoStub.java | 4 ++-- .../channel/socket/EncryptionInfoTLS.java | 2 +- .../channel/socket/PlainFactory.java | 2 +- .../channel/socket/PlainSocket.java | 2 +- .../{rlp_03 => net_01}/channel/socket/Socket.java | 2 +- .../channel/socket/SocketFactory.java | 2 +- .../channel/socket/TLSFactory.java | 2 +- .../{rlp_03 => net_01}/channel/socket/TLSSocket.java | 2 +- .../channel/socket/TransportInfo.java | 4 ++-- .../channel/socket/TransportInfoImpl.java | 2 +- .../{rlp_03 => net_01}/eventloop/EventLoop.java | 10 +++++----- .../eventloop/EventLoopFactory.java | 2 +- .../teragrep/{rlp_03 => net_01}/server/Server.java | 6 +++--- .../{rlp_03 => net_01}/server/ServerFactory.java | 12 ++++++------ .../com/teragrep/rlp_03/client/ClientDelegate.java | 2 +- .../com/teragrep/rlp_03/client/ClientFactory.java | 8 ++++---- .../java/com/teragrep/rlp_03/client/ClientImpl.java | 2 +- .../teragrep/rlp_03/frame/FrameClockLeaseful.java | 2 +- .../teragrep/rlp_03/frame/FrameDelegationClock.java | 6 +++--- .../rlp_03/frame/FrameDelegationClockFactory.java | 6 +++--- .../java/com/teragrep/rlp_03/frame/RelpFrame.java | 2 +- .../com/teragrep/rlp_03/frame/RelpFrameAccess.java | 6 +++--- .../com/teragrep/rlp_03/frame/RelpFrameImpl.java | 4 ++-- .../com/teragrep/rlp_03/frame/RelpFrameLeaseful.java | 8 ++++---- .../com/teragrep/rlp_03/frame/RelpFrameStub.java | 2 +- .../teragrep/rlp_03/frame/delegate/FrameContext.java | 2 +- .../rlp_03/frame/delegate/event/RelpEventClose.java | 6 +++--- .../frame/delegate/event/RelpEventServerClose.java | 4 ++-- .../com/teragrep/rlp_03/frame/fragment/Fragment.java | 2 +- .../rlp_03/frame/fragment/FragmentAccess.java | 8 ++++---- .../frame/fragment/FragmentByteStreamAccess.java | 4 ++-- .../teragrep/rlp_03/frame/fragment/FragmentImpl.java | 2 +- .../teragrep/rlp_03/frame/fragment/FragmentStub.java | 2 +- .../rlp_03/frame/fragment/FragmentWriteImpl.java | 2 +- .../channel/context/EgressFake.java | 4 ++-- .../channel/context/EstablishedContextFake.java | 4 ++-- .../channel/context/InterestOpsFake.java | 2 +- .../channel/context/buffer/BufferLeasePoolTest.java | 6 +++--- .../channel/context/frame/RelpFrameTest.java | 2 +- .../channel/context/frame/access/AccessTest.java | 6 +++--- .../context/frame/clocks/CommandClockTest.java | 2 +- .../context/frame/clocks/EndOfTransferClockTest.java | 2 +- .../context/frame/clocks/PayloadClockTest.java | 2 +- .../context/frame/clocks/PayloadLengthClockTest.java | 2 +- .../context/frame/clocks/TransactionClockTest.java | 2 +- .../channel/context/frame/fragment/FragmentTest.java | 2 +- .../channel/socket/SocketFake.java | 2 +- .../channel/socket/TransportInfoFake.java | 2 +- .../com/teragrep/rlp_03/CloseByteConsumerTest.java | 8 ++++---- .../rlp_03/CloseRelpFrameServerRXConsumerTest.java | 8 ++++---- .../com/teragrep/rlp_03/ConnectionStormTest.java | 8 ++++---- .../com/teragrep/rlp_03/ManualBenchmarkTest.java | 8 ++++---- .../com/teragrep/rlp_03/ManualPerformanceTest.java | 10 +++++----- src/test/java/com/teragrep/rlp_03/ManualTest.java | 12 ++++++------ .../java/com/teragrep/rlp_03/MultiClientTest.java | 8 ++++---- .../java/com/teragrep/rlp_03/SendMessageTest.java | 8 ++++---- .../java/com/teragrep/rlp_03/ServerShutdownTest.java | 8 ++++---- src/test/java/com/teragrep/rlp_03/TearDownTest.java | 8 ++++---- src/test/java/com/teragrep/rlp_03/TlsClientTest.java | 8 ++++---- .../java/com/teragrep/rlp_03/client/ClientTest.java | 12 ++++++------ .../teragrep/rlp_03/client/StuckClientCloseTest.java | 12 ++++++------ .../rlp_03/frame/pool/PoolingDelegateTest.java | 8 ++++---- .../teragrep/rlp_03/readme/ReadmeDeferredTest.java | 8 ++++---- .../java/com/teragrep/rlp_03/readme/ReadmeTest.java | 8 ++++---- 99 files changed, 223 insertions(+), 223 deletions(-) rename src/main/java/com/teragrep/{rlp_03 => net_01}/channel/buffer/BufferContainer.java (98%) rename src/main/java/com/teragrep/{rlp_03 => net_01}/channel/buffer/BufferContainerImpl.java (98%) rename src/main/java/com/teragrep/{rlp_03 => net_01}/channel/buffer/BufferContainerStub.java (98%) rename src/main/java/com/teragrep/{rlp_03 => net_01}/channel/buffer/BufferLease.java (98%) rename src/main/java/com/teragrep/{rlp_03 => net_01}/channel/buffer/BufferLeaseImpl.java (99%) rename src/main/java/com/teragrep/{rlp_03 => net_01}/channel/buffer/BufferLeasePool.java (99%) rename src/main/java/com/teragrep/{rlp_03 => net_01}/channel/buffer/BufferLeaseStub.java (98%) rename src/main/java/com/teragrep/{rlp_03/frame => net_01/channel/buffer}/access/Access.java (98%) rename src/main/java/com/teragrep/{rlp_03/frame => net_01/channel/buffer}/access/Lease.java (97%) rename src/main/java/com/teragrep/{rlp_03 => net_01}/channel/buffer/writable/Writeable.java (97%) rename src/main/java/com/teragrep/{rlp_03 => net_01}/channel/buffer/writable/WriteableAccess.java (94%) rename src/main/java/com/teragrep/{rlp_03 => net_01}/channel/buffer/writable/WriteableClosure.java (96%) rename src/main/java/com/teragrep/{rlp_03 => net_01}/channel/buffer/writable/WriteableInvalidation.java (98%) rename src/main/java/com/teragrep/{rlp_03 => net_01}/channel/buffer/writable/WriteableLeaseful.java (96%) rename src/main/java/com/teragrep/{rlp_03 => net_01}/channel/buffer/writable/WriteableStub.java (98%) rename src/main/java/com/teragrep/{rlp_03 => net_01}/channel/buffer/writable/Writeables.java (98%) rename src/main/java/com/teragrep/{rlp_03 => net_01}/channel/context/Clock.java (95%) rename src/main/java/com/teragrep/{rlp_03 => net_01}/channel/context/ClockFactory.java (97%) rename src/main/java/com/teragrep/{rlp_03 => net_01}/channel/context/ConnectContext.java (97%) rename src/main/java/com/teragrep/{rlp_03 => net_01}/channel/context/ConnectContextFactory.java (93%) rename src/main/java/com/teragrep/{rlp_03 => net_01}/channel/context/Context.java (98%) rename src/main/java/com/teragrep/{rlp_03 => net_01}/channel/context/Egress.java (95%) rename src/main/java/com/teragrep/{rlp_03 => net_01}/channel/context/EgressImpl.java (97%) rename src/main/java/com/teragrep/{rlp_03 => net_01}/channel/context/EndOfStreamException.java (98%) rename src/main/java/com/teragrep/{rlp_03 => net_01}/channel/context/EstablishedContext.java (94%) rename src/main/java/com/teragrep/{rlp_03 => net_01}/channel/context/EstablishedContextImpl.java (98%) rename src/main/java/com/teragrep/{rlp_03 => net_01}/channel/context/EstablishedContextStub.java (97%) rename src/main/java/com/teragrep/{rlp_03 => net_01}/channel/context/Ingress.java (98%) rename src/main/java/com/teragrep/{rlp_03 => net_01}/channel/context/IngressImpl.java (98%) rename src/main/java/com/teragrep/{rlp_03 => net_01}/channel/context/InterestOps.java (98%) rename src/main/java/com/teragrep/{rlp_03 => net_01}/channel/context/InterestOpsImpl.java (99%) rename src/main/java/com/teragrep/{rlp_03 => net_01}/channel/context/ListenContext.java (97%) rename src/main/java/com/teragrep/{rlp_03 => net_01}/channel/context/ListenContextFactory.java (95%) rename src/main/java/com/teragrep/{rlp_03 => net_01}/channel/socket/EncryptionInfo.java (96%) rename src/main/java/com/teragrep/{rlp_03 => net_01}/channel/socket/EncryptionInfoStub.java (97%) rename src/main/java/com/teragrep/{rlp_03 => net_01}/channel/socket/EncryptionInfoTLS.java (98%) rename src/main/java/com/teragrep/{rlp_03 => net_01}/channel/socket/PlainFactory.java (98%) rename src/main/java/com/teragrep/{rlp_03 => net_01}/channel/socket/PlainSocket.java (98%) rename src/main/java/com/teragrep/{rlp_03 => net_01}/channel/socket/Socket.java (98%) rename src/main/java/com/teragrep/{rlp_03 => net_01}/channel/socket/SocketFactory.java (98%) rename src/main/java/com/teragrep/{rlp_03 => net_01}/channel/socket/TLSFactory.java (98%) rename src/main/java/com/teragrep/{rlp_03 => net_01}/channel/socket/TLSSocket.java (98%) rename src/main/java/com/teragrep/{rlp_03 => net_01}/channel/socket/TransportInfo.java (95%) rename src/main/java/com/teragrep/{rlp_03 => net_01}/channel/socket/TransportInfoImpl.java (98%) rename src/main/java/com/teragrep/{rlp_03 => net_01}/eventloop/EventLoop.java (96%) rename src/main/java/com/teragrep/{rlp_03 => net_01}/eventloop/EventLoopFactory.java (98%) rename src/main/java/com/teragrep/{rlp_03 => net_01}/server/Server.java (94%) rename src/main/java/com/teragrep/{rlp_03 => net_01}/server/ServerFactory.java (92%) rename src/test/java/com/teragrep/{rlp_03 => net_01}/channel/context/EgressFake.java (96%) rename src/test/java/com/teragrep/{rlp_03 => net_01}/channel/context/EstablishedContextFake.java (96%) rename src/test/java/com/teragrep/{rlp_03 => net_01}/channel/context/InterestOpsFake.java (98%) rename src/test/java/com/teragrep/{rlp_03 => net_01}/channel/context/buffer/BufferLeasePoolTest.java (96%) rename src/test/java/com/teragrep/{rlp_03 => net_01}/channel/context/frame/RelpFrameTest.java (99%) rename src/test/java/com/teragrep/{rlp_03 => net_01}/channel/context/frame/access/AccessTest.java (94%) rename src/test/java/com/teragrep/{rlp_03 => net_01}/channel/context/frame/clocks/CommandClockTest.java (98%) rename src/test/java/com/teragrep/{rlp_03 => net_01}/channel/context/frame/clocks/EndOfTransferClockTest.java (98%) rename src/test/java/com/teragrep/{rlp_03 => net_01}/channel/context/frame/clocks/PayloadClockTest.java (98%) rename src/test/java/com/teragrep/{rlp_03 => net_01}/channel/context/frame/clocks/PayloadLengthClockTest.java (98%) rename src/test/java/com/teragrep/{rlp_03 => net_01}/channel/context/frame/clocks/TransactionClockTest.java (98%) rename src/test/java/com/teragrep/{rlp_03 => net_01}/channel/context/frame/fragment/FragmentTest.java (98%) rename src/test/java/com/teragrep/{rlp_03 => net_01}/channel/socket/SocketFake.java (98%) rename src/test/java/com/teragrep/{rlp_03 => net_01}/channel/socket/TransportInfoFake.java (98%) diff --git a/README.adoc b/README.adoc index 8e05d3df..b4ab2eab 100644 --- a/README.adoc +++ b/README.adoc @@ -67,13 +67,13 @@ Server with shared handler for all connections. See ExampleRelpClient.java for c ---- package com.teragrep.rlp_03.readme; -import com.teragrep.rlp_03.eventloop.EventLoop; -import com.teragrep.rlp_03.eventloop.EventLoopFactory; +import com.teragrep.net_01.eventloop.EventLoop; +import com.teragrep.net_01.eventloop.EventLoopFactory; import com.teragrep.rlp_03.frame.delegate.DefaultFrameDelegate; import com.teragrep.rlp_03.frame.delegate.FrameContext; import com.teragrep.rlp_03.frame.delegate.FrameDelegate; -import com.teragrep.rlp_03.server.ServerFactory; -import com.teragrep.rlp_03.channel.socket.PlainFactory; +import com.teragrep.net_01.server.ServerFactory; +import com.teragrep.net_01.channel.socket.PlainFactory; import org.junit.jupiter.api.Test; import java.io.IOException; diff --git a/src/main/java/com/teragrep/rlp_03/channel/buffer/BufferContainer.java b/src/main/java/com/teragrep/net_01/channel/buffer/BufferContainer.java similarity index 98% rename from src/main/java/com/teragrep/rlp_03/channel/buffer/BufferContainer.java rename to src/main/java/com/teragrep/net_01/channel/buffer/BufferContainer.java index cc60244d..8b98dae7 100644 --- a/src/main/java/com/teragrep/rlp_03/channel/buffer/BufferContainer.java +++ b/src/main/java/com/teragrep/net_01/channel/buffer/BufferContainer.java @@ -43,7 +43,7 @@ * Teragrep, the applicable Commercial License may apply to this file if you as * a licensee so wish it. */ -package com.teragrep.rlp_03.channel.buffer; +package com.teragrep.net_01.channel.buffer; import java.nio.ByteBuffer; diff --git a/src/main/java/com/teragrep/rlp_03/channel/buffer/BufferContainerImpl.java b/src/main/java/com/teragrep/net_01/channel/buffer/BufferContainerImpl.java similarity index 98% rename from src/main/java/com/teragrep/rlp_03/channel/buffer/BufferContainerImpl.java rename to src/main/java/com/teragrep/net_01/channel/buffer/BufferContainerImpl.java index af6b7441..ee744f79 100644 --- a/src/main/java/com/teragrep/rlp_03/channel/buffer/BufferContainerImpl.java +++ b/src/main/java/com/teragrep/net_01/channel/buffer/BufferContainerImpl.java @@ -43,7 +43,7 @@ * Teragrep, the applicable Commercial License may apply to this file if you as * a licensee so wish it. */ -package com.teragrep.rlp_03.channel.buffer; +package com.teragrep.net_01.channel.buffer; import org.slf4j.Logger; import org.slf4j.LoggerFactory; diff --git a/src/main/java/com/teragrep/rlp_03/channel/buffer/BufferContainerStub.java b/src/main/java/com/teragrep/net_01/channel/buffer/BufferContainerStub.java similarity index 98% rename from src/main/java/com/teragrep/rlp_03/channel/buffer/BufferContainerStub.java rename to src/main/java/com/teragrep/net_01/channel/buffer/BufferContainerStub.java index bda97a83..402f5d25 100644 --- a/src/main/java/com/teragrep/rlp_03/channel/buffer/BufferContainerStub.java +++ b/src/main/java/com/teragrep/net_01/channel/buffer/BufferContainerStub.java @@ -43,7 +43,7 @@ * Teragrep, the applicable Commercial License may apply to this file if you as * a licensee so wish it. */ -package com.teragrep.rlp_03.channel.buffer; +package com.teragrep.net_01.channel.buffer; import java.nio.ByteBuffer; diff --git a/src/main/java/com/teragrep/rlp_03/channel/buffer/BufferLease.java b/src/main/java/com/teragrep/net_01/channel/buffer/BufferLease.java similarity index 98% rename from src/main/java/com/teragrep/rlp_03/channel/buffer/BufferLease.java rename to src/main/java/com/teragrep/net_01/channel/buffer/BufferLease.java index 02d79ce0..b0c80ada 100644 --- a/src/main/java/com/teragrep/rlp_03/channel/buffer/BufferLease.java +++ b/src/main/java/com/teragrep/net_01/channel/buffer/BufferLease.java @@ -43,7 +43,7 @@ * Teragrep, the applicable Commercial License may apply to this file if you as * a licensee so wish it. */ -package com.teragrep.rlp_03.channel.buffer; +package com.teragrep.net_01.channel.buffer; import java.nio.ByteBuffer; diff --git a/src/main/java/com/teragrep/rlp_03/channel/buffer/BufferLeaseImpl.java b/src/main/java/com/teragrep/net_01/channel/buffer/BufferLeaseImpl.java similarity index 99% rename from src/main/java/com/teragrep/rlp_03/channel/buffer/BufferLeaseImpl.java rename to src/main/java/com/teragrep/net_01/channel/buffer/BufferLeaseImpl.java index eeb2f2a6..fcd8b350 100644 --- a/src/main/java/com/teragrep/rlp_03/channel/buffer/BufferLeaseImpl.java +++ b/src/main/java/com/teragrep/net_01/channel/buffer/BufferLeaseImpl.java @@ -43,7 +43,7 @@ * Teragrep, the applicable Commercial License may apply to this file if you as * a licensee so wish it. */ -package com.teragrep.rlp_03.channel.buffer; +package com.teragrep.net_01.channel.buffer; import java.nio.ByteBuffer; import java.util.concurrent.Phaser; diff --git a/src/main/java/com/teragrep/rlp_03/channel/buffer/BufferLeasePool.java b/src/main/java/com/teragrep/net_01/channel/buffer/BufferLeasePool.java similarity index 99% rename from src/main/java/com/teragrep/rlp_03/channel/buffer/BufferLeasePool.java rename to src/main/java/com/teragrep/net_01/channel/buffer/BufferLeasePool.java index 1adf936b..b179cff2 100644 --- a/src/main/java/com/teragrep/rlp_03/channel/buffer/BufferLeasePool.java +++ b/src/main/java/com/teragrep/net_01/channel/buffer/BufferLeasePool.java @@ -43,7 +43,7 @@ * Teragrep, the applicable Commercial License may apply to this file if you as * a licensee so wish it. */ -package com.teragrep.rlp_03.channel.buffer; +package com.teragrep.net_01.channel.buffer; import org.slf4j.Logger; import org.slf4j.LoggerFactory; diff --git a/src/main/java/com/teragrep/rlp_03/channel/buffer/BufferLeaseStub.java b/src/main/java/com/teragrep/net_01/channel/buffer/BufferLeaseStub.java similarity index 98% rename from src/main/java/com/teragrep/rlp_03/channel/buffer/BufferLeaseStub.java rename to src/main/java/com/teragrep/net_01/channel/buffer/BufferLeaseStub.java index 30424a7f..a2fa685f 100644 --- a/src/main/java/com/teragrep/rlp_03/channel/buffer/BufferLeaseStub.java +++ b/src/main/java/com/teragrep/net_01/channel/buffer/BufferLeaseStub.java @@ -43,7 +43,7 @@ * Teragrep, the applicable Commercial License may apply to this file if you as * a licensee so wish it. */ -package com.teragrep.rlp_03.channel.buffer; +package com.teragrep.net_01.channel.buffer; import java.nio.ByteBuffer; diff --git a/src/main/java/com/teragrep/rlp_03/frame/access/Access.java b/src/main/java/com/teragrep/net_01/channel/buffer/access/Access.java similarity index 98% rename from src/main/java/com/teragrep/rlp_03/frame/access/Access.java rename to src/main/java/com/teragrep/net_01/channel/buffer/access/Access.java index bfe9dde8..2d407491 100644 --- a/src/main/java/com/teragrep/rlp_03/frame/access/Access.java +++ b/src/main/java/com/teragrep/net_01/channel/buffer/access/Access.java @@ -43,7 +43,7 @@ * Teragrep, the applicable Commercial License may apply to this file if you as * a licensee so wish it. */ -package com.teragrep.rlp_03.frame.access; +package com.teragrep.net_01.channel.buffer.access; import java.util.concurrent.locks.Lock; import java.util.concurrent.locks.ReentrantLock; diff --git a/src/main/java/com/teragrep/rlp_03/frame/access/Lease.java b/src/main/java/com/teragrep/net_01/channel/buffer/access/Lease.java similarity index 97% rename from src/main/java/com/teragrep/rlp_03/frame/access/Lease.java rename to src/main/java/com/teragrep/net_01/channel/buffer/access/Lease.java index 2b1f6513..40ac9a00 100644 --- a/src/main/java/com/teragrep/rlp_03/frame/access/Lease.java +++ b/src/main/java/com/teragrep/net_01/channel/buffer/access/Lease.java @@ -43,7 +43,7 @@ * Teragrep, the applicable Commercial License may apply to this file if you as * a licensee so wish it. */ -package com.teragrep.rlp_03.frame.access; +package com.teragrep.net_01.channel.buffer.access; public final class Lease implements AutoCloseable { diff --git a/src/main/java/com/teragrep/rlp_03/channel/buffer/writable/Writeable.java b/src/main/java/com/teragrep/net_01/channel/buffer/writable/Writeable.java similarity index 97% rename from src/main/java/com/teragrep/rlp_03/channel/buffer/writable/Writeable.java rename to src/main/java/com/teragrep/net_01/channel/buffer/writable/Writeable.java index 46df8d72..43e00ce9 100644 --- a/src/main/java/com/teragrep/rlp_03/channel/buffer/writable/Writeable.java +++ b/src/main/java/com/teragrep/net_01/channel/buffer/writable/Writeable.java @@ -43,7 +43,7 @@ * Teragrep, the applicable Commercial License may apply to this file if you as * a licensee so wish it. */ -package com.teragrep.rlp_03.channel.buffer.writable; +package com.teragrep.net_01.channel.buffer.writable; import java.io.Closeable; import java.nio.ByteBuffer; diff --git a/src/main/java/com/teragrep/rlp_03/channel/buffer/writable/WriteableAccess.java b/src/main/java/com/teragrep/net_01/channel/buffer/writable/WriteableAccess.java similarity index 94% rename from src/main/java/com/teragrep/rlp_03/channel/buffer/writable/WriteableAccess.java rename to src/main/java/com/teragrep/net_01/channel/buffer/writable/WriteableAccess.java index a9c6ad00..3973ca2e 100644 --- a/src/main/java/com/teragrep/rlp_03/channel/buffer/writable/WriteableAccess.java +++ b/src/main/java/com/teragrep/net_01/channel/buffer/writable/WriteableAccess.java @@ -43,10 +43,10 @@ * Teragrep, the applicable Commercial License may apply to this file if you as * a licensee so wish it. */ -package com.teragrep.rlp_03.channel.buffer.writable; +package com.teragrep.net_01.channel.buffer.writable; -import com.teragrep.rlp_03.frame.access.Access; -import com.teragrep.rlp_03.frame.access.Lease; +import com.teragrep.net_01.channel.buffer.access.Access; +import com.teragrep.net_01.channel.buffer.access.Lease; import java.nio.ByteBuffer; diff --git a/src/main/java/com/teragrep/rlp_03/channel/buffer/writable/WriteableClosure.java b/src/main/java/com/teragrep/net_01/channel/buffer/writable/WriteableClosure.java similarity index 96% rename from src/main/java/com/teragrep/rlp_03/channel/buffer/writable/WriteableClosure.java rename to src/main/java/com/teragrep/net_01/channel/buffer/writable/WriteableClosure.java index a6511f76..37c73a0a 100644 --- a/src/main/java/com/teragrep/rlp_03/channel/buffer/writable/WriteableClosure.java +++ b/src/main/java/com/teragrep/net_01/channel/buffer/writable/WriteableClosure.java @@ -43,9 +43,9 @@ * Teragrep, the applicable Commercial License may apply to this file if you as * a licensee so wish it. */ -package com.teragrep.rlp_03.channel.buffer.writable; +package com.teragrep.net_01.channel.buffer.writable; -import com.teragrep.rlp_03.channel.context.EstablishedContext; +import com.teragrep.net_01.channel.context.EstablishedContext; import org.slf4j.Logger; import org.slf4j.LoggerFactory; diff --git a/src/main/java/com/teragrep/rlp_03/channel/buffer/writable/WriteableInvalidation.java b/src/main/java/com/teragrep/net_01/channel/buffer/writable/WriteableInvalidation.java similarity index 98% rename from src/main/java/com/teragrep/rlp_03/channel/buffer/writable/WriteableInvalidation.java rename to src/main/java/com/teragrep/net_01/channel/buffer/writable/WriteableInvalidation.java index f53588df..47694a78 100644 --- a/src/main/java/com/teragrep/rlp_03/channel/buffer/writable/WriteableInvalidation.java +++ b/src/main/java/com/teragrep/net_01/channel/buffer/writable/WriteableInvalidation.java @@ -43,7 +43,7 @@ * Teragrep, the applicable Commercial License may apply to this file if you as * a licensee so wish it. */ -package com.teragrep.rlp_03.channel.buffer.writable; +package com.teragrep.net_01.channel.buffer.writable; import java.nio.ByteBuffer; diff --git a/src/main/java/com/teragrep/rlp_03/channel/buffer/writable/WriteableLeaseful.java b/src/main/java/com/teragrep/net_01/channel/buffer/writable/WriteableLeaseful.java similarity index 96% rename from src/main/java/com/teragrep/rlp_03/channel/buffer/writable/WriteableLeaseful.java rename to src/main/java/com/teragrep/net_01/channel/buffer/writable/WriteableLeaseful.java index 00795adb..eb2871bc 100644 --- a/src/main/java/com/teragrep/rlp_03/channel/buffer/writable/WriteableLeaseful.java +++ b/src/main/java/com/teragrep/net_01/channel/buffer/writable/WriteableLeaseful.java @@ -43,9 +43,9 @@ * Teragrep, the applicable Commercial License may apply to this file if you as * a licensee so wish it. */ -package com.teragrep.rlp_03.channel.buffer.writable; +package com.teragrep.net_01.channel.buffer.writable; -import com.teragrep.rlp_03.channel.buffer.BufferLease; +import com.teragrep.net_01.channel.buffer.BufferLease; import org.slf4j.Logger; import org.slf4j.LoggerFactory; diff --git a/src/main/java/com/teragrep/rlp_03/channel/buffer/writable/WriteableStub.java b/src/main/java/com/teragrep/net_01/channel/buffer/writable/WriteableStub.java similarity index 98% rename from src/main/java/com/teragrep/rlp_03/channel/buffer/writable/WriteableStub.java rename to src/main/java/com/teragrep/net_01/channel/buffer/writable/WriteableStub.java index b092529c..263cc384 100644 --- a/src/main/java/com/teragrep/rlp_03/channel/buffer/writable/WriteableStub.java +++ b/src/main/java/com/teragrep/net_01/channel/buffer/writable/WriteableStub.java @@ -43,7 +43,7 @@ * Teragrep, the applicable Commercial License may apply to this file if you as * a licensee so wish it. */ -package com.teragrep.rlp_03.channel.buffer.writable; +package com.teragrep.net_01.channel.buffer.writable; import java.nio.ByteBuffer; diff --git a/src/main/java/com/teragrep/rlp_03/channel/buffer/writable/Writeables.java b/src/main/java/com/teragrep/net_01/channel/buffer/writable/Writeables.java similarity index 98% rename from src/main/java/com/teragrep/rlp_03/channel/buffer/writable/Writeables.java rename to src/main/java/com/teragrep/net_01/channel/buffer/writable/Writeables.java index dec8ec9e..f7bb925c 100644 --- a/src/main/java/com/teragrep/rlp_03/channel/buffer/writable/Writeables.java +++ b/src/main/java/com/teragrep/net_01/channel/buffer/writable/Writeables.java @@ -43,7 +43,7 @@ * Teragrep, the applicable Commercial License may apply to this file if you as * a licensee so wish it. */ -package com.teragrep.rlp_03.channel.buffer.writable; +package com.teragrep.net_01.channel.buffer.writable; import java.nio.ByteBuffer; diff --git a/src/main/java/com/teragrep/rlp_03/channel/context/Clock.java b/src/main/java/com/teragrep/net_01/channel/context/Clock.java similarity index 95% rename from src/main/java/com/teragrep/rlp_03/channel/context/Clock.java rename to src/main/java/com/teragrep/net_01/channel/context/Clock.java index 028a69b3..7cb3e8eb 100644 --- a/src/main/java/com/teragrep/rlp_03/channel/context/Clock.java +++ b/src/main/java/com/teragrep/net_01/channel/context/Clock.java @@ -43,9 +43,9 @@ * Teragrep, the applicable Commercial License may apply to this file if you as * a licensee so wish it. */ -package com.teragrep.rlp_03.channel.context; +package com.teragrep.net_01.channel.context; -import com.teragrep.rlp_03.channel.buffer.BufferLease; +import com.teragrep.net_01.channel.buffer.BufferLease; public interface Clock extends AutoCloseable { diff --git a/src/main/java/com/teragrep/rlp_03/channel/context/ClockFactory.java b/src/main/java/com/teragrep/net_01/channel/context/ClockFactory.java similarity index 97% rename from src/main/java/com/teragrep/rlp_03/channel/context/ClockFactory.java rename to src/main/java/com/teragrep/net_01/channel/context/ClockFactory.java index 5ff597e5..6e7a5cd8 100644 --- a/src/main/java/com/teragrep/rlp_03/channel/context/ClockFactory.java +++ b/src/main/java/com/teragrep/net_01/channel/context/ClockFactory.java @@ -43,7 +43,7 @@ * Teragrep, the applicable Commercial License may apply to this file if you as * a licensee so wish it. */ -package com.teragrep.rlp_03.channel.context; +package com.teragrep.net_01.channel.context; public interface ClockFactory { diff --git a/src/main/java/com/teragrep/rlp_03/channel/context/ConnectContext.java b/src/main/java/com/teragrep/net_01/channel/context/ConnectContext.java similarity index 97% rename from src/main/java/com/teragrep/rlp_03/channel/context/ConnectContext.java rename to src/main/java/com/teragrep/net_01/channel/context/ConnectContext.java index 454fd89a..18ce1c64 100644 --- a/src/main/java/com/teragrep/rlp_03/channel/context/ConnectContext.java +++ b/src/main/java/com/teragrep/net_01/channel/context/ConnectContext.java @@ -43,10 +43,10 @@ * Teragrep, the applicable Commercial License may apply to this file if you as * a licensee so wish it. */ -package com.teragrep.rlp_03.channel.context; +package com.teragrep.net_01.channel.context; -import com.teragrep.rlp_03.channel.socket.SocketFactory; -import com.teragrep.rlp_03.eventloop.EventLoop; +import com.teragrep.net_01.channel.socket.SocketFactory; +import com.teragrep.net_01.eventloop.EventLoop; import org.slf4j.Logger; import org.slf4j.LoggerFactory; diff --git a/src/main/java/com/teragrep/rlp_03/channel/context/ConnectContextFactory.java b/src/main/java/com/teragrep/net_01/channel/context/ConnectContextFactory.java similarity index 93% rename from src/main/java/com/teragrep/rlp_03/channel/context/ConnectContextFactory.java rename to src/main/java/com/teragrep/net_01/channel/context/ConnectContextFactory.java index d37c8e76..5ecb1400 100644 --- a/src/main/java/com/teragrep/rlp_03/channel/context/ConnectContextFactory.java +++ b/src/main/java/com/teragrep/net_01/channel/context/ConnectContextFactory.java @@ -43,10 +43,11 @@ * Teragrep, the applicable Commercial License may apply to this file if you as * a licensee so wish it. */ -package com.teragrep.rlp_03.channel.context; +package com.teragrep.net_01.channel.context; -import com.teragrep.rlp_03.channel.socket.SocketFactory; -import com.teragrep.rlp_03.eventloop.EventLoop; +import com.teragrep.net_01.channel.socket.Socket; +import com.teragrep.net_01.channel.socket.SocketFactory; +import com.teragrep.net_01.eventloop.EventLoop; import java.io.IOException; import java.net.InetSocketAddress; @@ -64,8 +65,7 @@ public final class ConnectContextFactory { /** * @param executorService {@link ExecutorService} to handle connection's events with - * @param socketFactory {@link SocketFactory} that produces the desired type - * {@link com.teragrep.rlp_03.channel.socket.Socket} for the connection. + * @param socketFactory {@link SocketFactory} that produces the desired type {@link Socket} for the connection. */ public ConnectContextFactory(ExecutorService executorService, SocketFactory socketFactory) { this.executorService = executorService; diff --git a/src/main/java/com/teragrep/rlp_03/channel/context/Context.java b/src/main/java/com/teragrep/net_01/channel/context/Context.java similarity index 98% rename from src/main/java/com/teragrep/rlp_03/channel/context/Context.java rename to src/main/java/com/teragrep/net_01/channel/context/Context.java index 632cac74..587c660a 100644 --- a/src/main/java/com/teragrep/rlp_03/channel/context/Context.java +++ b/src/main/java/com/teragrep/net_01/channel/context/Context.java @@ -43,7 +43,7 @@ * Teragrep, the applicable Commercial License may apply to this file if you as * a licensee so wish it. */ -package com.teragrep.rlp_03.channel.context; +package com.teragrep.net_01.channel.context; import java.io.Closeable; import java.nio.channels.SelectionKey; diff --git a/src/main/java/com/teragrep/rlp_03/channel/context/Egress.java b/src/main/java/com/teragrep/net_01/channel/context/Egress.java similarity index 95% rename from src/main/java/com/teragrep/rlp_03/channel/context/Egress.java rename to src/main/java/com/teragrep/net_01/channel/context/Egress.java index 756455f4..567ee38a 100644 --- a/src/main/java/com/teragrep/rlp_03/channel/context/Egress.java +++ b/src/main/java/com/teragrep/net_01/channel/context/Egress.java @@ -43,9 +43,9 @@ * Teragrep, the applicable Commercial License may apply to this file if you as * a licensee so wish it. */ -package com.teragrep.rlp_03.channel.context; +package com.teragrep.net_01.channel.context; -import com.teragrep.rlp_03.channel.buffer.writable.Writeable; +import com.teragrep.net_01.channel.buffer.writable.Writeable; import java.util.concurrent.atomic.AtomicBoolean; import java.util.function.Consumer; diff --git a/src/main/java/com/teragrep/rlp_03/channel/context/EgressImpl.java b/src/main/java/com/teragrep/net_01/channel/context/EgressImpl.java similarity index 97% rename from src/main/java/com/teragrep/rlp_03/channel/context/EgressImpl.java rename to src/main/java/com/teragrep/net_01/channel/context/EgressImpl.java index c6b2ff0b..7dcf05c8 100644 --- a/src/main/java/com/teragrep/rlp_03/channel/context/EgressImpl.java +++ b/src/main/java/com/teragrep/net_01/channel/context/EgressImpl.java @@ -43,10 +43,10 @@ * Teragrep, the applicable Commercial License may apply to this file if you as * a licensee so wish it. */ -package com.teragrep.rlp_03.channel.context; +package com.teragrep.net_01.channel.context; -import com.teragrep.rlp_03.channel.buffer.writable.Writeable; -import com.teragrep.rlp_03.channel.buffer.writable.WriteableStub; +import com.teragrep.net_01.channel.buffer.writable.Writeable; +import com.teragrep.net_01.channel.buffer.writable.WriteableStub; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import tlschannel.NeedsReadException; diff --git a/src/main/java/com/teragrep/rlp_03/channel/context/EndOfStreamException.java b/src/main/java/com/teragrep/net_01/channel/context/EndOfStreamException.java similarity index 98% rename from src/main/java/com/teragrep/rlp_03/channel/context/EndOfStreamException.java rename to src/main/java/com/teragrep/net_01/channel/context/EndOfStreamException.java index a48067ce..3beb696c 100644 --- a/src/main/java/com/teragrep/rlp_03/channel/context/EndOfStreamException.java +++ b/src/main/java/com/teragrep/net_01/channel/context/EndOfStreamException.java @@ -43,7 +43,7 @@ * Teragrep, the applicable Commercial License may apply to this file if you as * a licensee so wish it. */ -package com.teragrep.rlp_03.channel.context; +package com.teragrep.net_01.channel.context; import java.io.IOException; diff --git a/src/main/java/com/teragrep/rlp_03/channel/context/EstablishedContext.java b/src/main/java/com/teragrep/net_01/channel/context/EstablishedContext.java similarity index 94% rename from src/main/java/com/teragrep/rlp_03/channel/context/EstablishedContext.java rename to src/main/java/com/teragrep/net_01/channel/context/EstablishedContext.java index e3d32473..b8d18eb7 100644 --- a/src/main/java/com/teragrep/rlp_03/channel/context/EstablishedContext.java +++ b/src/main/java/com/teragrep/net_01/channel/context/EstablishedContext.java @@ -43,10 +43,10 @@ * Teragrep, the applicable Commercial License may apply to this file if you as * a licensee so wish it. */ -package com.teragrep.rlp_03.channel.context; +package com.teragrep.net_01.channel.context; -import com.teragrep.rlp_03.channel.buffer.writable.Writeable; -import com.teragrep.rlp_03.channel.socket.Socket; +import com.teragrep.net_01.channel.buffer.writable.Writeable; +import com.teragrep.net_01.channel.socket.Socket; /** * Established type of {@link Context}. It produces ingress data into the provided diff --git a/src/main/java/com/teragrep/rlp_03/channel/context/EstablishedContextImpl.java b/src/main/java/com/teragrep/net_01/channel/context/EstablishedContextImpl.java similarity index 98% rename from src/main/java/com/teragrep/rlp_03/channel/context/EstablishedContextImpl.java rename to src/main/java/com/teragrep/net_01/channel/context/EstablishedContextImpl.java index c1be78c9..bce9829a 100644 --- a/src/main/java/com/teragrep/rlp_03/channel/context/EstablishedContextImpl.java +++ b/src/main/java/com/teragrep/net_01/channel/context/EstablishedContextImpl.java @@ -43,10 +43,10 @@ * Teragrep, the applicable Commercial License may apply to this file if you as * a licensee so wish it. */ -package com.teragrep.rlp_03.channel.context; +package com.teragrep.net_01.channel.context; -import com.teragrep.rlp_03.channel.buffer.BufferLeasePool; -import com.teragrep.rlp_03.channel.socket.Socket; +import com.teragrep.net_01.channel.socket.Socket; +import com.teragrep.net_01.channel.buffer.BufferLeasePool; import org.slf4j.Logger; import org.slf4j.LoggerFactory; diff --git a/src/main/java/com/teragrep/rlp_03/channel/context/EstablishedContextStub.java b/src/main/java/com/teragrep/net_01/channel/context/EstablishedContextStub.java similarity index 97% rename from src/main/java/com/teragrep/rlp_03/channel/context/EstablishedContextStub.java rename to src/main/java/com/teragrep/net_01/channel/context/EstablishedContextStub.java index e163c38d..a6efc9a9 100644 --- a/src/main/java/com/teragrep/rlp_03/channel/context/EstablishedContextStub.java +++ b/src/main/java/com/teragrep/net_01/channel/context/EstablishedContextStub.java @@ -43,9 +43,9 @@ * Teragrep, the applicable Commercial License may apply to this file if you as * a licensee so wish it. */ -package com.teragrep.rlp_03.channel.context; +package com.teragrep.net_01.channel.context; -import com.teragrep.rlp_03.channel.socket.Socket; +import com.teragrep.net_01.channel.socket.Socket; import java.nio.channels.SelectionKey; import java.nio.channels.spi.AbstractSelectableChannel; diff --git a/src/main/java/com/teragrep/rlp_03/channel/context/Ingress.java b/src/main/java/com/teragrep/net_01/channel/context/Ingress.java similarity index 98% rename from src/main/java/com/teragrep/rlp_03/channel/context/Ingress.java rename to src/main/java/com/teragrep/net_01/channel/context/Ingress.java index e925855d..181238dc 100644 --- a/src/main/java/com/teragrep/rlp_03/channel/context/Ingress.java +++ b/src/main/java/com/teragrep/net_01/channel/context/Ingress.java @@ -43,7 +43,7 @@ * Teragrep, the applicable Commercial License may apply to this file if you as * a licensee so wish it. */ -package com.teragrep.rlp_03.channel.context; +package com.teragrep.net_01.channel.context; import java.util.concurrent.atomic.AtomicBoolean; diff --git a/src/main/java/com/teragrep/rlp_03/channel/context/IngressImpl.java b/src/main/java/com/teragrep/net_01/channel/context/IngressImpl.java similarity index 98% rename from src/main/java/com/teragrep/rlp_03/channel/context/IngressImpl.java rename to src/main/java/com/teragrep/net_01/channel/context/IngressImpl.java index c58b0bca..3d1fdb70 100644 --- a/src/main/java/com/teragrep/rlp_03/channel/context/IngressImpl.java +++ b/src/main/java/com/teragrep/net_01/channel/context/IngressImpl.java @@ -43,10 +43,10 @@ * Teragrep, the applicable Commercial License may apply to this file if you as * a licensee so wish it. */ -package com.teragrep.rlp_03.channel.context; +package com.teragrep.net_01.channel.context; -import com.teragrep.rlp_03.channel.buffer.BufferLease; -import com.teragrep.rlp_03.channel.buffer.BufferLeasePool; +import com.teragrep.net_01.channel.buffer.BufferLease; +import com.teragrep.net_01.channel.buffer.BufferLeasePool; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import tlschannel.NeedsReadException; diff --git a/src/main/java/com/teragrep/rlp_03/channel/context/InterestOps.java b/src/main/java/com/teragrep/net_01/channel/context/InterestOps.java similarity index 98% rename from src/main/java/com/teragrep/rlp_03/channel/context/InterestOps.java rename to src/main/java/com/teragrep/net_01/channel/context/InterestOps.java index 1f93fcf0..2b855b60 100644 --- a/src/main/java/com/teragrep/rlp_03/channel/context/InterestOps.java +++ b/src/main/java/com/teragrep/net_01/channel/context/InterestOps.java @@ -43,7 +43,7 @@ * Teragrep, the applicable Commercial License may apply to this file if you as * a licensee so wish it. */ -package com.teragrep.rlp_03.channel.context; +package com.teragrep.net_01.channel.context; import java.nio.channels.SelectionKey; diff --git a/src/main/java/com/teragrep/rlp_03/channel/context/InterestOpsImpl.java b/src/main/java/com/teragrep/net_01/channel/context/InterestOpsImpl.java similarity index 99% rename from src/main/java/com/teragrep/rlp_03/channel/context/InterestOpsImpl.java rename to src/main/java/com/teragrep/net_01/channel/context/InterestOpsImpl.java index deebca8a..c19c7487 100644 --- a/src/main/java/com/teragrep/rlp_03/channel/context/InterestOpsImpl.java +++ b/src/main/java/com/teragrep/net_01/channel/context/InterestOpsImpl.java @@ -43,7 +43,7 @@ * Teragrep, the applicable Commercial License may apply to this file if you as * a licensee so wish it. */ -package com.teragrep.rlp_03.channel.context; +package com.teragrep.net_01.channel.context; import org.slf4j.Logger; import org.slf4j.LoggerFactory; diff --git a/src/main/java/com/teragrep/rlp_03/channel/context/ListenContext.java b/src/main/java/com/teragrep/net_01/channel/context/ListenContext.java similarity index 97% rename from src/main/java/com/teragrep/rlp_03/channel/context/ListenContext.java rename to src/main/java/com/teragrep/net_01/channel/context/ListenContext.java index 7162ad30..d9ed554c 100644 --- a/src/main/java/com/teragrep/rlp_03/channel/context/ListenContext.java +++ b/src/main/java/com/teragrep/net_01/channel/context/ListenContext.java @@ -43,11 +43,11 @@ * Teragrep, the applicable Commercial License may apply to this file if you as * a licensee so wish it. */ -package com.teragrep.rlp_03.channel.context; +package com.teragrep.net_01.channel.context; -import com.teragrep.rlp_03.channel.socket.Socket; -import com.teragrep.rlp_03.channel.socket.SocketFactory; -import com.teragrep.rlp_03.eventloop.EventLoop; +import com.teragrep.net_01.channel.socket.Socket; +import com.teragrep.net_01.channel.socket.SocketFactory; +import com.teragrep.net_01.eventloop.EventLoop; import org.slf4j.Logger; import org.slf4j.LoggerFactory; diff --git a/src/main/java/com/teragrep/rlp_03/channel/context/ListenContextFactory.java b/src/main/java/com/teragrep/net_01/channel/context/ListenContextFactory.java similarity index 95% rename from src/main/java/com/teragrep/rlp_03/channel/context/ListenContextFactory.java rename to src/main/java/com/teragrep/net_01/channel/context/ListenContextFactory.java index 0d20d620..36f53ca8 100644 --- a/src/main/java/com/teragrep/rlp_03/channel/context/ListenContextFactory.java +++ b/src/main/java/com/teragrep/net_01/channel/context/ListenContextFactory.java @@ -43,10 +43,10 @@ * Teragrep, the applicable Commercial License may apply to this file if you as * a licensee so wish it. */ -package com.teragrep.rlp_03.channel.context; +package com.teragrep.net_01.channel.context; -import com.teragrep.rlp_03.channel.socket.SocketFactory; -import com.teragrep.rlp_03.eventloop.EventLoop; +import com.teragrep.net_01.channel.socket.SocketFactory; +import com.teragrep.net_01.eventloop.EventLoop; import java.io.IOException; import java.net.InetSocketAddress; diff --git a/src/main/java/com/teragrep/rlp_03/channel/socket/EncryptionInfo.java b/src/main/java/com/teragrep/net_01/channel/socket/EncryptionInfo.java similarity index 96% rename from src/main/java/com/teragrep/rlp_03/channel/socket/EncryptionInfo.java rename to src/main/java/com/teragrep/net_01/channel/socket/EncryptionInfo.java index c1fb5132..0e750461 100644 --- a/src/main/java/com/teragrep/rlp_03/channel/socket/EncryptionInfo.java +++ b/src/main/java/com/teragrep/net_01/channel/socket/EncryptionInfo.java @@ -43,7 +43,7 @@ * Teragrep, the applicable Commercial License may apply to this file if you as * a licensee so wish it. */ -package com.teragrep.rlp_03.channel.socket; +package com.teragrep.net_01.channel.socket; import javax.net.ssl.SSLPeerUnverifiedException; import javax.net.ssl.SSLSession; @@ -52,7 +52,7 @@ import java.security.cert.Certificate; /** - * Provides information about a {@link com.teragrep.rlp_03.channel.socket.Socket} encryption status. + * Provides information about a {@link Socket} encryption status. */ public interface EncryptionInfo { diff --git a/src/main/java/com/teragrep/rlp_03/channel/socket/EncryptionInfoStub.java b/src/main/java/com/teragrep/net_01/channel/socket/EncryptionInfoStub.java similarity index 97% rename from src/main/java/com/teragrep/rlp_03/channel/socket/EncryptionInfoStub.java rename to src/main/java/com/teragrep/net_01/channel/socket/EncryptionInfoStub.java index 4aaec98f..95e9380c 100644 --- a/src/main/java/com/teragrep/rlp_03/channel/socket/EncryptionInfoStub.java +++ b/src/main/java/com/teragrep/net_01/channel/socket/EncryptionInfoStub.java @@ -43,7 +43,7 @@ * Teragrep, the applicable Commercial License may apply to this file if you as * a licensee so wish it. */ -package com.teragrep.rlp_03.channel.socket; +package com.teragrep.net_01.channel.socket; import javax.net.ssl.SSLPeerUnverifiedException; import javax.security.cert.X509Certificate; @@ -51,7 +51,7 @@ import java.security.cert.Certificate; /** - * Stub implementation of {@link EncryptionInfo} which is used by {@link com.teragrep.rlp_03.channel.socket.PlainSocket} + * Stub implementation of {@link EncryptionInfo} which is used by {@link PlainSocket} */ final class EncryptionInfoStub implements EncryptionInfo { diff --git a/src/main/java/com/teragrep/rlp_03/channel/socket/EncryptionInfoTLS.java b/src/main/java/com/teragrep/net_01/channel/socket/EncryptionInfoTLS.java similarity index 98% rename from src/main/java/com/teragrep/rlp_03/channel/socket/EncryptionInfoTLS.java rename to src/main/java/com/teragrep/net_01/channel/socket/EncryptionInfoTLS.java index f76c9aae..636684a9 100644 --- a/src/main/java/com/teragrep/rlp_03/channel/socket/EncryptionInfoTLS.java +++ b/src/main/java/com/teragrep/net_01/channel/socket/EncryptionInfoTLS.java @@ -43,7 +43,7 @@ * Teragrep, the applicable Commercial License may apply to this file if you as * a licensee so wish it. */ -package com.teragrep.rlp_03.channel.socket; +package com.teragrep.net_01.channel.socket; import tlschannel.TlsChannel; diff --git a/src/main/java/com/teragrep/rlp_03/channel/socket/PlainFactory.java b/src/main/java/com/teragrep/net_01/channel/socket/PlainFactory.java similarity index 98% rename from src/main/java/com/teragrep/rlp_03/channel/socket/PlainFactory.java rename to src/main/java/com/teragrep/net_01/channel/socket/PlainFactory.java index 7f8a6a1a..c281cc1d 100644 --- a/src/main/java/com/teragrep/rlp_03/channel/socket/PlainFactory.java +++ b/src/main/java/com/teragrep/net_01/channel/socket/PlainFactory.java @@ -43,7 +43,7 @@ * Teragrep, the applicable Commercial License may apply to this file if you as * a licensee so wish it. */ -package com.teragrep.rlp_03.channel.socket; +package com.teragrep.net_01.channel.socket; import java.nio.channels.SocketChannel; diff --git a/src/main/java/com/teragrep/rlp_03/channel/socket/PlainSocket.java b/src/main/java/com/teragrep/net_01/channel/socket/PlainSocket.java similarity index 98% rename from src/main/java/com/teragrep/rlp_03/channel/socket/PlainSocket.java rename to src/main/java/com/teragrep/net_01/channel/socket/PlainSocket.java index 0a1226c6..f274f7f6 100644 --- a/src/main/java/com/teragrep/rlp_03/channel/socket/PlainSocket.java +++ b/src/main/java/com/teragrep/net_01/channel/socket/PlainSocket.java @@ -43,7 +43,7 @@ * Teragrep, the applicable Commercial License may apply to this file if you as * a licensee so wish it. */ -package com.teragrep.rlp_03.channel.socket; +package com.teragrep.net_01.channel.socket; import java.io.IOException; import java.nio.ByteBuffer; diff --git a/src/main/java/com/teragrep/rlp_03/channel/socket/Socket.java b/src/main/java/com/teragrep/net_01/channel/socket/Socket.java similarity index 98% rename from src/main/java/com/teragrep/rlp_03/channel/socket/Socket.java rename to src/main/java/com/teragrep/net_01/channel/socket/Socket.java index f81a5b86..ddc45e11 100644 --- a/src/main/java/com/teragrep/rlp_03/channel/socket/Socket.java +++ b/src/main/java/com/teragrep/net_01/channel/socket/Socket.java @@ -43,7 +43,7 @@ * Teragrep, the applicable Commercial License may apply to this file if you as * a licensee so wish it. */ -package com.teragrep.rlp_03.channel.socket; +package com.teragrep.net_01.channel.socket; import java.io.IOException; import java.nio.ByteBuffer; diff --git a/src/main/java/com/teragrep/rlp_03/channel/socket/SocketFactory.java b/src/main/java/com/teragrep/net_01/channel/socket/SocketFactory.java similarity index 98% rename from src/main/java/com/teragrep/rlp_03/channel/socket/SocketFactory.java rename to src/main/java/com/teragrep/net_01/channel/socket/SocketFactory.java index 616b5664..09283c11 100644 --- a/src/main/java/com/teragrep/rlp_03/channel/socket/SocketFactory.java +++ b/src/main/java/com/teragrep/net_01/channel/socket/SocketFactory.java @@ -43,7 +43,7 @@ * Teragrep, the applicable Commercial License may apply to this file if you as * a licensee so wish it. */ -package com.teragrep.rlp_03.channel.socket; +package com.teragrep.net_01.channel.socket; import java.nio.channels.SocketChannel; diff --git a/src/main/java/com/teragrep/rlp_03/channel/socket/TLSFactory.java b/src/main/java/com/teragrep/net_01/channel/socket/TLSFactory.java similarity index 98% rename from src/main/java/com/teragrep/rlp_03/channel/socket/TLSFactory.java rename to src/main/java/com/teragrep/net_01/channel/socket/TLSFactory.java index 4d707579..37791102 100644 --- a/src/main/java/com/teragrep/rlp_03/channel/socket/TLSFactory.java +++ b/src/main/java/com/teragrep/net_01/channel/socket/TLSFactory.java @@ -43,7 +43,7 @@ * Teragrep, the applicable Commercial License may apply to this file if you as * a licensee so wish it. */ -package com.teragrep.rlp_03.channel.socket; +package com.teragrep.net_01.channel.socket; import tlschannel.ServerTlsChannel; import tlschannel.TlsChannel; diff --git a/src/main/java/com/teragrep/rlp_03/channel/socket/TLSSocket.java b/src/main/java/com/teragrep/net_01/channel/socket/TLSSocket.java similarity index 98% rename from src/main/java/com/teragrep/rlp_03/channel/socket/TLSSocket.java rename to src/main/java/com/teragrep/net_01/channel/socket/TLSSocket.java index 0e12f7e5..f28698b4 100644 --- a/src/main/java/com/teragrep/rlp_03/channel/socket/TLSSocket.java +++ b/src/main/java/com/teragrep/net_01/channel/socket/TLSSocket.java @@ -43,7 +43,7 @@ * Teragrep, the applicable Commercial License may apply to this file if you as * a licensee so wish it. */ -package com.teragrep.rlp_03.channel.socket; +package com.teragrep.net_01.channel.socket; import tlschannel.TlsChannel; diff --git a/src/main/java/com/teragrep/rlp_03/channel/socket/TransportInfo.java b/src/main/java/com/teragrep/net_01/channel/socket/TransportInfo.java similarity index 95% rename from src/main/java/com/teragrep/rlp_03/channel/socket/TransportInfo.java rename to src/main/java/com/teragrep/net_01/channel/socket/TransportInfo.java index 1b662dcd..1b2e8441 100644 --- a/src/main/java/com/teragrep/rlp_03/channel/socket/TransportInfo.java +++ b/src/main/java/com/teragrep/net_01/channel/socket/TransportInfo.java @@ -43,10 +43,10 @@ * Teragrep, the applicable Commercial License may apply to this file if you as * a licensee so wish it. */ -package com.teragrep.rlp_03.channel.socket; +package com.teragrep.net_01.channel.socket; /** - * Provides information about a {@link com.teragrep.rlp_03.channel.socket.Socket} transport. + * Provides information about a {@link Socket} transport. */ public interface TransportInfo { diff --git a/src/main/java/com/teragrep/rlp_03/channel/socket/TransportInfoImpl.java b/src/main/java/com/teragrep/net_01/channel/socket/TransportInfoImpl.java similarity index 98% rename from src/main/java/com/teragrep/rlp_03/channel/socket/TransportInfoImpl.java rename to src/main/java/com/teragrep/net_01/channel/socket/TransportInfoImpl.java index 077ae880..7aa2ce7e 100644 --- a/src/main/java/com/teragrep/rlp_03/channel/socket/TransportInfoImpl.java +++ b/src/main/java/com/teragrep/net_01/channel/socket/TransportInfoImpl.java @@ -43,7 +43,7 @@ * Teragrep, the applicable Commercial License may apply to this file if you as * a licensee so wish it. */ -package com.teragrep.rlp_03.channel.socket; +package com.teragrep.net_01.channel.socket; import java.nio.channels.SocketChannel; diff --git a/src/main/java/com/teragrep/rlp_03/eventloop/EventLoop.java b/src/main/java/com/teragrep/net_01/eventloop/EventLoop.java similarity index 96% rename from src/main/java/com/teragrep/rlp_03/eventloop/EventLoop.java rename to src/main/java/com/teragrep/net_01/eventloop/EventLoop.java index 05c5f9f8..646dbe44 100644 --- a/src/main/java/com/teragrep/rlp_03/eventloop/EventLoop.java +++ b/src/main/java/com/teragrep/net_01/eventloop/EventLoop.java @@ -43,12 +43,12 @@ * Teragrep, the applicable Commercial License may apply to this file if you as * a licensee so wish it. */ -package com.teragrep.rlp_03.eventloop; +package com.teragrep.net_01.eventloop; -import com.teragrep.rlp_03.channel.context.ConnectContext; -import com.teragrep.rlp_03.channel.context.EstablishedContext; -import com.teragrep.rlp_03.channel.context.Context; -import com.teragrep.rlp_03.channel.context.ListenContext; +import com.teragrep.net_01.channel.context.ConnectContext; +import com.teragrep.net_01.channel.context.EstablishedContext; +import com.teragrep.net_01.channel.context.Context; +import com.teragrep.net_01.channel.context.ListenContext; import org.slf4j.Logger; import org.slf4j.LoggerFactory; diff --git a/src/main/java/com/teragrep/rlp_03/eventloop/EventLoopFactory.java b/src/main/java/com/teragrep/net_01/eventloop/EventLoopFactory.java similarity index 98% rename from src/main/java/com/teragrep/rlp_03/eventloop/EventLoopFactory.java rename to src/main/java/com/teragrep/net_01/eventloop/EventLoopFactory.java index 34825f78..1c2f0bb7 100644 --- a/src/main/java/com/teragrep/rlp_03/eventloop/EventLoopFactory.java +++ b/src/main/java/com/teragrep/net_01/eventloop/EventLoopFactory.java @@ -43,7 +43,7 @@ * Teragrep, the applicable Commercial License may apply to this file if you as * a licensee so wish it. */ -package com.teragrep.rlp_03.eventloop; +package com.teragrep.net_01.eventloop; import java.io.IOException; import java.nio.channels.Selector; diff --git a/src/main/java/com/teragrep/rlp_03/server/Server.java b/src/main/java/com/teragrep/net_01/server/Server.java similarity index 94% rename from src/main/java/com/teragrep/rlp_03/server/Server.java rename to src/main/java/com/teragrep/net_01/server/Server.java index aa77a704..efdc07fe 100644 --- a/src/main/java/com/teragrep/rlp_03/server/Server.java +++ b/src/main/java/com/teragrep/net_01/server/Server.java @@ -43,10 +43,10 @@ * Teragrep, the applicable Commercial License may apply to this file if you as * a licensee so wish it. */ -package com.teragrep.rlp_03.server; +package com.teragrep.net_01.server; -import com.teragrep.rlp_03.channel.context.ListenContext; -import com.teragrep.rlp_03.eventloop.EventLoop; +import com.teragrep.net_01.channel.context.ListenContext; +import com.teragrep.net_01.eventloop.EventLoop; import java.io.Closeable; import java.io.IOException; diff --git a/src/main/java/com/teragrep/rlp_03/server/ServerFactory.java b/src/main/java/com/teragrep/net_01/server/ServerFactory.java similarity index 92% rename from src/main/java/com/teragrep/rlp_03/server/ServerFactory.java rename to src/main/java/com/teragrep/net_01/server/ServerFactory.java index d7290b14..8f42c196 100644 --- a/src/main/java/com/teragrep/rlp_03/server/ServerFactory.java +++ b/src/main/java/com/teragrep/net_01/server/ServerFactory.java @@ -43,13 +43,13 @@ * Teragrep, the applicable Commercial License may apply to this file if you as * a licensee so wish it. */ -package com.teragrep.rlp_03.server; +package com.teragrep.net_01.server; -import com.teragrep.rlp_03.channel.context.ClockFactory; -import com.teragrep.rlp_03.eventloop.EventLoop; -import com.teragrep.rlp_03.channel.context.ListenContext; -import com.teragrep.rlp_03.channel.context.ListenContextFactory; -import com.teragrep.rlp_03.channel.socket.SocketFactory; +import com.teragrep.net_01.channel.context.ClockFactory; +import com.teragrep.net_01.eventloop.EventLoop; +import com.teragrep.net_01.channel.context.ListenContext; +import com.teragrep.net_01.channel.context.ListenContextFactory; +import com.teragrep.net_01.channel.socket.SocketFactory; import org.slf4j.Logger; import org.slf4j.LoggerFactory; diff --git a/src/main/java/com/teragrep/rlp_03/client/ClientDelegate.java b/src/main/java/com/teragrep/rlp_03/client/ClientDelegate.java index a3dce7b3..ba3c4191 100644 --- a/src/main/java/com/teragrep/rlp_03/client/ClientDelegate.java +++ b/src/main/java/com/teragrep/rlp_03/client/ClientDelegate.java @@ -46,7 +46,7 @@ package com.teragrep.rlp_03.client; import com.teragrep.rlp_03.frame.delegate.FrameContext; -import com.teragrep.rlp_03.channel.context.EstablishedContext; +import com.teragrep.net_01.channel.context.EstablishedContext; import com.teragrep.rlp_03.frame.delegate.FrameDelegate; import org.slf4j.Logger; import org.slf4j.LoggerFactory; diff --git a/src/main/java/com/teragrep/rlp_03/client/ClientFactory.java b/src/main/java/com/teragrep/rlp_03/client/ClientFactory.java index 433c6185..3ea607b0 100644 --- a/src/main/java/com/teragrep/rlp_03/client/ClientFactory.java +++ b/src/main/java/com/teragrep/rlp_03/client/ClientFactory.java @@ -45,10 +45,10 @@ */ package com.teragrep.rlp_03.client; -import com.teragrep.rlp_03.channel.context.ConnectContext; -import com.teragrep.rlp_03.channel.context.ConnectContextFactory; -import com.teragrep.rlp_03.channel.context.EstablishedContext; -import com.teragrep.rlp_03.eventloop.EventLoop; +import com.teragrep.net_01.channel.context.ConnectContext; +import com.teragrep.net_01.channel.context.ConnectContextFactory; +import com.teragrep.net_01.channel.context.EstablishedContext; +import com.teragrep.net_01.eventloop.EventLoop; import com.teragrep.rlp_03.frame.FrameDelegationClockFactory; import org.slf4j.Logger; import org.slf4j.LoggerFactory; diff --git a/src/main/java/com/teragrep/rlp_03/client/ClientImpl.java b/src/main/java/com/teragrep/rlp_03/client/ClientImpl.java index e3919bb5..4df944ed 100644 --- a/src/main/java/com/teragrep/rlp_03/client/ClientImpl.java +++ b/src/main/java/com/teragrep/rlp_03/client/ClientImpl.java @@ -45,7 +45,7 @@ */ package com.teragrep.rlp_03.client; -import com.teragrep.rlp_03.channel.context.EstablishedContext; +import com.teragrep.net_01.channel.context.EstablishedContext; import com.teragrep.rlp_03.frame.RelpFrame; import com.teragrep.rlp_03.frame.RelpFrameImpl; import com.teragrep.rlp_03.frame.fragment.Fragment; diff --git a/src/main/java/com/teragrep/rlp_03/frame/FrameClockLeaseful.java b/src/main/java/com/teragrep/rlp_03/frame/FrameClockLeaseful.java index 18528e83..83f12db8 100644 --- a/src/main/java/com/teragrep/rlp_03/frame/FrameClockLeaseful.java +++ b/src/main/java/com/teragrep/rlp_03/frame/FrameClockLeaseful.java @@ -45,7 +45,7 @@ */ package com.teragrep.rlp_03.frame; -import com.teragrep.rlp_03.channel.buffer.BufferLease; +import com.teragrep.net_01.channel.buffer.BufferLease; import java.util.ArrayList; import java.util.Collections; diff --git a/src/main/java/com/teragrep/rlp_03/frame/FrameDelegationClock.java b/src/main/java/com/teragrep/rlp_03/frame/FrameDelegationClock.java index dac33023..46e0955e 100644 --- a/src/main/java/com/teragrep/rlp_03/frame/FrameDelegationClock.java +++ b/src/main/java/com/teragrep/rlp_03/frame/FrameDelegationClock.java @@ -45,10 +45,10 @@ */ package com.teragrep.rlp_03.frame; -import com.teragrep.rlp_03.channel.buffer.BufferLease; +import com.teragrep.net_01.channel.buffer.BufferLease; -import com.teragrep.rlp_03.channel.context.Clock; -import com.teragrep.rlp_03.channel.context.EstablishedContext; +import com.teragrep.net_01.channel.context.Clock; +import com.teragrep.net_01.channel.context.EstablishedContext; import com.teragrep.rlp_03.frame.delegate.FrameContext; import com.teragrep.rlp_03.frame.delegate.FrameDelegate; import org.slf4j.Logger; diff --git a/src/main/java/com/teragrep/rlp_03/frame/FrameDelegationClockFactory.java b/src/main/java/com/teragrep/rlp_03/frame/FrameDelegationClockFactory.java index 9757e063..d256087d 100644 --- a/src/main/java/com/teragrep/rlp_03/frame/FrameDelegationClockFactory.java +++ b/src/main/java/com/teragrep/rlp_03/frame/FrameDelegationClockFactory.java @@ -45,9 +45,9 @@ */ package com.teragrep.rlp_03.frame; -import com.teragrep.rlp_03.channel.context.Clock; -import com.teragrep.rlp_03.channel.context.ClockFactory; -import com.teragrep.rlp_03.channel.context.EstablishedContext; +import com.teragrep.net_01.channel.context.Clock; +import com.teragrep.net_01.channel.context.ClockFactory; +import com.teragrep.net_01.channel.context.EstablishedContext; import com.teragrep.rlp_03.frame.delegate.FrameDelegate; import java.util.function.Supplier; diff --git a/src/main/java/com/teragrep/rlp_03/frame/RelpFrame.java b/src/main/java/com/teragrep/rlp_03/frame/RelpFrame.java index 5c9c82cd..3630632e 100644 --- a/src/main/java/com/teragrep/rlp_03/frame/RelpFrame.java +++ b/src/main/java/com/teragrep/rlp_03/frame/RelpFrame.java @@ -45,7 +45,7 @@ */ package com.teragrep.rlp_03.frame; -import com.teragrep.rlp_03.channel.buffer.writable.Writeable; +import com.teragrep.net_01.channel.buffer.writable.Writeable; import com.teragrep.rlp_03.frame.fragment.Fragment; public interface RelpFrame extends AutoCloseable { diff --git a/src/main/java/com/teragrep/rlp_03/frame/RelpFrameAccess.java b/src/main/java/com/teragrep/rlp_03/frame/RelpFrameAccess.java index 0c40cb80..2ddbde5a 100644 --- a/src/main/java/com/teragrep/rlp_03/frame/RelpFrameAccess.java +++ b/src/main/java/com/teragrep/rlp_03/frame/RelpFrameAccess.java @@ -45,9 +45,9 @@ */ package com.teragrep.rlp_03.frame; -import com.teragrep.rlp_03.channel.buffer.writable.Writeable; -import com.teragrep.rlp_03.channel.buffer.writable.WriteableAccess; -import com.teragrep.rlp_03.frame.access.Access; +import com.teragrep.net_01.channel.buffer.writable.Writeable; +import com.teragrep.net_01.channel.buffer.writable.WriteableAccess; +import com.teragrep.net_01.channel.buffer.access.Access; import com.teragrep.rlp_03.frame.fragment.Fragment; import com.teragrep.rlp_03.frame.fragment.FragmentAccess; diff --git a/src/main/java/com/teragrep/rlp_03/frame/RelpFrameImpl.java b/src/main/java/com/teragrep/rlp_03/frame/RelpFrameImpl.java index 8e497a2b..8f6dc214 100644 --- a/src/main/java/com/teragrep/rlp_03/frame/RelpFrameImpl.java +++ b/src/main/java/com/teragrep/rlp_03/frame/RelpFrameImpl.java @@ -45,8 +45,8 @@ */ package com.teragrep.rlp_03.frame; -import com.teragrep.rlp_03.channel.buffer.writable.Writeable; -import com.teragrep.rlp_03.channel.buffer.writable.Writeables; +import com.teragrep.net_01.channel.buffer.writable.Writeable; +import com.teragrep.net_01.channel.buffer.writable.Writeables; import com.teragrep.rlp_03.frame.fragment.Fragment; import com.teragrep.rlp_03.frame.fragment.FragmentFactory; diff --git a/src/main/java/com/teragrep/rlp_03/frame/RelpFrameLeaseful.java b/src/main/java/com/teragrep/rlp_03/frame/RelpFrameLeaseful.java index 1c48d91e..dbb1d8a7 100644 --- a/src/main/java/com/teragrep/rlp_03/frame/RelpFrameLeaseful.java +++ b/src/main/java/com/teragrep/rlp_03/frame/RelpFrameLeaseful.java @@ -45,10 +45,10 @@ */ package com.teragrep.rlp_03.frame; -import com.teragrep.rlp_03.channel.buffer.BufferLease; -import com.teragrep.rlp_03.channel.buffer.writable.Writeable; -import com.teragrep.rlp_03.channel.buffer.writable.WriteableInvalidation; -import com.teragrep.rlp_03.channel.buffer.writable.WriteableLeaseful; +import com.teragrep.net_01.channel.buffer.BufferLease; +import com.teragrep.net_01.channel.buffer.writable.Writeable; +import com.teragrep.net_01.channel.buffer.writable.WriteableInvalidation; +import com.teragrep.net_01.channel.buffer.writable.WriteableLeaseful; import com.teragrep.rlp_03.frame.fragment.Fragment; import org.slf4j.Logger; import org.slf4j.LoggerFactory; diff --git a/src/main/java/com/teragrep/rlp_03/frame/RelpFrameStub.java b/src/main/java/com/teragrep/rlp_03/frame/RelpFrameStub.java index a2e671ec..9178c99c 100644 --- a/src/main/java/com/teragrep/rlp_03/frame/RelpFrameStub.java +++ b/src/main/java/com/teragrep/rlp_03/frame/RelpFrameStub.java @@ -45,7 +45,7 @@ */ package com.teragrep.rlp_03.frame; -import com.teragrep.rlp_03.channel.buffer.writable.Writeable; +import com.teragrep.net_01.channel.buffer.writable.Writeable; import com.teragrep.rlp_03.frame.fragment.Fragment; public final class RelpFrameStub implements RelpFrame { diff --git a/src/main/java/com/teragrep/rlp_03/frame/delegate/FrameContext.java b/src/main/java/com/teragrep/rlp_03/frame/delegate/FrameContext.java index e236d58d..475f6be3 100644 --- a/src/main/java/com/teragrep/rlp_03/frame/delegate/FrameContext.java +++ b/src/main/java/com/teragrep/rlp_03/frame/delegate/FrameContext.java @@ -45,7 +45,7 @@ */ package com.teragrep.rlp_03.frame.delegate; -import com.teragrep.rlp_03.channel.context.EstablishedContext; +import com.teragrep.net_01.channel.context.EstablishedContext; import com.teragrep.rlp_03.frame.RelpFrame; public final class FrameContext { diff --git a/src/main/java/com/teragrep/rlp_03/frame/delegate/event/RelpEventClose.java b/src/main/java/com/teragrep/rlp_03/frame/delegate/event/RelpEventClose.java index eb1b1f66..06057eb6 100644 --- a/src/main/java/com/teragrep/rlp_03/frame/delegate/event/RelpEventClose.java +++ b/src/main/java/com/teragrep/rlp_03/frame/delegate/event/RelpEventClose.java @@ -45,11 +45,11 @@ */ package com.teragrep.rlp_03.frame.delegate.event; -import com.teragrep.rlp_03.channel.buffer.writable.Writeable; -import com.teragrep.rlp_03.channel.buffer.writable.WriteableClosure; +import com.teragrep.net_01.channel.buffer.writable.Writeable; +import com.teragrep.net_01.channel.buffer.writable.WriteableClosure; import com.teragrep.rlp_03.frame.RelpFrame; import com.teragrep.rlp_03.frame.RelpFrameImpl; -import com.teragrep.rlp_03.channel.buffer.writable.Writeables; +import com.teragrep.net_01.channel.buffer.writable.Writeables; import com.teragrep.rlp_03.frame.delegate.FrameContext; import com.teragrep.rlp_03.frame.fragment.Fragment; import com.teragrep.rlp_03.frame.fragment.FragmentFactory; diff --git a/src/main/java/com/teragrep/rlp_03/frame/delegate/event/RelpEventServerClose.java b/src/main/java/com/teragrep/rlp_03/frame/delegate/event/RelpEventServerClose.java index 07fcc78e..290c3725 100644 --- a/src/main/java/com/teragrep/rlp_03/frame/delegate/event/RelpEventServerClose.java +++ b/src/main/java/com/teragrep/rlp_03/frame/delegate/event/RelpEventServerClose.java @@ -45,8 +45,8 @@ */ package com.teragrep.rlp_03.frame.delegate.event; -import com.teragrep.rlp_03.channel.buffer.writable.Writeable; -import com.teragrep.rlp_03.channel.buffer.writable.WriteableClosure; +import com.teragrep.net_01.channel.buffer.writable.Writeable; +import com.teragrep.net_01.channel.buffer.writable.WriteableClosure; import com.teragrep.rlp_03.frame.RelpFrame; import com.teragrep.rlp_03.frame.RelpFrameImpl; import com.teragrep.rlp_03.frame.delegate.FrameContext; diff --git a/src/main/java/com/teragrep/rlp_03/frame/fragment/Fragment.java b/src/main/java/com/teragrep/rlp_03/frame/fragment/Fragment.java index 6d8d519f..766b41ff 100644 --- a/src/main/java/com/teragrep/rlp_03/frame/fragment/Fragment.java +++ b/src/main/java/com/teragrep/rlp_03/frame/fragment/Fragment.java @@ -45,7 +45,7 @@ */ package com.teragrep.rlp_03.frame.fragment; -import com.teragrep.rlp_03.channel.buffer.writable.Writeable; +import com.teragrep.net_01.channel.buffer.writable.Writeable; public interface Fragment { diff --git a/src/main/java/com/teragrep/rlp_03/frame/fragment/FragmentAccess.java b/src/main/java/com/teragrep/rlp_03/frame/fragment/FragmentAccess.java index 08503d68..225fd3c2 100644 --- a/src/main/java/com/teragrep/rlp_03/frame/fragment/FragmentAccess.java +++ b/src/main/java/com/teragrep/rlp_03/frame/fragment/FragmentAccess.java @@ -45,10 +45,10 @@ */ package com.teragrep.rlp_03.frame.fragment; -import com.teragrep.rlp_03.channel.buffer.writable.Writeable; -import com.teragrep.rlp_03.channel.buffer.writable.WriteableAccess; -import com.teragrep.rlp_03.frame.access.Access; -import com.teragrep.rlp_03.frame.access.Lease; +import com.teragrep.net_01.channel.buffer.writable.Writeable; +import com.teragrep.net_01.channel.buffer.writable.WriteableAccess; +import com.teragrep.net_01.channel.buffer.access.Access; +import com.teragrep.net_01.channel.buffer.access.Lease; public final class FragmentAccess implements Fragment { diff --git a/src/main/java/com/teragrep/rlp_03/frame/fragment/FragmentByteStreamAccess.java b/src/main/java/com/teragrep/rlp_03/frame/fragment/FragmentByteStreamAccess.java index fb6a3438..5cd74662 100644 --- a/src/main/java/com/teragrep/rlp_03/frame/fragment/FragmentByteStreamAccess.java +++ b/src/main/java/com/teragrep/rlp_03/frame/fragment/FragmentByteStreamAccess.java @@ -45,8 +45,8 @@ */ package com.teragrep.rlp_03.frame.fragment; -import com.teragrep.rlp_03.frame.access.Access; -import com.teragrep.rlp_03.frame.access.Lease; +import com.teragrep.net_01.channel.buffer.access.Access; +import com.teragrep.net_01.channel.buffer.access.Lease; // TODO tests public final class FragmentByteStreamAccess implements FragmentByteStream { diff --git a/src/main/java/com/teragrep/rlp_03/frame/fragment/FragmentImpl.java b/src/main/java/com/teragrep/rlp_03/frame/fragment/FragmentImpl.java index b8186c10..1a71d8f5 100644 --- a/src/main/java/com/teragrep/rlp_03/frame/fragment/FragmentImpl.java +++ b/src/main/java/com/teragrep/rlp_03/frame/fragment/FragmentImpl.java @@ -45,7 +45,7 @@ */ package com.teragrep.rlp_03.frame.fragment; -import com.teragrep.rlp_03.channel.buffer.writable.Writeable; +import com.teragrep.net_01.channel.buffer.writable.Writeable; import java.nio.ByteBuffer; import java.nio.charset.StandardCharsets; diff --git a/src/main/java/com/teragrep/rlp_03/frame/fragment/FragmentStub.java b/src/main/java/com/teragrep/rlp_03/frame/fragment/FragmentStub.java index eea285bc..cffde1e8 100644 --- a/src/main/java/com/teragrep/rlp_03/frame/fragment/FragmentStub.java +++ b/src/main/java/com/teragrep/rlp_03/frame/fragment/FragmentStub.java @@ -45,7 +45,7 @@ */ package com.teragrep.rlp_03.frame.fragment; -import com.teragrep.rlp_03.channel.buffer.writable.Writeable; +import com.teragrep.net_01.channel.buffer.writable.Writeable; public final class FragmentStub implements Fragment { diff --git a/src/main/java/com/teragrep/rlp_03/frame/fragment/FragmentWriteImpl.java b/src/main/java/com/teragrep/rlp_03/frame/fragment/FragmentWriteImpl.java index d117c977..c47ade20 100644 --- a/src/main/java/com/teragrep/rlp_03/frame/fragment/FragmentWriteImpl.java +++ b/src/main/java/com/teragrep/rlp_03/frame/fragment/FragmentWriteImpl.java @@ -45,7 +45,7 @@ */ package com.teragrep.rlp_03.frame.fragment; -import com.teragrep.rlp_03.channel.buffer.writable.Writeable; +import com.teragrep.net_01.channel.buffer.writable.Writeable; import java.nio.ByteBuffer; diff --git a/src/test/java/com/teragrep/rlp_03/channel/context/EgressFake.java b/src/test/java/com/teragrep/net_01/channel/context/EgressFake.java similarity index 96% rename from src/test/java/com/teragrep/rlp_03/channel/context/EgressFake.java rename to src/test/java/com/teragrep/net_01/channel/context/EgressFake.java index 62a49927..2fa47797 100644 --- a/src/test/java/com/teragrep/rlp_03/channel/context/EgressFake.java +++ b/src/test/java/com/teragrep/net_01/channel/context/EgressFake.java @@ -43,9 +43,9 @@ * Teragrep, the applicable Commercial License may apply to this file if you as * a licensee so wish it. */ -package com.teragrep.rlp_03.channel.context; +package com.teragrep.net_01.channel.context; -import com.teragrep.rlp_03.channel.buffer.writable.Writeable; +import com.teragrep.net_01.channel.buffer.writable.Writeable; import java.util.LinkedList; import java.util.List; diff --git a/src/test/java/com/teragrep/rlp_03/channel/context/EstablishedContextFake.java b/src/test/java/com/teragrep/net_01/channel/context/EstablishedContextFake.java similarity index 96% rename from src/test/java/com/teragrep/rlp_03/channel/context/EstablishedContextFake.java rename to src/test/java/com/teragrep/net_01/channel/context/EstablishedContextFake.java index dbbed2fa..cc191782 100644 --- a/src/test/java/com/teragrep/rlp_03/channel/context/EstablishedContextFake.java +++ b/src/test/java/com/teragrep/net_01/channel/context/EstablishedContextFake.java @@ -43,9 +43,9 @@ * Teragrep, the applicable Commercial License may apply to this file if you as * a licensee so wish it. */ -package com.teragrep.rlp_03.channel.context; +package com.teragrep.net_01.channel.context; -import com.teragrep.rlp_03.channel.socket.Socket; +import com.teragrep.net_01.channel.socket.Socket; import java.nio.channels.SelectionKey; import java.nio.channels.spi.AbstractSelectableChannel; diff --git a/src/test/java/com/teragrep/rlp_03/channel/context/InterestOpsFake.java b/src/test/java/com/teragrep/net_01/channel/context/InterestOpsFake.java similarity index 98% rename from src/test/java/com/teragrep/rlp_03/channel/context/InterestOpsFake.java rename to src/test/java/com/teragrep/net_01/channel/context/InterestOpsFake.java index 4b354016..698b9349 100644 --- a/src/test/java/com/teragrep/rlp_03/channel/context/InterestOpsFake.java +++ b/src/test/java/com/teragrep/net_01/channel/context/InterestOpsFake.java @@ -43,7 +43,7 @@ * Teragrep, the applicable Commercial License may apply to this file if you as * a licensee so wish it. */ -package com.teragrep.rlp_03.channel.context; +package com.teragrep.net_01.channel.context; public class InterestOpsFake implements InterestOps { diff --git a/src/test/java/com/teragrep/rlp_03/channel/context/buffer/BufferLeasePoolTest.java b/src/test/java/com/teragrep/net_01/channel/context/buffer/BufferLeasePoolTest.java similarity index 96% rename from src/test/java/com/teragrep/rlp_03/channel/context/buffer/BufferLeasePoolTest.java rename to src/test/java/com/teragrep/net_01/channel/context/buffer/BufferLeasePoolTest.java index 3942a6cc..81504433 100644 --- a/src/test/java/com/teragrep/rlp_03/channel/context/buffer/BufferLeasePoolTest.java +++ b/src/test/java/com/teragrep/net_01/channel/context/buffer/BufferLeasePoolTest.java @@ -43,10 +43,10 @@ * Teragrep, the applicable Commercial License may apply to this file if you as * a licensee so wish it. */ -package com.teragrep.rlp_03.channel.context.buffer; +package com.teragrep.net_01.channel.context.buffer; -import com.teragrep.rlp_03.channel.buffer.BufferLease; -import com.teragrep.rlp_03.channel.buffer.BufferLeasePool; +import com.teragrep.net_01.channel.buffer.BufferLease; +import com.teragrep.net_01.channel.buffer.BufferLeasePool; import org.junit.jupiter.api.Assertions; import org.junit.jupiter.api.Test; diff --git a/src/test/java/com/teragrep/rlp_03/channel/context/frame/RelpFrameTest.java b/src/test/java/com/teragrep/net_01/channel/context/frame/RelpFrameTest.java similarity index 99% rename from src/test/java/com/teragrep/rlp_03/channel/context/frame/RelpFrameTest.java rename to src/test/java/com/teragrep/net_01/channel/context/frame/RelpFrameTest.java index 02cac894..4526772a 100644 --- a/src/test/java/com/teragrep/rlp_03/channel/context/frame/RelpFrameTest.java +++ b/src/test/java/com/teragrep/net_01/channel/context/frame/RelpFrameTest.java @@ -43,7 +43,7 @@ * Teragrep, the applicable Commercial License may apply to this file if you as * a licensee so wish it. */ -package com.teragrep.rlp_03.channel.context.frame; +package com.teragrep.net_01.channel.context.frame; import com.teragrep.rlp_03.frame.*; import org.junit.jupiter.api.Assertions; diff --git a/src/test/java/com/teragrep/rlp_03/channel/context/frame/access/AccessTest.java b/src/test/java/com/teragrep/net_01/channel/context/frame/access/AccessTest.java similarity index 94% rename from src/test/java/com/teragrep/rlp_03/channel/context/frame/access/AccessTest.java rename to src/test/java/com/teragrep/net_01/channel/context/frame/access/AccessTest.java index 53656f07..7b1e876f 100644 --- a/src/test/java/com/teragrep/rlp_03/channel/context/frame/access/AccessTest.java +++ b/src/test/java/com/teragrep/net_01/channel/context/frame/access/AccessTest.java @@ -43,10 +43,10 @@ * Teragrep, the applicable Commercial License may apply to this file if you as * a licensee so wish it. */ -package com.teragrep.rlp_03.channel.context.frame.access; +package com.teragrep.net_01.channel.context.frame.access; -import com.teragrep.rlp_03.frame.access.Access; -import com.teragrep.rlp_03.frame.access.Lease; +import com.teragrep.net_01.channel.buffer.access.Access; +import com.teragrep.net_01.channel.buffer.access.Lease; import org.junit.jupiter.api.Assertions; import org.junit.jupiter.api.Test; diff --git a/src/test/java/com/teragrep/rlp_03/channel/context/frame/clocks/CommandClockTest.java b/src/test/java/com/teragrep/net_01/channel/context/frame/clocks/CommandClockTest.java similarity index 98% rename from src/test/java/com/teragrep/rlp_03/channel/context/frame/clocks/CommandClockTest.java rename to src/test/java/com/teragrep/net_01/channel/context/frame/clocks/CommandClockTest.java index 4394d6c2..5401db4d 100644 --- a/src/test/java/com/teragrep/rlp_03/channel/context/frame/clocks/CommandClockTest.java +++ b/src/test/java/com/teragrep/net_01/channel/context/frame/clocks/CommandClockTest.java @@ -43,7 +43,7 @@ * Teragrep, the applicable Commercial License may apply to this file if you as * a licensee so wish it. */ -package com.teragrep.rlp_03.channel.context.frame.clocks; +package com.teragrep.net_01.channel.context.frame.clocks; import com.teragrep.rlp_03.frame.fragment.Fragment; import com.teragrep.rlp_03.frame.fragment.clocks.CommandClock; diff --git a/src/test/java/com/teragrep/rlp_03/channel/context/frame/clocks/EndOfTransferClockTest.java b/src/test/java/com/teragrep/net_01/channel/context/frame/clocks/EndOfTransferClockTest.java similarity index 98% rename from src/test/java/com/teragrep/rlp_03/channel/context/frame/clocks/EndOfTransferClockTest.java rename to src/test/java/com/teragrep/net_01/channel/context/frame/clocks/EndOfTransferClockTest.java index 968b9589..ba80177b 100644 --- a/src/test/java/com/teragrep/rlp_03/channel/context/frame/clocks/EndOfTransferClockTest.java +++ b/src/test/java/com/teragrep/net_01/channel/context/frame/clocks/EndOfTransferClockTest.java @@ -43,7 +43,7 @@ * Teragrep, the applicable Commercial License may apply to this file if you as * a licensee so wish it. */ -package com.teragrep.rlp_03.channel.context.frame.clocks; +package com.teragrep.net_01.channel.context.frame.clocks; import com.teragrep.rlp_03.frame.fragment.Fragment; import com.teragrep.rlp_03.frame.fragment.clocks.EndOfTransferClock; diff --git a/src/test/java/com/teragrep/rlp_03/channel/context/frame/clocks/PayloadClockTest.java b/src/test/java/com/teragrep/net_01/channel/context/frame/clocks/PayloadClockTest.java similarity index 98% rename from src/test/java/com/teragrep/rlp_03/channel/context/frame/clocks/PayloadClockTest.java rename to src/test/java/com/teragrep/net_01/channel/context/frame/clocks/PayloadClockTest.java index ed164ba6..08ca0b93 100644 --- a/src/test/java/com/teragrep/rlp_03/channel/context/frame/clocks/PayloadClockTest.java +++ b/src/test/java/com/teragrep/net_01/channel/context/frame/clocks/PayloadClockTest.java @@ -43,7 +43,7 @@ * Teragrep, the applicable Commercial License may apply to this file if you as * a licensee so wish it. */ -package com.teragrep.rlp_03.channel.context.frame.clocks; +package com.teragrep.net_01.channel.context.frame.clocks; import com.teragrep.rlp_03.frame.fragment.Fragment; import com.teragrep.rlp_03.frame.fragment.clocks.PayloadClock; diff --git a/src/test/java/com/teragrep/rlp_03/channel/context/frame/clocks/PayloadLengthClockTest.java b/src/test/java/com/teragrep/net_01/channel/context/frame/clocks/PayloadLengthClockTest.java similarity index 98% rename from src/test/java/com/teragrep/rlp_03/channel/context/frame/clocks/PayloadLengthClockTest.java rename to src/test/java/com/teragrep/net_01/channel/context/frame/clocks/PayloadLengthClockTest.java index f80ebfc3..fa5afba8 100644 --- a/src/test/java/com/teragrep/rlp_03/channel/context/frame/clocks/PayloadLengthClockTest.java +++ b/src/test/java/com/teragrep/net_01/channel/context/frame/clocks/PayloadLengthClockTest.java @@ -43,7 +43,7 @@ * Teragrep, the applicable Commercial License may apply to this file if you as * a licensee so wish it. */ -package com.teragrep.rlp_03.channel.context.frame.clocks; +package com.teragrep.net_01.channel.context.frame.clocks; import com.teragrep.rlp_03.frame.fragment.Fragment; import com.teragrep.rlp_03.frame.fragment.clocks.PayloadLengthClock; diff --git a/src/test/java/com/teragrep/rlp_03/channel/context/frame/clocks/TransactionClockTest.java b/src/test/java/com/teragrep/net_01/channel/context/frame/clocks/TransactionClockTest.java similarity index 98% rename from src/test/java/com/teragrep/rlp_03/channel/context/frame/clocks/TransactionClockTest.java rename to src/test/java/com/teragrep/net_01/channel/context/frame/clocks/TransactionClockTest.java index 68555711..d2ec0633 100644 --- a/src/test/java/com/teragrep/rlp_03/channel/context/frame/clocks/TransactionClockTest.java +++ b/src/test/java/com/teragrep/net_01/channel/context/frame/clocks/TransactionClockTest.java @@ -43,7 +43,7 @@ * Teragrep, the applicable Commercial License may apply to this file if you as * a licensee so wish it. */ -package com.teragrep.rlp_03.channel.context.frame.clocks; +package com.teragrep.net_01.channel.context.frame.clocks; import com.teragrep.rlp_03.frame.fragment.Fragment; import com.teragrep.rlp_03.frame.fragment.clocks.TransactionClock; diff --git a/src/test/java/com/teragrep/rlp_03/channel/context/frame/fragment/FragmentTest.java b/src/test/java/com/teragrep/net_01/channel/context/frame/fragment/FragmentTest.java similarity index 98% rename from src/test/java/com/teragrep/rlp_03/channel/context/frame/fragment/FragmentTest.java rename to src/test/java/com/teragrep/net_01/channel/context/frame/fragment/FragmentTest.java index 708c6df5..c6f91b21 100644 --- a/src/test/java/com/teragrep/rlp_03/channel/context/frame/fragment/FragmentTest.java +++ b/src/test/java/com/teragrep/net_01/channel/context/frame/fragment/FragmentTest.java @@ -43,7 +43,7 @@ * Teragrep, the applicable Commercial License may apply to this file if you as * a licensee so wish it. */ -package com.teragrep.rlp_03.channel.context.frame.fragment; +package com.teragrep.net_01.channel.context.frame.fragment; import com.teragrep.rlp_03.frame.fragment.Fragment; import com.teragrep.rlp_03.frame.fragment.FragmentByteStream; diff --git a/src/test/java/com/teragrep/rlp_03/channel/socket/SocketFake.java b/src/test/java/com/teragrep/net_01/channel/socket/SocketFake.java similarity index 98% rename from src/test/java/com/teragrep/rlp_03/channel/socket/SocketFake.java rename to src/test/java/com/teragrep/net_01/channel/socket/SocketFake.java index f5d48690..950a243c 100644 --- a/src/test/java/com/teragrep/rlp_03/channel/socket/SocketFake.java +++ b/src/test/java/com/teragrep/net_01/channel/socket/SocketFake.java @@ -43,7 +43,7 @@ * Teragrep, the applicable Commercial License may apply to this file if you as * a licensee so wish it. */ -package com.teragrep.rlp_03.channel.socket; +package com.teragrep.net_01.channel.socket; import java.nio.ByteBuffer; import java.nio.channels.SocketChannel; diff --git a/src/test/java/com/teragrep/rlp_03/channel/socket/TransportInfoFake.java b/src/test/java/com/teragrep/net_01/channel/socket/TransportInfoFake.java similarity index 98% rename from src/test/java/com/teragrep/rlp_03/channel/socket/TransportInfoFake.java rename to src/test/java/com/teragrep/net_01/channel/socket/TransportInfoFake.java index 6b9ba998..9566e8e4 100644 --- a/src/test/java/com/teragrep/rlp_03/channel/socket/TransportInfoFake.java +++ b/src/test/java/com/teragrep/net_01/channel/socket/TransportInfoFake.java @@ -43,7 +43,7 @@ * Teragrep, the applicable Commercial License may apply to this file if you as * a licensee so wish it. */ -package com.teragrep.rlp_03.channel.socket; +package com.teragrep.net_01.channel.socket; final class TransportInfoFake implements TransportInfo { diff --git a/src/test/java/com/teragrep/rlp_03/CloseByteConsumerTest.java b/src/test/java/com/teragrep/rlp_03/CloseByteConsumerTest.java index ec708085..8de894be 100644 --- a/src/test/java/com/teragrep/rlp_03/CloseByteConsumerTest.java +++ b/src/test/java/com/teragrep/rlp_03/CloseByteConsumerTest.java @@ -47,13 +47,13 @@ import com.teragrep.rlp_01.RelpBatch; import com.teragrep.rlp_01.RelpConnection; -import com.teragrep.rlp_03.channel.socket.PlainFactory; -import com.teragrep.rlp_03.eventloop.EventLoop; -import com.teragrep.rlp_03.eventloop.EventLoopFactory; +import com.teragrep.net_01.channel.socket.PlainFactory; +import com.teragrep.net_01.eventloop.EventLoop; +import com.teragrep.net_01.eventloop.EventLoopFactory; import com.teragrep.rlp_03.frame.FrameDelegationClockFactory; import com.teragrep.rlp_03.frame.delegate.DefaultFrameDelegate; import com.teragrep.rlp_03.frame.delegate.FrameContext; -import com.teragrep.rlp_03.server.ServerFactory; +import com.teragrep.net_01.server.ServerFactory; import org.junit.jupiter.api.Assertions; import org.junit.jupiter.api.Test; import org.junit.jupiter.api.TestInstance; diff --git a/src/test/java/com/teragrep/rlp_03/CloseRelpFrameServerRXConsumerTest.java b/src/test/java/com/teragrep/rlp_03/CloseRelpFrameServerRXConsumerTest.java index 4cb79719..a84b656a 100644 --- a/src/test/java/com/teragrep/rlp_03/CloseRelpFrameServerRXConsumerTest.java +++ b/src/test/java/com/teragrep/rlp_03/CloseRelpFrameServerRXConsumerTest.java @@ -47,13 +47,13 @@ import com.teragrep.rlp_01.RelpBatch; import com.teragrep.rlp_01.RelpConnection; -import com.teragrep.rlp_03.channel.socket.PlainFactory; -import com.teragrep.rlp_03.eventloop.EventLoop; -import com.teragrep.rlp_03.eventloop.EventLoopFactory; +import com.teragrep.net_01.channel.socket.PlainFactory; +import com.teragrep.net_01.eventloop.EventLoop; +import com.teragrep.net_01.eventloop.EventLoopFactory; import com.teragrep.rlp_03.frame.FrameDelegationClockFactory; import com.teragrep.rlp_03.frame.delegate.DefaultFrameDelegate; import com.teragrep.rlp_03.frame.delegate.FrameContext; -import com.teragrep.rlp_03.server.ServerFactory; +import com.teragrep.net_01.server.ServerFactory; import org.junit.jupiter.api.AfterAll; import org.junit.jupiter.api.Assertions; import org.junit.jupiter.api.Test; diff --git a/src/test/java/com/teragrep/rlp_03/ConnectionStormTest.java b/src/test/java/com/teragrep/rlp_03/ConnectionStormTest.java index 60c23112..53657473 100644 --- a/src/test/java/com/teragrep/rlp_03/ConnectionStormTest.java +++ b/src/test/java/com/teragrep/rlp_03/ConnectionStormTest.java @@ -46,12 +46,12 @@ package com.teragrep.rlp_03; import com.teragrep.rlp_01.RelpConnection; -import com.teragrep.rlp_03.channel.socket.PlainFactory; -import com.teragrep.rlp_03.eventloop.EventLoop; +import com.teragrep.net_01.channel.socket.PlainFactory; +import com.teragrep.net_01.eventloop.EventLoop; import com.teragrep.rlp_03.frame.FrameDelegationClockFactory; import com.teragrep.rlp_03.frame.delegate.DefaultFrameDelegate; -import com.teragrep.rlp_03.eventloop.EventLoopFactory; -import com.teragrep.rlp_03.server.ServerFactory; +import com.teragrep.net_01.eventloop.EventLoopFactory; +import com.teragrep.net_01.server.ServerFactory; import org.junit.jupiter.api.*; import java.util.LinkedList; diff --git a/src/test/java/com/teragrep/rlp_03/ManualBenchmarkTest.java b/src/test/java/com/teragrep/rlp_03/ManualBenchmarkTest.java index 295f1880..8cdcdbec 100644 --- a/src/test/java/com/teragrep/rlp_03/ManualBenchmarkTest.java +++ b/src/test/java/com/teragrep/rlp_03/ManualBenchmarkTest.java @@ -45,14 +45,14 @@ */ package com.teragrep.rlp_03; -import com.teragrep.rlp_03.channel.socket.PlainFactory; -import com.teragrep.rlp_03.eventloop.EventLoop; -import com.teragrep.rlp_03.eventloop.EventLoopFactory; +import com.teragrep.net_01.channel.socket.PlainFactory; +import com.teragrep.net_01.eventloop.EventLoop; +import com.teragrep.net_01.eventloop.EventLoopFactory; import com.teragrep.rlp_03.frame.FrameDelegationClockFactory; import com.teragrep.rlp_03.frame.delegate.DefaultFrameDelegate; import com.teragrep.rlp_03.frame.delegate.FrameContext; import com.teragrep.rlp_03.frame.delegate.FrameDelegate; -import com.teragrep.rlp_03.server.ServerFactory; +import com.teragrep.net_01.server.ServerFactory; import com.teragrep.rlp_09.RelpFlooder; import com.teragrep.rlp_09.RelpFlooderConfig; import org.junit.jupiter.api.Assertions; diff --git a/src/test/java/com/teragrep/rlp_03/ManualPerformanceTest.java b/src/test/java/com/teragrep/rlp_03/ManualPerformanceTest.java index 7e45bd90..fdb3edd9 100644 --- a/src/test/java/com/teragrep/rlp_03/ManualPerformanceTest.java +++ b/src/test/java/com/teragrep/rlp_03/ManualPerformanceTest.java @@ -45,14 +45,14 @@ */ package com.teragrep.rlp_03; -import com.teragrep.rlp_03.channel.socket.PlainFactory; -import com.teragrep.rlp_03.eventloop.EventLoop; -import com.teragrep.rlp_03.eventloop.EventLoopFactory; +import com.teragrep.net_01.channel.socket.PlainFactory; +import com.teragrep.net_01.eventloop.EventLoop; +import com.teragrep.net_01.eventloop.EventLoopFactory; import com.teragrep.rlp_03.frame.FrameDelegationClockFactory; import com.teragrep.rlp_03.frame.delegate.DefaultFrameDelegate; import com.teragrep.rlp_03.frame.delegate.FrameDelegate; -import com.teragrep.rlp_03.server.Server; -import com.teragrep.rlp_03.server.ServerFactory; +import com.teragrep.net_01.server.Server; +import com.teragrep.net_01.server.ServerFactory; import org.junit.jupiter.api.Assertions; import org.junit.jupiter.api.Test; import org.junit.jupiter.api.condition.EnabledIfSystemProperty; diff --git a/src/test/java/com/teragrep/rlp_03/ManualTest.java b/src/test/java/com/teragrep/rlp_03/ManualTest.java index 0e44dc47..a00b051f 100644 --- a/src/test/java/com/teragrep/rlp_03/ManualTest.java +++ b/src/test/java/com/teragrep/rlp_03/ManualTest.java @@ -45,15 +45,15 @@ */ package com.teragrep.rlp_03; -import com.teragrep.rlp_03.channel.socket.EncryptionInfo; -import com.teragrep.rlp_03.channel.socket.PlainFactory; -import com.teragrep.rlp_03.channel.socket.TLSFactory; -import com.teragrep.rlp_03.eventloop.EventLoop; -import com.teragrep.rlp_03.eventloop.EventLoopFactory; +import com.teragrep.net_01.channel.socket.EncryptionInfo; +import com.teragrep.net_01.channel.socket.PlainFactory; +import com.teragrep.net_01.channel.socket.TLSFactory; +import com.teragrep.net_01.eventloop.EventLoop; +import com.teragrep.net_01.eventloop.EventLoopFactory; import com.teragrep.rlp_03.frame.FrameDelegationClockFactory; import com.teragrep.rlp_03.frame.delegate.DefaultFrameDelegate; import com.teragrep.rlp_03.frame.delegate.FrameContext; -import com.teragrep.rlp_03.server.ServerFactory; +import com.teragrep.net_01.server.ServerFactory; import com.teragrep.rlp_03.tls.SSLContextWithCustomTrustAndKeyManagerHelper; import org.junit.jupiter.api.Assertions; import org.junit.jupiter.api.Test; diff --git a/src/test/java/com/teragrep/rlp_03/MultiClientTest.java b/src/test/java/com/teragrep/rlp_03/MultiClientTest.java index d529113f..721121f1 100644 --- a/src/test/java/com/teragrep/rlp_03/MultiClientTest.java +++ b/src/test/java/com/teragrep/rlp_03/MultiClientTest.java @@ -47,13 +47,13 @@ import com.teragrep.rlp_01.RelpBatch; import com.teragrep.rlp_01.RelpConnection; -import com.teragrep.rlp_03.channel.socket.PlainFactory; -import com.teragrep.rlp_03.eventloop.EventLoop; -import com.teragrep.rlp_03.eventloop.EventLoopFactory; +import com.teragrep.net_01.channel.socket.PlainFactory; +import com.teragrep.net_01.eventloop.EventLoop; +import com.teragrep.net_01.eventloop.EventLoopFactory; import com.teragrep.rlp_03.frame.FrameDelegationClockFactory; import com.teragrep.rlp_03.frame.delegate.DefaultFrameDelegate; import com.teragrep.rlp_03.frame.delegate.FrameDelegate; -import com.teragrep.rlp_03.server.ServerFactory; +import com.teragrep.net_01.server.ServerFactory; import org.junit.jupiter.api.*; import org.junit.jupiter.api.condition.DisabledOnJre; import org.junit.jupiter.api.condition.JRE; diff --git a/src/test/java/com/teragrep/rlp_03/SendMessageTest.java b/src/test/java/com/teragrep/rlp_03/SendMessageTest.java index 4ca6b898..fd33a99d 100644 --- a/src/test/java/com/teragrep/rlp_03/SendMessageTest.java +++ b/src/test/java/com/teragrep/rlp_03/SendMessageTest.java @@ -47,12 +47,12 @@ import com.teragrep.rlp_01.RelpBatch; import com.teragrep.rlp_01.RelpConnection; -import com.teragrep.rlp_03.channel.socket.PlainFactory; -import com.teragrep.rlp_03.eventloop.EventLoop; -import com.teragrep.rlp_03.eventloop.EventLoopFactory; +import com.teragrep.net_01.channel.socket.PlainFactory; +import com.teragrep.net_01.eventloop.EventLoop; +import com.teragrep.net_01.eventloop.EventLoopFactory; import com.teragrep.rlp_03.frame.FrameDelegationClockFactory; import com.teragrep.rlp_03.frame.delegate.DefaultFrameDelegate; -import com.teragrep.rlp_03.server.ServerFactory; +import com.teragrep.net_01.server.ServerFactory; import org.junit.jupiter.api.*; import org.slf4j.Logger; import org.slf4j.LoggerFactory; diff --git a/src/test/java/com/teragrep/rlp_03/ServerShutdownTest.java b/src/test/java/com/teragrep/rlp_03/ServerShutdownTest.java index 18c49c17..86dad654 100644 --- a/src/test/java/com/teragrep/rlp_03/ServerShutdownTest.java +++ b/src/test/java/com/teragrep/rlp_03/ServerShutdownTest.java @@ -45,12 +45,12 @@ */ package com.teragrep.rlp_03; -import com.teragrep.rlp_03.channel.socket.PlainFactory; -import com.teragrep.rlp_03.eventloop.EventLoop; -import com.teragrep.rlp_03.eventloop.EventLoopFactory; +import com.teragrep.net_01.channel.socket.PlainFactory; +import com.teragrep.net_01.eventloop.EventLoop; +import com.teragrep.net_01.eventloop.EventLoopFactory; import com.teragrep.rlp_03.frame.FrameDelegationClockFactory; import com.teragrep.rlp_03.frame.delegate.DefaultFrameDelegate; -import com.teragrep.rlp_03.server.ServerFactory; +import com.teragrep.net_01.server.ServerFactory; import org.junit.jupiter.api.Assertions; import org.junit.jupiter.api.Test; diff --git a/src/test/java/com/teragrep/rlp_03/TearDownTest.java b/src/test/java/com/teragrep/rlp_03/TearDownTest.java index bbed3d10..f8bc362a 100644 --- a/src/test/java/com/teragrep/rlp_03/TearDownTest.java +++ b/src/test/java/com/teragrep/rlp_03/TearDownTest.java @@ -47,12 +47,12 @@ import com.teragrep.rlp_01.RelpBatch; import com.teragrep.rlp_01.RelpConnection; -import com.teragrep.rlp_03.channel.socket.PlainFactory; -import com.teragrep.rlp_03.eventloop.EventLoop; -import com.teragrep.rlp_03.eventloop.EventLoopFactory; +import com.teragrep.net_01.channel.socket.PlainFactory; +import com.teragrep.net_01.eventloop.EventLoop; +import com.teragrep.net_01.eventloop.EventLoopFactory; import com.teragrep.rlp_03.frame.FrameDelegationClockFactory; import com.teragrep.rlp_03.frame.delegate.DefaultFrameDelegate; -import com.teragrep.rlp_03.server.ServerFactory; +import com.teragrep.net_01.server.ServerFactory; import org.junit.jupiter.api.*; import java.nio.charset.StandardCharsets; diff --git a/src/test/java/com/teragrep/rlp_03/TlsClientTest.java b/src/test/java/com/teragrep/rlp_03/TlsClientTest.java index 34581a21..829c52c3 100644 --- a/src/test/java/com/teragrep/rlp_03/TlsClientTest.java +++ b/src/test/java/com/teragrep/rlp_03/TlsClientTest.java @@ -48,13 +48,13 @@ import com.teragrep.rlp_01.RelpBatch; import com.teragrep.rlp_01.RelpConnection; import com.teragrep.rlp_01.SSLContextFactory; -import com.teragrep.rlp_03.channel.socket.TLSFactory; -import com.teragrep.rlp_03.eventloop.EventLoop; -import com.teragrep.rlp_03.eventloop.EventLoopFactory; +import com.teragrep.net_01.channel.socket.TLSFactory; +import com.teragrep.net_01.eventloop.EventLoop; +import com.teragrep.net_01.eventloop.EventLoopFactory; import com.teragrep.rlp_03.frame.FrameDelegationClockFactory; import com.teragrep.rlp_03.frame.delegate.DefaultFrameDelegate; import com.teragrep.rlp_03.frame.delegate.FrameContext; -import com.teragrep.rlp_03.server.ServerFactory; +import com.teragrep.net_01.server.ServerFactory; import org.junit.jupiter.api.*; import javax.net.ssl.KeyManagerFactory; diff --git a/src/test/java/com/teragrep/rlp_03/client/ClientTest.java b/src/test/java/com/teragrep/rlp_03/client/ClientTest.java index 9e5c559b..24d486ff 100644 --- a/src/test/java/com/teragrep/rlp_03/client/ClientTest.java +++ b/src/test/java/com/teragrep/rlp_03/client/ClientTest.java @@ -45,16 +45,16 @@ */ package com.teragrep.rlp_03.client; -import com.teragrep.rlp_03.channel.context.ConnectContextFactory; -import com.teragrep.rlp_03.channel.socket.PlainFactory; -import com.teragrep.rlp_03.channel.socket.SocketFactory; -import com.teragrep.rlp_03.eventloop.EventLoopFactory; +import com.teragrep.net_01.channel.context.ConnectContextFactory; +import com.teragrep.net_01.channel.socket.PlainFactory; +import com.teragrep.net_01.channel.socket.SocketFactory; +import com.teragrep.net_01.eventloop.EventLoopFactory; import com.teragrep.rlp_03.frame.FrameDelegationClockFactory; import com.teragrep.rlp_03.frame.RelpFrame; import com.teragrep.rlp_03.frame.RelpFrameFactory; import com.teragrep.rlp_03.frame.delegate.DefaultFrameDelegate; -import com.teragrep.rlp_03.eventloop.EventLoop; -import com.teragrep.rlp_03.server.ServerFactory; +import com.teragrep.net_01.eventloop.EventLoop; +import com.teragrep.net_01.server.ServerFactory; import org.junit.jupiter.api.*; import org.slf4j.Logger; import org.slf4j.LoggerFactory; diff --git a/src/test/java/com/teragrep/rlp_03/client/StuckClientCloseTest.java b/src/test/java/com/teragrep/rlp_03/client/StuckClientCloseTest.java index 31d3da5b..739b5363 100644 --- a/src/test/java/com/teragrep/rlp_03/client/StuckClientCloseTest.java +++ b/src/test/java/com/teragrep/rlp_03/client/StuckClientCloseTest.java @@ -45,17 +45,17 @@ */ package com.teragrep.rlp_03.client; -import com.teragrep.rlp_03.eventloop.EventLoop; -import com.teragrep.rlp_03.eventloop.EventLoopFactory; -import com.teragrep.rlp_03.channel.context.ConnectContextFactory; -import com.teragrep.rlp_03.channel.socket.PlainFactory; -import com.teragrep.rlp_03.channel.socket.SocketFactory; +import com.teragrep.net_01.eventloop.EventLoop; +import com.teragrep.net_01.eventloop.EventLoopFactory; +import com.teragrep.net_01.channel.context.ConnectContextFactory; +import com.teragrep.net_01.channel.socket.PlainFactory; +import com.teragrep.net_01.channel.socket.SocketFactory; import com.teragrep.rlp_03.frame.FrameDelegationClockFactory; import com.teragrep.rlp_03.frame.RelpFrame; import com.teragrep.rlp_03.frame.RelpFrameFactory; import com.teragrep.rlp_03.frame.delegate.FrameContext; import com.teragrep.rlp_03.frame.delegate.FrameDelegate; -import com.teragrep.rlp_03.server.ServerFactory; +import com.teragrep.net_01.server.ServerFactory; import org.junit.jupiter.api.*; import org.slf4j.Logger; import org.slf4j.LoggerFactory; diff --git a/src/test/java/com/teragrep/rlp_03/frame/pool/PoolingDelegateTest.java b/src/test/java/com/teragrep/rlp_03/frame/pool/PoolingDelegateTest.java index 429e0bec..c5cc8956 100644 --- a/src/test/java/com/teragrep/rlp_03/frame/pool/PoolingDelegateTest.java +++ b/src/test/java/com/teragrep/rlp_03/frame/pool/PoolingDelegateTest.java @@ -46,14 +46,14 @@ package com.teragrep.rlp_03.frame.pool; import com.teragrep.rlp_01.RelpCommand; -import com.teragrep.rlp_03.eventloop.EventLoop; -import com.teragrep.rlp_03.eventloop.EventLoopFactory; +import com.teragrep.net_01.eventloop.EventLoop; +import com.teragrep.net_01.eventloop.EventLoopFactory; import com.teragrep.rlp_03.frame.FrameDelegationClockFactory; import com.teragrep.rlp_03.frame.delegate.FrameContext; import com.teragrep.rlp_03.frame.delegate.pool.FrameDelegatePool; import com.teragrep.rlp_03.frame.delegate.pool.PoolDelegate; -import com.teragrep.rlp_03.server.ServerFactory; -import com.teragrep.rlp_03.channel.socket.PlainFactory; +import com.teragrep.net_01.server.ServerFactory; +import com.teragrep.net_01.channel.socket.PlainFactory; import com.teragrep.rlp_03.frame.delegate.EventDelegate; import com.teragrep.rlp_03.frame.delegate.FrameDelegate; import com.teragrep.rlp_03.frame.delegate.SequencingDelegate; diff --git a/src/test/java/com/teragrep/rlp_03/readme/ReadmeDeferredTest.java b/src/test/java/com/teragrep/rlp_03/readme/ReadmeDeferredTest.java index ee6ea50a..38bb4e0c 100644 --- a/src/test/java/com/teragrep/rlp_03/readme/ReadmeDeferredTest.java +++ b/src/test/java/com/teragrep/rlp_03/readme/ReadmeDeferredTest.java @@ -46,15 +46,15 @@ package com.teragrep.rlp_03.readme; import com.teragrep.rlp_01.RelpCommand; -import com.teragrep.rlp_03.eventloop.EventLoop; -import com.teragrep.rlp_03.eventloop.EventLoopFactory; +import com.teragrep.net_01.eventloop.EventLoop; +import com.teragrep.net_01.eventloop.EventLoopFactory; import com.teragrep.rlp_03.frame.FrameDelegationClockFactory; import com.teragrep.rlp_03.frame.RelpFrameFactory; import com.teragrep.rlp_03.frame.delegate.DefaultFrameDelegate; import com.teragrep.rlp_03.frame.delegate.FrameContext; import com.teragrep.rlp_03.frame.delegate.FrameDelegate; -import com.teragrep.rlp_03.server.ServerFactory; -import com.teragrep.rlp_03.channel.socket.PlainFactory; +import com.teragrep.net_01.server.ServerFactory; +import com.teragrep.net_01.channel.socket.PlainFactory; import com.teragrep.rlp_03.frame.RelpFrame; import com.teragrep.rlp_03.frame.delegate.event.RelpEvent; import com.teragrep.rlp_03.frame.delegate.event.RelpEventClose; diff --git a/src/test/java/com/teragrep/rlp_03/readme/ReadmeTest.java b/src/test/java/com/teragrep/rlp_03/readme/ReadmeTest.java index 9e8ea58c..5714fff1 100644 --- a/src/test/java/com/teragrep/rlp_03/readme/ReadmeTest.java +++ b/src/test/java/com/teragrep/rlp_03/readme/ReadmeTest.java @@ -45,14 +45,14 @@ */ package com.teragrep.rlp_03.readme; -import com.teragrep.rlp_03.eventloop.EventLoop; -import com.teragrep.rlp_03.eventloop.EventLoopFactory; +import com.teragrep.net_01.eventloop.EventLoop; +import com.teragrep.net_01.eventloop.EventLoopFactory; import com.teragrep.rlp_03.frame.FrameDelegationClockFactory; import com.teragrep.rlp_03.frame.delegate.DefaultFrameDelegate; import com.teragrep.rlp_03.frame.delegate.FrameContext; import com.teragrep.rlp_03.frame.delegate.FrameDelegate; -import com.teragrep.rlp_03.server.ServerFactory; -import com.teragrep.rlp_03.channel.socket.PlainFactory; +import com.teragrep.net_01.server.ServerFactory; +import com.teragrep.net_01.channel.socket.PlainFactory; import org.junit.jupiter.api.Test; import java.io.IOException;