Class OnzProcedure

ZezeJava/ZezeJava/src/main/java/Zeze/Onz/OnzProcedure.java:20–140

import org.jetbrains.annotations.Nullable;

public class OnzProcedure implements FuncLong {
	private static final @NotNull Logger logger = LogManager.getLogger(OnzProcedure.class);
	private final BFuncProcedure.Data funcArgument;
	private final OnzProcedureStub<?, ?> stub;
	private final Bean argument;
	private final Bean result;
	private final Rpc<?, ?> rpc;
	private volatile TaskCompletionSource<Boolean> commitFuture;

	public Rpc<?, ?> getRpc() {
		return rpc;
	}

	public OnzProcedure(Rpc<?, ?> rpc,
						BFuncProcedure.Data funcArgument,
						OnzProcedureStub<?, ?> stub, Bean argument, Bean result) {
		this.rpc = rpc;
		this.funcArgument = funcArgument;
		this.stub = stub;
		this.argument = argument;
		this.result = result;
	}

	public int getFlushMode() {
		return funcArgument.getFlushMode();
	}

	public long getOnzTid() {
		return funcArgument.getOnzTid();
	}

	public OnzProcedureStub<?, ?> getStub() {
		return stub;
	}

	public Bean getArgument() {
		return argument;
	}

	public Bean getResult() {
		return result;
	}

	public boolean isEnd() {
		return true;
	}

	@Override
	public long call() throws Exception {
		// 这里实际上需要侵入Zeze.Transaction，在锁定，时戳检查完成后，
		// 发送result给调用者，完成ready状态，
		// Zeze.Transaction 需要同步进行等待。

		var txn = Transaction.getCurrent();
		if (null == txn)
			throw new RuntimeException("no transaction.");
		txn.setOnzProcedure(this);
		return stub.call(this, argument, result);