| /external/grpc-grpc/test/cpp/server/ |
| D | server_request_call_test.cc | 41 bool shutting_down = false; in TEST() local
56 std::thread t([address, &service, &cq, &mu, &shutting_down] { in TEST()
65 if (!shutting_down) { in TEST()
81 if (!shutting_down && !ok) { in TEST()
85 if (shutting_down && !ok) { in TEST()
101 if (shutting_down) { in TEST()
148 shutting_down = true; in TEST()
|
| /external/crosvm/cros_async/src/blocking/ |
| D | pool.rs | 34 shutting_down: bool, field
39 while !state.shutting_down { in run_blocking_thread()
53 !s.shutting_down && s.num_notified == 0 in run_blocking_thread()
115 if state.shutting_down { in spawn()
229 shutting_down: false, in new()
251 shutting_down: false, in with_capacity()
286 if state.shutting_down { in shutdown()
291 state.shutting_down = true; in shutdown()
329 pub(crate) fn shutting_down(&self) -> bool { in shutting_down() method
330 self.inner.state.lock().shutting_down in shutting_down()
[all …]
|
| /external/grpc-grpc/src/core/lib/iomgr/ |
| D | tcp_windows.cc | 124 int shutting_down; member
135 if (tcp->shutting_down) GRPC_ERROR_UNREF(tcp->shutdown_error); in tcp_free()
188 if (info->wsa_error != 0 && !tcp->shutting_down) { in on_read()
194 if (info->bytes_transfered != 0 && !tcp->shutting_down) { in on_read()
199 error = tcp->shutting_down in on_read()
222 if (tcp->shutting_down) { in win_read()
311 if (tcp->shutting_down) { in win_write()
401 if (!tcp->shutting_down) { in win_shutdown()
402 tcp->shutting_down = 1; in win_shutdown()
|
| D | tcp_server_windows.cc | 64 int shutting_down; member
169 sp->shutting_down = 1; in tcp_server_destroy()
237 sp->shutting_down = 0; in decrement_active_ports_and_notify_locked()
253 if (port->shutting_down) { in start_accept_locked()
330 if (!sp->shutting_down) { in on_accept()
337 if (!sp->shutting_down) { in on_accept()
432 sp->shutting_down = 0; in add_socket_to_server()
|
| D | tcp_custom.cc | 70 bool shutting_down; member
240 if (tcp->shutting_down) { in endpoint_write()
283 if (!tcp->shutting_down) { in endpoint_shutdown()
288 tcp->shutting_down = true; in endpoint_shutdown()
357 tcp->shutting_down = false; in custom_tcp_endpoint_create()
|
| D | pollset_windows.cc | 98 pollset->shutting_down = 1; in pollset_shutdown()
123 if (!pollset->kicked_without_pollers && !pollset->shutting_down) { in pollset_work()
148 if (pollset->shutting_down && pollset->on_shutdown != NULL) { in pollset_work()
|
| D | ev_epoll1_linux.cc | 211 bool shutting_down; /* Is the pollset shutting down ? */ member
539 pollset->shutting_down = false; in pollset_init()
619 GPR_ASSERT(!pollset->shutting_down); in pollset_shutdown()
621 pollset->shutting_down = true; in pollset_shutdown()
809 while (worker->state == UNKICKED && !pollset->shutting_down) { in begin_worker()
813 pollset->shutting_down); in begin_worker()
832 pollset->shutting_down, pollset->kicked_without_poller); in begin_worker()
849 return worker->state == DESIGNATED_POLLER && !pollset->shutting_down; in begin_worker()
1009 GPR_ASSERT(!ps->shutting_down); in pollset_work()
|
| D | pollset_windows.h | 58 int shutting_down; member
|
| D | ev_epollsig_linux.cc | 230 bool shutting_down; /* Is the pollset shutting down ? */ member
1098 pollset->shutting_down = false;
1136 GPR_ASSERT(!pollset->shutting_down);
1137 pollset->shutting_down = true;
1317 } else if (!pollset->shutting_down) {
1373 if (pollset->shutting_down && !pollset_has_workers(pollset) &&
|
| /external/rust/crates/grpcio-sys/grpc/src/core/ext/filters/client_channel/ |
| D | backup_poller.cc | 47 bool shutting_down; // guarded by pollset_mu member
103 p->shutting_down = true; in g_poller_unref()
125 if (p->shutting_down) { in run_poller()
144 g_poller->shutting_down = false; in g_poller_init_locked()
|
| /external/grpc-grpc/src/core/ext/filters/client_channel/ |
| D | backup_poller.cc | 45 bool shutting_down; // guarded by pollset_mu member
95 p->shutting_down = true; in g_poller_unref()
116 if (p->shutting_down) { in run_poller()
135 g_poller->shutting_down = false; in g_poller_init_locked()
|
| /external/rust/crates/grpcio-sys/grpc/src/core/lib/iomgr/ |
| D | tcp_windows.cc | 125 int shutting_down; member
137 if (tcp->shutting_down) GRPC_ERROR_UNREF(tcp->shutdown_error); in tcp_free()
193 if (info->wsa_error != 0 && !tcp->shutting_down) { in on_read()
199 if (info->bytes_transferred != 0 && !tcp->shutting_down) { in on_read()
226 error = tcp->shutting_down in on_read()
256 if (tcp->shutting_down) { in win_read()
370 if (tcp->shutting_down) { in win_write()
462 if (!tcp->shutting_down) { in win_shutdown()
463 tcp->shutting_down = 1; in win_shutdown()
|
| D | tcp_server_windows.cc | 69 int shutting_down; member
176 sp->shutting_down = 1; in tcp_server_destroy()
243 sp->shutting_down = 0; in decrement_active_ports_and_notify_locked()
259 if (port->shutting_down) { in start_accept_locked()
334 if (!sp->shutting_down) { in on_accept()
341 if (!sp->shutting_down) { in on_accept()
435 sp->shutting_down = 0; in add_socket_to_server()
|
| D | tcp_custom.cc | 70 bool shutting_down; member
246 if (tcp->shutting_down) { in endpoint_write()
290 if (!tcp->shutting_down) { in endpoint_shutdown()
295 tcp->shutting_down = true; in endpoint_shutdown()
383 tcp->shutting_down = false; in custom_tcp_endpoint_create()
|
| D | pollset_windows.cc | 98 pollset->shutting_down = 1; in pollset_shutdown()
123 if (!pollset->kicked_without_pollers && !pollset->shutting_down) { in pollset_work()
148 if (pollset->shutting_down && pollset->on_shutdown != NULL) { in pollset_work()
|
| D | ev_epoll1_linux.cc | 221 bool shutting_down; /* Is the pollset shutting down ? */ member
558 pollset->shutting_down = false; in pollset_init()
639 GPR_ASSERT(!pollset->shutting_down); in pollset_shutdown()
641 pollset->shutting_down = true; in pollset_shutdown()
830 while (worker->state == UNKICKED && !pollset->shutting_down) { in begin_worker()
834 pollset->shutting_down); in begin_worker()
853 pollset->shutting_down, pollset->kicked_without_poller); in begin_worker()
870 return worker->state == DESIGNATED_POLLER && !pollset->shutting_down; in begin_worker()
1032 GPR_ASSERT(!ps->shutting_down); in pollset_work()
|
| D | pollset_windows.h | 58 int shutting_down; member
|
| D | ev_poll_posix.cc | 200 int shutting_down; member
855 pollset->shutting_down = 0;
954 if (pollset->shutting_down) {
1127 if (pollset->shutting_down) {
1148 GPR_ASSERT(!pollset->shutting_down);
1149 pollset->shutting_down = 1;
1189 if (pollset->shutting_down && !pollset->called_shutdown &&
1247 if (pollset->shutting_down && !pollset->called_shutdown &&
|
| /external/grpc-grpc/src/core/ext/filters/client_channel/resolver/dns/c_ares/ |
| D | grpc_ares_ev_driver.cc | 74 bool shutting_down; member
143 (*ev_driver)->shutting_down = false; in grpc_ares_ev_driver_create_locked()
157 ev_driver->shutting_down = true; in grpc_ares_ev_driver_on_queries_complete_locked()
162 ev_driver->shutting_down = true; in grpc_ares_ev_driver_shutdown_locked()
241 if (!ev_driver->shutting_down) { in grpc_ares_notify_on_event_locked()
|
| /external/perfetto/src/profiling/memory/ |
| D | shared_ring_buffer.h | 166 meta_->shutting_down.store(true, std::memory_order_relaxed); in SetShuttingDown()
169 bool shutting_down() { in shutting_down() function
170 return meta_->shutting_down.load(std::memory_order_relaxed); in shutting_down()
199 alignas(sizeof(uint64_t)) std::atomic<bool> shutting_down; member
|
| D | client.cc | 417 if (shmem_.shutting_down()) in SendWireMessageWithRetriesIfBlocking()
500 if (shmem_.shutting_down()) { in SendControlSocketByte()
|
| /external/rust/crates/grpcio-sys/grpc/src/core/ext/filters/client_channel/resolver/dns/c_ares/ |
| D | grpc_ares_wrapper.cc | 118 bool shutting_down; member
223 ev_driver->shutting_down = true; in grpc_ares_ev_driver_on_queries_complete_locked()
230 ev_driver->shutting_down = true; in grpc_ares_ev_driver_shutdown_locked()
276 driver->request, driver, driver->shutting_down, in on_timeout_locked()
278 if (!driver->shutting_down && error == GRPC_ERROR_NONE) { in on_timeout_locked()
319 driver->request, driver, driver->shutting_down, in on_ares_backup_poll_alarm_locked()
321 if (!driver->shutting_down && error == GRPC_ERROR_NONE) { in on_ares_backup_poll_alarm_locked()
334 if (!driver->shutting_down) { in on_ares_backup_poll_alarm_locked()
421 if (!ev_driver->shutting_down) { in grpc_ares_notify_on_event_locked()
550 (*ev_driver)->shutting_down = false; in grpc_ares_ev_driver_create_locked()
|
| /external/rust/crates/grpcio-sys/grpc/src/core/ext/filters/client_channel/lb_policy/ |
| D | subchannel_list.h | 187 bool shutting_down() const { return shutting_down_; } in shutting_down() function
251 ConnectivityStateName(new_state), subchannel_list_->shutting_down(), in OnConnectivityStateChange()
254 if (!subchannel_list_->shutting_down() && in OnConnectivityStateChange()
|
| /external/grpc-grpc/src/core/ext/filters/client_channel/lb_policy/ |
| D | subchannel_list.h | 201 bool shutting_down() const { return shutting_down_; } in shutting_down() function
449 grpc_error_string(error), sd->subchannel_list_->shutting_down()); in OnConnectivityChangedLocked()
452 if (sd->subchannel_list_->shutting_down() || error == GRPC_ERROR_CANCELLED) { in OnConnectivityChangedLocked()
|
| /external/webrtc/rtc_base/ |
| D | event_tracer.cc | 131 bool shutting_down = shutdown_event_.Wait(kLoggingInterval); in Log() local
178 if (shutting_down) in Log()
|