| /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 | 97 final AtomicBoolean shutdown; field in GcFinalizationTest.Interruptenator
102 final AtomicBoolean shutdown) { in Interruptenator() argument
105 while (!shutdown.get()) { in Interruptenator()
109 this.shutdown = shutdown; in Interruptenator()
112 void shutdown() { in shutdown() method in GcFinalizationTest.Interruptenator
113 shutdown.set(true); in shutdown()
136 interruptenator.shutdown(); in testAwait_CountDownLatch_Interrupted()
152 interruptenator.shutdown(); in testAwaitDone_Future_Interrupted_Interrupted()
168 interruptenator.shutdown(); in testAwaitClear_Interrupted()
187 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/u-boot/drivers/net/phy/ |
| D | vitesse.c | 302 .shutdown = &genphy_shutdown,
312 .shutdown = &genphy_shutdown,
322 .shutdown = &genphy_shutdown,
332 .shutdown = &genphy_shutdown,
342 .shutdown = &genphy_shutdown,
352 .shutdown = &genphy_shutdown,
362 .shutdown = &genphy_shutdown,
372 .shutdown = &genphy_shutdown,
382 .shutdown = &genphy_shutdown,
392 .shutdown = &genphy_shutdown,
[all …]
|
| D | smsc.c | 52 .shutdown = &genphy_shutdown,
62 .shutdown = &genphy_shutdown,
72 .shutdown = &genphy_shutdown,
82 .shutdown = &genphy_shutdown,
92 .shutdown = &genphy_shutdown,
102 .shutdown = &genphy_shutdown,
|
| D | micrel_ksz8xxx.c | 24 .shutdown = &genphy_shutdown,
53 .shutdown = &genphy_shutdown,
81 .shutdown = &genphy_shutdown,
91 .shutdown = &genphy_shutdown,
148 .shutdown = &genphy_shutdown,
159 .shutdown = &genphy_shutdown,
184 .shutdown = &genphy_shutdown,
|
| D | aquantia.c | 121 .shutdown = &gen10g_shutdown,
134 .shutdown = &gen10g_shutdown,
147 .shutdown = &gen10g_shutdown,
160 .shutdown = &gen10g_shutdown,
173 .shutdown = &gen10g_shutdown,
186 .shutdown = &gen10g_shutdown,
|
| /external/guava/guava-testlib/src/com/google/common/util/concurrent/testing/ |
| D | TestingExecutors.java | 105 private volatile boolean shutdown; field in TestingExecutors.NoOpScheduledExecutorService
107 @Override public void shutdown() { in shutdown() method in TestingExecutors.NoOpScheduledExecutorService
108 shutdown = true; in shutdown()
112 shutdown(); in shutdownNow()
117 return shutdown; in isShutdown()
121 return shutdown; in isTerminated()
|
| /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/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/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/grpc-grpc-java/core/src/main/java/io/grpc/internal/ |
| 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()
|
| 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 | ManagedChannelImpl.java | 206 private final AtomicBoolean shutdown = new AtomicBoolean(false); field in ManagedChannelImpl
242 checkState(shutdown.get(), "Channel must have been shut down");
257 checkState(shutdown.get(), "Channel must have been shut down");
291 if (shutdown.get()) {
343 nameResolver.shutdown(); in shutdownNameResolverAndLoadBalancer()
348 lbHelper.lb.shutdown(); in shutdownNameResolverAndLoadBalancer()
361 if (shutdown.get() || panicMode) { in exitIdleMode()
470 if (shutdown.get()) {
680 public ManagedChannelImpl shutdown() { in shutdown() method in ManagedChannelImpl
682 if (!shutdown.compareAndSet(false, true)) { in shutdown()
[all …]
|
| /external/grpc-grpc-java/core/src/test/java/io/grpc/internal/ |
| D | AutoConfiguredLoadBalancerFactoryTest.java | 92 public void shutdown() { in forwardsCalls()
105 lb.shutdown(); in forwardsCalls()
162 final AtomicBoolean shutdown = new AtomicBoolean(); in handleResolvedAddressGroups_shutsDownOldBalancer() local
176 public void shutdown() { in handleResolvedAddressGroups_shutsDownOldBalancer()
177 shutdown.set(true); in handleResolvedAddressGroups_shutsDownOldBalancer()
185 assertTrue(shutdown.get()); in handleResolvedAddressGroups_shutsDownOldBalancer()
289 public void shutdown() { in shutdown() method in AutoConfiguredLoadBalancerFactoryTest.ForwardingLoadBalancer
290 delegate().shutdown(); in shutdown()
360 public void shutdown() { in shutdown() method in AutoConfiguredLoadBalancerFactoryTest.TestSubchannel
|
| D | ServerImplTest.java | 217 public void shutdown() {} in startStopImmediate()
220 server.shutdown(); in startStopImmediate()
231 public void shutdown() { in stopImmediate()
236 server.shutdown(); in stopImmediate()
247 boolean shutdown; in startStopImmediateWithChildTransport() field in ServerImplTest.DelayedShutdownServerTransport
250 public void shutdown() { in startStopImmediateWithChildTransport() method in ServerImplTest.DelayedShutdownServerTransport
251 shutdown = true; in startStopImmediateWithChildTransport()
257 server.shutdown(); in startStopImmediateWithChildTransport()
260 assertTrue(serverTransport.shutdown); in startStopImmediateWithChildTransport()
273 boolean shutdown; in startShutdownNowImmediateWithChildTransport() field in ServerImplTest.DelayedShutdownServerTransport
[all …]
|
| /external/guava/guava-tests/test/com/google/common/util/concurrent/ |
| D | MoreExecutorsTest.java | 211 executor.shutdown(); in testDirectExecutorServiceServiceTermination()
254 executor.shutdown(); in testExecuteAfterShutdown()
516 verify(service, Mockito.never()).shutdown(); in testAddDelayedShutdownHook_success()
517 application.shutdown(); in testAddDelayedShutdownHook_success()
519 shutdownFirst.verify(service).shutdown(); in testAddDelayedShutdownHook_success()
528 application.shutdown(); in testAddDelayedShutdownHook_interrupted()
529 verify(service).shutdown(); in testAddDelayedShutdownHook_interrupted()
555 application.shutdown(); in testGetExitingExcutorService_shutdownHookRegistered()
556 verify(executor).shutdown(); in testGetExitingExcutorService_shutdownHookRegistered()
582 application.shutdown(); in testGetScheduledExitingExcutorService_shutdownHookRegistered()
[all …]
|
| /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()
|
| /external/jacoco/org.jacoco.agent.rt.test/src/org/jacoco/agent/rt/internal/ |
| D | AgentTest.java | 121 public void shutdown() { in startup_should_log_exception()
151 agent.shutdown(); in startup_should_register_mbean_when_enabled()
176 agent.shutdown(); in shutdown_should_write_execution_data_when_enabled()
189 agent.shutdown(); in shutdown_should_not_write_execution_data_when_disabled()
206 public void shutdown() throws Exception { in shutdown_should_log_exception()
217 agent.shutdown(); in shutdown_should_log_exception()
229 agent.shutdown(); in shutdown_should_deregister_mbean_when_enabled()
370 public void shutdown() {
|
| /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/server/site_tests/firmware_ECLidShutdown/ |
| D | control | 10 CRITERIA = "This test will ensure disable lid shutdown GBB flag working"
20 This test check the functionality of disable lid shutdown GBB flag.
21 - Verifies that closing lid in recovery will shutdown DUT
23 - Verifies that closing lid in recovery will not shutdown DUT
|
| /external/selinux/python/sepolgen/src/share/ |
| D | perm_map | 298 shutdown w 1
326 shutdown w 1
352 shutdown w 1
377 shutdown w 1
418 shutdown w 1
442 shutdown w 1
466 shutdown w 1
493 shutdown w 1
517 shutdown w 1
709 shutdown w 1
[all …]
|