Skip to content

Commit

Permalink
net_01 restructuring (#204)
Browse files Browse the repository at this point in the history
* re-structure networking code from rlp_03 package to net_01 package

* apply spotless
  • Loading branch information
kortemik authored Jun 24, 2024
1 parent 16c844d commit e788d74
Show file tree
Hide file tree
Showing 99 changed files with 223 additions and 223 deletions.
8 changes: 4 additions & 4 deletions README.adoc
Original file line number Diff line number Diff line change
Expand Up @@ -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;
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -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;

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -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;
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -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;

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -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;

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -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;
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -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;
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -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;

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -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;
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -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 {

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -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;
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -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;

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -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;

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -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;

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -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;

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -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;

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -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;

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -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 {

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -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 {

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -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;

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -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;
Expand All @@ -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;
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -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;
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -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;
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -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;
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -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;

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -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
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -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;

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -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;
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -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;

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -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;
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -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;

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -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;
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -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;

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -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;
Expand Down
Loading

0 comments on commit e788d74

Please sign in to comment.