| /external/grpc-grpc-java/core/src/main/java/io/grpc/ |
| D | Contexts.java | 141 .withCause(cancellationCause); in statusFromCancelled()
148 return Status.CANCELLED.withDescription("Context cancelled").withCause(cancellationCause); in statusFromCancelled()
150 return status.withCause(cancellationCause); in statusFromCancelled()
|
| D | Status.java | 400 return UNKNOWN.withCause(t); in fromThrowable()
448 public Status withCause(Throwable cause) { in withCause() method in Status
|
| /external/grpc-grpc-java/examples/src/main/java/io/grpc/examples/advanced/ |
| D | JsonMarshaller.java | 70 .withCause(e) in jsonMarshaller()
88 .withCause(e).asRuntimeException(); in jsonMarshaller()
92 .withCause(e).asRuntimeException(); in jsonMarshaller()
|
| /external/grpc-grpc-java/auth/src/main/java/io/grpc/auth/ |
| D | GoogleAuthLibraryCallCredentials.java | 137 .withCause(t)); in applyRequestMetadata()
149 .withCause(e)); in applyRequestMetadata()
153 .withCause(e)); in applyRequestMetadata()
175 .withCause(e).asException(); in serviceUri()
190 "Unable to construct service URI after removing port").withCause(e).asException(); in removePort()
|
| D | ClientAuthInterceptor.java | 111 .withCause(e).asException();
127 .withCause(e).asException();
135 throw Status.UNAUTHENTICATED.withDescription("Unable to get request metadata").withCause(e)
|
| /external/grpc-grpc-java/netty/src/test/java/io/grpc/netty/ |
| D | UtilsTest.java | 60 assertStatusEquals(Status.UNAVAILABLE.withCause(t), Utils.statusFromThrowable(t)); in testStatusFromThrowable()
62 assertStatusEquals(Status.INTERNAL.withCause(t), Utils.statusFromThrowable(t)); in testStatusFromThrowable()
64 assertStatusEquals(Status.UNKNOWN.withCause(t), Utils.statusFromThrowable(t)); in testStatusFromThrowable()
|
| D | NettyServerStreamTest.java | 234 Status status = Status.INTERNAL.withCause(new Throwable()); in abortStreamAndNotSendStatus()
244 Status status = Status.INTERNAL.withCause(new Throwable()); in abortStreamAfterClientHalfCloseShouldCallClose()
|
| /external/grpc-grpc-java/core/src/main/java/io/grpc/internal/ |
| D | ClientCallImpl.java | 393 status = status.withCause(cause); in cancel()
425 stream.cancel(Status.CANCELLED.withCause(e).withDescription("Failed to stream message")); in sendMessage()
491 Status.CANCELLED.withCause(t).withDescription("Failed to read headers"); in headersRead()
529 Status.CANCELLED.withCause(t).withDescription("Failed to read message."); in messagesAvailable()
604 Status.CANCELLED.withCause(t).withDescription("Failed to call onReady."); in onReady()
|
| D | MessageFramer.java | 146 .withCause(e) in writePayload()
151 .withCause(e) in writePayload()
|
| D | CallCredentialsApplyingTransportFactory.java | 94 .withCause(t)); in newStream()
|
| D | AutoConfiguredLoadBalancerFactory.java | 92 .withCause(e); in handleResolvedAddressGroups()
|
| D | DnsNameResolver.java | 218 Status.UNAVAILABLE.withDescription("Unable to resolve host " + host).withCause(e));
243 Status.UNAVAILABLE.withDescription("Unable to resolve host " + host).withCause(e));
|
| /external/grpc-grpc-java/netty/src/main/java/io/grpc/netty/ |
| D | Utils.java | 171 return Status.UNKNOWN.withDescription("channel closed").withCause(extraT); in statusFromThrowable()
174 return Status.UNAVAILABLE.withDescription("io exception").withCause(t); in statusFromThrowable()
177 return Status.INTERNAL.withDescription("http2 exception").withCause(t); in statusFromThrowable()
|
| D | NettyClientTransport.java | 388 .withCause(new ClosedChannelException().initCause(t));
|
| /external/grpc-grpc-java/stub/src/main/java/io/grpc/stub/ |
| D | ClientCalls.java | 135 .withCause(e) in blockingUnaryCall()
211 .withCause(e) in getUnchecked()
237 return Status.UNKNOWN.withDescription("unexpected exception").withCause(t) in toStatusRuntimeException()
570 throw Status.CANCELLED.withDescription("interrupted").withCause(ie).asRuntimeException(); in hasNext()
|
| /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/protobuf-nano/src/main/java/io/grpc/protobuf/nano/ |
| D | NanoUtils.java | 71 throw Status.INTERNAL.withDescription("Failed parsing nano proto message").withCause(ipbe) in parse()
|
| /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/test/java/io/grpc/ |
| D | StatusTest.java | 50 assertSame(Status.CANCELLED, Status.CANCELLED.withCause(null)); in sameCauseReturnsSelf()
|
| /external/grpc-grpc-java/alts/src/main/java/io/grpc/alts/internal/ |
| D | AltsProtocolNegotiator.java | 142 return Status.UNAVAILABLE.withCause(cause).withDescription(msg).asRuntimeException();
|
| /external/grpc-grpc-java/alts/src/main/java/io/grpc/alts/ |
| D | GoogleDefaultChannelBuilder.java | 122 .withCause(e); in build()
|
| /external/grpc-grpc-java/protobuf-lite/src/main/java/io/grpc/protobuf/lite/ |
| D | ProtoLiteUtils.java | 218 .withCause(ipbe).asRuntimeException(); in parse()
|
| /external/grpc-grpc-java/testing/src/main/java/io/grpc/internal/testing/ |
| D | AbstractTransportTest.java | 901 Status status = strippedStatus.withCause(new Exception()); in earlyServerClose_withServerHeaders()
933 Status status = strippedStatus.withCause(new Exception()); in earlyServerClose_noServerHeaders()
977 Status status = strippedStatus.withCause(new Exception()); in earlyServerClose_serverFailure()
1006 clientStream.cancel(Status.CANCELLED.withCause(status.asRuntimeException())); in earlyServerClose_serverFailure_withClientCancelOnListenerClosed()
1014 clientStream.cancel(Status.CANCELLED.withCause(status.asRuntimeException())); in earlyServerClose_serverFailure_withClientCancelOnListenerClosed()
1024 Status status = strippedStatus.withCause(new Exception()); in earlyServerClose_serverFailure_withClientCancelOnListenerClosed()
1053 Status status = Status.CANCELLED.withDescription("Nevermind").withCause(new Exception()); in clientCancel()
1173 .withCause(new Exception()); in serverCancel()
|
| /external/grpc-grpc-java/services/src/main/java/io/grpc/services/ |
| D | ChannelzProtoUtil.java | 467 throw Status.INTERNAL.withCause(e).asRuntimeException(); in getFuture()
469 throw Status.INTERNAL.withCause(e).asRuntimeException(); in getFuture()
|
| /external/grpc-grpc-java/okhttp/src/main/java/io/grpc/okhttp/ |
| D | OkHttpClientTransport.java | 587 throw Status.UNAVAILABLE.withDescription("Failed trying to connect with proxy").withCause(e) in createHttpProxySocket()
735 Status status = Status.UNAVAILABLE.withCause(failureCause); in onException()
982 Status.UNAVAILABLE.withDescription("error in frame handler").withCause(t)); in run()
|