addAckNakCallback(void(*callback)(const transport::AckNakEventArgs &args)) | openjaus::core::services::Transport | |
addAckNakCallback(void(*callback)(void *object, const transport::AckNakEventArgs &args), void *object) | openjaus::core::services::Transport | |
addMessageCallback(bool(CallbackClass::*callback)(MessageType &messageRef), CallbackClass *object) | openjaus::core::services::Transport | inline |
addMessageCallback(bool(CallbackClass::*callback)(model::Trigger *trigger), CallbackClass *object) | openjaus::core::services::Transport | inline |
addMessageCallback(bool(*callback)(MessageType &messageRef)) | openjaus::core::services::Transport | inline |
openjaus::broadcastGlobalEnqueue(model::Trigger *trigger)=0 | openjaus::core::TransportInterface | pure virtual |
openjaus::core::services::Transport::broadcastGlobalEnqueue(model::Trigger *trigger) | openjaus::core::services::Transport | virtual |
openjaus::broadcastLocalEnqueue(model::Trigger *trigger)=0 | openjaus::core::TransportInterface | pure virtual |
openjaus::core::services::Transport::broadcastLocalEnqueue(model::Trigger *trigger) | openjaus::core::services::Transport | virtual |
openjaus::broadcastToNode(model::Trigger *trigger)=0 | openjaus::core::TransportInterface | pure virtual |
openjaus::core::services::Transport::broadcastToNode(model::Trigger *trigger) | openjaus::core::services::Transport | virtual |
openjaus::broadcastToSubsystem(model::Trigger *trigger)=0 | openjaus::core::TransportInterface | pure virtual |
openjaus::core::services::Transport::broadcastToSubsystem(model::Trigger *trigger) | openjaus::core::services::Transport | virtual |
openjaus::broadcastToSystem(model::Trigger *trigger)=0 | openjaus::core::TransportInterface | pure virtual |
openjaus::core::services::Transport::broadcastToSystem(model::Trigger *trigger) | openjaus::core::services::Transport | virtual |
cancelEvent(CancelEvent *cancelEvent) | openjaus::core::services::Events | virtual |
cancelIncomingConnection(model::ConnectionRequestInfo &requestInfo) | openjaus::core::services::Events | private |
cancelIncomingPeriodicEvents() | openjaus::core::services::Events | private |
cancelOutgoingPeriodicEvents() | openjaus::core::services::Events | private |
openjaus::checkTransportPolicy(model::Trigger *trigger)=0 | openjaus::core::TransportInterface | pure virtual |
openjaus::core::services::Transport::checkTransportPolicy(model::Trigger *trigger) | openjaus::core::services::Transport | virtual |
configure(EventsSettingsInterface *settings) | openjaus::core::services::Events | protected |
openjaus::core::services::Transport::configure(services::TransportSettingsInterface *settings) | openjaus::core::services::Transport | protected |
configureEventsService() | openjaus::core::services::Events | private |
confirmEvent(ConfirmEventRequest *confirmEventRequest) | openjaus::core::services::Events | virtual |
create() | openjaus::core::services::Events | static |
createEvent(CreateEvent *createEvent) | openjaus::core::services::Events | virtual |
createIncomingConnection(model::ConnectionRequestInfo &requestInfo, core::ConfirmEventRequest *confirmEventRequest) | openjaus::core::services::Events | private |
createOutgoingOnChangeEvent(uint8_t eventId, model::Message *query) | openjaus::core::services::Events | |
createOutgoingPeriodicEvent(uint8_t eventId, double rateHz, model::Message *query) | openjaus::core::services::Events | |
deleteConnectionRequest(model::Connection *connection) | openjaus::core::services::Events | private |
deleteIncomingConnection(model::Connection *connection) | openjaus::core::services::Events | private |
deleteOutgoingPeriodicTimers() | openjaus::core::services::Events | private |
deletePendingRequest(model::Connection *connection) | openjaus::core::services::Events | private |
openjaus::enqueue(model::Trigger *trigger)=0 | openjaus::core::TransportInterface | pure virtual |
openjaus::core::services::Transport::enqueue(model::Trigger *trigger) | openjaus::core::services::Transport | virtual |
errorString | openjaus::core::services::Events | private |
eventExists(CreateEvent *createEvent) | openjaus::core::services::Events | virtual |
eventExists(UpdateEvent *updateEvent) | openjaus::core::services::Events | virtual |
eventExists(CancelEvent *cancelEvent) | openjaus::core::services::Events | virtual |
Events() | openjaus::core::services::Events | |
eventsLoop | openjaus::core::services::Events | private |
EventsService() | openjaus::core::EventsInterface | inlinestatic |
EventsUri() | openjaus::core::EventsInterface | inlinestatic |
executeConnectionCallback(model::Connection *connection, std::map< uint32_t, Events::Callback *> &callbackMap, model::EventRequestResponseType responseType) | openjaus::core::services::Events | privatestatic |
executeConnectionCallback(model::Connection *connection, std::map< uint32_t, Events::Callback *> &callbackMap, model::EventRequestResponseType responseType, std::string errorString) | openjaus::core::services::Events | privatestatic |
findEventMetadata(uint16 messageId) | openjaus::core::services::Events | private |
findSupportedPeriodicRate_Hz(uint16 queryId) | openjaus::core::services::Events | private |
fireEvent(model::InternalEvent *event) | openjaus::core::services::Transport | protected |
getAvailableRequestId() | openjaus::core::services::Events | private |
getAvailableUniqueEventId() | openjaus::core::services::Events | private |
getComponentAddress() | openjaus::core::services::Transport | protected |
getConfirmedRate_Hz(uint32 subscriptionId) | openjaus::core::services::Events | |
getConfirmEventRequest(CreateEvent *createEvent) | openjaus::core::services::Events | virtual |
getConfirmEventRequest(UpdateEvent *updateEvent) | openjaus::core::services::Events | virtual |
getConfirmEventRequest(CancelEvent *cancelEvent) | openjaus::core::services::Events | virtual |
getCurrentState() | openjaus::core::services::Transport | |
getEventId(uint32 subscriptionId) | openjaus::core::services::Events | |
getRejectEventRequest(CreateEvent *createEvent) | openjaus::core::services::Events | virtual |
getRejectEventRequest(UpdateEvent *updateEvent) | openjaus::core::services::Events | virtual |
getRejectEventRequest(CancelEvent *cancelEvent) | openjaus::core::services::Events | virtual |
getReportEvents(QueryEvents *queryEvents) | openjaus::core::services::Events | virtual |
getReportEventTimeout(QueryEventTimeout *queryEventTimeout) | openjaus::core::services::Events | virtual |
openjaus::getReportTransportPolicy(QueryTransportPolicy *queryTransportPolicy)=0 | openjaus::core::TransportInterface | pure virtual |
openjaus::core::services::Transport::getReportTransportPolicy(QueryTransportPolicy *queryTransportPolicy) | openjaus::core::services::Transport | virtual |
getRequestId(const model::Connection &connection) | openjaus::core::services::Events | private |
getSubscriptionId(int16 requestId) | openjaus::core::services::Events | private |
handleIncomingEvent(Event *event) | openjaus::core::services::Events | virtual |
handleReportEvents(ReportEvents *reportEvents) | openjaus::core::services::Events | virtual |
inConnections | openjaus::core::services::Events | private |
isActive(uint32 subscriptionId) | openjaus::core::services::Events | |
isSupported(CreateEvent *createEvent) | openjaus::core::services::Events | virtual |
isSupported(UpdateEvent *updateEvent) | openjaus::core::services::Events | virtual |
isSupported(EventTypeEnumeration::EventTypeEnum type, model::Message *query, double requestedRate_Hz) | openjaus::core::services::Events | private |
localIdCount | openjaus::core::services::Events | private |
messageIdMap | openjaus::core::services::Events | private |
mutex | openjaus::core::services::Events | private |
notifyChanged(uint16 messageId) | openjaus::core::services::Events | |
outConnections | openjaus::core::services::Events | private |
periodicQueries | openjaus::core::services::Events | private |
processEvent(ProcessEventRequest *processEventRequest) | openjaus::core::services::Events | virtual |
publish(model::Message *message) | openjaus::core::services::Events | |
publish(uint16 messageId) | openjaus::core::services::Events | |
publish(uint16 messageId, double maximumRate_Hz, model::ConnectionType type) | openjaus::core::services::Events | |
publishedEvents | openjaus::core::services::Events | private |
receive | openjaus::core::services::Transport | protected |
receivingState | openjaus::core::services::Transport | protected |
rejectEvent(RejectEventRequest *rejectEventRequest) | openjaus::core::services::Events | virtual |
rejectIncomingConnection(model::ConnectionRequestInfo &requestInfo, core::RejectEventRequest *rejectEventRequest) | openjaus::core::services::Events | private |
requestIncomingConnection(const model::Connection &connection, int16 &requestId, Events::Callback *callback) | openjaus::core::services::Events | private |
requestMap | openjaus::core::services::Events | private |
resetEventTimer(CreateEvent *createEvent) | openjaus::core::services::Events | virtual |
resetEventTimer(UpdateEvent *updateEvent) | openjaus::core::services::Events | virtual |
responseCode | openjaus::core::services::Events | private |
sendCancelEventMessage(model::Connection *connection) | openjaus::core::services::Events | private |
sendCreateEventMessage(int16 requestId, const model::Connection &connection) | openjaus::core::services::Events | private |
openjaus::sendMessage(model::Trigger *trigger)=0 | openjaus::core::TransportInterface | pure virtual |
openjaus::core::services::Transport::sendMessage(model::Trigger *trigger) | openjaus::core::services::Transport | virtual |
sendToSelf(transport::Wrapper *wrapper) | openjaus::core::services::Transport | protected |
setComponentAddress(transport::Address *address) | openjaus::core::services::Transport | protected |
setComponentInterface(transport::Interface *interface) | openjaus::core::services::Transport | protected |
setJtcpInterface(transport::AS5669::JtcpInterface *interface) | openjaus::core::services::Transport | protected |
setNodeInterface(transport::Interface *interface) | openjaus::core::services::Transport | protected |
setReceiveQueue(system::PriorityQueue *queue) | openjaus::core::services::Transport | protected |
setSubsInterface(transport::Interface *interface) | openjaus::core::services::Transport | protected |
settings | openjaus::core::services::Events | private |
startService() | openjaus::core::services::Events | protected |
stopEventTimer(CancelEvent *cancelEvent) | openjaus::core::services::Events | virtual |
stopService() | openjaus::core::services::Events | protected |
openjaus::storeTransportPolicy(ReportTransportPolicy *reportTransportPolicy)=0 | openjaus::core::TransportInterface | pure virtual |
openjaus::core::services::Transport::storeTransportPolicy(ReportTransportPolicy *reportTransportPolicy) | openjaus::core::services::Transport | virtual |
subscribeCallbackMap | openjaus::core::services::Events | private |
subscribeIncoming(model::ConnectionType type, double rate_Hz, transport::Address &address, model::Message *query, Events::Callback *callback) | openjaus::core::services::Events | private |
subscribeOnChange(transport::Address &address, model::Message *query) | openjaus::core::services::Events | |
subscribeOnChange(transport::Address &address, model::Message *query, void(*subscribeCallback)(const model::EventRequestResponseArgs &args)) | openjaus::core::services::Events | |
subscribeOnChange(transport::Address &address, model::Message *query, void(*subscribeCallback)(void *object, const model::EventRequestResponseArgs &args), void *object) | openjaus::core::services::Events | |
subscribePeriodic(transport::Address &address, model::Message *query, double rate_Hz) | openjaus::core::services::Events | |
subscribePeriodic(transport::Address &address, model::Message *query, double rate_Hz, void(*subscribeCallback)(const model::EventRequestResponseArgs &args)) | openjaus::core::services::Events | |
subscribePeriodic(transport::Address &address, model::Message *query, double rate_Hz, void(*subscribeCallback)(void *object, const model::EventRequestResponseArgs &args), void *object) | openjaus::core::services::Events | |
timerEvent(system::Timer *timer) | openjaus::core::services::Events | private |
Transport() | openjaus::core::services::Transport | |
TransportService() | openjaus::core::TransportInterface | inlinestatic |
TransportUri() | openjaus::core::TransportInterface | inlinestatic |
tryGetConnection(uint32_t eventId, model::Connection *&connection) | openjaus::core::services::Events | private |
tryGetRequestInfo(int16 requestId, model::ConnectionRequestInfo &requestInfo) | openjaus::core::services::Events | private |
unpublish(model::Message *message) | openjaus::core::services::Events | |
unpublish(uint16 messageId) | openjaus::core::services::Events | |
unsubscribe(uint32_t subscriptionId) | openjaus::core::services::Events | |
unsubscribe(uint32_t subscriptionId, void(*callback)(const model::EventRequestResponseArgs &args)) | openjaus::core::services::Events | |
unsubscribe(uint32_t subscriptionId, void(*callback)(void *object, const model::EventRequestResponseArgs &args), void *object) | openjaus::core::services::Events | |
unsubscribeCallbackMap | openjaus::core::services::Events | private |
unsubscribeIncoming(uint32_t subscriptionId, Events::Callback *callback) | openjaus::core::services::Events | private |
updateEvent(CreateEvent *createEvent) | openjaus::core::services::Events | virtual |
updateEvent(UpdateEvent *updateEvent) | openjaus::core::services::Events | virtual |
updateIncomingConnection(model::ConnectionRequestInfo &requestInfo, core::ConfirmEventRequest *confirmEventRequest) | openjaus::core::services::Events | private |
updatePeriodic(uint32 subscriptionId, double rate_Hz) | openjaus::core::services::Events | |
uri() | openjaus::core::services::Events | static |
~Events() | openjaus::core::services::Events | virtual |
~EventsInterface() | openjaus::core::EventsInterface | inlinevirtual |
~Transport() | openjaus::core::services::Transport | virtual |
~TransportInterface() | openjaus::core::TransportInterface | inlinevirtual |