| /external/grpc-grpc-java/auth/src/main/java/io/grpc/auth/ |
| D | ClientAuthInterceptor.java | 100 throw Status.UNAUTHENTICATED.withDescription("Channel has no authority").asException();
111 .withCause(e).asException();
127 .withCause(e).asException();
136 .asException();
|
| D | GoogleAuthLibraryCallCredentials.java | 175 .withCause(e).asException(); in serviceUri()
190 "Unable to construct service URI after removing port").withCause(e).asException(); in removePort()
|
| /external/grpc-grpc-java/core/src/test/java/io/grpc/ |
| D | StatusTest.java | 38 assertEquals("UNKNOWN", Status.UNKNOWN.asException().getMessage()); in verifyExceptionMessage()
40 Status.CANCELLED.withDescription("This is a test").asException().getMessage()); in verifyExceptionMessage()
|
| D | ContextsTest.java | 196 cancellableContext.cancel(Status.DEADLINE_EXCEEDED.withDescription("foo bar").asException()); in statusFromCancelled_returnStatusAsSetOnCtx()
245 Exception e = Status.UNKNOWN.asException(); in statusFromCancelled_StatusUnknownShouldWork()
|
| /external/grpc-grpc-java/protobuf/src/main/java/io/grpc/protobuf/ |
| D | StatusProto.java | 85 return toStatus(statusProto).asException(toMetadata(statusProto)); in toStatusException()
103 return toStatus(statusProto).asException(toMetadata(statusProto, metadata)); in toStatusException()
|
| /external/grpc-grpc-java/protobuf/src/test/java/io/grpc/protobuf/ |
| D | StatusProtoTest.java | 133 assertNull(StatusProto.fromThrowable(status.asException())); in fromThrowable_shouldReturnNullIfTrailersAreNull()
142 assertNull(StatusProto.fromThrowable(status.asException(emptyMetadata))); in fromThrowable_shouldReturnNullIfStatusDetailsKeyIsMissing()
|
| /external/grpc-grpc-java/netty/src/main/java/io/grpc/netty/ |
| D | ClientTransportLifecycleManager.java | 52 shutdownThrowable = s.asException(); in notifyShutdown()
|
| D | NettyClientTransport.java | 128 callback.onFailure(statusExplainingWhyTheChannelIsNull.asException()); in ping()
140 Http2Ping.notifyFailed(callback, executor, s.asException()); in ping()
|
| D | NettyClientHandler.java | 627 .withCause(future.cause()).asException(); in sendPingFrame()
724 throw EXHAUSTED_STREAMS_STATUS.asException(); in incrementAndGetNextStreamId()
|
| /external/grpc-grpc-java/benchmarks/src/main/java/io/grpc/benchmarks/driver/ |
| D | LoadWorker.java | 156 responseObserver.onError(Status.INTERNAL.withCause(t).asException()); in runServer()
208 responseObserver.onError(Status.INTERNAL.withCause(t).asException());
|
| /external/grpc-grpc-java/core/src/main/java/io/grpc/internal/ |
| D | FailingClientTransport.java | 56 callback.onFailure(error.asException()); in ping()
|
| /external/grpc-grpc-java/examples/src/main/java/io/grpc/examples/manualflowcontrol/ |
| D | ManualFlowControlServer.java | 105 … Status.UNKNOWN.withDescription("Error handling request").withCause(throwable).asException()); in main()
|
| /external/grpc-grpc-java/core/src/main/java/io/grpc/ |
| D | Status.java | 533 public StatusException asException() { in asException() method in Status
541 public StatusException asException(@Nullable Metadata trailers) { in asException() method in Status
|
| /external/grpc-grpc-java/okhttp/src/main/java/io/grpc/okhttp/ |
| D | OkHttpClientTransport.java | 583 throw Status.UNAVAILABLE.withDescription(message).asException(); in createHttpProxySocket()
588 .asException(); in createHttpProxySocket()
895 return goAwayStatus.asException(); in getPingFailure()
897 return Status.UNAVAILABLE.withDescription("Connection closed").asException(); in getPingFailure()
|
| /external/grpc-grpc-java/grpclb/src/test/java/io/grpc/grpclb/ |
| D | GrpclbLoadBalancerTest.java | 559 lbResponseObserver.onError(Status.UNAVAILABLE.asException()); in loadReporting()
1084 lbResponseObserver.onError(streamError.asException()); in subtestGrpclbFallbackInitialTimeout()
1159 lbResponseObserver.onError(streamError.asException()); in subtestGrpclbFallbackInitialTimeout()
1257 lbResponseObserver.onError(Status.UNAVAILABLE.asException()); in subtestGrpclbFallbackConnectionLost()
1433 lbResponseObserver.onError(Status.UNAVAILABLE.asException()); in grpclbBalancerStreamRetry()
1455 lbResponseObserver.onError(Status.UNAVAILABLE.asException()); in grpclbBalancerStreamRetry()
1467 lbResponseObserver.onError(Status.UNAVAILABLE.asException()); in grpclbBalancerStreamRetry()
|
| /external/grpc-grpc-java/netty/src/test/java/io/grpc/netty/ |
| D | UtilsTest.java | 57 assertSame(s, Utils.statusFromThrowable(new Exception(s.asException()))); in testStatusFromThrowable()
|
| D | NettyClientTransportTest.java | 698 StatusException e = status.asException(); in closed()
|
| D | NettyServerHandlerTest.java | 327 assertEquals(e, captor.getValue().asException().getCause()); in streamErrorShouldNotCloseChannel()
|
| /external/grpc-grpc-java/benchmarks/src/main/java/io/grpc/benchmarks/qps/ |
| D | AsyncServer.java | 278 .withDescription("never received any requests").asException());
|