| /external/grpc-grpc-java/core/src/test/java/io/grpc/internal/ |
| D | InternalSubchannelTest.java | 78 ConnectivityStateInfo.forTransientFailure(Status.UNAVAILABLE);
81 private static final Status SHUTDOWN_REASON = Status.UNAVAILABLE.withDescription("for test");
188 transports.poll().listener.transportShutdown(Status.UNAVAILABLE); in singleAddressReconnect()
245 transports.poll().listener.transportShutdown(Status.UNAVAILABLE); in singleAddressReconnect()
284 transports.poll().listener.transportShutdown(Status.UNAVAILABLE); in twoAddressesReconnect()
297 transports.poll().listener.transportShutdown(Status.UNAVAILABLE); in twoAddressesReconnect()
322 transports.poll().listener.transportShutdown(Status.UNAVAILABLE); in twoAddressesReconnect()
364 transports.poll().listener.transportShutdown(Status.UNAVAILABLE); in twoAddressesReconnect()
377 transports.poll().listener.transportShutdown(Status.UNAVAILABLE); in twoAddressesReconnect()
386 transports.poll().listener.transportShutdown(Status.UNAVAILABLE); in twoAddressesReconnect()
[all …]
|
| D | GrpcUtilTest.java | 210 assertEquals(Status.Code.UNAVAILABLE, GrpcUtil.httpStatusToGrpcStatus(429).getCode()); in httpStatusToGrpcStatus_checkAgainstSpec()
211 assertEquals(Status.Code.UNAVAILABLE, GrpcUtil.httpStatusToGrpcStatus(502).getCode()); in httpStatusToGrpcStatus_checkAgainstSpec()
212 assertEquals(Status.Code.UNAVAILABLE, GrpcUtil.httpStatusToGrpcStatus(503).getCode()); in httpStatusToGrpcStatus_checkAgainstSpec()
213 assertEquals(Status.Code.UNAVAILABLE, GrpcUtil.httpStatusToGrpcStatus(504).getCode()); in httpStatusToGrpcStatus_checkAgainstSpec()
231 Status status = Status.UNAVAILABLE; in getTransportFromPickResult_errorPickResult_waitForReady()
240 Status status = Status.UNAVAILABLE; in getTransportFromPickResult_errorPickResult_failFast()
256 Status status = Status.UNAVAILABLE; in getTransportFromPickResult_dropPickResult_waitForReady()
272 Status status = Status.UNAVAILABLE; in getTransportFromPickResult_dropPickResult_failFast()
|
| D | DelayedClientTransportTest.java | 84 Status.UNAVAILABLE.withDescription("shutdown called");
179 delayedTransport.shutdownNow(Status.UNAVAILABLE); in assignTransportThenShutdownNowThenNewStream()
235 assertEquals(Status.Code.UNAVAILABLE, statusCaptor.getValue().getCode()); in newStreamThenShutdownTransportThenAssignTransport()
263 assertEquals(Status.Code.UNAVAILABLE, statusCaptor.getValue().getCode()); in shutdownThenNewStream()
269 delayedTransport.shutdownNow(Status.UNAVAILABLE); in startStreamThenShutdownNow()
273 assertEquals(Status.Code.UNAVAILABLE, statusCaptor.getValue().getCode()); in startStreamThenShutdownNow()
277 delayedTransport.shutdownNow(Status.UNAVAILABLE); in shutdownNowThenNewStream()
284 assertEquals(Status.Code.UNAVAILABLE, statusCaptor.getValue().getCode()); in shutdownNowThenNewStream()
350 PickResult.withError(Status.UNAVAILABLE), // ff2: fail in reprocessSemantics()
384 assertSame(Status.UNAVAILABLE, ((FailingClientStream) ff2.getRealStream()).getError()); in reprocessSemantics()
|
| D | FailingClientStreamTest.java | 40 Status status = Status.UNAVAILABLE; in processedRpcProgressPopulatedToListener()
50 Status status = Status.UNAVAILABLE; in droppedRpcProgressPopulatedToListener()
|
| D | HedgingPolicyTest.java | 85 ImmutableSet.of(Code.UNAVAILABLE, Code.RESOURCE_EXHAUSTED)), in getHedgingPolicies()
93 ImmutableSet.of(Code.UNAVAILABLE)), in getHedgingPolicies()
106 ImmutableSet.of(Code.UNAVAILABLE)), in getHedgingPolicies()
|
| D | RetryPolicyTest.java | 90 ImmutableSet.of(Code.UNAVAILABLE, Code.RESOURCE_EXHAUSTED)), in getRetryPolicies()
100 ImmutableSet.of(Code.UNAVAILABLE)), in getRetryPolicies()
115 ImmutableSet.of(Code.UNAVAILABLE)), in getRetryPolicies()
|
| D | ManagedChannelImplTest.java | 497 assertSame(Status.Code.UNAVAILABLE, statusCaptor.getValue().getCode()); in subtestCallsAndShutdown()
541 transportListener.transportShutdown(Status.UNAVAILABLE); in subtestCallsAndShutdown()
563 Status resolutionError = Status.UNAVAILABLE.withDescription("Resolution failed"); in noMoreCallbackAfterLoadBalancerShutdown()
669 transportListener.transportShutdown(Status.UNAVAILABLE); in callOptionsExecutor()
680 Status error = Status.UNAVAILABLE.withCause(new Throwable("fake name resolution error")); in nameResolutionFailed()
726 Status error = Status.UNAVAILABLE.withCause(new Throwable("fake name resolution error")); in nameResolutionFailed_delayedTransportShutdownCancelsBackoff()
750 Status status = Status.UNAVAILABLE.withDescription("for test"); in nameResolutionFailed_delayedTransportShutdownCancelsBackoff()
771 assertSame(Status.Code.UNAVAILABLE, status.getCode()); in nameResolverReturnsEmptySubLists()
869 badTransportInfo.listener.transportShutdown(Status.UNAVAILABLE); in firstResolvedServerFailedToConnect()
931 Status status = Status.UNAVAILABLE.withDescription("for test"); in subtestFailRpcFromBalancer()
[all …]
|
| /external/clang/test/ARCMT/ |
| D | objcmt-property-availability.m | 19 #define UNAVAILABLE __attribute__((unavailable("not available in automatic reference counting mode"… macro
35 - (void)setComp:(MKMapItem *)source UNAVAILABLE;
37 - (MKMapItem *)tally UNAVAILABLE NS_AVAILABLE(10_9, 6_0);
38 - (void)setTally:(MKMapItem *)source UNAVAILABLE NS_AVAILABLE(10_9, 6_0);
41 - (void)setItally:(MKMapItem *)source UNAVAILABLE NS_AVAILABLE(10_9, 6_0);
43 - (MKMapItem *)normal UNAVAILABLE; method
44 - (void)setNormal:(MKMapItem *)source UNAVAILABLE NS_AVAILABLE(10_9, 6_0);
|
| D | objcmt-property-availability.m.result | 19 #define UNAVAILABLE __attribute__((unavailable("not available in automatic reference counting mode"…
33 - (void)setComp:(MKMapItem *)source UNAVAILABLE;
35 @property (nonatomic, strong) MKMapItem *tally UNAVAILABLE NS_AVAILABLE(10_9, 6_0);
38 - (void)setItally:(MKMapItem *)source UNAVAILABLE NS_AVAILABLE(10_9, 6_0);
40 - (MKMapItem *)normal UNAVAILABLE;
41 - (void)setNormal:(MKMapItem *)source UNAVAILABLE NS_AVAILABLE(10_9, 6_0);
|
| /external/apache-http/src/org/apache/http/util/ |
| D | VersionInfo.java | 65 public final static String UNAVAILABLE = "UNAVAILABLE"; field in VersionInfo
109 infoModule = (module != null) ? module : UNAVAILABLE; in VersionInfo()
110 infoRelease = (release != null) ? release : UNAVAILABLE; in VersionInfo()
111 infoTimestamp = (time != null) ? time : UNAVAILABLE; in VersionInfo()
112 infoClassloader = (clsldr != null) ? clsldr : UNAVAILABLE; in VersionInfo()
185 if (!UNAVAILABLE.equals(infoRelease)) in toString()
187 if (!UNAVAILABLE.equals(infoTimestamp)) in toString()
192 if (!UNAVAILABLE.equals(infoClassloader)) in toString()
|
| /external/clang/test/SemaObjC/ |
| D | class-unavail-warning.m | 71 #define UNAVAILABLE __attribute__((unavailable("not available"))) macro
73 UNAVAILABLE
77 UNAVAILABLE
90 UNAVAILABLE
93 UNAVAILABLE
96 UNAVAILABLE
|
| /external/grpc-grpc/doc/ |
| D | http-grpc-status-mapping.md | 20 | 429 Too Many Requests | UNAVAILABLE |
21 | 502 Bad Gateway | UNAVAILABLE |
22 | 503 Service Unavailable | UNAVAILABLE |
23 | 504 Gateway Timeout | UNAVAILABLE |
|
| /external/opencensus-java/contrib/grpc_util/src/main/java/io/opencensus/contrib/grpc/util/ |
| D | StatusConverter.java | 113 case UNAVAILABLE: in opencensusStatusFromGrpcCode()
114 return io.opencensus.trace.Status.UNAVAILABLE; in opencensusStatusFromGrpcCode()
154 case UNAVAILABLE: in grpcStatusFromOpencensusCanonicalCode()
155 return io.grpc.Status.UNAVAILABLE; in grpcStatusFromOpencensusCanonicalCode()
|
| /external/grpc-grpc-java/core/src/test/java/io/grpc/ |
| D | ConnectivityStateInfoTest.java | 48 ConnectivityStateInfo info = ConnectivityStateInfo.forTransientFailure(Status.UNAVAILABLE); in forTransientFailure()
50 assertEquals(Status.UNAVAILABLE, info.getStatus()); in forTransientFailure()
63 ConnectivityStateInfo info4 = ConnectivityStateInfo.forTransientFailure(Status.UNAVAILABLE); in equality()
|
| /external/libchrome/mojo/public/java/system/src/org/chromium/mojo/system/ |
| D | MojoResult.java | 25 public static final int UNAVAILABLE = 14; field in MojoResult
69 case UNAVAILABLE: in describe()
|
| /external/opencensus-java/api/src/main/java/io/opencensus/trace/ |
| D | Status.java | 192 UNAVAILABLE(14), enumConstant
369 public static final Status UNAVAILABLE = CanonicalCode.UNAVAILABLE.toStatus(); field in Status
|
| /external/tensorflow/tensorflow/core/profiler/rpc/client/ |
| D | capture_profile.cc | 117 return Status(tensorflow::error::Code::UNAVAILABLE, in Profile()
160 return Status(tensorflow::error::Code::UNAVAILABLE, in NewSession()
217 status.code() != tensorflow::error::Code::UNAVAILABLE) in StartTracing()
224 if (status.code() == tensorflow::error::Code::UNAVAILABLE) { in StartTracing()
|
| /external/tensorflow/tensorflow/core/lib/core/ |
| D | error_codes.proto | 81 // between FAILED_PRECONDITION, ABORTED, and UNAVAILABLE:
82 // (a) Use UNAVAILABLE if the client can retry just the failing call.
100 // ABORTED, and UNAVAILABLE.
133 // ABORTED, and UNAVAILABLE.
134 UNAVAILABLE = 14; enumerator
|
| /external/tensorflow/tensorflow/python/framework/ |
| D | errors_impl.py | 197 UNAVAILABLE = error_codes_pb2.UNAVAILABLE variable
463 UNAVAILABLE)
497 UNAVAILABLE: UnavailableError,
|
| D | errors_test.py | 65 (errors.UNAVAILABLE, errors_impl.UnavailableError),
139 errors.UNAVAILABLE,
|
| /external/tensorflow/tensorflow/contrib/bigtable/kernels/ |
| D | bigtable_lib.cc | 26 status.error_code() == ::grpc::StatusCode::UNAVAILABLE || in GrpcStatusToTfStatus()
70 return ::tensorflow::error::UNAVAILABLE; in GcpErrorCodeToTfErrorCode()
|
| /external/grpc-grpc-java/core/src/main/java/io/grpc/internal/ |
| D | OobChannel.java | 148 subchannel.shutdown(Status.UNAVAILABLE.withDescription("OobChannel is shutdown")); in setSubchannel()
227 delayedTransport.shutdown(Status.UNAVAILABLE.withDescription("OobChannel.shutdown() called")); in shutdown()
240 Status.UNAVAILABLE.withDescription("OobChannel.shutdownNow() called")); in shutdownNow()
|
| /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/okhttp/src/main/java/io/grpc/okhttp/ |
| D | OkHttpClientTransport.java | 122 Status.UNAVAILABLE.withDescription("Refused stream")); in buildErrorCodeToStatusMap()
383 Status.UNAVAILABLE.withDescription("Stream ids exhausted")); in startStream()
583 throw Status.UNAVAILABLE.withDescription(message).asException(); in createHttpProxySocket()
587 throw Status.UNAVAILABLE.withDescription("Failed trying to connect with proxy").withCause(e) in createHttpProxySocket()
735 Status status = Status.UNAVAILABLE.withCause(failureCause); in onException()
897 return Status.UNAVAILABLE.withDescription("Connection closed").asException(); in getPingFailure()
976 Status.UNAVAILABLE.withDescription("End of stream or IOException")); in run()
982 Status.UNAVAILABLE.withDescription("error in frame handler").withCause(t)); in run()
|
| /external/grpc-grpc-java/netty/src/test/java/io/grpc/netty/ |
| D | TlsTest.java | 227 Status.Code.UNAVAILABLE, e.getStatus().getCode()); in serverRejectsUntrustedClientCert()
268 Status.Code.UNAVAILABLE, e.getStatus().getCode()); in noClientAuthFailure()
313 Status.Code.UNAVAILABLE, e.getStatus().getCode()); in clientRejectsUntrustedServerCert()
|