| /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 | ServerTransport.java | 37 void shutdownNow(Status reason); in shutdownNow() method
|
| D | ManagedClientTransport.java | 65 void shutdownNow(Status reason); in shutdownNow() method
|
| D | KeepAliveManager.java | 274 transport.shutdownNow(Status.UNAVAILABLE.withDescription( in ping()
282 transport.shutdownNow(Status.UNAVAILABLE.withDescription( in onPingTimeout()
|
| /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()
|
| /external/downloader/src/test/java/com/google/android/downloader/ |
| D | TestingExecutorService.java | 47 public List<Runnable> shutdownNow() { in shutdownNow() method in TestingExecutorService
48 return delegate.shutdownNow(); in shutdownNow()
|
| /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/android/guava/src/com/google/common/util/concurrent/ |
| D | ForwardingExecutorService.java | 93 public List<Runnable> shutdownNow() { in shutdownNow() method in ForwardingExecutorService
94 return delegate().shutdownNow(); in shutdownNow()
|
| D | WrappingExecutorService.java | 144 public final List<Runnable> shutdownNow() {
145 return delegate.shutdownNow();
|
| D | MoreExecutors.java | 285 public List<Runnable> shutdownNow() { in shutdownNow() method in MoreExecutors.DirectExecutorService
545 public final List<Runnable> shutdownNow() { in shutdownNow() method in MoreExecutors.ListeningDecorator
546 return delegate.shutdownNow(); in shutdownNow()
974 service.shutdownNow();
982 service.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/guava/guava/src/com/google/common/util/concurrent/ |
| D | ForwardingExecutorService.java | 93 public List<Runnable> shutdownNow() { in shutdownNow() method in ForwardingExecutorService
94 return delegate().shutdownNow(); in shutdownNow()
|
| D | WrappingExecutorService.java | 144 public final List<Runnable> shutdownNow() {
145 return delegate.shutdownNow();
|
| D | MoreExecutors.java | 346 public List<Runnable> shutdownNow() { in shutdownNow() method in MoreExecutors.DirectExecutorService
606 public final List<Runnable> shutdownNow() { in shutdownNow() method in MoreExecutors.ListeningDecorator
607 return delegate.shutdownNow(); in shutdownNow()
1079 service.shutdownNow();
1087 service.shutdownNow();
|
| /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/dagger2/javatests/dagger/grpc/functional/server/ |
| D | CoffeeServer.java | 31 server().shutdownNow(); in shutdown()
|
| /external/grpc-grpc-java/core/src/main/java/io/grpc/ |
| D | ManagedChannel.java | 63 public abstract ManagedChannel shutdownNow(); in shutdownNow() method in ManagedChannel
|
| /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 | CascadingTest.java | 91 channel.shutdownNow(); in tearDown()
92 server.shutdownNow(); in tearDown()
93 otherWork.shutdownNow(); in tearDown()
|