Method ProcessWalkRequest

ZezeJava/ZezeJava/src/main/java/Zeze/Dbh2/Dbh2.java:389–406

(Walk r)

	}

	@Override
	protected long ProcessWalkRequest(Walk r) throws Exception {
		if (r.Argument.getExclusiveStartKey().size() > 0
				&& !stateMachine.getBucket().inBucket(r.Argument.getExclusiveStartKey())) {
			r.Result.setBucketRefuse(true);
			r.SendResult();
			return 0;
		}
		var bucketEnd = walk(
				r.Argument.getExclusiveStartKey(),
				r.Argument.getProposeLimit(),
				r.Argument.isDesc(),
				r.Argument.getPrefix(),
				(key, it) -> r.Result.getKeyValues().add(new BWalkKeyValue.Data(key, new Binary(it.value()))));
		r.Result.setBucketEnd(bucketEnd);
		r.SendResult();
		return 0;
	}

	@Override
	protected long ProcessWalkKeyRequest(WalkKey r) throws Exception {