Method ProcessGetRequest

ZezeJava/ZezeJava/src/main/java/Zeze/Dbh2/Dbh2.java:207–229

(Zeze.Builtin.Dbh2.Get r)

	}

	@Override
	protected long ProcessGetRequest(Zeze.Builtin.Dbh2.Get r) throws RocksDBException, InterruptedException {
		stateMachine.counterGet.incrementAndGet();
//		var lock = getLocks().get(r.Argument.getKey());
//		lock.lock(this);
//		try {
		// 直接读取数据库。是否可以读取由raft控制。raft启动时有准备阶段。
		var bucket = stateMachine.getBucket();
		if (!bucket.inBucket(r.Argument.getDatabase(), r.Argument.getTable(), r.Argument.getKey()))
			return errorCode(eBucketMismatch);
		var value = bucket.get(r.Argument.getKey());
		if (null == value)
			r.Result.setNull(true);
		else {
			r.Result.setValue(value);
			stateMachine.sizeGet.addAndGet(value.size());
		}
		r.SendResult();
//		} finally {
//			lock.unlock();
//		}
		return 0;
	}

	@Override
	protected long ProcessKeepAliveRequest(KeepAlive r) throws Exception {