WsfXIO_MessageService Class Reference

Provides WsfMessages sent and received by a platform as requested by WsfXIO_MessageRequest. More...

#include <WsfXIO_MessageService.hpp>

Inheritance diagram for WsfXIO_MessageService:

Collaboration diagram for WsfXIO_MessageService:

Public Member Functions
	WsfXIO_MessageService (WsfXIO_Simulation &aXIO_Simulation)
Public Member Functions inherited from WsfXIO_Service
	WsfXIO_Service (WsfXIO_Interface *aInterfacePtr)
virtual	~WsfXIO_Service ()
WsfXIO_Subscription *	FindSubscription (WsfXIO_Connection *aConnectionPtr, int aSubscriptionId)
WsfXIO_Interface *	GetInterface () const

Protected Types
typedef std::vector< WsfXIO_Subscription * >	SubscriptionList
typedef std::map< size_t, SubscriptionList >	SubscriptionsMap
Protected Types inherited from WsfXIO_Service
using	SubscriptionMap = std::map<WsfXIO_SubscriptionId, WsfXIO_Subscription*>

Protected Member Functions
void	HandleRequest (WsfXIO_MessageRequestPkt &aPkt)
void	SubscriptionCancelled (WsfXIO_Subscription *aSubscriptionPtr) override
void	HandleReceivedMessage (double aSimTime, wsf::comm::Comm *aXmtrCommPtr, wsf::comm::Comm *aReceiverCommPtr, const WsfMessage &aMessage, wsf::comm::Result &aResult)
void	HandleTransmittedMessage (double aSimTime, wsf::comm::Comm *aXmtrCommPtr, const WsfMessage &aMessage)
void	HandleTransmitEndedMessage (double aSimTime, wsf::comm::Comm *aXmtrCommPtr, const WsfMessage &aMessage)
void	HandleTransmittedHeartbeatMessage (double aSimTime, wsf::comm::Comm *aXmtrCommPtr, const WsfMessage &aMessage)
void	HandleMessage (WsfPlatform *aPlatformPtr, const WsfMessage &aMessage, bool aIsReceived)
void	UpdateCallbacks ()
Protected Member Functions inherited from WsfXIO_Service
void	DenyRequest (WsfXIO_RequestDataPkt &aRequest)
void	HandleDisconnect (WsfXIO_Connection *aConnection)
void	AddSubscription (WsfXIO_Subscription *aSubscriptionPtr)
bool	RemoveSubscription (WsfXIO_Subscription *aSubscriptionPtr)
WsfXIO_Subscription *	CreateSubscription (WsfXIO_RequestDataPkt &aRequest)
void	HandleCancellation (WsfXIO_SubscriptionCancelPkt &aPkt)
const SubscriptionMap	GetSubscriptions () const
WsfXIO_Subscription *	FindSubscription (const WsfXIO_SubscriptionId &aSubscriptionId)
virtual void	RemovingSubscription (WsfXIO_Subscription *aSubscriptionPtr)

Protected Attributes
WsfSimulation &	mSimulation
UtCallbackHolder	mObserverCallbacks
SubscriptionsMap	mReceiveSubscribers
SubscriptionsMap	mTransmitSubscribers
Protected Attributes inherited from WsfXIO_Service
UtCallbackHolder	mCallbacks
WsfXIO_Interface *	mInterfacePtr

Detailed Description

Provides WsfMessages sent and received by a platform as requested by WsfXIO_MessageRequest.

Member Typedef Documentation

SubscriptionList

typedef std::vector<WsfXIO_Subscription*> WsfXIO_MessageService::SubscriptionList

protected

SubscriptionsMap

typedef std::map<size_t, SubscriptionList> WsfXIO_MessageService::SubscriptionsMap

protected

Constructor & Destructor Documentation

WsfXIO_MessageService()

WsfXIO_MessageService::WsfXIO_MessageService

(

WsfXIO_Simulation &

aXIO_Simulation

)

References WsfXIO_Service::GetInterface(), HandleRequest(), WsfXIO_Service::mCallbacks, mSimulation, and WsfXIO_Service::WsfXIO_Service().

Member Function Documentation

HandleMessage()

void WsfXIO_MessageService::HandleMessage ( WsfPlatform * aPlatformPtr, const WsfMessage & aMessage, bool aIsReceived )

protected

References WsfXIO_Destination::Add(), WsfXIO_MessagePkt::cRECEIVED, WsfXIO_MessagePkt::cSENT, WsfXIO_Subscription::GetConnection(), WsfPlatform::GetIndex(), WsfMessage::GetType(), WsfAssociationMessage::GetTypeId(), WsfControlMessage::GetTypeId(), WsfStatusMessage::GetTypeId(), WsfTaskAssignMessage::GetTypeId(), WsfTaskCancelMessage::GetTypeId(), WsfTaskControlMessage::GetTypeId(), WsfTaskStatusMessage::GetTypeId(), WsfTrackDropMessage::GetTypeId(), WsfTrackMessage::GetTypeId(), WsfXIO_Destination::IsEmpty(), WsfXIO_MessagePkt::mMessagePtr, WsfXIO_MessagePkt::mMessageType, WsfXIO_MessagePkt::mPlatformIndex, mReceiveSubscribers, mTransmitSubscribers, and WsfXIO_Destination::Send().

Referenced by HandleReceivedMessage(), HandleTransmitEndedMessage(), HandleTransmittedHeartbeatMessage(), and HandleTransmittedMessage().

HandleReceivedMessage()

void WsfXIO_MessageService::HandleReceivedMessage ( double aSimTime, wsf::comm::Comm * aXmtrCommPtr, wsf::comm::Comm * aReceiverCommPtr, const WsfMessage & aMessage, wsf::comm::Result & aResult )

protected

References WsfPlatformPart::GetPlatform(), and HandleMessage().

Referenced by UpdateCallbacks().

HandleRequest()

void WsfXIO_MessageService::HandleRequest ( WsfXIO_MessageRequestPkt & aPkt )

protected

References WsfXIO_Service::CreateSubscription(), WsfXIO_MessageRequestPkt::cRECEIVED_MESSAGES, WsfXIO_MessageRequestPkt::cSENT_MESSAGES, WsfXIO_MessageRequestPkt::mPlatformIndex, mReceiveSubscribers, WsfXIO_MessageRequestPkt::mRequestedMessages, mSimulation, mTransmitSubscribers, platformPtr, and UpdateCallbacks().

Referenced by WsfXIO_MessageService().

HandleTransmitEndedMessage()

void WsfXIO_MessageService::HandleTransmitEndedMessage ( double aSimTime, wsf::comm::Comm * aXmtrCommPtr, const WsfMessage & aMessage )

protected

References WsfPlatformPart::GetPlatform(), and HandleMessage().

Referenced by UpdateCallbacks().

HandleTransmittedHeartbeatMessage()

void WsfXIO_MessageService::HandleTransmittedHeartbeatMessage ( double aSimTime, wsf::comm::Comm * aXmtrCommPtr, const WsfMessage & aMessage )

protected

References WsfPlatformPart::GetPlatform(), and HandleMessage().

Referenced by UpdateCallbacks().

HandleTransmittedMessage()

void WsfXIO_MessageService::HandleTransmittedMessage ( double aSimTime, wsf::comm::Comm * aXmtrCommPtr, const WsfMessage & aMessage )

protected

References WsfPlatformPart::GetPlatform(), and HandleMessage().

Referenced by UpdateCallbacks().

SubscriptionCancelled()

void WsfXIO_MessageService::SubscriptionCancelled ( WsfXIO_Subscription * aSubscriptionPtr )

overrideprotectedvirtual

Reimplemented from WsfXIO_Service.

References mReceiveSubscribers, mTransmitSubscribers, and UpdateCallbacks().

UpdateCallbacks()

void WsfXIO_MessageService::UpdateCallbacks ( )

protected

References HandleReceivedMessage(), HandleTransmitEndedMessage(), HandleTransmittedHeartbeatMessage(), HandleTransmittedMessage(), WsfObserver::MessageReceived(), WsfObserver::MessageTransmitEnded(), WsfObserver::MessageTransmitted(), WsfObserver::MessageTransmittedHeartbeat(), mObserverCallbacks, mReceiveSubscribers, mSimulation, and mTransmitSubscribers.

Referenced by HandleRequest(), and SubscriptionCancelled().

Member Data Documentation

mObserverCallbacks

UtCallbackHolder WsfXIO_MessageService::mObserverCallbacks

protected

Referenced by UpdateCallbacks().

mReceiveSubscribers

SubscriptionsMap WsfXIO_MessageService::mReceiveSubscribers

protected

Referenced by HandleMessage(), HandleRequest(), SubscriptionCancelled(), and UpdateCallbacks().

mSimulation

WsfSimulation& WsfXIO_MessageService::mSimulation

protected

Referenced by HandleRequest(), UpdateCallbacks(), and WsfXIO_MessageService().

mTransmitSubscribers

SubscriptionsMap WsfXIO_MessageService::mTransmitSubscribers

protected

Referenced by HandleMessage(), HandleRequest(), SubscriptionCancelled(), and UpdateCallbacks().

---

The documentation for this class was generated from the following files:

• WsfXIO_MessageService.hpp
• WsfXIO_MessageService.cpp