com.alipay.sofa.jraft.rpc.impl.core

Class AppendEntriesRequestProcessor

java.lang.Object

com.alipay.sofa.jraft.rpc.RpcRequestProcessor<T>

com.alipay.sofa.jraft.rpc.impl.core.NodeRequestProcessor<RpcRequests.AppendEntriesRequest>

com.alipay.sofa.jraft.rpc.impl.core.AppendEntriesRequestProcessor

All Implemented Interfaces:

ConnectionClosedEventListener, RpcProcessor<RpcRequests.AppendEntriesRequest>

public class AppendEntriesRequestProcessor
extends NodeRequestProcessor<RpcRequests.AppendEntriesRequest>
implements ConnectionClosedEventListener

Append entries request processor.

Author:

boyan (boyan@alibaba-inc.com) 2018-Apr-04 3:00:13 PM

Nested Class Summary

Nested classes/interfaces inherited from interface com.alipay.sofa.jraft.rpc.RpcProcessor

RpcProcessor.ExecutorSelector

Field Summary

Fields inherited from class com.alipay.sofa.jraft.rpc.RpcRequestProcessor

LOG

Constructor Summary

Constructors

Constructor and Description
AppendEntriesRequestProcessor(Executor executor)

Method Summary

Modifier and Type	Method and Description
void	destroy()
RpcProcessor.ExecutorSelector	executorSelector()
protected String	getGroupId(RpcRequests.AppendEntriesRequest request)
protected String	getPeerId(RpcRequests.AppendEntriesRequest request)
String	interest() The class name of user request.
void	onClosed(String remoteAddress, Connection conn)
com.google.protobuf.Message	processRequest0(RaftServerService service, RpcRequests.AppendEntriesRequest request, RpcRequestClosure done)

Methods inherited from class com.alipay.sofa.jraft.rpc.impl.core.NodeRequestProcessor

processRequest

Methods inherited from class com.alipay.sofa.jraft.rpc.RpcRequestProcessor

defaultResp, executor, handleRequest

Methods inherited from class java.lang.Object

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

Constructor Detail

AppendEntriesRequestProcessor

public AppendEntriesRequestProcessor(Executor executor)

Method Detail

getPeerId

protected String getPeerId(RpcRequests.AppendEntriesRequest request)

Specified by:

getPeerId in class NodeRequestProcessor<RpcRequests.AppendEntriesRequest>

getGroupId

protected String getGroupId(RpcRequests.AppendEntriesRequest request)

Specified by:

getGroupId in class NodeRequestProcessor<RpcRequests.AppendEntriesRequest>

processRequest0

public com.google.protobuf.Message processRequest0(RaftServerService service,
                                                   RpcRequests.AppendEntriesRequest request,
                                                   RpcRequestClosure done)

Specified by:

processRequest0 in class NodeRequestProcessor<RpcRequests.AppendEntriesRequest>

interest

public String interest()

Description copied from interface: RpcProcessor

The class name of user request. Use String type to avoid loading class.

Specified by:

interest in interface RpcProcessor<RpcRequests.AppendEntriesRequest>

Returns:

interested request's class name

executorSelector

public RpcProcessor.ExecutorSelector executorSelector()

Specified by:

executorSelector in interface RpcProcessor<RpcRequests.AppendEntriesRequest>

Returns:

the executor selector

destroy

public void destroy()

onClosed

public void onClosed(String remoteAddress,
                     Connection conn)

Specified by:

onClosed in interface ConnectionClosedEventListener