Class Agent

ZezeJava/ZezeJava/src/main/java/Zeze/Raft/Agent.java:39–723

import org.jetbrains.annotations.NotNull;

public final class Agent {
	private static final Logger logger = LogManager.getLogger(Agent.class);
	private static final boolean isDebugEnabled = logger.isDebugEnabled();

	// 保证在Raft-Server检查UniqueRequestId唯一性过期前唯一即可。
	// 使用持久化是为了避免短时间重启，Id重复。
	private final PersistentAtomicLong uniqueRequestIdGenerator;
	private RaftConfig raftConfig;
	private NetClient client;
	private volatile ConnectorProxy leader;
	private final ConcurrentHashMapOrdered<Long, RaftRpc<?, ?>> pending = new ConcurrentHashMapOrdered<>();
	private long term;
	public boolean dispatchProtocolToInternalThreadPool;
	private volatile int pendingLimit = -1; // -1 no limit // 实际上没有进行线程保护。
	private Future<?> resendTask;

	private Action1<Agent> onSetLeader;
	private final Lock mutex = new ReentrantLock();
	private final ProxyAgent proxyAgent;

	public RaftConfig getRaftConfig() {
		return raftConfig;
	}

	public int getPendingLimit() {
		return pendingLimit;
	}

	public void setPendingLimit(int value) {
		pendingLimit = value;
	}

	public NetClient getClient() {
		return client;
	}

	public String getName() {
		return client.getName();
	}

	public ConnectorProxy getLeader() {
		return leader;
	}

	public long getTerm() {
		return term;
	}

	public Action1<Agent> getOnSetLeader() {
		return onSetLeader;
	}

	public void setOnSetLeader(Action1<Agent> onSetLeader) {
		this.onSetLeader = onSetLeader;
	}

	/**
	 * 发送Rpc请求。