Uses of Class
org.corfudb.infrastructure.ServerHandler

Packages that use ServerHandler

Package	Description
org.corfudb.infrastructure

Uses of ServerHandler in org.corfudb.infrastructure

Methods in org.corfudb.infrastructure with annotations of type ServerHandler

Modifier and Type	Method and Description
void	ManagementServer.handleFailureDetectedMsg(CorfuPayloadMsg<DetectorMsg> msg, io.netty.channel.ChannelHandlerContext ctx, IServerRouter r) Triggers the failure handler.
void	ManagementServer.handleFailureDetectorMetricsRequest(CorfuMsg msg, io.netty.channel.ChannelHandlerContext ctx, IServerRouter r)
void	ManagementServer.handleHealingDetectedMsg(CorfuPayloadMsg<DetectorMsg> msg, io.netty.channel.ChannelHandlerContext ctx, IServerRouter r) Triggers the healing handler.
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	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	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	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.handleTrimMarkRequest(CorfuMsg msg, io.netty.channel.ChannelHandlerContext ctx, IServerRouter r) Service an incoming request to retrieve the starting address of this logging unit.
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.