com.hazelcast.internal.networking.nio

Class InboundHandlerWithCounters<S,D>

java.lang.Object

com.hazelcast.internal.networking.ChannelHandler<InboundHandler,S,D>

com.hazelcast.internal.networking.InboundHandler<S,D>

com.hazelcast.internal.networking.nio.InboundHandlerWithCounters<S,D>

Direct Known Subclasses:

ClientMessageDecoder, PacketDecoder

public abstract class InboundHandlerWithCounters<S,D>
extends InboundHandler<S,D>

Trigger for the ChannelReader to inject the appropriate counters. This is a temporary solution, it would be best if the counters could be defined directly on handlers and automatically get registered + unregistered. Todo: This class is a hack. We don't want to have any dependencies on this packet.

Field Summary

Fields

Modifier and Type	Field and Description
protected Counter	normalPacketsRead
protected Counter	priorityPacketsRead

Fields inherited from class com.hazelcast.internal.networking.ChannelHandler

channel, dst, src

Constructor Summary

Constructors

Constructor and Description
InboundHandlerWithCounters()

Method Summary

Modifier and Type	Method and Description
void	setNormalPacketsRead(Counter normalPacketsRead)
void	setPriorityPacketsRead(Counter priorityPacketsRead)

Methods inherited from class com.hazelcast.internal.networking.InboundHandler

initSrcBuffer, initSrcBuffer, onRead

Methods inherited from class com.hazelcast.internal.networking.ChannelHandler

dst, dst, handlerAdded, interceptError, setChannel, src, src

Methods inherited from class java.lang.Object

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

Field Detail

normalPacketsRead

protected Counter normalPacketsRead

priorityPacketsRead

protected Counter priorityPacketsRead

Constructor Detail

InboundHandlerWithCounters

public InboundHandlerWithCounters()

Method Detail

setNormalPacketsRead

public void setNormalPacketsRead(Counter normalPacketsRead)

setPriorityPacketsRead

public void setPriorityPacketsRead(Counter priorityPacketsRead)