com.hazelcast.nio.tcp

Class SingleProtocolDecoder

java.lang.Object

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

com.hazelcast.internal.networking.InboundHandler<ByteBuffer,Void>

com.hazelcast.nio.tcp.SingleProtocolDecoder

Direct Known Subclasses:

TextHandshakeDecoder

public class SingleProtocolDecoder
extends InboundHandler<ByteBuffer,Void>

Field Summary

Fields

Modifier and Type	Field and Description
protected InboundHandler[]	inboundHandlers
protected ProtocolType	supportedProtocol

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

channel, dst, src

Constructor Summary

Constructors

Constructor and Description
SingleProtocolDecoder(ProtocolType supportedProtocol, InboundHandler next)
SingleProtocolDecoder(ProtocolType supportedProtocol, InboundHandler[] next, MemberProtocolEncoder encoder) Decodes first 3 incoming bytes, validates against supportedProtocol and, when matching, replaces itself in the inbound pipeline with the next InboundHandlers.

Method Summary

Modifier and Type	Method and Description
void	handlerAdded() Gets called when this ChannelHandler is added to the pipeline.
HandlerStatus	onRead() A callback to indicate that data is available in the src to be processed.
protected void	setupNextDecoder()
protected void	verifyProtocol(String incomingProtocol)

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

initSrcBuffer, initSrcBuffer

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

dst, dst, interceptError, setChannel, src, src

Methods inherited from class java.lang.Object

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

Field Detail

inboundHandlers

protected final InboundHandler[] inboundHandlers

supportedProtocol

protected final ProtocolType supportedProtocol

Constructor Detail

SingleProtocolDecoder

public SingleProtocolDecoder(ProtocolType supportedProtocol,
                             InboundHandler next)

SingleProtocolDecoder

public SingleProtocolDecoder(ProtocolType supportedProtocol,
                             InboundHandler[] next,
                             MemberProtocolEncoder encoder)

Decodes first 3 incoming bytes, validates against supportedProtocol and, when matching, replaces itself in the inbound pipeline with the next InboundHandlers.

Parameters:

supportedProtocol - the ProtocolType supported by this ProtocolDecoder

next - the InboundHandlers to replace this one in the inbound pipeline upon match of protocol bytes

encoder - a OutboundHandler that will be notified when matching protocol bytes have been received

Method Detail

handlerAdded

public void handlerAdded()

Description copied from class: ChannelHandler

Gets called when this ChannelHandler is added to the pipeline. This method should execute very quickly because it could be executed on an io thread. Will be called from a thread owning this handler.

Overrides:

handlerAdded in class ChannelHandler<InboundHandler,ByteBuffer,Void>

onRead

public HandlerStatus onRead()

Description copied from class: InboundHandler

A callback to indicate that data is available in the src to be processed. InboundHandlers should be able to deal with spurious onReads (so a read even though there is nothing to be processed).

Specified by:

onRead in class InboundHandler<ByteBuffer,Void>

Returns:

HandlerStatus the status of the handler after processing the src.

setupNextDecoder

protected void setupNextDecoder()

verifyProtocol

protected void verifyProtocol(String incomingProtocol)