Method sendForWaitHandle

ZezeJava/ZezeJava/src/main/java/Zeze/Raft/Agent.java:160–183

(Rpc<TArgument, TResult> p, RaftRpc<TArgument, TResult> rpc)

	}

	@SuppressWarnings("SameReturnValue")
	private <TArgument extends Serializable, TResult extends Serializable>
	long sendForWaitHandle(Rpc<TArgument, TResult> p, RaftRpc<TArgument, TResult> rpc) {
		var net = (RaftRpc<TArgument, TResult>)p;
		if (net.isTimeout() || isRetryError(net.getResultCode()))
			return Procedure.Success; // Pending Will Resend.

		long requestId = rpc.getUnique().getRequestId();
		if (pending.remove(requestId) != null) {
			rpc.setRequest(net.isRequest());
			rpc.Result = net.Result;
			rpc.setSender(net.getSender());
			rpc.setResultCode(net.getResultCode());

			if (rpc.getResultCode() == Procedure.RaftApplied)
				rpc.setIsTimeout(false);
			if (isDebugEnabled) {
				logger.debug("sendForWaitHandle Rpc={} RequestId={} ResultCode={} Sender={}",
						rpc.getClass().getSimpleName(), requestId, rpc.getResultCode(), rpc.getSender());
			}
			rpc.future.setResult(rpc);
		}
		return Procedure.Success;
	}

	public <TArgument extends Serializable, TResult extends Serializable>
	TaskCompletionSourceX<RaftRpc<TArgument, TResult>> sendForWait(RaftRpc<TArgument, TResult> rpc) {