admin/eagle0
1
0
Fork 0
mirror of https://github.com/nolen777/eagle0.git synced 2026-07-28 22:35:42 +00:00
Code Issues Packages Projects Releases Wiki Activity

Suppress expected cancelled stream logs (#8425)

Browse Source
This commit is contained in:
admin
2026-07-10 19:20:04 -07:00
committed by GitHub
parent 43ee2bfd1f
commit 311cf6e262
1 changed files with 13 additions and 9 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/main/scala/net/eagle0/eagle/service/EagleServiceImpl.scala
+13 -9
View File
@@ -5,8 +5,8 @@ import scala.concurrent.Future
import scala.util.{Random, Try}
import scala.util.hashing.MurmurHash3
import io.grpc.{Status, StatusRuntimeException}
import io.grpc.stub.StreamObserver
import io.grpc.StatusRuntimeException
import io.sentry.Sentry
import net.eagle0.common.{FunctionalRandom, RandomState, SimpleTimedLogger}
import net.eagle0.eagle.api.eagle.*
@@ -389,14 +389,16 @@ class EagleServiceImpl(
}
override def onError(t: Throwable): Unit = t match {
case ce: EagleClientException =>
case ce: EagleClientException =>
responseObserver.onError(ce)
case sre: StatusRuntimeException =>
case sre: StatusRuntimeException if sre.getStatus.getCode == Status.Code.CANCELLED =>
responseObserver.onError(sre)
case sre: StatusRuntimeException =>
SimpleTimedLogger.printLogger.logLine(
s"Caught StatusRuntimeError $sre for ${responseObserver.userName}, it's probably fine"
s"Caught StatusRuntimeError $sre for ${responseObserver.userName}"
)
responseObserver.onError(sre)
case e: Exception =>
case e: Exception =>
SimpleTimedLogger.printLogger.logLine(
s"Caught error $e for ${responseObserver.userName}"
)
@@ -552,7 +554,7 @@ class EagleServiceImpl(
)
)
} catch {
case ce: EagleClientException =>
case ce: EagleClientException =>
// Send failure acknowledgment before error (wrapped to prevent cascading failures)
try
responseObserver.onNext(
@@ -571,12 +573,14 @@ class EagleServiceImpl(
}
end try
responseObserver.onError(ce)
case sre: StatusRuntimeException =>
case sre: StatusRuntimeException if sre.getStatus.getCode == Status.Code.CANCELLED =>
responseObserver.onError(sre)
case sre: StatusRuntimeException =>
SimpleTimedLogger.printLogger.logLine(
s"Caught StatusRuntimeError $sre for ${responseObserver.userName}, it's probably fine"
s"Caught StatusRuntimeError $sre for ${responseObserver.userName}"
)
responseObserver.onError(sre)
case e: Exception =>
case e: Exception =>
SimpleTimedLogger.printLogger.logLine(s"Caught error $e")
e.printStackTrace()
// Send failure acknowledgment before error (wrapped to prevent cascading failures)