andreacavalli/rockserver
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Fix reduce range bug

Browse Source
This commit is contained in:
Andrea Cavalli 2024-10-24 00:26:00 +02:00
parent dd11e24351
commit fbf17c8650
1 changed files with 15 additions and 16 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

21
src/main/java/it/cavallium/rockserver/core/server/GrpcServer.java
View File

@ -469,23 +469,22 @@ public class GrpcServer extends Server {
@Override @Override
public Mono<FirstAndLast> reduceRangeFirstAndLast(GetRangeRequest request) { public Mono<FirstAndLast> reduceRangeFirstAndLast(GetRangeRequest request) {
return executeSync(() -> { var arena = Arena.ofAuto();
try (var arena = Arena.ofConfined()) { return Mono.fromFuture(() -> asyncApi.reduceRangeAsync(arena, request.getTransactionId(), request.getColumnId(),
it.cavallium.rockserver.core.common.FirstAndLast<it.cavallium.rockserver.core.common.KV> firstAndLast
= api.reduceRange(arena,
request.getTransactionId(),
request.getColumnId(),
mapKeys(arena, request.getStartKeysInclusiveCount(), request::getStartKeysInclusive), mapKeys(arena, request.getStartKeysInclusiveCount(), request::getStartKeysInclusive),
mapKeys(arena, request.getEndKeysExclusiveCount(), request::getEndKeysExclusive), mapKeys(arena, request.getEndKeysExclusiveCount(), request::getEndKeysExclusive),
request.getReverse(), request.getReverse(),
RequestType.firstAndLast(), RequestType.firstAndLast(),
request.getTimeoutMs() request.getTimeoutMs()
); )).map(firstAndLast -> {
return FirstAndLast.newBuilder() var resultBuilder = FirstAndLast.newBuilder();
.setFirst(unmapKV(firstAndLast.first())) if (firstAndLast.first() != null) {
.setLast(unmapKV(firstAndLast.last())) resultBuilder.setFirst(unmapKV(firstAndLast.first()));
.build();
} }
if (firstAndLast.last() != null) {
resultBuilder.setLast(unmapKV(firstAndLast.last()));
}
return resultBuilder.build();
}); });
} }