Uses of Class
org.corfudb.protocols.wireprotocol.CorfuMsg

Packages that use CorfuMsg

Package	Description
org.corfudb.infrastructure
org.corfudb.protocols.wireprotocol
org.corfudb.runtime.clients

Uses of CorfuMsg in org.corfudb.infrastructure

Methods in org.corfudb.infrastructure with type parameters of type CorfuMsg

Modifier and Type	Method and Description
<T extends CorfuMsg> CorfuMsgHandler	CorfuMsgHandler.addHandler(CorfuMsgType messageType, org.corfudb.infrastructure.CorfuMsgHandler.Handler<T> handler) Add a handler to this message handler.

Methods in org.corfudb.infrastructure that return types with arguments of type CorfuMsg

Modifier and Type	Method and Description
org.corfudb.infrastructure.CorfuMsgHandler.Handler<CorfuMsg>	CorfuMsgHandler.getHandler(CorfuMsgType type) Get a handler for a specific message type.

Methods in org.corfudb.infrastructure with parameters of type CorfuMsg

Modifier and Type	Method and Description
boolean	CorfuMsgHandler.handle(CorfuMsg message, io.netty.channel.ChannelHandlerContext ctx, IServerRouter r) Handle an incoming CorfuMsg.
void	ManagementServer.handleFailureDetectorMetricsRequest(CorfuMsg msg, io.netty.channel.ChannelHandlerContext ctx, IServerRouter r)
void	ManagementServer.handleLayoutRequest(CorfuMsg msg, io.netty.channel.ChannelHandlerContext ctx, IServerRouter r) Handles the Management layout request.
void	LogUnitServer.handleLogAddressSpaceRequest(CorfuMsg msg, io.netty.channel.ChannelHandlerContext ctx, IServerRouter r) Service an incoming request for log address space, i.e., the map of addresses for every stream in the log.
void	AbstractServer.handleMessage(CorfuMsg msg, io.netty.channel.ChannelHandlerContext ctx, IServerRouter r) Handle a incoming Netty message.
void	SequencerServer.handleMetricsRequest(CorfuMsg msg, io.netty.channel.ChannelHandlerContext ctx, IServerRouter r) Service an incoming metrics request with the metrics response.
void	ManagementServer.handleNodeStateRequest(CorfuMsg msg, io.netty.channel.ChannelHandlerContext ctx, IServerRouter r) Returns current NodeState provided by failure detector.
void	LogUnitServer.handleTrimMarkRequest(CorfuMsg msg, io.netty.channel.ChannelHandlerContext ctx, IServerRouter r) Service an incoming request to retrieve the starting address of this logging unit.
boolean	LayoutServer.isServerReadyToHandleMsg(CorfuMsg msg)
boolean	ManagementServer.isServerReadyToHandleMsg(CorfuMsg msg)
boolean	LogUnitServer.isServerReadyToHandleMsg(CorfuMsg msg)
boolean	BaseServer.isServerReadyToHandleMsg(CorfuMsg msg)
boolean	SequencerServer.isServerReadyToHandleMsg(CorfuMsg msg)
abstract boolean	AbstractServer.isServerReadyToHandleMsg(CorfuMsg msg)
void	NettyServerRouter.sendResponse(io.netty.channel.ChannelHandlerContext ctx, CorfuMsg inMsg, CorfuMsg outMsg) Send a netty message through this router, setting the fields in the outgoing message.
void	IServerRouter.sendResponse(io.netty.channel.ChannelHandlerContext ctx, CorfuMsg inMsg, CorfuMsg outMsg)
boolean	NettyServerRouter.validateEpoch(CorfuMsg msg, io.netty.channel.ChannelHandlerContext ctx) Validate the epoch of a CorfuMsg, and send a WRONG_EPOCH response if the server is in the wrong epoch.

Uses of CorfuMsg in org.corfudb.protocols.wireprotocol

Subclasses of CorfuMsg in org.corfudb.protocols.wireprotocol

Modifier and Type	Class and Description
class	CorfuPayloadMsg<T> A message type which represents an encapsulated Corfu payload.
class	JSONPayloadMsg<T> Created by mwei on 7/27/16.
class	LayoutMsg Created by mwei on 12/14/15.

Fields in org.corfudb.protocols.wireprotocol with type parameters of type CorfuMsg

Modifier and Type	Field and Description
com.google.common.reflect.TypeToken<? extends CorfuMsg>	CorfuMsgType.messageType

Methods in org.corfudb.protocols.wireprotocol that return CorfuMsg

Modifier and Type	Method and Description
static CorfuMsg	CorfuMsg.deserialize(io.netty.buffer.ByteBuf buffer) Take the given bytebuffer and deserialize it into a message.
CorfuMsg	CorfuMsgType.msg()

Methods in org.corfudb.protocols.wireprotocol that return types with arguments of type CorfuMsg

Modifier and Type	Method and Description
List<CorfuMsg>	MsgHandlingFilter.apply(CorfuMsg corfuMsg)

Methods in org.corfudb.protocols.wireprotocol with parameters of type CorfuMsg

Modifier and Type	Method and Description
List<CorfuMsg>	MsgHandlingFilter.apply(CorfuMsg corfuMsg)
void	CorfuMsg.copyBaseFields(CorfuMsg msg) Copy the base fields over to this message.
protected void	NettyCorfuMessageEncoder.encode(io.netty.channel.ChannelHandlerContext channelHandlerContext, CorfuMsg corfuMsg, io.netty.buffer.ByteBuf byteBuf)

Constructor parameters in org.corfudb.protocols.wireprotocol with type arguments of type CorfuMsg

Constructor and Description
MsgHandlingFilter(Function<CorfuMsg,Boolean> filter, Function<CorfuMsg,CorfuMsg> transformFunction) A convenience constructor for when MsgHandlingFilter is being constructed by a filter and a single transformation function on the message.
MsgHandlingFilter(Function<CorfuMsg,Boolean> filter, Function<CorfuMsg,CorfuMsg> transformFunction) A convenience constructor for when MsgHandlingFilter is being constructed by a filter and a single transformation function on the message.
MsgHandlingFilter(Function<CorfuMsg,Boolean> filter, Function<CorfuMsg,CorfuMsg> transformFunction) A convenience constructor for when MsgHandlingFilter is being constructed by a filter and a single transformation function on the message.
MsgHandlingFilter(Function<CorfuMsg,Boolean> filter, List<Function<CorfuMsg,CorfuMsg>> transformFunctions) Constructing a MsgHandlingFilter.
MsgHandlingFilter(Function<CorfuMsg,Boolean> filter, List<Function<CorfuMsg,CorfuMsg>> transformFunctions) Constructing a MsgHandlingFilter.
MsgHandlingFilter(Function<CorfuMsg,Boolean> filter, List<Function<CorfuMsg,CorfuMsg>> transformFunctions) Constructing a MsgHandlingFilter.

Uses of CorfuMsg in org.corfudb.runtime.clients

Classes in org.corfudb.runtime.clients with type parameters of type CorfuMsg

Modifier and Type	Interface and Description
static interface	ClientMsgHandler.Handler<T extends CorfuMsg>

Methods in org.corfudb.runtime.clients with type parameters of type CorfuMsg

Modifier and Type	Method and Description
<T extends CorfuMsg> ClientMsgHandler	ClientMsgHandler.addHandler(CorfuMsgType messageType, ClientMsgHandler.Handler<T> handler) Add a handler to this message handler.

Methods in org.corfudb.runtime.clients with parameters of type CorfuMsg

Modifier and Type	Method and Description
protected void	NettyClientRouter.channelRead0(io.netty.channel.ChannelHandlerContext ctx, CorfuMsg m)
boolean	ClientMsgHandler.handle(CorfuMsg message, io.netty.channel.ChannelHandlerContext ctx) Handle an incoming CorfuMsg.
default void	IClient.handleMessage(CorfuMsg msg, io.netty.channel.ChannelHandlerContext ctx) Handle a incoming message on the channel.
void	NettyClientRouter.sendMessage(io.netty.channel.ChannelHandlerContext ctx, CorfuMsg message) Send a one way message, without adding a completable future.
void	IClientRouter.sendMessage(io.netty.channel.ChannelHandlerContext ctx, CorfuMsg message) Send a one way message, without adding a completable future.
default void	IClientRouter.sendMessage(CorfuMsg message) Send a one way message using the default channel handler, without adding a completable future.
<T> CompletableFuture<T>	NettyClientRouter.sendMessageAndGetCompletable(io.netty.channel.ChannelHandlerContext ctx, CorfuMsg message) Send a message and get a completable future to be fulfilled by the reply.
<T> CompletableFuture<T>	IClientRouter.sendMessageAndGetCompletable(io.netty.channel.ChannelHandlerContext ctx, CorfuMsg message) Send a message and get a completable future to be fulfilled by the reply.
default <T> CompletableFuture<T>	IClientRouter.sendMessageAndGetCompletable(CorfuMsg message) Send a message using the router channel handler and get a completable future to be fulfilled by the reply.
void	NettyClientRouter.sendResponseToServer(io.netty.channel.ChannelHandlerContext ctx, CorfuMsg inMsg, CorfuMsg outMsg) Send a netty message through this router, setting the fields in the outgoing message.
void	IClientRouter.sendResponseToServer(io.netty.channel.ChannelHandlerContext ctx, CorfuMsg inMsg, CorfuMsg outMsg) Send a netty message through this router, setting the fields in the outgoing message.