| /third_party/boost/boost/thread/executors/ |
| D | scheduler.hpp | 70 is_closed(false) in resubmit_at_executor()
100 is_closed = true; in close()
105 return is_closed || sch.closed() || ex.closed(); in closed()
112 bool is_closed; member in boost::executors::resubmit_at_executor
177 is_closed(false) in at_executor()
192 is_closed = true; in close()
197 return is_closed || sch.closed(); in closed()
219 bool is_closed; member in boost::executors::at_executor
|
| /third_party/boost/boost/fiber/ |
| D | unbuffered_channel.hpp | 108 bool is_closed() const noexcept { in is_closed() function in boost::fibers::unbuffered_channel
159 if ( BOOST_UNLIKELY( is_closed() ) ) { in push()
192 if ( BOOST_UNLIKELY( is_closed() ) ) { in push()
210 if ( BOOST_UNLIKELY( is_closed() ) ) { in push()
242 if ( BOOST_UNLIKELY( is_closed() ) ) { in push()
277 if ( BOOST_UNLIKELY( is_closed() ) ) { in push_wait_until()
317 if ( BOOST_UNLIKELY( is_closed() ) ) { in push_wait_until()
344 if ( BOOST_UNLIKELY( is_closed() ) ) { in push_wait_until()
383 if ( BOOST_UNLIKELY( is_closed() ) ) { in push_wait_until()
439 if ( BOOST_UNLIKELY( is_closed() ) ) { in pop()
[all …]
|
| D | buffered_channel.hpp | 82 bool is_closed() const noexcept { in is_closed() function in boost::fibers::buffered_channel
|
| /third_party/boost/libs/fiber/performance/thread/ |
| D | buffered_channel.hpp | 160 bool is_closed() const noexcept { in is_closed() function in buffered_channel
173 if ( is_closed() ) { in push()
185 if ( is_closed() ) { in push()
191 not_full_cnd_.wait( lk, [this]{ return is_closed() || ! is_full_(); }); in push()
212 if ( is_closed() ) { in value_pop()
218 not_empty_cnd_.wait( lk, [this](){ return is_closed() || ! is_empty_(); }); in value_pop()
|
| /third_party/libinput/src/ |
| D | evdev-fallback.c | 55 if (dispatch->lid.is_closed ^ dispatch->lid.is_closed_client_state) { in fallback_lid_notify_toggle()
59 dispatch->lid.is_closed); in fallback_lid_notify_toggle()
60 dispatch->lid.is_closed_client_state = dispatch->lid.is_closed; in fallback_lid_notify_toggle()
687 if (!dispatch->lid.is_closed) in fallback_lid_keyboard_event()
716 dispatch->lid.is_closed = false; in fallback_lid_keyboard_event()
723 bool is_closed) in fallback_lid_toggle_keyboard_listener() argument
729 if (is_closed) { in fallback_lid_toggle_keyboard_listener()
742 bool is_closed) in fallback_lid_toggle_keyboard_listeners() argument
752 is_closed); in fallback_lid_toggle_keyboard_listeners()
763 bool is_closed; in fallback_process_switch() local
[all …]
|
| D | evdev-fallback.h | 133 bool is_closed; member
|
| /third_party/icu/tools/commit-checker/ |
| D | check.py | 181 closed_jira_issue_ids = set(issue.issue_id for issue in issues if issue.is_closed)
204 if not issue.is_closed:
224 if not issue.is_closed:
|
| /third_party/gstreamer/gstreamer/tests/check/gst/ |
| D | gstminiobject.c | 223 gboolean is_closed;
313 g_atomic_int_set (&pool->is_closed, TRUE);
330 while (!g_atomic_int_get (&pool->is_closed));
|
| /third_party/grpc/test/core/transport/chttp2/ |
| D | hpack_encoder_test.cc | 78 bool is_closed = false; in verify_frames() local
110 if (is_closed && in verify_frames()
143 is_closed = true; in verify_frames()
|
| /third_party/gstreamer/gstplugins_bad/gst-libs/gst/vulkan/win32/ |
| D | gstvkwindow_win32.h | 55 gboolean is_closed; member
|
| /third_party/gstreamer/gstplugins_base/gst-libs/gst/gl/win32/ |
| D | gstglwindow_win32.h | 50 gboolean is_closed; member
|
| /third_party/gstreamer/gstplugins_bad/ext/webrtc/ |
| D | gstwebrtcbin.h | 122 gboolean is_closed; member
|
| D | gstwebrtcbin.c | 898 webrtc->priv->is_closed = FALSE; in _start_thread()
906 webrtc->priv->is_closed = TRUE; in _stop_thread()
924 if (op->webrtc->priv->is_closed) { in _execute_op()
983 if (webrtc->priv->is_closed) { in gst_webrtc_bin_enqueue_task()
1058 if (webrtc->priv->is_closed) { in _collate_ice_connection_states()
1283 if (webrtc->priv->is_closed) { in _collate_peer_connection_states()
1686 if (webrtc->priv->is_closed) in _update_need_negotiation()
6306 g_return_val_if_fail (webrtc->priv->is_closed != TRUE, NULL); in gst_webrtc_bin_create_data_channel()
7982 webrtc->priv->is_closed = TRUE; in gst_webrtc_bin_init()
|
| /third_party/cef/include/capi/views/ |
| D | cef_window_capi.h | 91 int(CEF_CALLBACK* is_closed)(struct _cef_window_t* self);
|
| /third_party/boost/boost/thread/concurrent_queues/ |
| D | sync_bounded_queue.hpp | 487 bool is_closed = false; in wait_pull_front() local
488 wait_until_not_empty(lk, is_closed); in wait_pull_front()
489 if (is_closed) {return queue_op_status::closed;} in wait_pull_front()
|
| /third_party/grpc/src/core/ext/transport/inproc/ |
| D | inproc_transport.cc | 119 bool is_closed = false; member
999 if (s->t->is_closed) { in perform_stream_op()
1129 INPROC_LOG(GPR_INFO, "close_transport %p %d", t, t->is_closed); in close_transport_locked()
1132 if (!t->is_closed) { in close_transport_locked()
1133 t->is_closed = true; in close_transport_locked()
|
| /third_party/python/Lib/test/test_asyncio/ |
| D | test_runners.py | 52 self.assertTrue(policy.loop.is_closed())
|
| D | utils.py | 515 if not loop.is_closed():
|
| /third_party/python/Lib/asyncio/ |
| D | selector_events.py | 90 if self.is_closed():
274 if self.is_closed():
312 if self.is_closed():
659 if self._loop is not None and not self._loop.is_closed():
|
| D | futures.py | 393 dest_loop is not None and dest_loop.is_closed()):
|
| D | proactor_events.py | 677 if self.is_closed():
834 if self.is_closed():
|
| D | base_events.py | 518 if not self.is_closed():
674 def is_closed(self): member in BaseEventLoop
679 if not self.is_closed():
|
| D | events.py | 232 def is_closed(self): member in AbstractEventLoop
|
| D | unix_events.py | 1309 if loop.is_closed():
1407 if loop.is_closed():
|
| /third_party/cef/libcef_dll/ctocpp/views/ |
| D | window_ctocpp.cc | 111 if (CEF_MEMBER_MISSING(_struct, is_closed)) in IsClosed()
117 int _retval = _struct->is_closed(_struct); in IsClosed()
|