Method recoverSplitting

ZezeJava/ZezeJava/src/main/java/Zeze/Dbh2/Dbh2.java:488–508

()

	}

	private void recoverSplitting() throws Exception {
		if (!raft.isLeader())
			return;

		stateMachine.setLoadSwitch(true);
		var bucket = stateMachine.getBucket();
		if (null != bucket.getSplittingMeta()) {
			var bucketKeyFirst = bucket.getSplittingMeta().getKeyFirst();
			boolean isMove = bucketKeyFirst.size() == 0; // keyFirst 为空肯定是move
			if (!isMove) {
				// keyFirst不为空，还不能确认就是split，需要进一步判断keyFirst确实是第一条数据。
				try (var it = bucket.getData().iterator()) {
					it.seekToFirst();
					// keyFirst 就是第一条数据，那么当前还是move。
					//noinspection EqualsBetweenInconvertibleTypes
					isMove = it.isValid() && bucketKeyFirst.equals(it.key());
				}
			}
			startSplit(isMove);
		}
	}

	private volatile long splitSerialNo;
	private volatile Dbh2Agent dbh2Splitting;