![]() |
MAK RTIspy API Documentation for HLA 1.3
|
Collaboration diagram for DtNetStatsMonitor:Public Member Functions | |
| DtNetStatsMonitor (DtRtiAmbassadorImplementor *rtiAmb, DtNetStatsFedAmbWrapper *fedAmb, DtRtiAssistantLrcClient *assistantClient) | |
| virtual | ~DtNetStatsMonitor () |
| virtual void | postJoinInit (const DtFederateHandle &fedId) |
| virtual const DtTrafficStats & | getNetworkStats () const |
| virtual void | reset () |
| virtual void | printStats (bool withHeader=false) const |
| virtual void | recordSentMsgStats (const DtRtiMsg &msg, double sendTime) |
| virtual void | recordRecvdMsgStats (const DtRtiMsg &msg, double sendTime) |
| virtual void | recordApiStats (const DtRtiAmbAPIType callName, double callTime) |
| virtual void | recordFedAmbStats (const DtFedAmbAPIType callName, double callTime) |
| virtual void | addRegisteredObject (DtObjectInstanceHandle objHandle, DtObjectClassHandle theClass, const char *theObject) |
| virtual void | addDiscoveredObject (DtObjectInstanceHandle objHandle, DtObjectClassHandle theClass, const char *theObject) |
| virtual void | addSentInteraction (DtInteractionClassHandle theInteraction) |
| virtual void | addRecvdInteraction (DtInteractionClassHandle theInteraction) |
| virtual void | recordObjectStats (bool isSent, unsigned int msgKind, unsigned int msgSize, double time, const DtRtiMsg &msg) |
| virtual void | recordInteractionStats (bool isSent, unsigned int msgKind, unsigned int msgSize, double time, const DtRtiMsg &msg) |
| virtual void | changedPubSubTransOrder (DtObjectClassHandle classHandle) |
| virtual void | changedInterPubSubTransOrder (DtInteractionClassHandle classHandle) |
| virtual bool | isChanged () |
Static Public Member Functions | |
| static void | processMsg (const DtRtiMsg &msg, void *thisMonitor) |
| static void | netStatsPostTick (void *instance) |
Public Attributes | |
| bool | isJoined |
Protected Member Functions | |
| virtual void | processMsg (const DtRtiMsg &msg) |
| virtual void | netStatsPostTick () |
| virtual void | processNetStatsObserveReqMsg (const DtAssistantNetStatsObserveReqMsg &msg) |
| virtual void | gatherClassDataAndSend (DtFomClassMgr *fomMgr, DtRtiAssistantLrcClient *rtiAstntLrcClient) |
| virtual void | gatherInstanceDataAndSend (DtRtiAssistantLrcClient *rtiAstntLrcClient) |
| virtual void | createSerializedTreesAndSend () |
| virtual void | recursivelyAddObjects (MAKRti::DtList *objectClasses, MAKRti::DtU32 parentHandle, std::vector< MAKRti::DtU32 > &objectClassHandles, std::vector< MAKRti::DtU32 > &parentObjectClassHandles, std::vector< MAKRti::DtString > &objectClassNames) |
| void | recursivelyAddInteractions (MAKRti::DtList *interactionClasses, MAKRti::DtU32 parentHandle, std::vector< MAKRti::DtU32 > &interactionClassHandles, std::vector< MAKRti::DtU32 > &parentInteractionClassHandles, std::vector< MAKRti::DtString > &interactionClassNames) |
| void | sendCurrentAttributeAndParameterValues () |
| void | sendAttributeNames () |
| void | recursivelyAddAttributes (MAKRti::DtList *objectClasses, std::vector< MAKRti::DtU32 > &objectClassHandles, std::vector< MAKRti::DtU32 > &attributeHandles, std::vector< MAKRti::DtString > &attributeNames, std::vector< bool > &attributePub, std::vector< bool > &attributeSub, std::vector< DtTransportType > &attributeTransport, std::vector< DtOrderType > &attributeOrder) |
| void | recursivelyAddAttributesNames (MAKRti::DtList *objectClasses, std::vector< MAKRti::DtU32 > &objectClassHandles, std::vector< MAKRti::DtU32 > &attributeHandles, std::vector< MAKRti::DtString > &attributeNames, std::vector< MAKRti::DtU32 > &parentClassHandles, std::set< MAKRti::DtString > parentAttributeNames, MAKRti::DtU32 parentClassHandle, std::vector< MAKRti::DtU32 > &totalObjectHandles) |
| void | sendParameterNames () |
| void | recursivelyAddParametersNames (MAKRti::DtList *interactionClasses, std::vector< MAKRti::DtU32 > &interactionClassHandles, std::vector< MAKRti::DtU32 > ¶meterHandles, std::vector< MAKRti::DtString > ¶meterNames, std::vector< MAKRti::DtU32 > &parentInterHandles, std::set< MAKRti::DtString > parentParametersNames, MAKRti::DtU32 parentInterHandle, std::vector< MAKRti::DtU32 > &totalInterHandles) |
| void | sendInitAttrState () |
| void | recursivelyAddAttrInitState (MAKRti::DtList *objectClasses, std::vector< MAKRti::DtU32 > &objectClassHandles, std::vector< MAKRti::DtU32 > &attributeHandles, std::vector< bool > &attributePub, std::vector< bool > &attributeSub, std::vector< DtTransportType > &attributeTransport, std::vector< DtOrderType > &attributeOrder, std::vector< bool > &objectPub, std::vector< bool > &objectSub, std::vector< MAKRti::DtU32 > &objPubSubHandles) |
| void | recursivelyAddParamInitState (MAKRti::DtList *objectClasses, std::vector< MAKRti::DtU32 > &objectClassHandles, std::vector< MAKRti::DtU32 > &attributeHandles, std::vector< bool > &attributePub, std::vector< bool > &attributeSub, std::vector< DtTransportType > &attributeTransport, std::vector< DtOrderType > &attributeOrder, std::vector< bool > &objectPub, std::vector< bool > &objectSub, std::vector< MAKRti::DtU32 > &objPubSubHandles) |
| void | sendInitParamState () |
| void | sendAttributeParameterState () |
| void | sendAttributeState () |
| void | sendParameterState () |
Static Protected Member Functions | |
| static void | processNetStatsObserveReqMsg (const DtAssistantNetStatsObserveReqMsg &msg, void *usr) |
Protected Attributes | |
| DtFederateHandle | myFedId |
| DtRtiAmbassadorImplementor * | myRtiAmb |
| DtNetStatsFedAmbWrapper * | myFedAmbWrap |
| DtConnectionMgr * | myConnMgr |
| DtTrafficStats | myNetStats |
| bool | myChanged |
| bool | isObserved |
| bool | haveSentClassData |
| bool | isFomObserved |
| bool | haveSentInitialFomData |
| bool | haveSentInitState |
| MAKRti::DtTime | interval |
| MAKRti::DtTime | fomInterval |
| MAKRti::DtClock | intervalTimer |
| MAKRti::DtClock | fomIntervalTimer |
| DtRtiAssistantLrcClient * | myAssistantClient |
| bool | shouldSendTransport |
| bool | shouldSendOrder |
Private Member Functions | |
| DtNetStatsMonitor () | |
| DtNetStatsMonitor (const DtNetStatsMonitor &orig) | |
| DtNetStatsMonitor & | operator= (const DtNetStatsMonitor &orig) |
| MAKRti::DtString | getNameFromObject (DtObjectClassInfo *object) |
| MAKRti::DtString | getNameFromInteraction (DtInteractionClassInfo *interaction) |
| DtNetStatsMonitor::DtNetStatsMonitor | ( | DtRtiAmbassadorImplementor * | rtiAmb, |
| DtNetStatsFedAmbWrapper * | fedAmb, | ||
| DtRtiAssistantLrcClient * | assistantClient | ||
| ) |
References DtConnectionMgr::addMsgCallback(), DtFederateMgr::addPostTickCallback(), DtInvalidMsgKind, fomIntervalTimer, intervalTimer, myAssistantClient, myConnMgr, myFedAmbWrap, netStatsPostTick(), processMsg(), processNetStatsObserveReqMsg(), reset(), and DtNetStatsAsyncConnMgr::setTrafficMonitor().
|
virtual |
|
private |
|
private |
|
virtual |
References DtTrafficStats::addObject(), DtFomClassMgr::className(), DtFederateMgr::fom(), myNetStats, myRtiAmb, and theClassName.
|
virtual |
|
virtual |
References DtTrafficStats::addObject(), DtFomClassMgr::className(), DtFederateMgr::fom(), myNetStats, myRtiAmb, and theClassName.
|
virtual |
|
virtual |
References DtTrafficStats::myChangedPubSubTransOrdInteractionHandlesSet, and myNetStats.
|
virtual |
References DtTrafficStats::myChangedPubSubTransOrdObjectClassHandlesSet, and myNetStats.
|
protectedvirtual |
References getNameFromInteraction(), getNameFromObject(), DtInteractionClassInfo::handle(), DtObjectClassInfo::handle(), DtFomClassMgr::interactionRootClass(), myRtiAmb, DtFomClassMgr::numClasses(), DtFomClassMgr::numInteractions(), DtFomClassMgr::objectRootClass(), recursivelyAddInteractions(), recursivelyAddObjects(), DtInteractionClassInfo::subclasses(), and DtObjectClassInfo::subclasses().
Referenced by netStatsPostTick().
|
protectedvirtual |
References DtFomClassMgr::classByHandle(), DtInteractionClassInfo::handle(), DtObjectClassInfo::handle(), DtFomClassMgr::interactionByHandle(), DtObjectClassInfo::isUnknown(), DtInteractionClassInfo::name(), DtObjectClassInfo::name(), DtFomClassMgr::numClasses(), DtFomClassMgr::numInteractions(), and DtRtiAssistantLrcClient::sendNetStatsStringUpdate().
Referenced by netStatsPostTick().
|
protectedvirtual |
|
private |
References DtInteractionClassInfo::baseClass(), DtInteractionClassInfo::name(), and removeBaseFromName().
Referenced by createSerializedTreesAndSend(), and recursivelyAddInteractions().
|
private |
References DtObjectClassInfo::baseClass(), DtObjectClassInfo::name(), and removeBaseFromName().
Referenced by createSerializedTreesAndSend(), and recursivelyAddObjects().
|
inlinevirtual |
References myNetStats.
|
virtual |
References myChanged.
|
static |
References netStatsPostTick().
|
protectedvirtual |
References createSerializedTreesAndSend(), fomInterval, fomIntervalTimer, gatherClassDataAndSend(), gatherInstanceDataAndSend(), haveSentClassData, haveSentInitialFomData, interval, intervalTimer, isFomObserved, isJoined, isObserved, MAX_OBJECTS_PER_NETSTAT_UPDATE, DtTrafficStats::myApiDataByCallName, DtTrafficStats::myFedDataByCallName, DtTrafficStats::myInteractionData, DtTrafficStats::myMsgDataByKind, myNetStats, DtTrafficStats::myObjectData, DtTrafficStats::myObjectInstanceNamesToSend, myRtiAmb, DtTrafficStats::resetFomStats(), sendAttributeParameterState(), and sendCurrentAttributeAndParameterValues().
Referenced by DtNetStatsMonitor(), and netStatsPostTick().
|
private |
|
virtual |
References myFedId.
|
virtual |
References myNetStats, and DtTrafficStats::toDtString().
|
static |
Referenced by DtNetStatsMonitor(), and ~DtNetStatsMonitor().
|
protectedvirtual |
|
staticprotected |
Referenced by DtNetStatsMonitor().
|
protectedvirtual |
|
virtual |
References myChanged, myNetStats, and DtTrafficStats::rtiAmbCalled().
|
virtual |
References DtTrafficStats::fedAmbCalled(), myChanged, and myNetStats.
|
virtual |
References DtInteractionClassInfo::discoveredHandle(), DtFederateMgr::fom(), DtInteractionMsg::handle(), DtFomClassMgr::interactionByHandle(), DtFomClassMgr::interactionName(), DtRtiMsg::isInteractionMsgType(), DtInteractionClassInfo::isUnknown(), myNetStats, myRtiAmb, DtInteractionClassInfo::name(), and DtTrafficStats::recordInteraction().
Referenced by recordRecvdMsgStats(), and recordSentMsgStats().
|
virtual |
References DtUpdateMsg::classHandle(), DtFomClassMgr::className(), DtDeleteRoMsgKind, DtDeleteTsoMsgKind, DtRegObjMsgKind, DtFederateMgr::fom(), DtRtiMsg::isUpdateMsgType(), myNetStats, myRtiAmb, DtUpdateMsg::objHandle(), DtUpdateMsg::objName(), and DtTrafficStats::recordUpdate().
Referenced by recordRecvdMsgStats(), and recordSentMsgStats().
|
virtual |
References DtRtiMsg::federateHandle(), DtRtiMsg::msgKind(), DtTrafficStats::msgRcvd(), myChanged, myFedId, myNetStats, recordInteractionStats(), and recordObjectStats().
Referenced by DtNetStatsAsyncConnMgr::getMessage(), DtNetStatsAsyncConnMgr::processConnection(), and DtNetStatsAsyncConnMgr::processMsg().
|
virtual |
References DtRtiMsg::federateHandle(), DtRtiMsg::msgKind(), DtTrafficStats::msgSent(), myChanged, myNetStats, recordInteractionStats(), and recordObjectStats().
Referenced by DtNetStatsAsyncConnMgr::send().
|
protected |
|
protected |
References DtObjectClassInfo::attrs(), DtAttrInfo::handle(), DtObjectClassInfo::handle(), DtObjectClassInfo::isUnknown(), DtAttrInfo::name(), NULL, and DtObjectClassInfo::subclasses().
Referenced by sendAttributeNames().
|
protected |
References DtObjectClassInfo::attrs(), DtAttrInfo::handle(), DtObjectClassInfo::handle(), DtObjectClassInfo::isUnknown(), NULL, DtAttrInfo::order(), DtAttrInfo::published(), shouldSendOrder, shouldSendTransport, DtObjectClassInfo::subclasses(), DtAttrInfo::subscribed(), and DtAttrInfo::transport().
Referenced by sendInitAttrState().
|
protected |
|
protectedvirtual |
References getNameFromObject(), DtObjectClassInfo::handle(), DtObjectClassInfo::isUnknown(), NULL, and DtObjectClassInfo::subclasses().
Referenced by createSerializedTreesAndSend().
|
protected |
|
protected |
References DtParamInfo::handle(), DtInteractionClassInfo::handle(), DtInteractionClassInfo::isUnknown(), NULL, DtInteractionClassInfo::order(), DtInteractionClassInfo::params(), DtInteractionClassInfo::published(), shouldSendOrder, shouldSendTransport, DtInteractionClassInfo::subclasses(), DtInteractionClassInfo::subscribed(), and DtInteractionClassInfo::transport().
Referenced by sendInitParamState().
|
virtual |
References myNetStats, and DtTrafficStats::reset().
Referenced by DtNetStatsMonitor().
|
protected |
References DtObjectClassInfo::attrs(), DtAttrInfo::handle(), DtObjectClassInfo::handle(), myRtiAmb, DtAttrInfo::name(), DtFomClassMgr::objectRootClass(), DtAttrInfo::order(), DtAttrInfo::published(), recursivelyAddAttributesNames(), DtObjectClassInfo::subclasses(), DtAttrInfo::subscribed(), and DtAttrInfo::transport().
Referenced by sendCurrentAttributeAndParameterValues().
|
protected |
|
protected |
References DtObjectClassInfo::attrs(), DtFomClassMgr::classByHandle(), DtAssistantAttributeHandleType, DtAttrInfo::handle(), DtObjectClassInfo::handle(), DtObjectClassInfo::isUnknown(), DtTrafficStats::myChangedPubSubTransOrdObjectClassHandlesSet, myNetStats, myRtiAmb, DtAttrInfo::order(), DtAttrInfo::published(), shouldSendOrder, shouldSendTransport, DtAttrInfo::subscribed(), and DtAttrInfo::transport().
Referenced by sendAttributeParameterState().
|
protected |
References sendAttributeNames(), sendInitAttrState(), sendInitParamState(), and sendParameterNames().
Referenced by netStatsPostTick().
|
protected |
References DtObjectClassInfo::attrs(), DtAssistantAttributeHandleType, DtAttrInfo::handle(), DtObjectClassInfo::handle(), myRtiAmb, DtFomClassMgr::objectRootClass(), DtAttrInfo::order(), DtAttrInfo::published(), recursivelyAddAttrInitState(), shouldSendOrder, shouldSendTransport, DtObjectClassInfo::subclasses(), DtAttrInfo::subscribed(), and DtAttrInfo::transport().
Referenced by sendCurrentAttributeAndParameterValues().
|
protected |
References DtAssistantParameterHandleType, DtParamInfo::handle(), DtInteractionClassInfo::handle(), DtFomClassMgr::interactionRootClass(), myRtiAmb, DtInteractionClassInfo::order(), DtInteractionClassInfo::params(), DtInteractionClassInfo::published(), recursivelyAddParamInitState(), shouldSendOrder, shouldSendTransport, DtInteractionClassInfo::subclasses(), DtInteractionClassInfo::subscribed(), and DtInteractionClassInfo::transport().
Referenced by sendCurrentAttributeAndParameterValues().
|
protected |
References DtParamInfo::handle(), DtInteractionClassInfo::handle(), DtFomClassMgr::interactionRootClass(), myRtiAmb, DtParamInfo::name(), DtInteractionClassInfo::params(), recursivelyAddParametersNames(), and DtInteractionClassInfo::subclasses().
Referenced by sendCurrentAttributeAndParameterValues().
|
protected |
References DtAssistantParameterHandleType, DtParamInfo::handle(), DtInteractionClassInfo::handle(), DtFomClassMgr::interactionByHandle(), DtInteractionClassInfo::isUnknown(), DtTrafficStats::myChangedPubSubTransOrdInteractionHandlesSet, myNetStats, myRtiAmb, DtInteractionClassInfo::order(), DtInteractionClassInfo::params(), DtInteractionClassInfo::published(), shouldSendOrder, shouldSendTransport, DtInteractionClassInfo::subscribed(), and DtInteractionClassInfo::transport().
Referenced by sendAttributeParameterState().
|
protected |
Referenced by netStatsPostTick(), and processNetStatsObserveReqMsg().
|
protected |
Referenced by DtNetStatsMonitor(), and netStatsPostTick().
|
protected |
Referenced by netStatsPostTick().
|
protected |
Referenced by netStatsPostTick(), and processNetStatsObserveReqMsg().
|
protected |
Referenced by processNetStatsObserveReqMsg().
|
protected |
Referenced by netStatsPostTick(), and processNetStatsObserveReqMsg().
|
protected |
Referenced by DtNetStatsMonitor(), and netStatsPostTick().
|
protected |
Referenced by netStatsPostTick(), and processNetStatsObserveReqMsg().
| bool DtNetStatsMonitor::isJoined |
Referenced by netStatsPostTick().
|
protected |
Referenced by netStatsPostTick(), and processNetStatsObserveReqMsg().
|
protected |
Referenced by DtNetStatsMonitor().
|
protected |
Referenced by isChanged(), processMsg(), recordApiStats(), recordFedAmbStats(), recordRecvdMsgStats(), and recordSentMsgStats().
|
protected |
Referenced by DtNetStatsMonitor(), and ~DtNetStatsMonitor().
|
protected |
Referenced by DtNetStatsMonitor().
|
protected |
Referenced by postJoinInit(), processMsg(), and recordRecvdMsgStats().
|
protected |
Referenced by addDiscoveredObject(), addRecvdInteraction(), addRegisteredObject(), addSentInteraction(), changedInterPubSubTransOrder(), changedPubSubTransOrder(), gatherInstanceDataAndSend(), getNetworkStats(), netStatsPostTick(), printStats(), processMsg(), processNetStatsObserveReqMsg(), recordApiStats(), recordFedAmbStats(), recordInteractionStats(), recordObjectStats(), recordRecvdMsgStats(), recordSentMsgStats(), reset(), sendAttributeParameterState(), sendAttributeState(), and sendParameterState().
|
protected |
Referenced by addDiscoveredObject(), addRecvdInteraction(), addRegisteredObject(), addSentInteraction(), createSerializedTreesAndSend(), netStatsPostTick(), recordInteractionStats(), recordObjectStats(), sendAttributeNames(), sendAttributeState(), sendInitAttrState(), sendInitParamState(), sendParameterNames(), sendParameterState(), and ~DtNetStatsMonitor().
|
protected |
|
protected |