|
| UntypedServerImpl (const capro::ServiceDescription &service, const ServerOptions &serverOptions={}) noexcept |
|
| UntypedServerImpl (const UntypedServerImpl &)=delete |
|
| UntypedServerImpl (UntypedServerImpl &&)=delete |
|
UntypedServerImpl & | operator= (const UntypedServerImpl &)=delete |
|
UntypedServerImpl & | operator= (UntypedServerImpl &&)=delete |
|
cxx::expected< const void *, ServerRequestResult > | take () noexcept |
| Take the request chunk from the top of the receive queue. More...
|
|
void | releaseRequest (const void *const requestPayload) noexcept |
| Releases the ownership of the request chunk provided by the payload pointer. More...
|
|
cxx::expected< void *, AllocationError > | loan (const RequestHeader *const requestHeader, const uint32_t payloadSize, const uint32_t payloadAlignment) noexcept |
| Get a response chunk from loaned shared memory. More...
|
|
cxx::expected< ServerSendError > | send (void *const responsePayload) noexcept |
| Sends the provided memory chunk as response to the client. More...
|
|
void | releaseResponse (void *const responsePayload) noexcept |
| Releases the ownership of the response chunk provided by the payload pointer. More...
|
|
| BaseServer (const BaseServer &other)=delete |
|
BaseServer & | operator= (const BaseServer &)=delete |
|
| BaseServer (BaseServer &&rhs)=delete |
|
BaseServer & | operator= (BaseServer &&rhs)=delete |
|
uid_t | getUid () const noexcept |
| Get the UID of the server. More...
|
|
const capro::ServiceDescription & | getServiceDescription () const noexcept |
| Get the service description of the server. More...
|
|
void | offer () noexcept |
| Offer the service to be connected to when not already offering, otherwise nothing.
|
|
void | stopOffer () noexcept |
| Stop offering the service when already offering, otherwise nothing.
|
|
bool | isOffered () const noexcept |
| Check if the server is offering. More...
|
|
bool | hasClients () const noexcept |
| Check if the server has clients. More...
|
|
bool | hasRequests () const noexcept |
| Check if requests are available. More...
|
|
bool | hasMissedRequests () noexcept |
| Check if requests has been missed since the last call of this method. More...
|
|
void | releaseQueuedRequests () noexcept |
| Releases any unread queued requests.
|
|
using | SelfType = BaseServer< PortT, TriggerHandleT > |
|
using | PortType = PortT |
|
| BaseServer (const capro::ServiceDescription &service, const ServerOptions &serverOptions) noexcept |
|
void | invalidateTrigger (const uint64_t uniqueTriggerId) noexcept |
| Only usable by the WaitSet/Listener, not for public use. Invalidates the internal triggerHandle. More...
|
|
void | enableState (TriggerHandleT &&triggerHandle, const ServerState serverState) noexcept |
| Only usable by the WaitSet/Listener, not for public use. Attaches the triggerHandle to the internal trigger. More...
|
|
WaitSetIsConditionSatisfiedCallback | getCallbackForIsStateConditionSatisfied (const ServerState serverState) const noexcept |
| Only usable by the WaitSet/Listener, not for public use. Returns method pointer to the event corresponding hasTriggered method callback. More...
|
|
void | disableState (const ServerState serverState) noexcept |
| Only usable by the WaitSet/Listener, not for public use. Resets the internal triggerHandle. More...
|
|
void | enableEvent (TriggerHandleT &&triggerHandle, const ServerEvent serverEvent) noexcept |
| Only usable by the WaitSet/Listener, not for public use. Attaches the triggerHandle to the internal trigger. More...
|
|
void | disableEvent (const ServerEvent serverEvent) noexcept |
| Only usable by the WaitSet/Listener, not for public use. Resets the internal triggerHandle. More...
|
|
const PortT & | port () const noexcept |
| port More...
|
|
PortT & | port () noexcept |
| port More...
|
|
PortT | m_port |
|
TriggerHandleT | m_trigger |
|