Package com.linkedin.alpini.router.impl.netty4

Class Router4Impl<C extends io.netty.channel.Channel>

java.lang.Object

com.linkedin.alpini.router.impl.netty4.Router4Impl<C>

All Implemented Interfaces:

ResourceRegistry.Sync, Shutdownable, ShutdownableResource, Router

public class Router4Impl<C extends io.netty.channel.Channel>
extends Object
implements Router, ResourceRegistry.Sync

Nested Class Summary

Nested classes/interfaces inherited from interface com.linkedin.alpini.router.impl.Router

Router.Builder, Router.PipelineFactory<CHANNEL_HANDLER>

Constructor Summary

Constructors

Constructor

Description

Router4Impl(String name, Class<? extends io.netty.channel.socket.ServerSocketChannel> channelClass, io.netty.channel.EventLoopGroup bossPool, io.netty.channel.EventLoopGroup workerPool, io.netty.util.concurrent.EventExecutor workerExecutor, ConnectionLimitHandler connectionLimit, ActiveStreamsCountHandler activeStreamsCountHandler, Http2SettingsFrameLogger http2SettingsFrameLogger, RouterTimeoutProcessor timeoutProcessor, io.netty.util.Timer nettyTimer, Map<String,Object> serverSocketOptions, ScatterGatherHelper<H,P,K,R,BasicFullHttpRequest,io.netty.handler.codec.http.FullHttpResponse,io.netty.handler.codec.http.HttpResponseStatus> scatterGatherHelper)

Method Summary

Modifier and Type	Method	Description
protected io.netty.bootstrap.ServerBootstrap	bootstrap()
protected <H, P extends ResourcePath<K>, K, R> Router4PipelineFactory<C>	constructRouterPipelineFactory(ScatterGatherRequestHandler4<H,P,K,R> scatterGatherRequestHandler)
int	getActiveStreams()
ActiveStreamsCountHandler	getActiveStreamsCountHandler()
int	getConnectedCount()
ConnectionLimitHandler	getConnectionLimit()
Http2SettingsFrameLogger	getHttp2SettingsFrameLogger()
AsyncFuture<SocketAddress>	getLocalAddress()
io.netty.util.Timer	getNettyTimer()
Supplier<Router4PipelineFactory<C>>	getPipelineSupplier()
long	getRstErrorCount()
boolean	isBusyAutoReadDisable()
static boolean	isBusyAutoReadDisable(Router router)
boolean	isShutdown()	Returns true if this resource has been shut down.
boolean	isTerminated()	Returns true if the resource has completed shutting down.
Netty	nettyVersion()
AsyncFuture<Void>	setAcceptConnection(boolean enabled)
void	setBusyAutoReadDisable(boolean busyAutoReadDisable)
static void	setBusyAutoReadDisable(Router router, boolean busyAutoReadDisable)
void	setPipelineSupplier(Supplier<Router4PipelineFactory<C>> pipelineSupplier)
void	shutdown()	Starts the shutdown process.
AsyncFuture<SocketAddress>	start(SocketAddress address)
void	waitForShutdown()	Waits for shutdown to complete
void	waitForShutdown(long timeoutInMs)	Waits for shutdown to complete with a timeout

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

Router4Impl

public Router4Impl(String name,
 Class<? extends io.netty.channel.socket.ServerSocketChannel> channelClass,
 io.netty.channel.EventLoopGroup bossPool,
 io.netty.channel.EventLoopGroup workerPool,
 io.netty.util.concurrent.EventExecutor workerExecutor,
 ConnectionLimitHandler connectionLimit,
 ActiveStreamsCountHandler activeStreamsCountHandler,
 Http2SettingsFrameLogger http2SettingsFrameLogger,
 RouterTimeoutProcessor timeoutProcessor,
 io.netty.util.Timer nettyTimer,
 Map<String,Object> serverSocketOptions,
 @Nonnull
 ScatterGatherHelper<H,P,K,R,BasicFullHttpRequest,io.netty.handler.codec.http.FullHttpResponse,io.netty.handler.codec.http.HttpResponseStatus> scatterGatherHelper)

Method Details

getPipelineSupplier

public Supplier<Router4PipelineFactory<C>> getPipelineSupplier()

setPipelineSupplier

public void setPipelineSupplier(@Nonnull
 Supplier<Router4PipelineFactory<C>> pipelineSupplier)

constructRouterPipelineFactory

protected <H,
P extends ResourcePath<K>,
K,
R>
Router4PipelineFactory<C> constructRouterPipelineFactory(@Nonnull
 ScatterGatherRequestHandler4<H,P,K,R> scatterGatherRequestHandler)

nettyVersion

public Netty nettyVersion()

Specified by:

nettyVersion in interface Router

bootstrap

protected io.netty.bootstrap.ServerBootstrap bootstrap()

start

public AsyncFuture<SocketAddress> start(SocketAddress address)

Specified by:

start in interface Router

getLocalAddress

public AsyncFuture<SocketAddress> getLocalAddress()

Specified by:

getLocalAddress in interface Router

setAcceptConnection

public AsyncFuture<Void> setAcceptConnection(boolean enabled)

Specified by:

setAcceptConnection in interface Router

getConnectedCount

public int getConnectedCount()

Specified by:

getConnectedCount in interface Router

getActiveStreams

public int getActiveStreams()

Specified by:

getActiveStreams in interface Router

getRstErrorCount

public long getRstErrorCount()

Specified by:

getRstErrorCount in interface Router

isBusyAutoReadDisable

public boolean isBusyAutoReadDisable()

setBusyAutoReadDisable

public void setBusyAutoReadDisable(boolean busyAutoReadDisable)

setBusyAutoReadDisable

public static void setBusyAutoReadDisable(Router router,
 boolean busyAutoReadDisable)

isBusyAutoReadDisable

public static boolean isBusyAutoReadDisable(Router router)

isShutdown

public boolean isShutdown()

Returns true if this resource has been shut down.

Specified by:

isShutdown in interface ShutdownableResource

Returns:

true if this resource has been shut down

isTerminated

public boolean isTerminated()

Returns true if the resource has completed shutting down. Note that isTerminated is never true unless shutdown was called first.

Specified by:

isTerminated in interface ShutdownableResource

Returns:

true if the resource has completed shutting down.

shutdown

public void shutdown()

Starts the shutdown process. It is recommended to perform the actual shutdown activity in a separate thread from the thread that calls shutdown

Specified by:

shutdown in interface Shutdownable

waitForShutdown

public void waitForShutdown()
                     throws InterruptedException,
IllegalStateException

Waits for shutdown to complete

Specified by:

waitForShutdown in interface Shutdownable

Throws:

InterruptedException - when the wait is interrupted

IllegalStateException - when the method is invoked when the shutdown has yet to be started

waitForShutdown

public void waitForShutdown(long timeoutInMs)
                     throws InterruptedException,
IllegalStateException,
TimeoutException

Waits for shutdown to complete with a timeout

Specified by:

waitForShutdown in interface Shutdownable

Parameters:

timeoutInMs - number of milliseconds to wait before throwing TimeoutException

Throws:

InterruptedException - when the wait is interrupted

IllegalStateException - when the method is invoked when the shutdown has yet to be started

TimeoutException - when the operation times out

getNettyTimer

public io.netty.util.Timer getNettyTimer()

getConnectionLimit

public ConnectionLimitHandler getConnectionLimit()

getActiveStreamsCountHandler

public ActiveStreamsCountHandler getActiveStreamsCountHandler()

getHttp2SettingsFrameLogger

public Http2SettingsFrameLogger getHttp2SettingsFrameLogger()