| /external/rust/crates/tokio/src/runtime/blocking/ |
| D | pool.rs | 6 use crate::runtime::blocking::shutdown;
18 shutdown_rx: shutdown::Receiver,
57 shutdown: bool, field
58 shutdown_tx: Option<shutdown::Sender>,
91 let (shutdown_tx, shutdown_rx) = shutdown::channel(); in new()
102 shutdown: false, in new()
125 pub(crate) fn shutdown(&mut self, timeout: Option<Duration>) { in shutdown() method
131 if shared.shutdown { in shutdown()
135 shared.shutdown = true; in shutdown()
161 self.shutdown(None); in drop()
[all …]
|
| /external/linux-kselftest/tools/testing/selftests/mqueue/ |
| D | mq_perf_tests.c | 154 void shutdown(int exit_val, char *err_cause, int line_no);
173 void shutdown(int exit_val, char *err_cause, int line_no) in shutdown() function
217 shutdown(0, "", 0); in sig_action_SIGUSR1()
229 shutdown(0, "", 0); in sig_action()
240 shutdown(4, "Error reading /proc entry", __LINE__); in get()
250 return shutdown(5, "Failed writing to /proc file", __LINE__); in set()
253 return shutdown(5, "We didn't get what we wrote to /proc back", in set()
270 shutdown(6, "getrlimit()", __LINE__); in getr()
276 shutdown(7, "setrlimit()", __LINE__); in setr()
296 shutdown(1, "mq_open()", __LINE__); in open_queue()
[all …]
|
| D | mq_open_tests.c | 62 void shutdown(int exit_val, char *err_cause, int line_no);
79 void shutdown(int exit_val, char *err_cause, int line_no) in shutdown() function
123 shutdown(4, "Error reading /proc entry", __LINE__ - 1); in get()
133 return shutdown(5, "Failed writing to /proc file", in set()
137 return shutdown(5, "We didn't get what we wrote to /proc back", in set()
144 shutdown(6, "getrlimit()", __LINE__ - 1); in getr()
150 shutdown(7, "setrlimit()", __LINE__ - 1); in setr()
206 shutdown(1, "mq_open()", __LINE__); in test_queue()
208 shutdown(1, "mq_getattr()", __LINE__); in test_queue()
210 shutdown(1, "mq_close()", __LINE__); in test_queue()
[all …]
|
| /external/guava/guava-testlib/test/com/google/common/testing/ |
| D | GcFinalizationTest.java | 111 final AtomicBoolean shutdown; field in GcFinalizationTest.Interruptenator
117 Interruptenator(final Thread interruptee, final AtomicBoolean shutdown) { in Interruptenator() argument
122 while (!shutdown.get()) { in Interruptenator()
128 this.shutdown = shutdown; in Interruptenator()
132 void shutdown() { in shutdown() method in GcFinalizationTest.Interruptenator
133 shutdown.set(true); in shutdown()
156 interruptenator.shutdown(); in testAwait_CountDownLatch_Interrupted()
172 interruptenator.shutdown(); in testAwaitDone_Future_Interrupted_Interrupted()
188 interruptenator.shutdown(); in testAwaitClear_Interrupted()
209 interruptenator.shutdown(); in testAwaitDone_FinalizationPredicate_Interrupted()
|
| /external/guava/android/guava-testlib/test/com/google/common/testing/ |
| D | GcFinalizationTest.java | 110 final AtomicBoolean shutdown; field in GcFinalizationTest.Interruptenator
116 Interruptenator(final Thread interruptee, final AtomicBoolean shutdown) { in Interruptenator() argument
120 while (!shutdown.get()) { in Interruptenator()
126 this.shutdown = shutdown; in Interruptenator()
130 void shutdown() { in shutdown() method in GcFinalizationTest.Interruptenator
131 shutdown.set(true); in shutdown()
154 interruptenator.shutdown(); in testAwait_CountDownLatch_Interrupted()
170 interruptenator.shutdown(); in testAwaitDone_Future_Interrupted_Interrupted()
186 interruptenator.shutdown(); in testAwaitClear_Interrupted()
206 interruptenator.shutdown(); in testAwaitDone_FinalizationPredicate_Interrupted()
|
| /external/grpc-grpc-java/grpclb/src/test/java/io/grpc/grpclb/ |
| D | CachedSubchannelPoolTest.java | 104 verify(subchannel, atMost(1)).shutdown(); in wrapUp()
123 verify(subchannel1, never()).shutdown(); in subchannelExpireAfterReturned()
129 verify(subchannel1).shutdown(); in subchannelExpireAfterReturned()
133 verify(subchannel2).shutdown(); in subchannelExpireAfterReturned()
163 verify(subchannel2, never()).shutdown(); in subchannelReused()
165 verify(subchannel2).shutdown(); in subchannelReused()
175 verify(subchannel1a, never()).shutdown(); in subchannelReused()
177 verify(subchannel1a).shutdown(); in subchannelReused()
196 verify(subchannel1, never()).shutdown(); in returnDuplicateAddressSubchannel()
199 verify(subchannel1).shutdown(); in returnDuplicateAddressSubchannel()
[all …]
|
| /external/apache-http/src/org/apache/http/impl/conn/ |
| D | SingleClientConnManager.java | 140 shutdown(); in finalize()
228 boolean shutdown = false;
235 shutdown = (tracker == null || // can happen if method is aborted
246 if (shutdown) {
249 uniquePoolEntry.shutdown();
322 sca.shutdown();
372 public void shutdown() {
381 uniquePoolEntry.shutdown();
404 uniquePoolEntry.shutdown();
440 protected void shutdown()
[all …]
|
| /external/guava/android/guava-testlib/src/com/google/common/util/concurrent/testing/ |
| D | TestingExecutors.java | 98 private volatile boolean shutdown; field in TestingExecutors.NoOpScheduledExecutorService
101 public void shutdown() { in shutdown() method in TestingExecutors.NoOpScheduledExecutorService
102 shutdown = true; in shutdown()
107 shutdown(); in shutdownNow()
113 return shutdown; in isShutdown()
118 return shutdown; in isTerminated()
|
| /external/guava/guava-testlib/src/com/google/common/util/concurrent/testing/ |
| D | TestingExecutors.java | 98 private volatile boolean shutdown; field in TestingExecutors.NoOpScheduledExecutorService
101 public void shutdown() { in shutdown() method in TestingExecutors.NoOpScheduledExecutorService
102 shutdown = true; in shutdown()
107 shutdown(); in shutdownNow()
113 return shutdown; in isShutdown()
118 return shutdown; in isTerminated()
|
| /external/libiio/src/examples/ |
| D | dummy-iiostream.c | 116 static void shutdown() in shutdown() function
230 shutdown(); in main()
243 shutdown(); in main()
248 shutdown(); in main()
260 shutdown(); in main()
270 shutdown(); in main()
277 shutdown(); in main()
294 shutdown(); in main()
370 shutdown(); in main()
|
| /external/rust/crates/grpcio/src/ |
| D | cq.rs | 60 let shutdown = loop { in unref() localVariable
74 if shutdown { in unref()
81 fn shutdown(&self) { in shutdown() method
83 let shutdown = loop { in shutdown() localVariable
102 if shutdown { in shutdown()
215 pub fn shutdown(&self) { in shutdown() method
216 self.handle.shutdown() in shutdown()
|
| /external/rust/crates/tokio/src/runtime/task/ |
| D | raw.rs | 29 pub(super) shutdown: unsafe fn(NonNull<Header>), field
40 shutdown: shutdown::<T, S>, in vtable()
92 pub(super) fn shutdown(self) { in shutdown() method
94 unsafe { (vtable.shutdown)(self.ptr) } in shutdown()
142 unsafe fn shutdown<T: Future, S: Schedule>(ptr: NonNull<Header>) { in shutdown() function
144 harness.shutdown() in shutdown()
|
| /external/grpc-grpc-java/benchmarks/src/main/java/io/grpc/benchmarks/driver/ |
| D | LoadClient.java | 64 private volatile boolean shutdown; field in LoadClient
270 shutdown = true; in shutdownNow()
273 channels[i].shutdown(); in shutdownNow()
313 while (!shutdown) { in run()
337 if (shutdown) { in run()
351 Level level = shutdown ? Level.FINE : Level.INFO; in run()
379 while (!shutdown) { in run()
390 if (shutdown) { in run()
402 Level level = shutdown ? Level.FINE : Level.INFO; in run()
431 while (!shutdown) { in run()
[all …]
|
| /external/grpc-grpc/src/core/lib/channel/ |
| D | handshaker.cc | 49 handshaker->vtable->shutdown(handshaker, why); in grpc_handshaker_shutdown()
71 bool shutdown; member
181 if (!mgr->shutdown && mgr->index > 0) { in grpc_handshake_manager_shutdown()
182 mgr->shutdown = true; in grpc_handshake_manager_shutdown()
215 mgr, grpc_error_string(error), mgr->shutdown, mgr->index, args_str); in call_next_handshaker_locked()
222 if (error != GRPC_ERROR_NONE || mgr->shutdown || mgr->args.exit_early || in call_next_handshaker_locked()
224 if (error == GRPC_ERROR_NONE && mgr->shutdown) { in call_next_handshaker_locked()
254 mgr->shutdown = true; in call_next_handshaker_locked()
267 return mgr->shutdown; in call_next_handshaker_locked()
302 GPR_ASSERT(!mgr->shutdown); in grpc_handshake_manager_do_handshake()
|
| /external/rust/crates/flate2/tests/ |
| D | tokio.rs | 20 use tokio_io::io::{copy, shutdown};
53 a.finish().unwrap().shutdown(Shutdown::Write).unwrap(); in tcp_stream_echo_pattern()
69 shutdown(b).map(|_| ()) in tcp_stream_echo_pattern()
75 threadpool.shutdown().wait().unwrap(); in tcp_stream_echo_pattern()
109 a.finish().unwrap().shutdown(Shutdown::Write).unwrap(); in echo_random()
125 shutdown(b).map(|_| ()) in echo_random()
131 threadpool.shutdown().wait().unwrap(); in echo_random()
|
| /external/autotest/client/site_tests/platform_CleanShutdown/ |
| D | control | 4 Tests that the last shutdown was clean (without errors).
6 NOTE: You need to shutdown or reboot the device at least once before running
11 PURPOSE = 'Verify the last shutdown was clean.'
13 Fails if the stateful partition was not cleanly unmounted on the last shutdown.
|
| /external/rust/crates/tokio/src/runtime/tests/ |
| D | task.rs | 94 notified.shutdown(); in create_shutdown1()
109 notified.shutdown(); in create_shutdown2()
128 rt.shutdown(); in schedule()
133 fn shutdown() { in shutdown() function
143 rt.shutdown(); in shutdown()
156 rt.shutdown(); in shutdown_immediately()
183 rt.shutdown(); in spawn_during_shutdown()
265 fn shutdown(&self) { in shutdown() method
|
| /external/grpc-grpc-java/core/src/main/java/io/grpc/internal/ |
| D | ManagedChannelOrphanWrapper.java | 57 public ManagedChannel shutdown() { in shutdown() method in ManagedChannelOrphanWrapper
58 phantom.shutdown = true; in shutdown()
59 return super.shutdown(); in shutdown()
92 private volatile boolean shutdown; field in ManagedChannelOrphanWrapper.ManagedChannelReference
147 if (!(ref.shutdown && ref.channel.isTerminated())) { in cleanQueue()
154 + (!ref.shutdown ? "shutdown" : "terminated") in cleanQueue()
|
| D | OobChannel.java | 81 private volatile boolean shutdown; field in OobChannel
123 subchannelImpl.shutdown(); in OobChannel()
147 public void shutdown() { in setSubchannel()
148 subchannel.shutdown(Status.UNAVAILABLE.withDescription("OobChannel is shutdown")); in setSubchannel()
225 public ManagedChannel shutdown() { in shutdown() method in OobChannel
226 shutdown = true; in shutdown()
227 delayedTransport.shutdown(Status.UNAVAILABLE.withDescription("OobChannel.shutdown() called")); in shutdown()
233 return shutdown; in isShutdown()
238 shutdown = true; in shutdownNow()
|
| /external/grpc-grpc/src/core/ext/filters/client_channel/ |
| D | http_connect_handshaker.cc | 48 bool shutdown; member
105 if (!handshaker->shutdown) { in handshake_failed_locked()
116 handshaker->shutdown = true; in handshake_failed_locked()
127 if (error != GRPC_ERROR_NONE || handshaker->shutdown) { in on_write_done()
148 if (error != GRPC_ERROR_NONE || handshaker->shutdown) { in on_read_done()
221 handshaker->shutdown = true; in on_read_done()
241 if (!handshaker->shutdown) { in http_connect_handshaker_shutdown()
242 handshaker->shutdown = true; in http_connect_handshaker_shutdown()
264 handshaker->shutdown = true; in http_connect_handshaker_do_handshake()
|
| /external/autotest/server/site_tests/firmware_ECPowerButton/ |
| D | control | 21 - Short press (200ms) does not trigger shutdown
22 - Short press wake system from G3 (shutdown for more than 10 sec)
23 - Short press wake system from S5 (shutdown for less than 10 sec)
24 - Long press wake system from G3 (shutdown for more than 10 sec)
25 - Long press wake system from S5 (shutdown for less than 10 sec)
|
| /external/libnl/lib/idiag/ |
| D | idiag.c | 171 __ADD(INET_DIAG_SHUTDOWN, shutdown),
197 __ADD((1 << (INET_DIAG_SHUTDOWN - 1)), shutdown),
262 char * idiagnl_shutdown2str(uint8_t shutdown, char *buf, size_t len) in idiagnl_shutdown2str() argument
264 if (shutdown == 0) { in idiagnl_shutdown2str()
267 } else if (shutdown == 1) { in idiagnl_shutdown2str()
270 } else if (shutdown == 2) { in idiagnl_shutdown2str()
|
| /external/robolectric/robolectric/src/test/java/org/robolectric/shadows/ |
| D | ShadowRcsUceAdapterSTest.java | 66 executorService.shutdown(); in setCapabilitiesForUri_requestCapabilities_overridesCapabilitiesForUri()
85 executorService.shutdown(); in setCapabilitiesForUri_requestCapabilities_doesNotOverrideCapabilitiesForOtherUri()
98 executorService.shutdown(); in setCapabilitiesFailureForUri_requestCapabilities_failsForUri()
116 executorService.shutdown(); in setCapabilitiesFailureForUri_requestCapabilities_doesNotFailForOtherUri()
132 executorService.shutdown(); in setCapabilitiesForUri_requestAvailability_overridesCapabilitiesForUri()
150 executorService.shutdown(); in setCapabilitiesForUri_requestAvailability_doesNotOverrideCapabilitiesForOtherUri()
163 executorService.shutdown(); in setCapabilitiesFailureForUri_requestAvailability_failsForUri()
180 executorService.shutdown(); in setCapabilitiesFailureForUri_requestAvailability_doesNotFailForOtherUri()
|
| /external/grpc-grpc-java/benchmarks/src/main/java/io/grpc/benchmarks/qps/ |
| D | AsyncServer.java | 82 server.shutdown(); in run()
203 private final AtomicBoolean shutdown = new AtomicBoolean(); field in AsyncServer.BenchmarkServiceImpl
208 public void shutdown() { in shutdown() method in AsyncServer.BenchmarkServiceImpl
209 shutdown.set(true); in shutdown()
228 if (shutdown.get()) { in streamingCall()
257 if (shutdown.get()) {
298 return !shutdown.get() && !responseObserver.isCancelled();
326 return !shutdown.get() && !responseObserver.isCancelled();
|
| /external/autotest/client/tests/signaltest/src/ |
| D | signaltest.c | 67 static int shutdown; variable
140 while (!shutdown) { in signalthread()
182 shutdown++; in signalthread()
288 shutdown = 1; in sighand()
368 while (!shutdown) { in main()
385 while (!shutdown) { in main()
402 if (shutdown || allstopped) in main()
409 shutdown = 1; in main()
|