12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091929394959697989910010110210310410510610710810911011111211311411511611711811912012112212312412512612712812913013113213313413513613713813914014114214314414514614714814915015115215315415515615715815916016116216316416516616716816917017117217317417517617717817918018118218318418518618718818919019119219319419519619719819920020120220320420520620720820921021121221321421521621721821922022122222322422522622722822923023123223323423523623723823924024124224324424524624724824925025125225325425525625725825926026126226326426526626726826927027127227327427527627727827928028128228328428528628728828929029129229329429529629729829930030130230330430530630730830931031131231331431531631731831932032132232332432532632732832933033133233333433533633733833934034134234334434534634734834935035135235335435535635735835936036136236336436536636736836937037137237337437537637737837938038138238338438538638738838939039139239339439539639739839940040140240340440540640740840941041141241341441541641741841942042142242342442542642742842943043143243343443543643743843944044144244344444544644744844945045145245345445545645745845946046146246346446546646746846947047147247347447547647747847948048148248348448548648748848949049149249349449549649749849950050150250350450550650750850951051151251351451551651751851952052152252352452552652752852953053153253353453553653753853954054154254354454554654754854955055155255355455555655755855956056156256356456556656756856957057157257357457557657757857958058158258358458558658758858959059159259359459559659759859960060160260360460560660760860961061161261361461561661761861962062162262362462562662762862963063163263363463563663763863964064164264364464564664764864965065165265365465565665765865966066166266366466566666766866967067167267367467567667767867968068168268368468568668768868969069169269369469569669769869970070170270370470570670770870971071171271371471571671771871972072172272372472572672772872973073173273373473573673773873974074174274374474574674774874975075175275375475575675775875976076176276376476576676776876977077177277377477577677777877978078178278378478578678778878979079179279379479579679779879980080180280380480580680780880981081181281381481581681781881982082182282382482582682782882983083183283383483583683783883984084184284384484584684784884985085185285385485585685785885986086186286386486586686786886987087187287387487587687787887988088188288388488588688788888989089189289389489589689789889990090190290390490590690790890991091191291391491591691791891992092192292392492592692792892993093193293393493593693793893994094194294394494594694794894995095195295395495595695795895996096196296396496596696796896997097197297397497597697797897998098198298398498598698798898999099199299399499599699799899910001001100210031004100510061007100810091010101110121013101410151016101710181019102010211022102310241025102610271028102910301031103210331034103510361037103810391040104110421043104410451046104710481049105010511052105310541055105610571058105910601061106210631064106510661067106810691070107110721073107410751076107710781079108010811082108310841085108610871088108910901091109210931094109510961097109810991100110111021103110411051106110711081109111011111112111311141115111611171118111911201121112211231124112511261127112811291130113111321133113411351136113711381139114011411142114311441145114611471148114911501151115211531154115511561157115811591160116111621163116411651166116711681169117011711172117311741175117611771178117911801181118211831184118511861187118811891190119111921193119411951196119711981199120012011202120312041205120612071208120912101211121212131214121512161217 |
- //
- // execution/bulk_guarantee.hpp
- // ~~~~~~~~~~~~~~~~~~~~~~~~~~~~
- //
- // Copyright (c) 2003-2021 Christopher M. Kohlhoff (chris at kohlhoff dot com)
- //
- // Distributed under the Boost Software License, Version 1.0. (See accompanying
- // file LICENSE_1_0.txt or copy at http://www.boost.org/LICENSE_1_0.txt)
- //
- #ifndef BOOST_ASIO_EXECUTION_BULK_GUARANTEE_HPP
- #define BOOST_ASIO_EXECUTION_BULK_GUARANTEE_HPP
- #if defined(_MSC_VER) && (_MSC_VER >= 1200)
- # pragma once
- #endif // defined(_MSC_VER) && (_MSC_VER >= 1200)
- #include <boost/asio/detail/config.hpp>
- #include <boost/asio/detail/type_traits.hpp>
- #include <boost/asio/execution/executor.hpp>
- #include <boost/asio/execution/scheduler.hpp>
- #include <boost/asio/execution/sender.hpp>
- #include <boost/asio/is_applicable_property.hpp>
- #include <boost/asio/query.hpp>
- #include <boost/asio/traits/query_free.hpp>
- #include <boost/asio/traits/query_member.hpp>
- #include <boost/asio/traits/query_static_constexpr_member.hpp>
- #include <boost/asio/traits/static_query.hpp>
- #include <boost/asio/traits/static_require.hpp>
- #include <boost/asio/detail/push_options.hpp>
- namespace boost {
- namespace asio {
- #if defined(GENERATING_DOCUMENTATION)
- namespace execution {
- /// A property to communicate the forward progress and ordering guarantees of
- /// execution agents associated with the bulk execution.
- struct bulk_guarantee_t
- {
- /// The bulk_guarantee_t property applies to executors, senders, and
- /// schedulers.
- template <typename T>
- static constexpr bool is_applicable_property_v =
- is_executor_v<T> || is_sender_v<T> || is_scheduler_v<T>;
- /// The top-level bulk_guarantee_t property cannot be required.
- static constexpr bool is_requirable = false;
- /// The top-level bulk_guarantee_t property cannot be preferred.
- static constexpr bool is_preferable = false;
- /// The type returned by queries against an @c any_executor.
- typedef bulk_guarantee_t polymorphic_query_result_type;
- /// A sub-property that indicates that execution agents within the same bulk
- /// execution may be parallelised and vectorised.
- struct unsequenced_t
- {
- /// The bulk_guarantee_t::unsequenced_t property applies to executors,
- /// senders, and schedulers.
- template <typename T>
- static constexpr bool is_applicable_property_v =
- is_executor_v<T> || is_sender_v<T> || is_scheduler_v<T>;
- /// The bulk_guarantee_t::unsequenced_t property can be required.
- static constexpr bool is_requirable = true;
- /// The bulk_guarantee_t::unsequenced_t property can be preferred.
- static constexpr bool is_preferable = true;
- /// The type returned by queries against an @c any_executor.
- typedef bulk_guarantee_t polymorphic_query_result_type;
- /// Default constructor.
- constexpr unsequenced_t();
- /// Get the value associated with a property object.
- /**
- * @returns unsequenced_t();
- */
- static constexpr bulk_guarantee_t value();
- };
- /// A sub-property that indicates that execution agents within the same bulk
- /// execution may not be parallelised and vectorised.
- struct sequenced_t
- {
- /// The bulk_guarantee_t::sequenced_t property applies to executors,
- /// senders, and schedulers.
- template <typename T>
- static constexpr bool is_applicable_property_v =
- is_executor_v<T> || is_sender_v<T> || is_scheduler_v<T>;
- /// The bulk_guarantee_t::sequenced_t property can be required.
- static constexpr bool is_requirable = true;
- /// The bulk_guarantee_t::sequenced_t property can be preferred.
- static constexpr bool is_preferable = true;
- /// The type returned by queries against an @c any_executor.
- typedef bulk_guarantee_t polymorphic_query_result_type;
- /// Default constructor.
- constexpr sequenced_t();
- /// Get the value associated with a property object.
- /**
- * @returns sequenced_t();
- */
- static constexpr bulk_guarantee_t value();
- };
- /// A sub-property that indicates that execution agents within the same bulk
- /// execution may be parallelised.
- struct parallel_t
- {
- /// The bulk_guarantee_t::parallel_t property applies to executors,
- /// senders, and schedulers.
- template <typename T>
- static constexpr bool is_applicable_property_v =
- is_executor_v<T> || is_sender_v<T> || is_scheduler_v<T>;
- /// The bulk_guarantee_t::parallel_t property can be required.
- static constexpr bool is_requirable = true;
- /// The bulk_guarantee_t::parallel_t property can be preferred.
- static constexpr bool is_preferable = true;
- /// The type returned by queries against an @c any_executor.
- typedef bulk_guarantee_t polymorphic_query_result_type;
- /// Default constructor.
- constexpr parallel_t();
- /// Get the value associated with a property object.
- /**
- * @returns parallel_t();
- */
- static constexpr bulk_guarantee_t value();
- };
- /// A special value used for accessing the bulk_guarantee_t::unsequenced_t
- /// property.
- static constexpr unsequenced_t unsequenced;
- /// A special value used for accessing the bulk_guarantee_t::sequenced_t
- /// property.
- static constexpr sequenced_t sequenced;
- /// A special value used for accessing the bulk_guarantee_t::parallel_t
- /// property.
- static constexpr parallel_t parallel;
- /// Default constructor.
- constexpr bulk_guarantee_t();
- /// Construct from a sub-property value.
- constexpr bulk_guarantee_t(unsequenced_t);
- /// Construct from a sub-property value.
- constexpr bulk_guarantee_t(sequenced_t);
- /// Construct from a sub-property value.
- constexpr bulk_guarantee_t(parallel_t);
- /// Compare property values for equality.
- friend constexpr bool operator==(
- const bulk_guarantee_t& a, const bulk_guarantee_t& b) noexcept;
- /// Compare property values for inequality.
- friend constexpr bool operator!=(
- const bulk_guarantee_t& a, const bulk_guarantee_t& b) noexcept;
- };
- /// A special value used for accessing the bulk_guarantee_t property.
- constexpr bulk_guarantee_t bulk_guarantee;
- } // namespace execution
- #else // defined(GENERATING_DOCUMENTATION)
- namespace execution {
- namespace detail {
- namespace bulk_guarantee {
- template <int I> struct unsequenced_t;
- template <int I> struct sequenced_t;
- template <int I> struct parallel_t;
- } // namespace bulk_guarantee
- template <int I = 0>
- struct bulk_guarantee_t
- {
- #if defined(BOOST_ASIO_HAS_VARIABLE_TEMPLATES)
- template <typename T>
- BOOST_ASIO_STATIC_CONSTEXPR(bool,
- is_applicable_property_v = (
- is_executor<T>::value
- || conditional<
- is_executor<T>::value,
- false_type,
- is_sender<T>
- >::type::value
- || conditional<
- is_executor<T>::value,
- false_type,
- is_scheduler<T>
- >::type::value));
- #endif // defined(BOOST_ASIO_HAS_VARIABLE_TEMPLATES)
- BOOST_ASIO_STATIC_CONSTEXPR(bool, is_requirable = false);
- BOOST_ASIO_STATIC_CONSTEXPR(bool, is_preferable = false);
- typedef bulk_guarantee_t polymorphic_query_result_type;
- typedef detail::bulk_guarantee::unsequenced_t<I> unsequenced_t;
- typedef detail::bulk_guarantee::sequenced_t<I> sequenced_t;
- typedef detail::bulk_guarantee::parallel_t<I> parallel_t;
- BOOST_ASIO_CONSTEXPR bulk_guarantee_t()
- : value_(-1)
- {
- }
- BOOST_ASIO_CONSTEXPR bulk_guarantee_t(unsequenced_t)
- : value_(0)
- {
- }
- BOOST_ASIO_CONSTEXPR bulk_guarantee_t(sequenced_t)
- : value_(1)
- {
- }
- BOOST_ASIO_CONSTEXPR bulk_guarantee_t(parallel_t)
- : value_(2)
- {
- }
- template <typename T>
- struct proxy
- {
- #if defined(BOOST_ASIO_HAS_DEDUCED_QUERY_MEMBER_TRAIT)
- struct type
- {
- template <typename P>
- auto query(BOOST_ASIO_MOVE_ARG(P) p) const
- noexcept(
- noexcept(
- declval<typename conditional<true, T, P>::type>().query(
- BOOST_ASIO_MOVE_CAST(P)(p))
- )
- )
- -> decltype(
- declval<typename conditional<true, T, P>::type>().query(
- BOOST_ASIO_MOVE_CAST(P)(p))
- );
- };
- #else // defined(BOOST_ASIO_HAS_DEDUCED_QUERY_MEMBER_TRAIT)
- typedef T type;
- #endif // defined(BOOST_ASIO_HAS_DEDUCED_QUERY_MEMBER_TRAIT)
- };
- template <typename T>
- struct static_proxy
- {
- #if defined(BOOST_ASIO_HAS_DEDUCED_QUERY_STATIC_CONSTEXPR_MEMBER_TRAIT)
- struct type
- {
- template <typename P>
- static constexpr auto query(BOOST_ASIO_MOVE_ARG(P) p)
- noexcept(
- noexcept(
- conditional<true, T, P>::type::query(BOOST_ASIO_MOVE_CAST(P)(p))
- )
- )
- -> decltype(
- conditional<true, T, P>::type::query(BOOST_ASIO_MOVE_CAST(P)(p))
- )
- {
- return T::query(BOOST_ASIO_MOVE_CAST(P)(p));
- }
- };
- #else // defined(BOOST_ASIO_HAS_DEDUCED_QUERY_STATIC_CONSTEXPR_MEMBER_TRAIT)
- typedef T type;
- #endif // defined(BOOST_ASIO_HAS_DEDUCED_QUERY_STATIC_CONSTEXPR_MEMBER_TRAIT)
- };
- template <typename T>
- struct query_member :
- traits::query_member<typename proxy<T>::type, bulk_guarantee_t> {};
- template <typename T>
- struct query_static_constexpr_member :
- traits::query_static_constexpr_member<
- typename static_proxy<T>::type, bulk_guarantee_t> {};
- #if defined(BOOST_ASIO_HAS_DEDUCED_STATIC_QUERY_TRAIT) \
- && defined(BOOST_ASIO_HAS_SFINAE_VARIABLE_TEMPLATES)
- template <typename T>
- static BOOST_ASIO_CONSTEXPR
- typename query_static_constexpr_member<T>::result_type
- static_query()
- BOOST_ASIO_NOEXCEPT_IF((
- query_static_constexpr_member<T>::is_noexcept))
- {
- return query_static_constexpr_member<T>::value();
- }
- template <typename T>
- static BOOST_ASIO_CONSTEXPR
- typename traits::static_query<T, unsequenced_t>::result_type
- static_query(
- typename enable_if<
- !query_static_constexpr_member<T>::is_valid
- >::type* = 0,
- typename enable_if<
- !query_member<T>::is_valid
- >::type* = 0,
- typename enable_if<
- traits::static_query<T, unsequenced_t>::is_valid
- >::type* = 0) BOOST_ASIO_NOEXCEPT
- {
- return traits::static_query<T, unsequenced_t>::value();
- }
- template <typename T>
- static BOOST_ASIO_CONSTEXPR
- typename traits::static_query<T, sequenced_t>::result_type
- static_query(
- typename enable_if<
- !query_static_constexpr_member<T>::is_valid
- >::type* = 0,
- typename enable_if<
- !query_member<T>::is_valid
- >::type* = 0,
- typename enable_if<
- !traits::static_query<T, unsequenced_t>::is_valid
- >::type* = 0,
- typename enable_if<
- traits::static_query<T, sequenced_t>::is_valid
- >::type* = 0) BOOST_ASIO_NOEXCEPT
- {
- return traits::static_query<T, sequenced_t>::value();
- }
- template <typename T>
- static BOOST_ASIO_CONSTEXPR
- typename traits::static_query<T, parallel_t>::result_type
- static_query(
- typename enable_if<
- !query_static_constexpr_member<T>::is_valid
- >::type* = 0,
- typename enable_if<
- !query_member<T>::is_valid
- >::type* = 0,
- typename enable_if<
- !traits::static_query<T, unsequenced_t>::is_valid
- >::type* = 0,
- typename enable_if<
- !traits::static_query<T, sequenced_t>::is_valid
- >::type* = 0,
- typename enable_if<
- traits::static_query<T, parallel_t>::is_valid
- >::type* = 0) BOOST_ASIO_NOEXCEPT
- {
- return traits::static_query<T, parallel_t>::value();
- }
- template <typename E,
- typename T = decltype(bulk_guarantee_t::static_query<E>())>
- static BOOST_ASIO_CONSTEXPR const T static_query_v
- = bulk_guarantee_t::static_query<E>();
- #endif // defined(BOOST_ASIO_HAS_DEDUCED_STATIC_QUERY_TRAIT)
- // && defined(BOOST_ASIO_HAS_SFINAE_VARIABLE_TEMPLATES)
- friend BOOST_ASIO_CONSTEXPR bool operator==(
- const bulk_guarantee_t& a, const bulk_guarantee_t& b)
- {
- return a.value_ == b.value_;
- }
- friend BOOST_ASIO_CONSTEXPR bool operator!=(
- const bulk_guarantee_t& a, const bulk_guarantee_t& b)
- {
- return a.value_ != b.value_;
- }
- struct convertible_from_bulk_guarantee_t
- {
- BOOST_ASIO_CONSTEXPR convertible_from_bulk_guarantee_t(bulk_guarantee_t) {}
- };
- template <typename Executor>
- friend BOOST_ASIO_CONSTEXPR bulk_guarantee_t query(
- const Executor& ex, convertible_from_bulk_guarantee_t,
- typename enable_if<
- can_query<const Executor&, unsequenced_t>::value
- >::type* = 0)
- #if !defined(__clang__) // Clang crashes if noexcept is used here.
- #if defined(BOOST_ASIO_MSVC) // Visual C++ wants the type to be qualified.
- BOOST_ASIO_NOEXCEPT_IF((
- is_nothrow_query<const Executor&,
- bulk_guarantee_t<>::unsequenced_t>::value))
- #else // defined(BOOST_ASIO_MSVC)
- BOOST_ASIO_NOEXCEPT_IF((
- is_nothrow_query<const Executor&, unsequenced_t>::value))
- #endif // defined(BOOST_ASIO_MSVC)
- #endif // !defined(__clang__)
- {
- return boost::asio::query(ex, unsequenced_t());
- }
- template <typename Executor>
- friend BOOST_ASIO_CONSTEXPR bulk_guarantee_t query(
- const Executor& ex, convertible_from_bulk_guarantee_t,
- typename enable_if<
- !can_query<const Executor&, unsequenced_t>::value
- >::type* = 0,
- typename enable_if<
- can_query<const Executor&, sequenced_t>::value
- >::type* = 0)
- #if !defined(__clang__) // Clang crashes if noexcept is used here.
- #if defined(BOOST_ASIO_MSVC) // Visual C++ wants the type to be qualified.
- BOOST_ASIO_NOEXCEPT_IF((
- is_nothrow_query<const Executor&,
- bulk_guarantee_t<>::sequenced_t>::value))
- #else // defined(BOOST_ASIO_MSVC)
- BOOST_ASIO_NOEXCEPT_IF((
- is_nothrow_query<const Executor&, sequenced_t>::value))
- #endif // defined(BOOST_ASIO_MSVC)
- #endif // !defined(__clang__)
- {
- return boost::asio::query(ex, sequenced_t());
- }
- template <typename Executor>
- friend BOOST_ASIO_CONSTEXPR bulk_guarantee_t query(
- const Executor& ex, convertible_from_bulk_guarantee_t,
- typename enable_if<
- !can_query<const Executor&, unsequenced_t>::value
- >::type* = 0,
- typename enable_if<
- !can_query<const Executor&, sequenced_t>::value
- >::type* = 0,
- typename enable_if<
- can_query<const Executor&, parallel_t>::value
- >::type* = 0)
- #if !defined(__clang__) // Clang crashes if noexcept is used here.
- #if defined(BOOST_ASIO_MSVC) // Visual C++ wants the type to be qualified.
- BOOST_ASIO_NOEXCEPT_IF((
- is_nothrow_query<const Executor&, bulk_guarantee_t<>::parallel_t>::value))
- #else // defined(BOOST_ASIO_MSVC)
- BOOST_ASIO_NOEXCEPT_IF((
- is_nothrow_query<const Executor&, parallel_t>::value))
- #endif // defined(BOOST_ASIO_MSVC)
- #endif // !defined(__clang__)
- {
- return boost::asio::query(ex, parallel_t());
- }
- BOOST_ASIO_STATIC_CONSTEXPR_DEFAULT_INIT(unsequenced_t, unsequenced);
- BOOST_ASIO_STATIC_CONSTEXPR_DEFAULT_INIT(sequenced_t, sequenced);
- BOOST_ASIO_STATIC_CONSTEXPR_DEFAULT_INIT(parallel_t, parallel);
- #if !defined(BOOST_ASIO_HAS_CONSTEXPR)
- static const bulk_guarantee_t instance;
- #endif // !defined(BOOST_ASIO_HAS_CONSTEXPR)
- private:
- int value_;
- };
- #if defined(BOOST_ASIO_HAS_DEDUCED_STATIC_QUERY_TRAIT) \
- && defined(BOOST_ASIO_HAS_SFINAE_VARIABLE_TEMPLATES)
- template <int I> template <typename E, typename T>
- const T bulk_guarantee_t<I>::static_query_v;
- #endif // defined(BOOST_ASIO_HAS_DEDUCED_STATIC_QUERY_TRAIT)
- // && defined(BOOST_ASIO_HAS_SFINAE_VARIABLE_TEMPLATES)
- #if !defined(BOOST_ASIO_HAS_CONSTEXPR)
- template <int I>
- const bulk_guarantee_t<I> bulk_guarantee_t<I>::instance;
- #endif
- template <int I>
- const typename bulk_guarantee_t<I>::unsequenced_t
- bulk_guarantee_t<I>::unsequenced;
- template <int I>
- const typename bulk_guarantee_t<I>::sequenced_t
- bulk_guarantee_t<I>::sequenced;
- template <int I>
- const typename bulk_guarantee_t<I>::parallel_t
- bulk_guarantee_t<I>::parallel;
- namespace bulk_guarantee {
- template <int I = 0>
- struct unsequenced_t
- {
- #if defined(BOOST_ASIO_HAS_VARIABLE_TEMPLATES)
- template <typename T>
- BOOST_ASIO_STATIC_CONSTEXPR(bool,
- is_applicable_property_v = (
- is_executor<T>::value
- || conditional<
- is_executor<T>::value,
- false_type,
- is_sender<T>
- >::type::value
- || conditional<
- is_executor<T>::value,
- false_type,
- is_scheduler<T>
- >::type::value));
- #endif // defined(BOOST_ASIO_HAS_VARIABLE_TEMPLATES)
- BOOST_ASIO_STATIC_CONSTEXPR(bool, is_requirable = true);
- BOOST_ASIO_STATIC_CONSTEXPR(bool, is_preferable = true);
- typedef bulk_guarantee_t<I> polymorphic_query_result_type;
- BOOST_ASIO_CONSTEXPR unsequenced_t()
- {
- }
- template <typename T>
- struct query_member :
- traits::query_member<
- typename bulk_guarantee_t<I>::template proxy<T>::type,
- unsequenced_t> {};
- template <typename T>
- struct query_static_constexpr_member :
- traits::query_static_constexpr_member<
- typename bulk_guarantee_t<I>::template static_proxy<T>::type,
- unsequenced_t> {};
- #if defined(BOOST_ASIO_HAS_DEDUCED_STATIC_QUERY_TRAIT) \
- && defined(BOOST_ASIO_HAS_SFINAE_VARIABLE_TEMPLATES)
- template <typename T>
- static BOOST_ASIO_CONSTEXPR
- typename query_static_constexpr_member<T>::result_type
- static_query()
- BOOST_ASIO_NOEXCEPT_IF((
- query_static_constexpr_member<T>::is_noexcept))
- {
- return query_static_constexpr_member<T>::value();
- }
- template <typename T>
- static BOOST_ASIO_CONSTEXPR unsequenced_t static_query(
- typename enable_if<
- !query_static_constexpr_member<T>::is_valid
- >::type* = 0,
- typename enable_if<
- !query_member<T>::is_valid
- >::type* = 0,
- typename enable_if<
- !traits::query_free<T, unsequenced_t>::is_valid
- >::type* = 0,
- typename enable_if<
- !can_query<T, sequenced_t<I> >::value
- >::type* = 0,
- typename enable_if<
- !can_query<T, parallel_t<I> >::value
- >::type* = 0) BOOST_ASIO_NOEXCEPT
- {
- return unsequenced_t();
- }
- template <typename E, typename T = decltype(unsequenced_t::static_query<E>())>
- static BOOST_ASIO_CONSTEXPR const T static_query_v
- = unsequenced_t::static_query<E>();
- #endif // defined(BOOST_ASIO_HAS_DEDUCED_STATIC_QUERY_TRAIT)
- // && defined(BOOST_ASIO_HAS_SFINAE_VARIABLE_TEMPLATES)
- static BOOST_ASIO_CONSTEXPR bulk_guarantee_t<I> value()
- {
- return unsequenced_t();
- }
- friend BOOST_ASIO_CONSTEXPR bool operator==(
- const unsequenced_t&, const unsequenced_t&)
- {
- return true;
- }
- friend BOOST_ASIO_CONSTEXPR bool operator!=(
- const unsequenced_t&, const unsequenced_t&)
- {
- return false;
- }
- friend BOOST_ASIO_CONSTEXPR bool operator==(
- const unsequenced_t&, const sequenced_t<I>&)
- {
- return false;
- }
- friend BOOST_ASIO_CONSTEXPR bool operator!=(
- const unsequenced_t&, const sequenced_t<I>&)
- {
- return true;
- }
- friend BOOST_ASIO_CONSTEXPR bool operator==(
- const unsequenced_t&, const parallel_t<I>&)
- {
- return false;
- }
- friend BOOST_ASIO_CONSTEXPR bool operator!=(
- const unsequenced_t&, const parallel_t<I>&)
- {
- return true;
- }
- };
- #if defined(BOOST_ASIO_HAS_DEDUCED_STATIC_QUERY_TRAIT) \
- && defined(BOOST_ASIO_HAS_SFINAE_VARIABLE_TEMPLATES)
- template <int I> template <typename E, typename T>
- const T unsequenced_t<I>::static_query_v;
- #endif // defined(BOOST_ASIO_HAS_DEDUCED_STATIC_QUERY_TRAIT)
- // && defined(BOOST_ASIO_HAS_SFINAE_VARIABLE_TEMPLATES)
- template <int I = 0>
- struct sequenced_t
- {
- #if defined(BOOST_ASIO_HAS_VARIABLE_TEMPLATES)
- template <typename T>
- BOOST_ASIO_STATIC_CONSTEXPR(bool,
- is_applicable_property_v = (
- is_executor<T>::value
- || conditional<
- is_executor<T>::value,
- false_type,
- is_sender<T>
- >::type::value
- || conditional<
- is_executor<T>::value,
- false_type,
- is_scheduler<T>
- >::type::value));
- #endif // defined(BOOST_ASIO_HAS_VARIABLE_TEMPLATES)
- BOOST_ASIO_STATIC_CONSTEXPR(bool, is_requirable = true);
- BOOST_ASIO_STATIC_CONSTEXPR(bool, is_preferable = true);
- typedef bulk_guarantee_t<I> polymorphic_query_result_type;
- BOOST_ASIO_CONSTEXPR sequenced_t()
- {
- }
- template <typename T>
- struct query_member :
- traits::query_member<
- typename bulk_guarantee_t<I>::template proxy<T>::type,
- sequenced_t> {};
- template <typename T>
- struct query_static_constexpr_member :
- traits::query_static_constexpr_member<
- typename bulk_guarantee_t<I>::template static_proxy<T>::type,
- sequenced_t> {};
- #if defined(BOOST_ASIO_HAS_DEDUCED_STATIC_QUERY_TRAIT) \
- && defined(BOOST_ASIO_HAS_SFINAE_VARIABLE_TEMPLATES)
- template <typename T>
- static BOOST_ASIO_CONSTEXPR
- typename query_static_constexpr_member<T>::result_type
- static_query()
- BOOST_ASIO_NOEXCEPT_IF((
- query_static_constexpr_member<T>::is_noexcept))
- {
- return query_static_constexpr_member<T>::value();
- }
- template <typename E, typename T = decltype(sequenced_t::static_query<E>())>
- static BOOST_ASIO_CONSTEXPR const T static_query_v
- = sequenced_t::static_query<E>();
- #endif // defined(BOOST_ASIO_HAS_DEDUCED_STATIC_QUERY_TRAIT)
- // && defined(BOOST_ASIO_HAS_SFINAE_VARIABLE_TEMPLATES)
- static BOOST_ASIO_CONSTEXPR bulk_guarantee_t<I> value()
- {
- return sequenced_t();
- }
- friend BOOST_ASIO_CONSTEXPR bool operator==(
- const sequenced_t&, const sequenced_t&)
- {
- return true;
- }
- friend BOOST_ASIO_CONSTEXPR bool operator!=(
- const sequenced_t&, const sequenced_t&)
- {
- return false;
- }
- friend BOOST_ASIO_CONSTEXPR bool operator==(
- const sequenced_t&, const unsequenced_t<I>&)
- {
- return false;
- }
- friend BOOST_ASIO_CONSTEXPR bool operator!=(
- const sequenced_t&, const unsequenced_t<I>&)
- {
- return true;
- }
- friend BOOST_ASIO_CONSTEXPR bool operator==(
- const sequenced_t&, const parallel_t<I>&)
- {
- return false;
- }
- friend BOOST_ASIO_CONSTEXPR bool operator!=(
- const sequenced_t&, const parallel_t<I>&)
- {
- return true;
- }
- };
- #if defined(BOOST_ASIO_HAS_DEDUCED_STATIC_QUERY_TRAIT) \
- && defined(BOOST_ASIO_HAS_SFINAE_VARIABLE_TEMPLATES)
- template <int I> template <typename E, typename T>
- const T sequenced_t<I>::static_query_v;
- #endif // defined(BOOST_ASIO_HAS_DEDUCED_STATIC_QUERY_TRAIT)
- // && defined(BOOST_ASIO_HAS_SFINAE_VARIABLE_TEMPLATES)
- template <int I>
- struct parallel_t
- {
- #if defined(BOOST_ASIO_HAS_VARIABLE_TEMPLATES)
- template <typename T>
- BOOST_ASIO_STATIC_CONSTEXPR(bool,
- is_applicable_property_v = (
- is_executor<T>::value
- || conditional<
- is_executor<T>::value,
- false_type,
- is_sender<T>
- >::type::value
- || conditional<
- is_executor<T>::value,
- false_type,
- is_scheduler<T>
- >::type::value));
- #endif // defined(BOOST_ASIO_HAS_VARIABLE_TEMPLATES)
- BOOST_ASIO_STATIC_CONSTEXPR(bool, is_requirable = true);
- BOOST_ASIO_STATIC_CONSTEXPR(bool, is_preferable = true);
- typedef bulk_guarantee_t<I> polymorphic_query_result_type;
- BOOST_ASIO_CONSTEXPR parallel_t()
- {
- }
- template <typename T>
- struct query_member :
- traits::query_member<
- typename bulk_guarantee_t<I>::template proxy<T>::type,
- parallel_t> {};
- template <typename T>
- struct query_static_constexpr_member :
- traits::query_static_constexpr_member<
- typename bulk_guarantee_t<I>::template static_proxy<T>::type,
- parallel_t> {};
- #if defined(BOOST_ASIO_HAS_DEDUCED_STATIC_QUERY_TRAIT) \
- && defined(BOOST_ASIO_HAS_SFINAE_VARIABLE_TEMPLATES)
- template <typename T>
- static BOOST_ASIO_CONSTEXPR
- typename query_static_constexpr_member<T>::result_type
- static_query()
- BOOST_ASIO_NOEXCEPT_IF((
- query_static_constexpr_member<T>::is_noexcept))
- {
- return query_static_constexpr_member<T>::value();
- }
- template <typename E, typename T = decltype(parallel_t::static_query<E>())>
- static BOOST_ASIO_CONSTEXPR const T static_query_v
- = parallel_t::static_query<E>();
- #endif // defined(BOOST_ASIO_HAS_DEDUCED_STATIC_QUERY_TRAIT)
- // && defined(BOOST_ASIO_HAS_SFINAE_VARIABLE_TEMPLATES)
- static BOOST_ASIO_CONSTEXPR bulk_guarantee_t<I> value()
- {
- return parallel_t();
- }
- friend BOOST_ASIO_CONSTEXPR bool operator==(
- const parallel_t&, const parallel_t&)
- {
- return true;
- }
- friend BOOST_ASIO_CONSTEXPR bool operator!=(
- const parallel_t&, const parallel_t&)
- {
- return false;
- }
- friend BOOST_ASIO_CONSTEXPR bool operator==(
- const parallel_t&, const unsequenced_t<I>&)
- {
- return false;
- }
- friend BOOST_ASIO_CONSTEXPR bool operator!=(
- const parallel_t&, const unsequenced_t<I>&)
- {
- return true;
- }
- friend BOOST_ASIO_CONSTEXPR bool operator==(
- const parallel_t&, const sequenced_t<I>&)
- {
- return false;
- }
- friend BOOST_ASIO_CONSTEXPR bool operator!=(
- const parallel_t&, const sequenced_t<I>&)
- {
- return true;
- }
- };
- #if defined(BOOST_ASIO_HAS_DEDUCED_STATIC_QUERY_TRAIT) \
- && defined(BOOST_ASIO_HAS_SFINAE_VARIABLE_TEMPLATES)
- template <int I> template <typename E, typename T>
- const T parallel_t<I>::static_query_v;
- #endif // defined(BOOST_ASIO_HAS_DEDUCED_STATIC_QUERY_TRAIT)
- // && defined(BOOST_ASIO_HAS_SFINAE_VARIABLE_TEMPLATES)
- } // namespace bulk_guarantee
- } // namespace detail
- typedef detail::bulk_guarantee_t<> bulk_guarantee_t;
- #if defined(BOOST_ASIO_HAS_CONSTEXPR) || defined(GENERATING_DOCUMENTATION)
- constexpr bulk_guarantee_t bulk_guarantee;
- #else // defined(BOOST_ASIO_HAS_CONSTEXPR) || defined(GENERATING_DOCUMENTATION)
- namespace { static const bulk_guarantee_t&
- bulk_guarantee = bulk_guarantee_t::instance; }
- #endif
- } // namespace execution
- #if !defined(BOOST_ASIO_HAS_VARIABLE_TEMPLATES)
- template <typename T>
- struct is_applicable_property<T, execution::bulk_guarantee_t>
- : integral_constant<bool,
- execution::is_executor<T>::value
- || conditional<
- execution::is_executor<T>::value,
- false_type,
- execution::is_sender<T>
- >::type::value
- || conditional<
- execution::is_executor<T>::value,
- false_type,
- execution::is_scheduler<T>
- >::type::value>
- {
- };
- template <typename T>
- struct is_applicable_property<T, execution::bulk_guarantee_t::unsequenced_t>
- : integral_constant<bool,
- execution::is_executor<T>::value
- || conditional<
- execution::is_executor<T>::value,
- false_type,
- execution::is_sender<T>
- >::type::value
- || conditional<
- execution::is_executor<T>::value,
- false_type,
- execution::is_scheduler<T>
- >::type::value>
- {
- };
- template <typename T>
- struct is_applicable_property<T, execution::bulk_guarantee_t::sequenced_t>
- : integral_constant<bool,
- execution::is_executor<T>::value
- || conditional<
- execution::is_executor<T>::value,
- false_type,
- execution::is_sender<T>
- >::type::value
- || conditional<
- execution::is_executor<T>::value,
- false_type,
- execution::is_scheduler<T>
- >::type::value>
- {
- };
- template <typename T>
- struct is_applicable_property<T, execution::bulk_guarantee_t::parallel_t>
- : integral_constant<bool,
- execution::is_executor<T>::value
- || conditional<
- execution::is_executor<T>::value,
- false_type,
- execution::is_sender<T>
- >::type::value
- || conditional<
- execution::is_executor<T>::value,
- false_type,
- execution::is_scheduler<T>
- >::type::value>
- {
- };
- #endif // !defined(BOOST_ASIO_HAS_VARIABLE_TEMPLATES)
- namespace traits {
- #if !defined(BOOST_ASIO_HAS_DEDUCED_QUERY_FREE_TRAIT)
- template <typename T>
- struct query_free_default<T, execution::bulk_guarantee_t,
- typename enable_if<
- can_query<T, execution::bulk_guarantee_t::unsequenced_t>::value
- >::type>
- {
- BOOST_ASIO_STATIC_CONSTEXPR(bool, is_valid = true);
- BOOST_ASIO_STATIC_CONSTEXPR(bool, is_noexcept =
- (is_nothrow_query<T, execution::bulk_guarantee_t::unsequenced_t>::value));
- typedef execution::bulk_guarantee_t result_type;
- };
- template <typename T>
- struct query_free_default<T, execution::bulk_guarantee_t,
- typename enable_if<
- !can_query<T, execution::bulk_guarantee_t::unsequenced_t>::value
- && can_query<T, execution::bulk_guarantee_t::sequenced_t>::value
- >::type>
- {
- BOOST_ASIO_STATIC_CONSTEXPR(bool, is_valid = true);
- BOOST_ASIO_STATIC_CONSTEXPR(bool, is_noexcept =
- (is_nothrow_query<T, execution::bulk_guarantee_t::sequenced_t>::value));
- typedef execution::bulk_guarantee_t result_type;
- };
- template <typename T>
- struct query_free_default<T, execution::bulk_guarantee_t,
- typename enable_if<
- !can_query<T, execution::bulk_guarantee_t::unsequenced_t>::value
- && !can_query<T, execution::bulk_guarantee_t::sequenced_t>::value
- && can_query<T, execution::bulk_guarantee_t::parallel_t>::value
- >::type>
- {
- BOOST_ASIO_STATIC_CONSTEXPR(bool, is_valid = true);
- BOOST_ASIO_STATIC_CONSTEXPR(bool, is_noexcept =
- (is_nothrow_query<T, execution::bulk_guarantee_t::parallel_t>::value));
- typedef execution::bulk_guarantee_t result_type;
- };
- #endif // !defined(BOOST_ASIO_HAS_DEDUCED_QUERY_FREE_TRAIT)
- #if !defined(BOOST_ASIO_HAS_DEDUCED_STATIC_QUERY_TRAIT) \
- || !defined(BOOST_ASIO_HAS_SFINAE_VARIABLE_TEMPLATES)
- template <typename T>
- struct static_query<T, execution::bulk_guarantee_t,
- typename enable_if<
- execution::detail::bulk_guarantee_t<0>::
- query_static_constexpr_member<T>::is_valid
- >::type>
- {
- BOOST_ASIO_STATIC_CONSTEXPR(bool, is_valid = true);
- BOOST_ASIO_STATIC_CONSTEXPR(bool, is_noexcept = true);
- typedef typename execution::detail::bulk_guarantee_t<0>::
- query_static_constexpr_member<T>::result_type result_type;
- static BOOST_ASIO_CONSTEXPR result_type value()
- {
- return execution::detail::bulk_guarantee_t<0>::
- query_static_constexpr_member<T>::value();
- }
- };
- template <typename T>
- struct static_query<T, execution::bulk_guarantee_t,
- typename enable_if<
- !execution::detail::bulk_guarantee_t<0>::
- query_static_constexpr_member<T>::is_valid
- && !execution::detail::bulk_guarantee_t<0>::
- query_member<T>::is_valid
- && traits::static_query<T,
- execution::bulk_guarantee_t::unsequenced_t>::is_valid
- >::type>
- {
- BOOST_ASIO_STATIC_CONSTEXPR(bool, is_valid = true);
- BOOST_ASIO_STATIC_CONSTEXPR(bool, is_noexcept = true);
- typedef typename traits::static_query<T,
- execution::bulk_guarantee_t::unsequenced_t>::result_type result_type;
- static BOOST_ASIO_CONSTEXPR result_type value()
- {
- return traits::static_query<T,
- execution::bulk_guarantee_t::unsequenced_t>::value();
- }
- };
- template <typename T>
- struct static_query<T, execution::bulk_guarantee_t,
- typename enable_if<
- !execution::detail::bulk_guarantee_t<0>::
- query_static_constexpr_member<T>::is_valid
- && !execution::detail::bulk_guarantee_t<0>::
- query_member<T>::is_valid
- && !traits::static_query<T,
- execution::bulk_guarantee_t::unsequenced_t>::is_valid
- && traits::static_query<T,
- execution::bulk_guarantee_t::sequenced_t>::is_valid
- >::type>
- {
- BOOST_ASIO_STATIC_CONSTEXPR(bool, is_valid = true);
- BOOST_ASIO_STATIC_CONSTEXPR(bool, is_noexcept = true);
- typedef typename traits::static_query<T,
- execution::bulk_guarantee_t::sequenced_t>::result_type result_type;
- static BOOST_ASIO_CONSTEXPR result_type value()
- {
- return traits::static_query<T,
- execution::bulk_guarantee_t::sequenced_t>::value();
- }
- };
- template <typename T>
- struct static_query<T, execution::bulk_guarantee_t,
- typename enable_if<
- !execution::detail::bulk_guarantee_t<0>::
- query_static_constexpr_member<T>::is_valid
- && !execution::detail::bulk_guarantee_t<0>::
- query_member<T>::is_valid
- && !traits::static_query<T,
- execution::bulk_guarantee_t::unsequenced_t>::is_valid
- && !traits::static_query<T,
- execution::bulk_guarantee_t::sequenced_t>::is_valid
- && traits::static_query<T,
- execution::bulk_guarantee_t::parallel_t>::is_valid
- >::type>
- {
- BOOST_ASIO_STATIC_CONSTEXPR(bool, is_valid = true);
- BOOST_ASIO_STATIC_CONSTEXPR(bool, is_noexcept = true);
- typedef typename traits::static_query<T,
- execution::bulk_guarantee_t::parallel_t>::result_type result_type;
- static BOOST_ASIO_CONSTEXPR result_type value()
- {
- return traits::static_query<T,
- execution::bulk_guarantee_t::parallel_t>::value();
- }
- };
- template <typename T>
- struct static_query<T, execution::bulk_guarantee_t::unsequenced_t,
- typename enable_if<
- execution::detail::bulk_guarantee::unsequenced_t<0>::
- query_static_constexpr_member<T>::is_valid
- >::type>
- {
- BOOST_ASIO_STATIC_CONSTEXPR(bool, is_valid = true);
- BOOST_ASIO_STATIC_CONSTEXPR(bool, is_noexcept = true);
- typedef typename execution::detail::bulk_guarantee::unsequenced_t<0>::
- query_static_constexpr_member<T>::result_type result_type;
- static BOOST_ASIO_CONSTEXPR result_type value()
- {
- return execution::detail::bulk_guarantee::unsequenced_t<0>::
- query_static_constexpr_member<T>::value();
- }
- };
- template <typename T>
- struct static_query<T, execution::bulk_guarantee_t::unsequenced_t,
- typename enable_if<
- !execution::detail::bulk_guarantee::unsequenced_t<0>::
- query_static_constexpr_member<T>::is_valid
- && !execution::detail::bulk_guarantee::unsequenced_t<0>::
- query_member<T>::is_valid
- && !traits::query_free<T,
- execution::bulk_guarantee_t::unsequenced_t>::is_valid
- && !can_query<T, execution::bulk_guarantee_t::sequenced_t>::value
- && !can_query<T, execution::bulk_guarantee_t::parallel_t>::value
- >::type>
- {
- BOOST_ASIO_STATIC_CONSTEXPR(bool, is_valid = true);
- BOOST_ASIO_STATIC_CONSTEXPR(bool, is_noexcept = true);
- typedef execution::bulk_guarantee_t::unsequenced_t result_type;
- static BOOST_ASIO_CONSTEXPR result_type value()
- {
- return result_type();
- }
- };
- template <typename T>
- struct static_query<T, execution::bulk_guarantee_t::sequenced_t,
- typename enable_if<
- execution::detail::bulk_guarantee::sequenced_t<0>::
- query_static_constexpr_member<T>::is_valid
- >::type>
- {
- BOOST_ASIO_STATIC_CONSTEXPR(bool, is_valid = true);
- BOOST_ASIO_STATIC_CONSTEXPR(bool, is_noexcept = true);
- typedef typename execution::detail::bulk_guarantee::sequenced_t<0>::
- query_static_constexpr_member<T>::result_type result_type;
- static BOOST_ASIO_CONSTEXPR result_type value()
- {
- return execution::detail::bulk_guarantee::sequenced_t<0>::
- query_static_constexpr_member<T>::value();
- }
- };
- template <typename T>
- struct static_query<T, execution::bulk_guarantee_t::parallel_t,
- typename enable_if<
- execution::detail::bulk_guarantee::parallel_t<0>::
- query_static_constexpr_member<T>::is_valid
- >::type>
- {
- BOOST_ASIO_STATIC_CONSTEXPR(bool, is_valid = true);
- BOOST_ASIO_STATIC_CONSTEXPR(bool, is_noexcept = true);
- typedef typename execution::detail::bulk_guarantee::parallel_t<0>::
- query_static_constexpr_member<T>::result_type result_type;
- static BOOST_ASIO_CONSTEXPR result_type value()
- {
- return execution::detail::bulk_guarantee::parallel_t<0>::
- query_static_constexpr_member<T>::value();
- }
- };
- #endif // !defined(BOOST_ASIO_HAS_DEDUCED_STATIC_QUERY_TRAIT)
- // || !defined(BOOST_ASIO_HAS_SFINAE_VARIABLE_TEMPLATES)
- #if !defined(BOOST_ASIO_HAS_DEDUCED_STATIC_REQUIRE_TRAIT)
- template <typename T>
- struct static_require<T, execution::bulk_guarantee_t::unsequenced_t,
- typename enable_if<
- static_query<T, execution::bulk_guarantee_t::unsequenced_t>::is_valid
- >::type>
- {
- BOOST_ASIO_STATIC_CONSTEXPR(bool, is_valid =
- (is_same<typename static_query<T,
- execution::bulk_guarantee_t::unsequenced_t>::result_type,
- execution::bulk_guarantee_t::unsequenced_t>::value));
- };
- template <typename T>
- struct static_require<T, execution::bulk_guarantee_t::sequenced_t,
- typename enable_if<
- static_query<T, execution::bulk_guarantee_t::sequenced_t>::is_valid
- >::type>
- {
- BOOST_ASIO_STATIC_CONSTEXPR(bool, is_valid =
- (is_same<typename static_query<T,
- execution::bulk_guarantee_t::sequenced_t>::result_type,
- execution::bulk_guarantee_t::sequenced_t>::value));
- };
- template <typename T>
- struct static_require<T, execution::bulk_guarantee_t::parallel_t,
- typename enable_if<
- static_query<T, execution::bulk_guarantee_t::parallel_t>::is_valid
- >::type>
- {
- BOOST_ASIO_STATIC_CONSTEXPR(bool, is_valid =
- (is_same<typename static_query<T,
- execution::bulk_guarantee_t::parallel_t>::result_type,
- execution::bulk_guarantee_t::parallel_t>::value));
- };
- #endif // !defined(BOOST_ASIO_HAS_DEDUCED_STATIC_REQUIRE_TRAIT)
- } // namespace traits
- #endif // defined(GENERATING_DOCUMENTATION)
- } // namespace asio
- } // namespace boost
- #include <boost/asio/detail/pop_options.hpp>
- #endif // BOOST_ASIO_EXECUTION_BULK_GUARANTEE_HPP
|