| /external/grpc-grpc-java/netty/src/test/java/io/grpc/netty/ |
| D | NettyClientTransportTest.java | 164 new Rpc(transport).halfClose().waitForResponse(); in addDefaultUserAgent()
201 new Rpc(transport, new Metadata()).halfClose().waitForResponse(); in overrideDefaultUserAgent()
220 new Rpc(transport).halfClose().waitForResponse(); in maxMessageSizeShouldBeEnforced()
247 rpcs.add(new Rpc(transport).halfClose()); in creatingMultipleTlsTransportsShouldSucceed()
273 Rpc rpc = new Rpc(transport).halfClose(); in negotiationFailurePropagatesToStatus()
306 Rpc rpc = new Rpc(transport).halfClose(); in tlsNegotiationFailurePropagatesToStatus()
329 Rpc rpc = new Rpc(transport).halfClose(); in channelExceptionDuringNegotiatonPropagatesToStatus()
360 Rpc rpc = new Rpc(transport).halfClose(); in handlerExceptionDuringNegotiatonPropagatesToStatus()
379 new Rpc(transport).halfClose().waitForResponse(); in bufferedStreamsShouldBeClosedWhenConnectionTerminates()
478 new Rpc(transport, new Metadata()).halfClose().waitForResponse(); in maxHeaderListSizeShouldBeEnforcedOnClient()
[all …]
|
| D | NettyClientStreamTest.java | 142 stream().halfClose(); in closeShouldSucceed()
278 stream.halfClose(); in inboundTrailersAfterHalfCloseDoesNotSendRstStream()
487 stream.halfClose(); in getRequestSentThroughHeader()
|
| /external/grpc-grpc-java/core/src/main/java/io/grpc/ |
| D | PartialForwardingClientCall.java | 43 public void halfClose() { in halfClose() method in PartialForwardingClientCall
44 delegate().halfClose(); in halfClose()
|
| D | ClientCall.java | 222 public abstract void halfClose(); in halfClose() method in ClientCall
|
| D | ClientInterceptors.java | 176 public void halfClose() {}
|
| /external/grpc-grpc-java/core/src/main/java/io/grpc/internal/ |
| D | ForwardingClientStream.java | 66 public void halfClose() { in halfClose() method in ForwardingClientStream
67 delegate().halfClose(); in halfClose()
|
| D | ClientStream.java | 49 void halfClose(); in halfClose() method
|
| D | NoopClientStream.java | 62 public void halfClose() {} in halfClose() method in NoopClientStream
|
| D | DelayedStream.java | 282 public void halfClose() { in halfClose() method in DelayedStream
286 realStream.halfClose(); in halfClose()
|
| D | ClientCallImpl.java | 403 public void halfClose() { in halfClose() method in ClientCallImpl
408 stream.halfClose(); in halfClose()
|
| D | RetriableStream.java | 433 public final void halfClose() { in halfClose() method in RetriableStream
437 substream.stream.halfClose(); in halfClose()
|
| D | AbstractClientStream.java | 188 public final void halfClose() { in halfClose() method in AbstractClientStream
|
| /external/grpc-grpc-java/testing/src/main/java/io/grpc/internal/ |
| D | NoopClientCall.java | 47 public void halfClose() {} in halfClose() method in NoopClientCall
|
| /external/grpc-grpc-java/alts/src/main/java/io/grpc/alts/ |
| D | FailingClientCall.java | 44 public void halfClose() {} in halfClose() method in FailingClientCall
|
| /external/grpc-grpc-java/examples/android/clientcache/app/src/main/java/io/grpc/clientcacheexample/ |
| D | SafeMethodCachingInterceptor.java | 292 public void halfClose() {
297 super.halfClose();
|
| /external/grpc-grpc-java/core/src/test/java/io/grpc/ |
| D | ClientInterceptorsTest.java | 328 interceptedCall.halfClose(); in normalCall()
361 interceptedCall.halfClose(); in exceptionInStart()
374 noop.halfClose(); in exceptionInStart()
455 public void halfClose() { in halfClose() method in ClientInterceptorsTest.BaseClientCall
|
| /external/grpc-grpc-java/core/src/test/java/io/grpc/internal/ |
| D | DelayedStreamTest.java | 126 stream.halfClose(); in setStream_halfClose()
129 verify(realStream).halfClose(); in setStream_halfClose()
|
| D | ClientCallImplTest.java | 641 call.halfClose(); in contextAlreadyCancelledNotifiesImmediately()
897 call.halfClose(); in cancelInOnMessageShouldInvokeStreamCancel()
|
| /external/grpc-grpc-java/testing/src/main/java/io/grpc/internal/testing/ |
| D | AbstractTransportTest.java | 398 clientStream.halfClose(); in openStreamPreventsTermination()
634 stream1.halfClose(); in transportInUse_normalClose()
636 stream2.halfClose(); in transportInUse_normalClose()
734 clientStream.halfClose(); in basicStream()
862 clientStream.halfClose(); in zeroMessageStream()
1117 clientStream.halfClose(); in clientCancelFromWithinMessageRead()
1322 clientStream.halfClose(); in flowControlPushBack()
1420 clientStream.halfClose(); in interactionsAfterClientStreamCancelAreNoops()
1533 clientStream.halfClose(); in transportTracer_server_streamEnded_ok()
1651 clientStream.halfClose(); in transportTracer_server_receive_msg()
|
| /external/grpc-grpc-java/stub/src/main/java/io/grpc/stub/ |
| D | ClientCalls.java | 283 call.halfClose(); in asyncUnaryRequestCall()
345 call.halfClose(); in onCompleted()
|
| /external/grpc-grpc-java/examples/src/main/java/io/grpc/examples/errorhandling/ |
| D | ErrorHandlingClient.java | 196 call.halfClose(); in advancedAsyncCall()
|
| D | DetailErrorSample.java | 222 call.halfClose(); in advancedAsyncCall()
|
| /external/grpc-grpc-java/okhttp/src/test/java/io/grpc/okhttp/ |
| D | OkHttpClientStreamTest.java | 205 stream.halfClose(); in getUnaryRequest()
|
| /external/grpc-grpc-java/auth/src/test/java/io/grpc/auth/ |
| D | ClientAuthInterceptorTest.java | 211 public void halfClose() { in halfClose() method in ClientAuthInterceptorTest.ClientCallRecorder
|
| /external/grpc-grpc-java/services/src/main/java/io/grpc/services/ |
| D | BinlogHelper.java | 484 public void halfClose() { in getClientInterceptor() method
489 super.halfClose(); in getClientInterceptor()
|