| /third_party/boost/boost/thread/concurrent_queues/ |
| D | sync_queue.hpp | 54 inline queue_op_status try_push(const value_type& x);
58 inline queue_op_status try_push(BOOST_THREAD_RV_REF(value_type) x);
75 inline queue_op_status try_push(const value_type& x, unique_lock<mutex>& lk);
77 inline queue_op_status try_push(BOOST_THREAD_RV_REF(value_type) x, unique_lock<mutex>& lk);
203 …queue_op_status sync_queue<ValueType, Container>::try_push(const ValueType& elem, unique_lock<mute… in try_push() function in boost::concurrent::sync_queue
211 queue_op_status sync_queue<ValueType, Container>::try_push(const ValueType& elem) in try_push() function in boost::concurrent::sync_queue
214 return try_push(elem, lk); in try_push()
237 return try_push(elem, lk); in nonblocking_push()
249 …queue_op_status sync_queue<ValueType, Container>::try_push(BOOST_THREAD_RV_REF(ValueType) elem, un… in try_push() function in boost::concurrent::sync_queue
257 queue_op_status sync_queue<ValueType, Container>::try_push(BOOST_THREAD_RV_REF(ValueType) elem) in try_push() function in boost::concurrent::sync_queue
[all …]
|
| D | queue_adaptor.hpp | 54 queue_op_status try_push(const value_type& x) { return queue.try_push(x); } in try_push() function in boost::concurrent::detail::queue_adaptor_copyable_only
98 …queue_op_status try_push(BOOST_THREAD_RV_REF(value_type) x) { return queue.try_push(boost::move(x)… in try_push() function in boost::concurrent::detail::queue_adaptor_movable_only
132 queue_op_status try_push(const value_type& x) { return queue.try_push(x); } in try_push() function in boost::concurrent::detail::queue_adaptor_copyable_and_movable
142 …queue_op_status try_push(BOOST_THREAD_RV_REF(value_type) x) { return queue.try_push(boost::move(x)… in try_push() function in boost::concurrent::detail::queue_adaptor_copyable_and_movable
|
| D | sync_bounded_queue.hpp | 58 inline bool try_push(const value_type& x);
59 inline bool try_push(BOOST_THREAD_RV_REF(value_type) x);
60 inline bool try_push(no_block_tag, const value_type& x);
61 inline bool try_push(no_block_tag, BOOST_THREAD_RV_REF(value_type) x);
139 inline bool try_push(const value_type& x, unique_lock<mutex>& lk);
140 inline bool try_push(BOOST_THREAD_RV_REF(value_type) x, unique_lock<mutex>& lk);
502 bool sync_bounded_queue<ValueType>::try_push(const ValueType& elem, unique_lock<mutex>& lk) in try_push() function in boost::concurrent::sync_bounded_queue
514 bool sync_bounded_queue<ValueType>::try_push(const ValueType& elem) in try_push() function in boost::concurrent::sync_bounded_queue
517 return try_push(elem, lk); in try_push()
559 bool sync_bounded_queue<ValueType>::try_push(no_block_tag, const ValueType& elem) in try_push() function in boost::concurrent::sync_bounded_queue
[all …]
|
| D | queue_views.hpp | 48 queue_op_status try_push(const value_type& x) { return queue->try_push(x); } in try_push() function in boost::concurrent::queue_back_view
54 …queue_op_status try_push(BOOST_THREAD_RV_REF(value_type) x) { return queue->try_push(boost::move(x… in try_push() function in boost::concurrent::queue_back_view
|
| D | sync_timed_queue.hpp | 152 queue_op_status try_push(const T& elem, chrono::time_point<clock,Duration> const& tp);
154 queue_op_status try_push(const T& elem, chrono::duration<Rep,Period> const& dura);
157 …queue_op_status try_push(BOOST_THREAD_RV_REF(T) elem, chrono::time_point<clock,Duration> const& tp…
159 queue_op_status try_push(BOOST_THREAD_RV_REF(T) elem, chrono::duration<Rep,Period> const& dura);
220 …queue_op_status sync_timed_queue<T, Clock, TimePoint>::try_push(const T& elem, chrono::time_point<… in try_push() function in boost::concurrent::sync_timed_queue
222 return super::try_push(stype(elem,tp)); in try_push()
227 …queue_op_status sync_timed_queue<T, Clock, TimePoint>::try_push(const T& elem, chrono::duration<Re… in try_push() function in boost::concurrent::sync_timed_queue
229 return try_push(elem,clock::now() + dura); in try_push()
234 …queue_op_status sync_timed_queue<T, Clock, TimePoint>::try_push(BOOST_THREAD_RV_REF(T) elem, chron… in try_push() function in boost::concurrent::sync_timed_queue
236 return super::try_push(stype(boost::move(elem), tp)); in try_push()
[all …]
|
| D | queue_base.hpp | 54 virtual queue_op_status try_push(const value_type& x) = 0;
94 virtual queue_op_status try_push(BOOST_THREAD_RV_REF(value_type) x) = 0;
125 virtual queue_op_status try_push(const value_type& x) = 0;
135 virtual queue_op_status try_push(BOOST_THREAD_RV_REF(value_type) x) = 0;
|
| D | deque_views.hpp | 52 queue_op_status try_push(const value_type& x) { return queue->try_push_back(x); } in try_push() function in boost::concurrent::deque_back_view
64 …queue_op_status try_push(BOOST_THREAD_RV_REF(value_type) x) { return queue->try_push_back(boost::m… in try_push() function in boost::concurrent::deque_back_view
95 queue_op_status try_push(const value_type& x) { return queue->try_push_front(x); } in try_push() function in boost::concurrent::deque_front_view
106 …queue_op_status try_push(BOOST_THREAD_RV_REF(value_type) x) { return queue->try_push_front(forward… in try_push() function in boost::concurrent::deque_front_view
|
| D | sync_priority_queue.hpp | 126 queue_op_status try_push(const ValueType& elem);
127 queue_op_status try_push(BOOST_THREAD_RV_REF(ValueType) elem);
148 queue_op_status try_push(unique_lock<mutex>&, const ValueType& elem);
149 queue_op_status try_push(unique_lock<mutex>&, BOOST_THREAD_RV_REF(ValueType) elem);
217 queue_op_status sync_priority_queue<T,Container,Cmp>::try_push(const T& elem) in try_push() function in boost::concurrent::sync_priority_queue
227 queue_op_status sync_priority_queue<T,Container,Cmp>::try_push(BOOST_THREAD_RV_REF(T) elem) in try_push() function in boost::concurrent::sync_priority_queue
|
| /third_party/boost/libs/thread/test/sync/mutual_exclusion/sync_queue/ |
| D | single_thread_pass.cpp | 95 BOOST_TEST(boost::queue_op_status::success == q.try_push(1)); in main()
104 BOOST_TEST(boost::queue_op_status::success == q.try_push(1)); in main()
115 BOOST_TEST(boost::queue_op_status::success ==q.try_push(non_copyable(1))); in main()
126 BOOST_TEST(boost::queue_op_status::success == q.try_push(boost::move(nc))); in main()
137 BOOST_TEST(boost::queue_op_status::success == q.try_push(i)); in main()
|
| /third_party/boost/libs/thread/test/sync/mutual_exclusion/sync_bounded_queue/ |
| D | single_thread_pass.cpp | 116 BOOST_TEST(q.try_push(1)); in main()
126 BOOST_TEST(q.try_push(boost::move(nc))); in main()
136 BOOST_TEST(q.try_push(i)); in main()
145 BOOST_TEST(q.try_push(boost::no_block, 1)); in main()
155 BOOST_TEST(q.try_push(boost::no_block, boost::move(nc))); in main()
237 BOOST_TEST(! q.try_push(3)); in main()
|
| /third_party/boost/libs/fiber/doc/ |
| D | buffered_channel.qbk | 97 channel_op_status try_push( value_type const& va);
98 channel_op_status try_push( value_type && va);
174 [member_heading buffered_channel..try_push]
176 channel_op_status try_push( value_type const& va);
177 channel_op_status try_push( value_type && va);
|
| /third_party/boost/libs/thread/test/sync/mutual_exclusion/sync_pq/ |
| D | tq_single_thread_pass.cpp | 69 boost::queue_op_status st = pq.try_push(i, milliseconds(i*100)); in test_all_with_try()
76 boost::queue_op_status st = pq.try_push(i,steady_clock::now() + milliseconds(i*100)); in test_all_with_try()
|
| D | pq_single_thread_pass.cpp | 127 boost::queue_op_status succ = pq.try_push(i); in main()
159 BOOST_TEST(boost::queue_op_status::success ==q.try_push(non_copyable(1))); in main()
170 BOOST_TEST(boost::queue_op_status::success == q.try_push(boost::move(nc))); in main()
182 BOOST_TEST(boost::queue_op_status::success == q.try_push(i)); in main()
|
| /third_party/boost/libs/thread/test/sync/mutual_exclusion/queue_views/ |
| D | single_thread_pass.cpp | 155 BOOST_TEST(boost::queue_op_status::success == q.try_push(1)); in main()
165 BOOST_TEST(boost::queue_op_status::success == q.try_push(1)); in main()
178 BOOST_TEST(boost::queue_op_status::success == q.try_push(boost::move(nc))); in main()
191 BOOST_TEST(boost::queue_op_status::success == q.try_push(i)); in main()
|
| /third_party/boost/libs/thread/test/sync/mutual_exclusion/deque_views/ |
| D | single_thread_pass.cpp | 154 BOOST_TEST(boost::queue_op_status::success == q.try_push(1)); in main()
164 BOOST_TEST(boost::queue_op_status::success == q.try_push(1)); in main()
177 BOOST_TEST(boost::queue_op_status::success == q.try_push(boost::move(nc))); in main()
190 BOOST_TEST(boost::queue_op_status::success == q.try_push(i)); in main()
|
| /third_party/boost/libs/fiber/test/ |
| D | test_buffered_channel_dispatch.cpp | 76 BOOST_CHECK( boost::fibers::channel_op_status::success == c.try_push( 1) ); in test_try_push_closed()
78 BOOST_CHECK( boost::fibers::channel_op_status::closed == c.try_push( 2) ); in test_try_push_closed()
83 BOOST_CHECK( boost::fibers::channel_op_status::success == c.try_push( 1) ); in test_try_push_full()
84 BOOST_CHECK( boost::fibers::channel_op_status::full == c.try_push( 1) ); in test_try_push_full()
|
| D | test_buffered_channel_post.cpp | 76 BOOST_CHECK( boost::fibers::channel_op_status::success == c.try_push( 1) ); in test_try_push_closed()
78 BOOST_CHECK( boost::fibers::channel_op_status::closed == c.try_push( 2) ); in test_try_push_closed()
83 BOOST_CHECK( boost::fibers::channel_op_status::success == c.try_push( 1) ); in test_try_push_full()
84 BOOST_CHECK( boost::fibers::channel_op_status::full == c.try_push( 2) ); in test_try_push_full()
|
| /third_party/boost/boost/fiber/ |
| D | buffered_channel.hpp | 123 channel_op_status try_push( value_type const& value) { in try_push() function in boost::fibers::buffered_channel
156 channel_op_status try_push( value_type && value) { in try_push() function in boost::fibers::buffered_channel
|
| /third_party/boost/libs/thread/doc/ |
| D | compliance.qbk | 160 [[X.1.2.1] [try_push] [yes] [ renamed try_push_back ]]
|
| D | sync_queues_ref.qbk | 772 queue_op_status try_push(const value_type& x);
773 queue_op_status try_push(BOOST_THREAD_RV_REF(value_type) x);
|