Method sendForWait

ZezeJava/ZezeJava/src/main/java/Zeze/Raft/Agent.java:185–214

(RaftRpc<TArgument, TResult> rpc)

	}

	public <TArgument extends Serializable, TResult extends Serializable>
	TaskCompletionSourceX<RaftRpc<TArgument, TResult>> sendForWait(RaftRpc<TArgument, TResult> rpc) {
		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
		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());

		var future = new TaskCompletionSourceX<RaftRpc<TArgument, TResult>>();
		rpc.future = future;
		if (pending.putIfAbsent(rpc.getUnique().getRequestId(), rpc) != null)
			throw new IllegalStateException("duplicate requestId rpc=" + rpc);

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

	/**
	 * Connector 代理，