iox::popo::BaseServer🔗

The BaseServer class contains the common implementation for the different server. More...

#include <iceoryx_posh/internal/popo/base_server.hpp>

Inherited by iox::popo::ServerImpl< Req, Res, BaseServerT >, iox::popo::UntypedServerImpl< BaseServerT >

Protected Types🔗

	Name
using BaseServer< PortT, TriggerHandleT >	SelfType
using PortT	PortType

Public Functions🔗

	Name
virtual	~BaseServer()
	BaseServer(const BaseServer & other)
BaseServer &	operator=(const BaseServer & )
	BaseServer(BaseServer && rhs)
BaseServer &	operator=(BaseServer && rhs)
uid_t	getUid() const Get the UID of the server.
const capro::ServiceDescription &	getServiceDescription() const Get the service description of the server.
void	offer() Offer the service to be connected to when not already offering, otherwise nothing.
void	stopOffer() Stop offering the service when already offering, otherwise nothing.
bool	isOffered() const Check if the server is offering.
bool	hasClients() const Check if the server has clients.
bool	hasRequests() const Check if requests are available.
bool	hasMissedRequests() Check if requests has been missed since the last call of this method.
void	releaseQueuedRequests() Releases any unread queued requests.

Protected Functions🔗

	Name
	BaseServer(const capro::ServiceDescription & service, const ServerOptions & serverOptions)
void	invalidateTrigger(const uint64_t uniqueTriggerId) Only usable by the WaitSet/Listener, not for public use. Invalidates the internal triggerHandle.
void	enableState(TriggerHandleT && triggerHandle, const ServerState serverState) Only usable by the WaitSet/Listener, not for public use. Attaches the triggerHandle to the internal trigger.
WaitSetIsConditionSatisfiedCallback	getCallbackForIsStateConditionSatisfied(const ServerState serverState) const Only usable by the WaitSet/Listener, not for public use. Returns method pointer to the event corresponding hasTriggered method callback.
void	disableState(const ServerState serverState) Only usable by the WaitSet/Listener, not for public use. Resets the internal triggerHandle.
void	enableEvent(TriggerHandleT && triggerHandle, const ServerEvent serverEvent) Only usable by the WaitSet/Listener, not for public use. Attaches the triggerHandle to the internal trigger.
void	disableEvent(const ServerEvent serverEvent) Only usable by the WaitSet/Listener, not for public use. Resets the internal triggerHandle.
const PortT &	port() const port
PortT &	port() port

Protected Attributes🔗

	Name
PortT	m_port
TriggerHandleT	m_trigger

Friends🔗

	Name
class	NotificationAttorney

Detailed Description🔗

template <typename PortT  =ServerPortUser,
typename TriggerHandleT  =TriggerHandle>
class iox::popo::BaseServer;

The BaseServer class contains the common implementation for the different server.

Parameters:

PortT type of the underlying port, required for testing specializations.
TriggerHandleT type of the underlying trigger handle, required for testing

Note: Not intended for public usage! Use the [Server](/v2.0.1/API-reference/posh/Classes/classiox_1_1popo_1_1Server/) or [UntypedServer](/v2.0.1/API-reference/posh/Classes/classiox_1_1popo_1_1UntypedServer/) instead!

Protected Types Documentation🔗

using SelfType🔗

using iox::popo::BaseServer< PortT, TriggerHandleT >::SelfType =  BaseServer<PortT, TriggerHandleT>;

using PortType🔗

using iox::popo::BaseServer< PortT, TriggerHandleT >::PortType =  PortT;

Public Functions Documentation🔗

function ~BaseServer🔗

virtual ~BaseServer()

function BaseServer🔗

BaseServer(
    const BaseServer & other
)

function operator=🔗

BaseServer & operator=(
    const BaseServer & 
)

function BaseServer🔗

BaseServer(
    BaseServer && rhs
)

function operator=🔗

BaseServer & operator=(
    BaseServer && rhs
)

function getUid🔗

uid_t getUid() const

Get the UID of the server.

Return: The server's UID.

function getServiceDescription🔗

const capro::ServiceDescription & getServiceDescription() const

Get the service description of the server.

Return: A reference to the service description.

function offer🔗

void offer()

Offer the service to be connected to when not already offering, otherwise nothing.

function stopOffer🔗

void stopOffer()

Stop offering the service when already offering, otherwise nothing.

function isOffered🔗

bool isOffered() const

Check if the server is offering.

Return: True if service is currently being offered.

function hasClients🔗

bool hasClients() const

Check if the server has clients.

Return: True if currently has subscribers to the service.

function hasRequests🔗

bool hasRequests() const

Check if requests are available.

Return: True if requests are available.

function hasMissedRequests🔗

bool hasMissedRequests()

Check if requests has been missed since the last call of this method.

Return: True if requests has been missed.

Requests may be missed due to overflowing receive queue.

function releaseQueuedRequests🔗

void releaseQueuedRequests()

Releases any unread queued requests.

Protected Functions Documentation🔗

function BaseServer🔗

BaseServer(
    const capro::ServiceDescription & service,
    const ServerOptions & serverOptions
)

function invalidateTrigger🔗

void invalidateTrigger(
    const uint64_t uniqueTriggerId
)

Only usable by the WaitSet/Listener, not for public use. Invalidates the internal triggerHandle.

Parameters:

uniqueTriggerId the id of the corresponding trigger

function enableState🔗

void enableState(
    TriggerHandleT && triggerHandle,
    const ServerState serverState
)

Only usable by the WaitSet/Listener, not for public use. Attaches the triggerHandle to the internal trigger.

Parameters:

triggerHandle rvalue reference to the triggerHandle. This class takes the ownership of that handle.
serverState the state which should be attached

function getCallbackForIsStateConditionSatisfied🔗

WaitSetIsConditionSatisfiedCallback getCallbackForIsStateConditionSatisfied(
    const ServerState serverState
) const

Only usable by the WaitSet/Listener, not for public use. Returns method pointer to the event corresponding hasTriggered method callback.

Parameters:

serverState the state to which the hasTriggeredCallback is required

function disableState🔗

void disableState(
    const ServerState serverState
)

Only usable by the WaitSet/Listener, not for public use. Resets the internal triggerHandle.

Parameters:

serverState the state which should be detached

function enableEvent🔗

void enableEvent(
    TriggerHandleT && triggerHandle,
    const ServerEvent serverEvent
)

Only usable by the WaitSet/Listener, not for public use. Attaches the triggerHandle to the internal trigger.

Parameters:

triggerHandle rvalue reference to the triggerHandle. This class takes the ownership of that handle.
serverEvent the event which should be attached

function disableEvent🔗

void disableEvent(
    const ServerEvent serverEvent
)

Only usable by the WaitSet/Listener, not for public use. Resets the internal triggerHandle.

Parameters:

serverEvent the event which should be detached

function port🔗

const PortT & port() const

port

Return: const accessor of the underlying port

function port🔗

PortT & port()

port

Return: accessor of the underlying port

Protected Attributes Documentation🔗

variable m_port🔗

PortT m_port;

variable m_trigger🔗

TriggerHandleT m_trigger;

Friends🔗

friend NotificationAttorney🔗

friend class NotificationAttorney(
    NotificationAttorney 
);

Updated on 2 April 2022 at 16:37:47 CEST