Searched refs:REFUSED (Results 1 – 14 of 14) sorted by relevance
77 REFUSED, enumConstant
568 if (rpcProgress == RpcProgress.REFUSED && !noMoreTransparentRetry) { in closed()
21 import static io.grpc.internal.ClientStreamListener.RpcProgress.REFUSED;344 verify(streamListener).closed(any(Status.class), eq(REFUSED), any(Metadata.class)); in receivedGoAwayShouldRefuseLaterStreamId()363 verify(streamListener).closed(any(Status.class), eq(REFUSED), any(Metadata.class)); in receivedResetWithRefuseCode()382 verify(streamListener).closed(captor.capture(), same(REFUSED), notNull(Metadata.class)); in receivedGoAwayShouldFailUnknownStreams()
117 #define REFUSED 5 /* query refused */ macro
133 #define REFUSED 5 /* query refused */ macro
440 if ((header->rcode == SERVFAIL || header->rcode == REFUSED) && !(daemon->options & OPT_ORDER) && in reply_query()464 if (header->rcode == SERVFAIL || header->rcode == REFUSED) in reply_query()486 (header->rcode != REFUSED && header->rcode != SERVFAIL)) { in reply_query()
766 header->rcode = REFUSED; in setup_reply()
373 ? RpcProgress.REFUSED : RpcProgress.PROCESSED, in onRstStreamRead()491 lifecycleManager.getShutdownStatus(), RpcProgress.REFUSED, true, new Metadata()); in createStream()682 goAwayStatus, RpcProgress.REFUSED, false, new Metadata()); in goingAway()
357 goAwayStatus, RpcProgress.REFUSED, true, new Metadata()); in streamReadyToStart()765 status, RpcProgress.REFUSED, false, new Metadata()); in startGoAway()771 status, RpcProgress.REFUSED, true, new Metadata()); in startGoAway()1067 errorCode == ErrorCode.REFUSED_STREAM ? RpcProgress.REFUSED : RpcProgress.PROCESSED, in rstStream()
22 import static io.grpc.internal.ClientStreamListener.RpcProgress.REFUSED;1410 .closed(Status.fromCode(NON_RETRIABLE_STATUS_CODE), REFUSED, new Metadata()); in transparentRetry() local1423 .closed(Status.fromCode(RETRIABLE_STATUS_CODE_1), REFUSED, new Metadata()); in transparentRetry() local1473 .closed(Status.fromCode(RETRIABLE_STATUS_CODE_1), REFUSED, new Metadata()); in normalRetry_thenNoTransparentRetry_butNormalRetry() local1523 .closed(Status.fromCode(NON_RETRIABLE_STATUS_CODE), REFUSED, new Metadata()); in normalRetry_thenNoTransparentRetry_andNoMoreRetry() local
22 import static io.grpc.internal.ClientStreamListener.RpcProgress.REFUSED;1735 assertEquals(REFUSED, listener2.rpcProgress); in goAway_streamListenerRpcProgress()1736 assertEquals(REFUSED, listener3.rpcProgress); in goAway_streamListenerRpcProgress()1773 assertEquals(REFUSED, listener2.rpcProgress); in reset_streamListenerRpcProgress()
366 upstream servers to forward a query to, return REFUSED.1374 Improve handling of SERVFAIL and REFUSED errors. Receiving1569 Tweak behaviour on receipt of REFUSED or SERVFAIL rcodes,2450 Fix bug with --address and ANY query type seeing REFUSED
META-INF/ META-INF/MANIFEST.MF io/ io/grpc/ io/ ...