com.mongodb.connection.netty

Class ReadTimeoutHandler

java.lang.Object

io.netty.channel.ChannelHandlerAdapter

io.netty.channel.ChannelInboundHandlerAdapter

com.mongodb.connection.netty.ReadTimeoutHandler

All Implemented Interfaces:

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

final class ReadTimeoutHandler
extends io.netty.channel.ChannelInboundHandlerAdapter

Passes a ReadTimeoutException if the time between a scheduleTimeout(io.netty.channel.ChannelHandlerContext) and removeTimeout(io.netty.channel.ChannelHandlerContext) is longer than the set timeout.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
private static class	ReadTimeoutHandler.ReadTimeoutTask

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

io.netty.channel.ChannelHandler.Sharable

Field Summary

Fields

Modifier and Type	Field and Description
private long	readTimeout
private java.util.concurrent.ScheduledFuture<?>	timeout

Constructor Summary

Constructors

Constructor and Description
ReadTimeoutHandler(long readTimeout)

Method Summary

Modifier and Type	Method and Description
(package private) void	removeTimeout(io.netty.channel.ChannelHandlerContext ctx)
(package private) void	scheduleTimeout(io.netty.channel.ChannelHandlerContext ctx)

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

handlerAdded, handlerRemoved, 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, handlerRemoved

Field Detail

readTimeout

private final long readTimeout

timeout

private volatile java.util.concurrent.ScheduledFuture<?> timeout

Constructor Detail

ReadTimeoutHandler

public ReadTimeoutHandler(long readTimeout)

Method Detail

scheduleTimeout

void scheduleTimeout(io.netty.channel.ChannelHandlerContext ctx)

removeTimeout

void removeTimeout(io.netty.channel.ChannelHandlerContext ctx)