Method send

ZezeJava/ZezeJava/src/main/java/Zeze/Raft/Agent.java:98–128

发送Rpc请求。

(RaftRpc<TArgument, TResult> rpc, ToLongFunction<Protocol<?>> handle)

	 * 发送Rpc请求。
	 */
	public <TArgument extends Serializable, TResult extends Serializable>
	void send(RaftRpc<TArgument, TResult> rpc, ToLongFunction<Protocol<?>> handle) {
		if (handle == null)
			throw new IllegalArgumentException("null handle");
		if (pendingLimit > 0 && pending.size() > pendingLimit) // UrgentPending不限制。
			throw new IllegalStateException("too many pending");

		// 由于interface不能把setter弄成保护的，实际上外面可以修改。
		// 简单检查一下吧。
		if (rpc.getUnique().getRequestId() != 0)
			throw new IllegalStateException("RaftRpc.UniqueRequestId != 0. Need A Fresh RaftRpc");

		rpc.getUnique().setRequestId(uniqueRequestIdGenerator.next());
		// 外面可以设置clientId，默认使用Generator.getName();
		if (rpc.getUnique().getClientId().isEmpty())
			rpc.getUnique().setClientId(uniqueRequestIdGenerator.getName());
		rpc.setCreateTime(System.currentTimeMillis());
		rpc.setSendTime(rpc.getCreateTime());
		if (rpc.getTimeout() == 0) // set default timeout
			rpc.setTimeout(raftConfig.getAgentTimeout());

		rpc.handle = handle;
		if (pending.putIfAbsent(rpc.getUnique().getRequestId(), rpc) != null)
			throw new IllegalStateException("duplicate requestId rpc=" + rpc);

		rpc.setResponseHandle(p -> sendHandle(p, rpc));
		ConnectorProxy leader = this.leader;
		if (!ProxyAgent.send(client, proxyAgent, rpc, leader,
				leader != null ? leader.getConnector().TryGetReadySocket() : null))
			logger.debug("send failed: leader={}, rpc={}", leader, rpc);
	}

	private <TArgument extends Serializable, TResult extends Serializable>
	long sendHandle(Rpc<TArgument, TResult> p, RaftRpc<TArgument, TResult> rpc) {