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

Packages that use CorfuPayloadMsg

Package	Description
org.corfudb.infrastructure
org.corfudb.infrastructure.orchestrator
org.corfudb.protocols.wireprotocol

Uses of CorfuPayloadMsg in org.corfudb.infrastructure

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

Modifier and Type	Method and Description
<T> CompletableFuture<T>	BatchProcessor.addTask(BatchWriterOperation.Type type, CorfuPayloadMsg msg) Add a task to the processor.
void	ManagementServer.handleFailureDetectedMsg(CorfuPayloadMsg<DetectorMsg> msg, io.netty.channel.ChannelHandlerContext ctx, IServerRouter r) Triggers the failure handler.
void	ManagementServer.handleHealingDetectedMsg(CorfuPayloadMsg<DetectorMsg> msg, io.netty.channel.ChannelHandlerContext ctx, IServerRouter r) Triggers the healing handler.
void	ManagementServer.handleManagementBootstrap(CorfuPayloadMsg<Layout> msg, io.netty.channel.ChannelHandlerContext ctx, IServerRouter r) Bootstraps the management server.
void	LayoutServer.handleMessageLayoutBootstrap(CorfuPayloadMsg<LayoutBootstrapRequest> msg, io.netty.channel.ChannelHandlerContext ctx, IServerRouter r) Sets the new layout if the server has not been bootstrapped with one already.
void	LayoutServer.handleMessageLayoutCommit(CorfuPayloadMsg<LayoutCommittedRequest> msg, io.netty.channel.ChannelHandlerContext ctx, IServerRouter r) Accepts any committed layouts for the current epoch or newer epochs.
void	LayoutServer.handleMessageLayoutPrepare(CorfuPayloadMsg<LayoutPrepareRequest> msg, io.netty.channel.ChannelHandlerContext ctx, IServerRouter r) Accepts a prepare message if the rank is higher than any accepted so far.
void	LayoutServer.handleMessageLayoutPropose(CorfuPayloadMsg<LayoutProposeRequest> msg, io.netty.channel.ChannelHandlerContext ctx, IServerRouter r) Accepts a proposal for which it had accepted in the prepare phase.
void	LayoutServer.handleMessageLayoutRequest(CorfuPayloadMsg<Long> msg, io.netty.channel.ChannelHandlerContext ctx, IServerRouter r) Handle a layout request message.
void	BaseServer.handleMessageSetEpoch(CorfuPayloadMsg<Long> msg, io.netty.channel.ChannelHandlerContext ctx, IServerRouter r) Respond to a epoch change message.
void	ManagementServer.handleOrchestratorMsg(CorfuPayloadMsg<OrchestratorMsg> msg, io.netty.channel.ChannelHandlerContext ctx, IServerRouter r) Forward an orchestrator request to the orchestrator service.
void	LogUnitServer.handleTailRequest(CorfuPayloadMsg<TailsRequest> msg, io.netty.channel.ChannelHandlerContext ctx, IServerRouter r) Service an incoming request for maximum global address the log unit server has written.
void	LogUnitServer.rangeWrite(CorfuPayloadMsg<RangeWriteMsg> msg, io.netty.channel.ChannelHandlerContext ctx, IServerRouter r) Services incoming range write calls.
void	SequencerServer.resetServer(CorfuPayloadMsg<SequencerRecoveryMsg> msg, io.netty.channel.ChannelHandlerContext ctx, IServerRouter r) Service an incoming request to reset the sequencer.
void	SequencerServer.tokenRequest(CorfuPayloadMsg<TokenRequest> msg, io.netty.channel.ChannelHandlerContext ctx, IServerRouter r) Service an incoming token request.
void	SequencerServer.trimCache(CorfuPayloadMsg<Long> msg, io.netty.channel.ChannelHandlerContext ctx, IServerRouter r)
void	LogUnitServer.write(CorfuPayloadMsg<WriteRequest> msg, io.netty.channel.ChannelHandlerContext ctx, IServerRouter r) Service an incoming write request.

Uses of CorfuPayloadMsg in org.corfudb.infrastructure.orchestrator

Methods in org.corfudb.infrastructure.orchestrator with parameters of type CorfuPayloadMsg

Modifier and Type	Method and Description
void	Orchestrator.handle(CorfuPayloadMsg<OrchestratorMsg> msg, io.netty.channel.ChannelHandlerContext ctx, IServerRouter r)

Uses of CorfuPayloadMsg in org.corfudb.protocols.wireprotocol

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

Modifier and Type	Method and Description
<T> CorfuPayloadMsg<T>	CorfuMsgType.payloadMsg(T payload)