iox::popo::WaitSet🔗
Logical disjunction of a certain number of Triggers. More...
#include <iceoryx_posh/popo/wait_set.hpp>
Public Types🔗
Name | |
---|---|
using cxx::optional< Trigger >[Capacity] | TriggerArray |
using cxx::vector< const NotificationInfo *, CAPACITY > | NotificationInfoVector |
Public Functions🔗
Name | |
---|---|
WaitSet() | |
~WaitSet() | |
WaitSet(const WaitSet & rhs) all the Trigger have a pointer pointing to this waitset for cleanup calls, therefore the WaitSet cannot be moved |
|
WaitSet(WaitSet && rhs) | |
WaitSet & | operator=(const WaitSet & rhs) |
WaitSet & | operator=(WaitSet && rhs) |
void | markForDestruction() Non-reversible call. After this call wait() and timedWait() do not block any longer and never return triggered events/states. This method can be used to manually initialize destruction and to wakeup any thread which is waiting in wait() or timedWait(). |
template <typename T ,typename EventType ,typename ContextDataType =internal::NoType_t,typename =std::enable_if_t cxx::expected< WaitSetError > |
attachEvent(T & eventOrigin, const EventType eventType, const uint64_t notificationId =0U, const NotificationCallback< T, ContextDataType > & eventCallback ={}) attaches an event of a given class to the WaitSet. |
template <typename T ,typename EventType ,typename ContextDataType =internal::NoType_t,typename =std::enable_if_t cxx::expected< WaitSetError > |
attachEvent(T & eventOrigin, const EventType eventType, const NotificationCallback< T, ContextDataType > & eventCallback) attaches an event of a given class to the WaitSet. |
template <typename T ,typename ContextDataType =internal::NoType_t> cxx::expected< WaitSetError > |
attachEvent(T & eventOrigin, const uint64_t notificationId =0U, const NotificationCallback< T, ContextDataType > & eventCallback ={}) attaches an event of a given class to the WaitSet. |
template <typename T ,typename ContextDataType =internal::NoType_t> cxx::expected< WaitSetError > |
attachEvent(T & eventOrigin, const NotificationCallback< T, ContextDataType > & eventCallback) attaches an event of a given class to the WaitSet. |
template <typename T ,typename StateType ,typename ContextDataType =internal::NoType_t,typename =std::enable_if_t cxx::expected< WaitSetError > |
attachState(T & stateOrigin, const StateType stateType, const uint64_t id =0U, const NotificationCallback< T, ContextDataType > & stateCallback ={}) attaches a state of a given class to the WaitSet. |
template <typename T ,typename StateType ,typename ContextDataType =internal::NoType_t,typename =std::enable_if_t cxx::expected< WaitSetError > |
attachState(T & stateOrigin, const StateType stateType, const NotificationCallback< T, ContextDataType > & stateCallback) attaches a state of a given class to the WaitSet. |
template <typename T ,typename ContextDataType =internal::NoType_t> cxx::expected< WaitSetError > |
attachState(T & stateOrigin, const uint64_t id =0U, const NotificationCallback< T, ContextDataType > & stateCallback ={}) attaches a state of a given class to the WaitSet. |
template <typename T ,typename ContextDataType =internal::NoType_t> cxx::expected< WaitSetError > |
attachState(T & stateOrigin, const NotificationCallback< T, ContextDataType > & stateCallback) attaches a state of a given class to the WaitSet. |
template <typename T ,typename... Targs> void |
detachEvent(T & eventOrigin, const Targs &... args) detaches an event from the WaitSet |
template <typename T ,typename... Targs> void |
detachState(T & stateOrigin, const Targs &... args) detaches a state based trigger from the WaitSet |
NotificationInfoVector | timedWait(const units::Duration timeout) Blocking wait with time limit till one or more of the triggers are triggered. |
NotificationInfoVector | wait() Blocking wait till one or more of the triggers are triggered. |
uint64_t | size() const Returns the amount of stored Trigger inside of the WaitSet. |
constexpr uint64_t | capacity() returns the maximum amount of triggers which can be acquired from a waitset |
Protected Functions🔗
Name | |
---|---|
WaitSet(ConditionVariableData & condVarData) |
Public Attributes🔗
Name | |
---|---|
constexpr uint64_t | CAPACITY |
Detailed Description🔗
template <uint64_t Capacity =MAX_NUMBER_OF_ATTACHMENTS_PER_WAITSET>
class iox::popo::WaitSet;
Logical disjunction of a certain number of Triggers.
Parameters:
- Capacity the amount of events/states which can be attached to the waitset
The WaitSet stores Triggers and allows the user to wait till one or more of those Triggers are triggered. It works over process borders. With the creation of a WaitSet it requests a condition variable from RouDi and destroys it with the destructor. Hence the lifetime of the condition variable is bound to the lifetime of the WaitSet.
Public Types Documentation🔗
using TriggerArray🔗
using iox::popo::WaitSet< Capacity >::TriggerArray = cxx::optional<Trigger>[Capacity];
using NotificationInfoVector🔗
using iox::popo::WaitSet< Capacity >::NotificationInfoVector = cxx::vector<const NotificationInfo*, CAPACITY>;
Public Functions Documentation🔗
function WaitSet🔗
WaitSet()
function ~WaitSet🔗
~WaitSet()
function WaitSet🔗
WaitSet(
const WaitSet & rhs
)
all the Trigger have a pointer pointing to this waitset for cleanup calls, therefore the WaitSet cannot be moved
function WaitSet🔗
WaitSet(
WaitSet && rhs
)
function operator=🔗
WaitSet & operator=(
const WaitSet & rhs
)
function operator=🔗
WaitSet & operator=(
WaitSet && rhs
)
function markForDestruction🔗
void markForDestruction()
Non-reversible call. After this call wait() and timedWait() do not block any longer and never return triggered events/states. This method can be used to manually initialize destruction and to wakeup any thread which is waiting in wait() or timedWait().
function attachEvent🔗
template <typename T ,
typename EventType ,
typename ContextDataType =internal::NoType_t,
typename =std::enable_if_t<std::is_enum<EventType>::value>>
cxx::expected< WaitSetError > attachEvent(
T & eventOrigin,
const EventType eventType,
const uint64_t notificationId =0U,
const NotificationCallback< T, ContextDataType > & eventCallback ={}
)
attaches an event of a given class to the WaitSet.
Parameters:
- eventOrigin the class from which the event originates.
- eventType the event specified by the class
- notificationId an arbitrary user defined id for the event
- eventCallback a callback which should be assigned to the event
Note: attachEvent does not take ownership of callback in the underlying eventCallback or the optional contextData. The user has to ensure that both will live as long as the event is attached.
function attachEvent🔗
template <typename T ,
typename EventType ,
typename ContextDataType =internal::NoType_t,
typename =std::enable_if_t<std::is_enum<EventType>::value, void>>
cxx::expected< WaitSetError > attachEvent(
T & eventOrigin,
const EventType eventType,
const NotificationCallback< T, ContextDataType > & eventCallback
)
attaches an event of a given class to the WaitSet.
Parameters:
- eventOrigin the class from which the event originates.
- eventType the event specified by the class
- eventCallback a callback which should be assigned to the event
Note: attachEvent does not take ownership of callback in the underlying eventCallback or the optional contextData. The user has to ensure that both will live as long as the event is attached.
function attachEvent🔗
template <typename T ,
typename ContextDataType =internal::NoType_t>
cxx::expected< WaitSetError > attachEvent(
T & eventOrigin,
const uint64_t notificationId =0U,
const NotificationCallback< T, ContextDataType > & eventCallback ={}
)
attaches an event of a given class to the WaitSet.
Parameters:
- eventOrigin the class from which the event originates.
- notificationId an arbitrary user defined id for the event
- eventCallback a callback which should be assigned to the event
Note: attachEvent does not take ownership of callback in the underlying eventCallback or the optional contextData. The user has to ensure that both will live as long as the event is attached.
function attachEvent🔗
template <typename T ,
typename ContextDataType =internal::NoType_t>
cxx::expected< WaitSetError > attachEvent(
T & eventOrigin,
const NotificationCallback< T, ContextDataType > & eventCallback
)
attaches an event of a given class to the WaitSet.
Parameters:
- eventOrigin the class from which the event originates.
- eventCallback a callback which should be assigned to the event
Note: attachEvent does not take ownership of callback in the underlying eventCallback or the optional contextData. The user has to ensure that both will live as long as the event is attached.
function attachState🔗
template <typename T ,
typename StateType ,
typename ContextDataType =internal::NoType_t,
typename =std::enable_if_t<std::is_enum<StateType>::value>>
cxx::expected< WaitSetError > attachState(
T & stateOrigin,
const StateType stateType,
const uint64_t id =0U,
const NotificationCallback< T, ContextDataType > & stateCallback ={}
)
attaches a state of a given class to the WaitSet.
Parameters:
- stateOrigin the class from which the state originates.
- stateType the state specified by the class
- id an arbitrary user defined id for the state
- stateCallback a callback which should be assigned to the state
Note: attachState does not take ownership of callback in the underlying stateCallback or the optional contextData. The user has to ensure that both will live as long as the state is attached.
function attachState🔗
template <typename T ,
typename StateType ,
typename ContextDataType =internal::NoType_t,
typename =std::enable_if_t<std::is_enum<StateType>::value, void>>
cxx::expected< WaitSetError > attachState(
T & stateOrigin,
const StateType stateType,
const NotificationCallback< T, ContextDataType > & stateCallback
)
attaches a state of a given class to the WaitSet.
Parameters:
- stateOrigin the class from which the state originates.
- stateType the state specified by the class
- stateCallback a callback which should be assigned to the state
Note: attachState does not take ownership of callback in the underlying stateCallback or the optional contextData. The user has to ensure that both will live as long as the state is attached.
function attachState🔗
template <typename T ,
typename ContextDataType =internal::NoType_t>
cxx::expected< WaitSetError > attachState(
T & stateOrigin,
const uint64_t id =0U,
const NotificationCallback< T, ContextDataType > & stateCallback ={}
)
attaches a state of a given class to the WaitSet.
Parameters:
- stateOrigin the class from which the state originates.
- id an arbitrary user defined id for the state
- stateCallback a callback which should be assigned to the state
Note: attachState does not take ownership of callback in the underlying stateCallback or the optional contextData. The user has to ensure that both will live as long as the state is attached.
function attachState🔗
template <typename T ,
typename ContextDataType =internal::NoType_t>
cxx::expected< WaitSetError > attachState(
T & stateOrigin,
const NotificationCallback< T, ContextDataType > & stateCallback
)
attaches a state of a given class to the WaitSet.
Parameters:
- stateOrigin the class from which the state originates.
- stateCallback a callback which should be assigned to the state
Note: attachState does not take ownership of callback in the underlying stateCallback or the optional contextData. The user has to ensure that both will live as long as the state is attached.
function detachEvent🔗
template <typename T ,
typename... Targs>
void detachEvent(
T & eventOrigin,
const Targs &... args
)
detaches an event from the WaitSet
Parameters:
- eventOrigin the origin of the event that should be detached
- args... additional event identifying arguments
function detachState🔗
template <typename T ,
typename... Targs>
void detachState(
T & stateOrigin,
const Targs &... args
)
detaches a state based trigger from the WaitSet
Parameters:
- stateOrigin the origin of the state that should be detached
- args... additional state identifying arguments
function timedWait🔗
NotificationInfoVector timedWait(
const units::Duration timeout
)
Blocking wait with time limit till one or more of the triggers are triggered.
Parameters:
- timeout How long shall we waite for a trigger
Return: NotificationInfoVector of NotificationInfos that have been triggered
function wait🔗
NotificationInfoVector wait()
Blocking wait till one or more of the triggers are triggered.
Return: NotificationInfoVector of NotificationInfos that have been triggered
function size🔗
uint64_t size() const
Returns the amount of stored Trigger inside of the WaitSet.
function capacity🔗
static constexpr uint64_t capacity()
returns the maximum amount of triggers which can be acquired from a waitset
Protected Functions Documentation🔗
function WaitSet🔗
explicit WaitSet(
ConditionVariableData & condVarData
)
Public Attributes Documentation🔗
variable CAPACITY🔗
static constexpr uint64_t CAPACITY = Capacity;
Updated on 17 March 2022 at 12:15:57 CET