| /external/grpc-grpc-java/core/src/main/java/io/grpc/internal/ |
| D | ManagedChannelOrphanWrapper.java | 63 public ManagedChannel shutdownNow() { in shutdownNow() method in ManagedChannelOrphanWrapper
64 phantom.shutdownNow = true; in shutdownNow()
65 return super.shutdownNow(); in shutdownNow()
93 private volatile boolean shutdownNow; field in ManagedChannelOrphanWrapper.ManagedChannelReference
149 Level level = ref.shutdownNow ? Level.FINE : Level.SEVERE; in cleanQueue()
|
| D | ForwardingManagedChannel.java | 51 public ManagedChannel shutdownNow() { in shutdownNow() method in ForwardingManagedChannel
52 return delegate.shutdownNow(); in shutdownNow()
|
| D | ForwardingConnectionClientTransport.java | 42 public void shutdownNow(Status status) { in shutdownNow() method in ForwardingConnectionClientTransport
43 delegate().shutdownNow(status); in shutdownNow()
|
| D | KeepAliveManager.java | 274 transport.shutdownNow(Status.UNAVAILABLE.withDescription( in ping()
282 transport.shutdownNow(Status.UNAVAILABLE.withDescription( in onPingTimeout()
|
| D | ServerTransport.java | 37 void shutdownNow(Status reason); in shutdownNow() method
|
| D | ManagedClientTransport.java | 65 void shutdownNow(Status reason); in shutdownNow() method
|
| /external/guice/extensions/servlet/test/com/google/inject/servlet/ |
| D | TransferRequestIntegrationTest.java | 106 executor.shutdownNow(); in testTransferNonHttpRequest()
150 executor.shutdownNow(); in testTransferNonHttpRequest_closeable()
169 executor.shutdownNow(); in testTransferNonHttpRequest_concurrentUseBlocks()
205 executor.shutdownNow(); in testTransferNonHttpRequest_concurrentUseBlocks_closeable()
|
| /external/grpc-grpc-java/core/src/test/java/io/grpc/internal/ |
| D | ForwardingManagedChannelTest.java | 73 public void shutdownNow() { in shutdownNow() method in ForwardingManagedChannelTest
75 when(mock.shutdownNow()).thenReturn(ret); in shutdownNow()
76 assertSame(ret, forward.shutdownNow()); in shutdownNow()
|
| D | ManagedChannelImplTest.java | 279 channel.shutdownNow(); in allPendingTasksAreRun()
334 channel.shutdownNow(); in channelzMembership()
425 private void subtestCallsAndShutdown(boolean shutdownNow, boolean shutdownNowAfterShutdown) { in subtestCallsAndShutdown() argument
476 if (shutdownNow) { in subtestCallsAndShutdown()
477 channel.shutdownNow(); in subtestCallsAndShutdown()
481 channel.shutdownNow(); in subtestCallsAndShutdown()
482 shutdownNow = true; in subtestCallsAndShutdown()
499 if (shutdownNow) { in subtestCallsAndShutdown()
526 if (shutdownNow) { in subtestCallsAndShutdown()
528 verify(mockTransport).shutdownNow(ManagedChannelImpl.SHUTDOWN_NOW_STATUS); in subtestCallsAndShutdown()
[all …]
|
| D | ServerImplTest.java | 279 public void shutdownNow(Status reason) { in startShutdownNowImmediateWithChildTransport() method in ServerImplTest.DelayedShutdownServerTransport
286 server.shutdownNow(); in startShutdownNowImmediateWithChildTransport()
308 public void shutdownNow(Status reason) { in shutdownNowAfterShutdown() method in ServerImplTest.DelayedShutdownServerTransport
317 server.shutdownNow(); in shutdownNowAfterShutdown()
344 public void shutdownNow(Status reason) { in shutdownNowAfterSlowShutdown() method in ServerImplTest.DelayedShutdownServerTransport
352 server.shutdownNow(); in shutdownNowAfterSlowShutdown()
389 @Override public void shutdownNow(Status status) { in transportHandshakeTimeout_expired() method in ServerImplTest.ShutdownRecordingTransport
391 super.shutdownNow(status); in transportHandshakeTimeout_expired()
1283 server.shutdownNow().awaitTermination(); in channelz_membership()
1391 public void shutdownNow(Status status) { in shutdownNow() method in ServerImplTest.SimpleServerTransport
|
| /external/grpc-grpc-java/testing/src/main/java/io/grpc/testing/ |
| D | GrpcServerRule.java | 109 channel.shutdownNow(); in after()
112 server.shutdownNow(); in after()
|
| D | GrpcCleanupRule.java | 213 channel.shutdownNow();
241 server.shutdownNow();
|
| /external/guava/guava/src/com/google/common/util/concurrent/ |
| D | ForwardingExecutorService.java | 95 public List<Runnable> shutdownNow() { in shutdownNow() method in ForwardingExecutorService
96 return delegate().shutdownNow(); in shutdownNow()
|
| D | MoreExecutors.java | 327 public List<Runnable> shutdownNow() { in shutdownNow() method in MoreExecutors.DirectExecutorService
544 public List<Runnable> shutdownNow() { in shutdownNow() method in MoreExecutors.ListeningDecorator
545 return delegate.shutdownNow(); in shutdownNow()
950 service.shutdownNow();
958 service.shutdownNow();
|
| D | WrappingExecutorService.java | 147 public final List<Runnable> shutdownNow() {
148 return delegate.shutdownNow();
|
| /external/grpc-grpc-java/interop-testing/src/main/java/io/grpc/testing/integration/ |
| D | ReconnectTestClient.java | 96 controlChannel.shutdownNow(); in runTest()
97 retryChannel.shutdownNow(); in runTest()
|
| /external/grpc-grpc-java/benchmarks/src/main/java/io/grpc/benchmarks/driver/ |
| D | LoadWorker.java | 175 workerServer.shutdownNow(); in runServer()
227 workerClient.shutdownNow();
254 driverServer.shutdownNow();
|
| /external/grpc-grpc-java/netty/shaded/src/testShadow/java/io/grpc/netty/shaded/ |
| D | ShadingTest.java | 52 channel.shutdownNow(); in tearDown()
56 server.shutdownNow(); in tearDown()
|
| /external/robolectric-shadows/shadows/framework/src/main/java/org/robolectric/android/util/concurrent/ |
| D | RoboExecutorService.java | 53 shutdownNow(); in shutdown()
57 public List<Runnable> shutdownNow() { in shutdownNow() method in RoboExecutorService
|
| /external/grpc-grpc-java/android/src/test/java/io/grpc/android/ |
| D | AndroidChannelBuilderTest.java | 282 androidChannel.shutdownNow(); in shutdownNowUnregistersBroadcastReceiver_api23()
299 androidChannel.shutdownNow(); in shutdownNowUnregistersNetworkCallback_api24()
384 public ManagedChannel shutdownNow() { in shutdownNow() method in AndroidChannelBuilderTest.TestChannel
480 public List<Runnable> shutdownNow() { in shutdownNow() method in AndroidChannelBuilderTest.ScheduledExecutorImpl
|
| /external/grpc-grpc-java/interop-testing/src/test/java/io/grpc/testing/integration/ |
| D | CompressionTest.java | 139 channel.shutdownNow(); in tearDown()
140 server.shutdownNow(); in tearDown()
141 executor.shutdownNow(); in tearDown()
|
| D | CascadingTest.java | 91 channel.shutdownNow(); in tearDown()
92 server.shutdownNow(); in tearDown()
93 otherWork.shutdownNow(); in tearDown()
|
| /external/guava/guava-testlib/src/com/google/common/util/concurrent/testing/ |
| D | SameThreadScheduledExecutorService.java | 59 public List<Runnable> shutdownNow() { in shutdownNow() method in SameThreadScheduledExecutorService
60 return delegate.shutdownNow(); in shutdownNow()
|
| /external/grpc-grpc-java/core/src/main/java/io/grpc/ |
| D | ManagedChannel.java | 63 public abstract ManagedChannel shutdownNow(); in shutdownNow() method in ManagedChannel
|
| D | Server.java | 103 public abstract Server shutdownNow(); in shutdownNow() method in Server
|