Method commit

ZezeJava/ZezeJava/src/main/java/Zeze/Dbh2/CommitRocks.java:211–238

(String queryHost, int queryPort, BPrepareBatches.Data batches)

	}

	public void commit(String queryHost, int queryPort, BPrepareBatches.Data batches) {
		var state = buildTransactionState(batches);
		var tidBytes = new byte[8];
		var tid = prepare(queryHost, queryPort, state, batches, tidBytes);

		try {
			// 保存 commit-point，如果失败，则 undo。
			saveCommitPoint(tidBytes, state, Commit.eCommitting);
		} catch (Throwable ex) {
			undo(tid, state);
			removeCommitIndex(tidBytes);
			throw new RuntimeException(ex);
		}

		// commit
		try {
			var futures = new ArrayList<TaskCompletionSource<?>>();
			for (var e : state.getBuckets()) {
				futures.add(manager.openBucket(e).commitBatch(tid));
			}
			for (var e : futures)
				e.await();
			removeCommitIndex(tidBytes);
		} catch (Throwable ex) {
			// timer will redo
			logger.error("", ex);
		}
	}

	public static BTransactionState.Data buildTransactionState(BPrepareBatches.Data batches) {
		var bState = new BTransactionState.Data();