| /external/grpc-grpc-java/stub/src/main/java/io/grpc/stub/ |
| D | ClientCalls.java | 136 .asRuntimeException(); in blockingUnaryCall()
212 .asRuntimeException(); in getUnchecked()
238 .asRuntimeException(); in toStatusRuntimeException()
418 .asRuntimeException(); in onMessage()
434 observer.onError(status.asRuntimeException(trailers)); in onClose()
466 .asRuntimeException(); in onMessage()
478 .asRuntimeException(trailers)); in onClose()
482 responseFuture.setException(status.asRuntimeException(trailers)); in onClose()
570 throw Status.CANCELLED.withDescription("interrupted").withCause(ie).asRuntimeException(); in hasNext()
576 throw e.getStatus().asRuntimeException(e.getTrailers()); in hasNext()
[all …]
|
| D | ServerCalls.java | 272 .asRuntimeException()); in onCancel()
335 throw Status.CANCELLED.withDescription("call already cancelled").asRuntimeException(); in onNext()
356 throw Status.CANCELLED.withDescription("call already cancelled").asRuntimeException(); in onCompleted()
409 .asRuntimeException()); in asyncUnimplementedUnaryCall()
|
| /external/grpc-grpc-java/core/src/main/java/io/grpc/internal/ |
| D | MessageFramer.java | 147 .asRuntimeException(); in writePayload()
152 .asRuntimeException(); in writePayload()
157 throw Status.INTERNAL.withDescription(err).asRuntimeException(); in writePayload()
175 .asRuntimeException(); in writeUncompressed()
195 .asRuntimeException(); in writeCompressed()
218 .asRuntimeException(); in writeKnownLengthUncompressed()
|
| D | MessageDeframer.java | 377 .asRuntimeException(); in processHeader()
387 .asRuntimeException(); in processHeader()
424 .asRuntimeException(); in getCompressedBody()
517 maxMessageSize, count)).asRuntimeException(); in verifySize()
|
| D | AbstractClientStream.java | 311 .asRuntimeException()); in inboundHeadersReceived()
323 .asRuntimeException()); in inboundHeadersReceived()
331 .asRuntimeException()); in inboundHeadersReceived()
|
| D | AbstractServerStream.java | 238 .asRuntimeException()); in deframerClosed()
|
| /external/grpc-grpc-java/services/src/main/java/io/grpc/services/ |
| D | ChannelzService.java | 81 responseObserver.onError(Status.NOT_FOUND.asRuntimeException()); in getChannel()
109 responseObserver.onError(Status.NOT_FOUND.asRuntimeException()); in getSubchannel()
127 responseObserver.onError(Status.NOT_FOUND.asRuntimeException()); in getSocket()
145 responseObserver.onError(Status.NOT_FOUND.asRuntimeException()); in getServerSockets()
|
| D | ChannelzProtoUtil.java | 463 .asRuntimeException(); in getFuture()
467 throw Status.INTERNAL.withCause(e).asRuntimeException(); in getFuture()
469 throw Status.INTERNAL.withCause(e).asRuntimeException(); in getFuture()
|
| /external/grpc-grpc-java/examples/src/main/java/io/grpc/examples/advanced/ |
| D | JsonMarshaller.java | 72 .asRuntimeException(); in jsonMarshaller()
88 .withCause(e).asRuntimeException(); in jsonMarshaller()
92 .withCause(e).asRuntimeException(); in jsonMarshaller()
|
| /external/grpc-grpc-java/core/src/test/java/io/grpc/ |
| D | StatusTest.java | 35 assertEquals("UNKNOWN", Status.UNKNOWN.asRuntimeException().getMessage()); in verifyExceptionMessage()
37 Status.CANCELLED.withDescription("This is a test").asRuntimeException().getMessage()); in verifyExceptionMessage()
|
| /external/grpc-grpc-java/protobuf/src/main/java/io/grpc/protobuf/ |
| D | StatusProto.java | 52 return toStatus(statusProto).asRuntimeException(toMetadata(statusProto)); in toStatusRuntimeException()
70 return toStatus(statusProto).asRuntimeException(toMetadata(statusProto, metadata)); in toStatusRuntimeException()
|
| /external/grpc-grpc-java/alts/src/main/java/io/grpc/alts/internal/ |
| D | AltsProtocolNegotiator.java | 120 fail(ctx, Status.UNAVAILABLE.withDescription(errorMessage).asRuntimeException());
142 return Status.UNAVAILABLE.withCause(cause).withDescription(msg).asRuntimeException();
|
| /external/grpc-grpc-java/protobuf/src/test/java/io/grpc/protobuf/ |
| D | StatusProtoTest.java | 132 assertNull(StatusProto.fromThrowable(status.asRuntimeException())); in fromThrowable_shouldReturnNullIfTrailersAreNull()
141 assertNull(StatusProto.fromThrowable(status.asRuntimeException(emptyMetadata))); in fromThrowable_shouldReturnNullIfStatusDetailsKeyIsMissing()
|
| /external/grpc-grpc-java/benchmarks/src/main/java/io/grpc/benchmarks/driver/ |
| D | LoadWorker.java | 152 .asRuntimeException()); in runServer()
204 .asRuntimeException());
|
| D | LoadClient.java | 211 .asRuntimeException(); in start()
|
| /external/grpc-grpc-java/interop-testing/src/main/java/io/grpc/testing/integration/ |
| D | TestServiceImpl.java | 101 .asRuntimeException()); in unaryCall()
122 .asRuntimeException()); in unaryCall()
185 .asRuntimeException()); in fullDuplexCall()
|
| /external/grpc-grpc-java/protobuf-nano/src/main/java/io/grpc/protobuf/nano/ |
| D | NanoUtils.java | 72 .asRuntimeException(); in parse()
|
| /external/grpc-grpc-java/core/src/main/java/io/grpc/ |
| D | Status.java | 516 public StatusRuntimeException asRuntimeException() { in asRuntimeException() method in Status
525 public StatusRuntimeException asRuntimeException(@Nullable Metadata trailers) { in asRuntimeException() method in Status
|
| /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/netty/src/test/java/io/grpc/netty/ |
| D | NettyClientTransportTest.java | 263 failureStatus.asRuntimeException()); in negotiationFailurePropagatesToStatus()
321 transport.channel().pipeline().fireExceptionCaught(failureStatus.asRuntimeException()); in channelExceptionDuringNegotiatonPropagatesToStatus()
347 failureStatus.asRuntimeException()); in handlerExceptionDuringNegotiatonPropagatesToStatus()
|
| /external/grpc-grpc-java/examples/src/main/java/io/grpc/examples/errorhandling/ |
| D | ErrorHandlingClient.java | 62 .withDescription("Eggplant Xerxes Crybaby Overbite Narwhal").asRuntimeException()); in run()
|
| D | DetailErrorSample.java | 82 .asRuntimeException(trailers)); in run()
|
| /external/grpc-grpc-java/benchmarks/src/main/java/io/grpc/benchmarks/ |
| D | Utils.java | 252 throw Status.INTERNAL.augmentDescription("Error creating payload.").asRuntimeException(); in makeResponse()
|
| /external/grpc-grpc-java/core/src/main/java/io/grpc/inprocess/ |
| D | InProcessTransport.java | 170 callback.onFailure(shutdownStatus.asRuntimeException());
|
| /external/grpc-grpc-java/netty/src/main/java/io/grpc/netty/ |
| D | ProtocolNegotiators.java | 363 return Status.UNAVAILABLE.withDescription(msg).asRuntimeException();
|