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

Fix errors not handled when closed

Browse Source
This commit is contained in:
Andrea Cavalli 2024-10-02 18:09:08 +02:00
parent b4c610be08
commit 60474f2a75
1 changed files with 13 additions and 8 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

@ -772,15 +772,20 @@ public class GrpcServer extends Server {
if (ex instanceof CompletionException exx) { if (ex instanceof CompletionException exx) {
handleError(responseObserver, exx.getCause()); handleError(responseObserver, exx.getCause());
} else { } else {
if (ex instanceof RocksDBException e) { var serverResponseObserver = ((ServerCallStreamObserver<?>) responseObserver);
responseObserver.onError(Status.INTERNAL if (!serverResponseObserver.isCancelled()) {
.withDescription(e.getLocalizedMessage()) if (ex instanceof RocksDBException e) {
.withCause(e) responseObserver.onError(Status.INTERNAL
.asException()); .withDescription(e.getLocalizedMessage())
.withCause(e)
.asException());
} else {
responseObserver.onError(Status.INTERNAL
.withCause(ex)
.asException());
}
} else { } else {
responseObserver.onError(Status.INTERNAL LOG.error("Unexpected error", ex);
.withCause(ex)
.asException());
} }
} }
} }