Package com.hypixel.hytale.server.core.io.netty

Class LatencySimulationHandler

java.lang.Object

io.netty.channel.ChannelHandlerAdapter

io.netty.channel.ChannelInboundHandlerAdapter

io.netty.channel.ChannelDuplexHandler

com.hypixel.hytale.server.core.io.netty.LatencySimulationHandler

All Implemented Interfaces:

io.netty.channel.ChannelHandler, io.netty.channel.ChannelInboundHandler, io.netty.channel.ChannelOutboundHandler

public class LatencySimulationHandler
extends io.netty.channel.ChannelDuplexHandler

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
private static class	LatencySimulationHandler.DelayedFlush
private static class	LatencySimulationHandler.DelayedHandler
private static class	LatencySimulationHandler.DelayedRead
private static class	LatencySimulationHandler.DelayedWrite

Nested classes/interfaces inherited from interface io.netty.channel.ChannelHandler

io.netty.channel.ChannelHandler.Sharable

Field Summary

Fields

Modifier and Type	Field	Description
private static final AtomicInteger	counter
private final DelayQueue<LatencySimulationHandler.DelayedHandler>	delayedQueue
private final long	delayNanos
static final String	PIPELINE_KEY
private final Thread	taskThread

Constructor Summary

Constructors

Constructor	Description
LatencySimulationHandler(long delay, TimeUnit unit)

Method Summary

Modifier and Type	Method	Description
void	close(io.netty.channel.ChannelHandlerContext ctx, io.netty.channel.ChannelPromise promise)
void	flush(io.netty.channel.ChannelHandlerContext ctx)
void	handlerRemoved(io.netty.channel.ChannelHandlerContext ctx)
void	read(io.netty.channel.ChannelHandlerContext ctx)
static void	setLatency(io.netty.channel.Channel channel, long delay, TimeUnit unit)
void	write(io.netty.channel.ChannelHandlerContext ctx, Object msg, io.netty.channel.ChannelPromise promise)

Methods inherited from class io.netty.channel.ChannelDuplexHandler

bind, connect, deregister, disconnect

Methods inherited from class io.netty.channel.ChannelInboundHandlerAdapter

channelActive, channelInactive, channelRead, channelReadComplete, channelRegistered, channelUnregistered, channelWritabilityChanged, exceptionCaught, userEventTriggered

Methods inherited from class io.netty.channel.ChannelHandlerAdapter

ensureNotSharable, handlerAdded, isSharable

Methods inherited from class java.lang.Object

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

Methods inherited from interface io.netty.channel.ChannelHandler

handlerAdded

Field Details

PIPELINE_KEY

public static final String PIPELINE_KEY

See Also:

• Constant Field Values

counter

private static final AtomicInteger counter

delayedQueue

private final DelayQueue<LatencySimulationHandler.DelayedHandler> delayedQueue

taskThread

@Nonnull
private final Thread taskThread

delayNanos

private final long delayNanos

Constructor Details

LatencySimulationHandler

public LatencySimulationHandler(long delay,
 @Nonnull
 TimeUnit unit)

Method Details

read

public void read(io.netty.channel.ChannelHandlerContext ctx)
          throws Exception

Specified by:

read in interface io.netty.channel.ChannelOutboundHandler

Overrides:

read in class io.netty.channel.ChannelDuplexHandler

Throws:

Exception

write

public void write(io.netty.channel.ChannelHandlerContext ctx,
 Object msg,
 io.netty.channel.ChannelPromise promise)
           throws Exception

Specified by:

write in interface io.netty.channel.ChannelOutboundHandler

Overrides:

write in class io.netty.channel.ChannelDuplexHandler

Throws:

Exception

flush

public void flush(io.netty.channel.ChannelHandlerContext ctx)

Specified by:

flush in interface io.netty.channel.ChannelOutboundHandler

Overrides:

flush in class io.netty.channel.ChannelDuplexHandler

handlerRemoved

public void handlerRemoved(io.netty.channel.ChannelHandlerContext ctx)
                    throws Exception

Specified by:

handlerRemoved in interface io.netty.channel.ChannelHandler

Overrides:

handlerRemoved in class io.netty.channel.ChannelHandlerAdapter

Throws:

Exception

close

public void close(io.netty.channel.ChannelHandlerContext ctx,
 io.netty.channel.ChannelPromise promise)
           throws Exception

Specified by:

close in interface io.netty.channel.ChannelOutboundHandler

Overrides:

close in class io.netty.channel.ChannelDuplexHandler

Throws:

Exception

setLatency

public static void setLatency(@Nonnull
 io.netty.channel.Channel channel,
 long delay,
 @Nonnull
 TimeUnit unit)