Home
last modified time | relevance | path

Searched refs:fromThrowable (Results 1 – 25 of 35) sorted by relevance

12

/external/grpc-grpc-java/protobuf/src/test/java/io/grpc/protobuf/
DStatusProtoTest.java47 com.google.rpc.Status extractedStatusProto = StatusProto.fromThrowable(sre); in toStatusRuntimeException()
57 com.google.rpc.Status extractedStatusProto = StatusProto.fromThrowable(sre); in toStatusRuntimeExceptionWithMetadata_shouldIncludeMetadata()
89 com.google.rpc.Status extractedStatusProto = StatusProto.fromThrowable(se); in toStatusException()
99 com.google.rpc.Status extractedStatusProto = StatusProto.fromThrowable(se); in toStatusExceptionWithMetadata_shouldIncludeMetadata()
132 assertNull(StatusProto.fromThrowable(status.asRuntimeException())); in fromThrowable_shouldReturnNullIfTrailersAreNull()
133 assertNull(StatusProto.fromThrowable(status.asException())); in fromThrowable_shouldReturnNullIfTrailersAreNull()
141 assertNull(StatusProto.fromThrowable(status.asRuntimeException(emptyMetadata))); in fromThrowable_shouldReturnNullIfStatusDetailsKeyIsMissing()
142 assertNull(StatusProto.fromThrowable(status.asException(emptyMetadata))); in fromThrowable_shouldReturnNullIfStatusDetailsKeyIsMissing()
150 com.google.rpc.Status extractedStatusProto = StatusProto.fromThrowable(sre); in fromThrowableWithNestedStatusRuntimeException()
151 com.google.rpc.Status extractedStatusProtoFromNestedSre = StatusProto.fromThrowable(nestedSre); in fromThrowableWithNestedStatusRuntimeException()
[all …]
/external/grpc-grpc-java/examples/src/main/java/io/grpc/examples/errorhandling/
DErrorHandlingClient.java85 Status status = Status.fromThrowable(e); in blockingCall()
103 Status status = Status.fromThrowable(e.getCause()); in futureCallDirect()
127 Status status = Status.fromThrowable(t); in futureCallCallback()
154 Status status = Status.fromThrowable(t); in asyncCall()
DDetailErrorSample.java101 Status status = Status.fromThrowable(t); in verifyErrorReply()
/external/grpc-grpc-java/core/src/test/java/io/grpc/internal/
DAbstractClientStreamTest.java247 assertEquals(Status.INTERNAL.getCode(), Status.fromThrowable(t).getCode()); in inboundHeadersReceived_failsOnUnrecognizedContentEncoding()
250 Status.fromThrowable(t) in inboundHeadersReceived_failsOnUnrecognizedContentEncoding()
269 assertEquals(Status.INTERNAL.getCode(), Status.fromThrowable(t).getCode()); in inboundHeadersReceived_disallowsContentAndMessageEncoding()
272 Status.fromThrowable(t) in inboundHeadersReceived_disallowsContentAndMessageEncoding()
313 assertEquals(Status.INTERNAL.getCode(), Status.fromThrowable(t).getCode()); in inboundHeadersReceived_failsOnUnrecognizedMessageEncoding()
316 Status.fromThrowable(t).getDescription().startsWith("Can't find decompressor for")); in inboundHeadersReceived_failsOnUnrecognizedMessageEncoding()
/external/grpc-grpc-java/examples/src/test/java/io/grpc/examples/routeguide/
DRouteGuideClientTest.java160 assertEquals(fakeError.getStatus(), Status.fromThrowable(errorCaptor.getValue())); in getFeature_error()
237 assertEquals(fakeError.getStatus(), Status.fromThrowable(errorCaptor.getValue())); in listFeatures_error()
350 assertEquals(fakeError.getStatus(), Status.fromThrowable(errorCaptor.getValue())); in recordRoute_serverError()
516 assertEquals(fakeError.getStatus(), Status.fromThrowable(errorCaptor.getValue())); in routeChat_errorResponse()
/external/grpc-grpc-java/interop-testing/src/test/java/io/grpc/testing/integration/
DMoreInProcessTest.java190 assertEquals(fakeError.getCode(), Status.fromThrowable(throwableRef.get()).getCode()); in asyncClientStreaming_serverErrorPriorToRequest()
250 assertEquals(Status.UNKNOWN, Status.fromThrowable(throwableRef.get())); in asyncClientStreaming_erroneousServiceImpl()
DCascadingTest.java120 Status status = Status.fromThrowable(ex); in testCascadingCancellationViaOuterContextCancellation()
313 Status status = Status.fromThrowable(t); in startCallTreeServer()
/external/grpc-grpc-java/benchmarks/src/main/java/io/grpc/benchmarks/driver/
DLoadWorker.java164 Status status = Status.fromThrowable(t); in runServer()
216 Status status = Status.fromThrowable(t);
/external/grpc-grpc-java/examples/src/main/java/io/grpc/examples/routeguide/
DRouteGuideClient.java150 warning("RecordRoute Failed: {0}", Status.fromThrowable(t)); in recordRoute()
215 warning("RouteChat Failed: {0}", Status.fromThrowable(t)); in routeChat()
/external/downloader/src/main/java/com/google/android/downloader/
DErrorDetails.java110 public static ErrorDetails fromThrowable(Throwable throwable) { in fromThrowable() method in ErrorDetails
/external/grpc-grpc-java/core/src/main/java/io/grpc/
DContexts.java143 Status status = Status.fromThrowable(cancellationCause); in statusFromCancelled()
DClientInterceptors.java239 responseListener.onClose(Status.fromThrowable(e), new Metadata());
/external/grpc-grpc-java/interop-testing/src/main/java/io/grpc/testing/integration/
DHttp2Client.java236 assertRstStreamReceived(Status.fromThrowable(responseObserver.getError())); in rstAfterData()
252 assertRstStreamReceived(Status.fromThrowable(responseObserver.getError())); in rstDuringData()
DAbstractInteropTest.java612 assertEquals(Status.INVALID_ARGUMENT.getCode(), Status.fromThrowable(e).getCode()); in clientCompressedStreaming()
764 Status.fromThrowable(responseObserver.getError()).getCode()); in cancelAfterBegin()
803 Status.fromThrowable(responseObserver.getError()).getCode()); in cancelAfterFirstResponse()
1129 Status.fromThrowable(recorder.getError()).getCode()); in deadlineExceededServerStreaming()
1539 assertEquals(Status.UNKNOWN.getCode(), Status.fromThrowable(captor.getValue()).getCode()); in statusCodeAndMessage()
1540 assertEquals(errorMessage, Status.fromThrowable(captor.getValue()).getDescription()); in statusCodeAndMessage()
1620 Status.fromThrowable(responseObserver.getError()).getCode()); in timeoutOnSleepingServer()
/external/grpc-grpc-java/protobuf/src/main/java/io/grpc/protobuf/
DStatusProto.java134 public static com.google.rpc.Status fromThrowable(Throwable t) { in fromThrowable() method in StatusProto
/external/grpc-grpc-java/benchmarks/src/main/java/io/grpc/benchmarks/qps/
DAsyncClient.java166 Status status = Status.fromThrowable(t); in doUnaryCalls()
246 Status status = Status.fromThrowable(t); in onError()
DOpenLoopClient.java190 Status status = Status.fromThrowable(t); in newRpc()
/external/grpc-grpc-java/netty/src/main/java/io/grpc/netty/
DNettyServerStream.java192 Status status = Status.fromThrowable(cause); in deframeFailed()
DNettyClientStream.java290 http2ProcessingFailed(Status.fromThrowable(cause), true, new Metadata()); in deframeFailed()
DUtils.java157 Status s = Status.fromThrowable(t); in statusFromThrowable()
/external/grpc-grpc-java/netty/src/test/java/io/grpc/netty/
DNettyClientHandlerTest.java335 Status status = Status.fromThrowable(future.cause()); in receivedGoAwayShouldCancelBufferedStream()
398 Status status = Status.fromThrowable(future.cause()); in receivedGoAwayShouldFailUnknownBufferedStreams()
413 Status status = Status.fromThrowable(future.cause()); in receivedGoAwayShouldFailNewStreams()
/external/grpc-grpc-java/core/src/main/java/io/grpc/internal/
DServerCallImpl.java142 close(Status.fromThrowable(e), new Metadata()); in sendMessage()
DServerImpl.java482 stream.close(Status.fromThrowable(e), new Metadata()); in streamCreated()
486 stream.close(Status.fromThrowable(e), new Metadata()); in streamCreated()
/external/grpc-grpc-java/stub/src/test/java/io/grpc/stub/
DClientCallsTest.java183 Status status = Status.fromThrowable(e); in unaryFutureCallFailed()
561 Status status = Status.fromThrowable(e); in blockingResponseStreamFailed()
/external/grpc-grpc-java/stub/src/main/java/io/grpc/stub/
DServerCalls.java350 call.close(Status.fromThrowable(t), metadata); in onError()

12