MAK RTIspy API Documentation for HLA Evolved
 All Classes Namespaces Files Functions Variables Typedefs Enumerations Enumerator Properties Friends Macros Groups Pages
List of all members | Public Types | Public Member Functions | Static Public Member Functions | Public Attributes | Protected Types | Protected Member Functions | Protected Attributes
FederateProxy Class Reference
+ Collaboration diagram for FederateProxy:

Public Types

enum  Status { Normal = 0, Terminated = 1, Disconnected = 2, InternalError = 99 }
 

Public Member Functions

 FederateProxy (DtTcpMsgSocket *msgSocket, unsigned long long sessionId)
 
virtual ~FederateProxy ()
 
bool initialize ()
 
Status status () const
 
MAKRti::DtClock const & clock () const
 
unsigned long long sessionId () const
 
bool isConnected () const
 
void setDisconnected ()
 
void reconnect (DtTcpMsgSocket *msgSocket, unsigned long lastReceived)
 
void reconnectFailed (DtTcpMsgSocket *msgSocket)
 
bool isJoined () const
 
void resignReset ()
 
void terminate (FedProSess::DtSessionTerminatedMessage::SessionStatus status)
 
int readAndProcess ()
 
int sendMessage (FedProSess::DtFedproMessage &message)
 
int sendMessage (FedProSess::DtFedproMessage *message)
 
int resendMessage (FedProSess::DtFedproMessage *message)
 
unsigned long lastRecievedMessage () const
 
unsigned long oldestSentMessage () const
 
char * enumAsString (Status status) const
 
void print ()
 
DtTcpMsgSocket * socket ()
 
rti1516_2025::RTIambassador * rtiAmb ()
 

Static Public Member Functions

static FederateProxy * create (DtTcpMsgSocket *msgSocket, unsigned long long sessionId)
 

Public Attributes

rti1516_2025::RTIambassadorFactory theRtiAmbFactory
 

Protected Types

typedef void(FederateProxy::* CallRequestFunction )(const rti1516_2025::fedpro::CallRequest &request, unsigned long sequenceNumber, rti1516_2025::fedpro::CallResponse &response)
 

Protected Member Functions

void processMessage (FedProSess::DtFedproMessage *message)
 
void processCallRequest (FedProSess::DtCallRequestMessage *message)
 
void processCallbackResponse (FedProSess::DtCallResponseMessage *message)
 
void handleMalformedRequest (rti1516_2025::fedpro::CallResponse &response, rti1516_2025::fedpro::CallRequest const &request, char const *serviceCall)
 
void handleUnrecognizedRequest (rti1516_2025::fedpro::CallResponse &response, rti1516_2025::fedpro::CallRequest const &request, char const *serviceCall)
 
void handleUnknownException (rti1516_2025::fedpro::CallResponse &response, char const *serviceCall)
 
void handleException (rti1516_2025::Exception const &ex, rti1516_2025::fedpro::CallResponse &response)
 
void sendResponse (unsigned long sequenceNumber, const rti1516_2025::fedpro::CallResponse &response)
 
void disconnect (const rti1516_2025::fedpro::CallRequest &request, unsigned long sequenceNumber, rti1516_2025::fedpro::CallResponse &response)
 
void listFederationExecutions (const rti1516_2025::fedpro::CallRequest &request, unsigned long sequenceNumber, rti1516_2025::fedpro::CallResponse &response)
 
void listFederationExecutionMembers (const rti1516_2025::fedpro::CallRequest &request, unsigned long sequenceNumber, rti1516_2025::fedpro::CallResponse &response)
 
void destroyFederationExecution (const rti1516_2025::fedpro::CallRequest &request, unsigned long sequenceNumber, rti1516_2025::fedpro::CallResponse &response)
 
void joinFederationExecution (const rti1516_2025::fedpro::CallRequest &request, unsigned long sequenceNumber, rti1516_2025::fedpro::CallResponse &response)
 Join Federation. More...
 
void resignFederationExecution (const rti1516_2025::fedpro::CallRequest &request, unsigned long sequenceNumber, rti1516_2025::fedpro::CallResponse &response)
 
void getObjectClassHandle (const rti1516_2025::fedpro::CallRequest &request, unsigned long sequenceNumber, rti1516_2025::fedpro::CallResponse &response)
 
void getAttributeHandle (const rti1516_2025::fedpro::CallRequest &request, unsigned long sequenceNumber, rti1516_2025::fedpro::CallResponse &response)
 
void publishObjectClassAttributes (const rti1516_2025::fedpro::CallRequest &request, unsigned long sequenceNumber, rti1516_2025::fedpro::CallResponse &response)
 
void subscribeObjectClassAttributes (const rti1516_2025::fedpro::CallRequest &request, unsigned long sequenceNumber, rti1516_2025::fedpro::CallResponse &response)
 
void reserveObjectName (const rti1516_2025::fedpro::CallRequest &request, unsigned long sequenceNumber, rti1516_2025::fedpro::CallResponse &response)
 
void registerObjectInstanceWithName (const rti1516_2025::fedpro::CallRequest &request, unsigned long sequenceNumber, rti1516_2025::fedpro::CallResponse &response)
 
void updateAttributeValues (const rti1516_2025::fedpro::CallRequest &request, unsigned long sequenceNumber, rti1516_2025::fedpro::CallResponse &response)
 
void deleteObjectInstance (const rti1516_2025::fedpro::CallRequest &request, unsigned long sequenceNumber, rti1516_2025::fedpro::CallResponse &response)
 
void getInteractionClassHandle (const rti1516_2025::fedpro::CallRequest &request, unsigned long sequenceNumber, rti1516_2025::fedpro::CallResponse &response)
 
void getParameterHandle (const rti1516_2025::fedpro::CallRequest &request, unsigned long sequenceNumber, rti1516_2025::fedpro::CallResponse &response)
 
void publishInteractionClass (const rti1516_2025::fedpro::CallRequest &request, unsigned long sequenceNumber, rti1516_2025::fedpro::CallResponse &response)
 
void subscribeInteractionClass (const rti1516_2025::fedpro::CallRequest &request, unsigned long sequenceNumber, rti1516_2025::fedpro::CallResponse &response)
 
void sendInteraction (const rti1516_2025::fedpro::CallRequest &request, unsigned long sequenceNumber, rti1516_2025::fedpro::CallResponse &response)
 
void bufferMessage (FedProSess::DtFedproMessage *message)
 
void clearBuffer (unsigned long lastReceived)
 
bool convertFomModule (rti1516_2025::fedpro::FomModule const &inMod, std::wstring &outMod) const
 
void convertFomModules (rti1516_2025::fedpro::FomModuleSet const &inMods, std::vector< std::wstring > &outMods) const
 
virtual
rti1516_2025::FederateHandle 		decodeFederateHandle (rti1516_2025::VariableLengthData const &encodedValue) const
 
virtual
rti1516_2025::ObjectClassHandle 		decodeObjectClassHandle (rti1516_2025::VariableLengthData const &encodedValue) const
 
virtual
rti1516_2025::InteractionClassHandle 		decodeInteractionClassHandle (rti1516_2025::VariableLengthData const &encodedValue) const
 
virtual
rti1516_2025::ObjectInstanceHandle 		decodeObjectInstanceHandle (rti1516_2025::VariableLengthData const &encodedValue) const
 
virtual
rti1516_2025::AttributeHandle 		decodeAttributeHandle (rti1516_2025::VariableLengthData const &encodedValue) const
 
virtual
rti1516_2025::ParameterHandle 		decodeParameterHandle (rti1516_2025::VariableLengthData const &encodedValue) const
 
virtual
rti1516_2025::DimensionHandle 		decodeDimensionHandle (rti1516_2025::VariableLengthData const &encodedValue) const
 
virtual
rti1516_2025::MessageRetractionHandle 		decodeMessageRetractionHandle (rti1516_2025::VariableLengthData const &encodedValue) const
 
virtual rti1516_2025::RegionHandle decodeRegionHandle (rti1516_2025::VariableLengthData const &encodedValue) const
 
void connect (const rti1516_2025::fedpro::CallRequest &request, unsigned long sequenceNumber, rti1516_2025::fedpro::CallResponse &response)
 Connect. More...
 
void connectWithCredentialsRequest (const rti1516_2025::fedpro::CallRequest &request, unsigned long sequenceNumber, rti1516_2025::fedpro::CallResponse &response)
 Connect. More...
 
void connectWithConfigurationRequest (const rti1516_2025::fedpro::CallRequest &request, unsigned long sequenceNumber, rti1516_2025::fedpro::CallResponse &response)
 Connect. More...
 
void connectWithConfigurationAndCredentialsRequest (const rti1516_2025::fedpro::CallRequest &request, unsigned long sequenceNumber, rti1516_2025::fedpro::CallResponse &response)
 Connect. More...
 
void createFederationExecution (const rti1516_2025::fedpro::CallRequest &request, unsigned long sequenceNumber, rti1516_2025::fedpro::CallResponse &response)
 Create Federation. More...
 
void createFederationExecutionWithTimeRequest (const rti1516_2025::fedpro::CallRequest &request, unsigned long sequenceNumber, rti1516_2025::fedpro::CallResponse &response)
 Create Federation. More...
 
void createFederationExecutionWithModulesRequest (const rti1516_2025::fedpro::CallRequest &request, unsigned long sequenceNumber, rti1516_2025::fedpro::CallResponse &response)
 Create Federation. More...
 
void createFederationExecutionWithModulesAndTimeRequest (const rti1516_2025::fedpro::CallRequest &request, unsigned long sequenceNumber, rti1516_2025::fedpro::CallResponse &response)
 Create Federation. More...
 
void createFederationExecutionWithMIMRequest (const rti1516_2025::fedpro::CallRequest &request, unsigned long sequenceNumber, rti1516_2025::fedpro::CallResponse &response)
 Create Federation. More...
 
void createFederationExecutionWithMIMAndTimeRequest (const rti1516_2025::fedpro::CallRequest &request, unsigned long sequenceNumber, rti1516_2025::fedpro::CallResponse &response)
 Create Federation. More...
 

Protected Attributes

DtUniquePtr
< rti1516_2025::RTIambassador > 		myRtiAmbassador
 
DtUniquePtr
< FederateAmbassadorProxy > 		myFederateAmbassador
 
std::map< int,
CallRequestFunction > 		myCallRequestFunctions
 
std::map< unsigned long,
FedProSess::DtFedproMessage * > 		myMessageBuffer
 
DtTcpMsgSocket * mySocket
 
MAKRti::DtClock myClock
 
unsigned long long mySessionId
 
unsigned long mySequenceNumber
 
unsigned long myLastReceivedMessageNumber
 
Status myStatus
 
bool myIsRtiConnected
 
rti1516_2025::FederateHandle myFederateHandle
 
std::string myJoinedFederation
 
std::string myFederateType
 
std::string myFederateName
 
FedProSess::DtHeartbeatResponseMessage myHeartbeatResponseMessage
 
rti1516_2025::VariableLengthData myVarData
 
std::vector< char > myDataBuff
 
DtUniquePtr
< rti1516_2025::LogicalTimeFactory > 		myTimeFactory
 

Member Typedef Documentation

typedef void(FederateProxy::* FederateProxy::CallRequestFunction)(const rti1516_2025::fedpro::CallRequest &request, unsigned long sequenceNumber, rti1516_2025::fedpro::CallResponse &response)
protected

Member Enumeration Documentation

enum FederateProxy::Status
Enumerator
Normal 
Terminated 
Disconnected 
InternalError 

Constructor & Destructor Documentation

FederateProxy::FederateProxy ( DtTcpMsgSocket *  msgSocket,
unsigned long long  sessionId 
)
virtual FederateProxy::~FederateProxy ( )
virtual

Member Function Documentation

void FederateProxy::bufferMessage ( FedProSess::DtFedproMessage *  message)
protected
void FederateProxy::clearBuffer ( unsigned long  lastReceived)
protected
MAKRti::DtClock const& FederateProxy::clock ( ) const
inline
void FederateProxy::connect ( const rti1516_2025::fedpro::CallRequest &  request,
unsigned long  sequenceNumber,
rti1516_2025::fedpro::CallResponse &  response 
)
protected

Connect.

void FederateProxy::connectWithConfigurationAndCredentialsRequest ( const rti1516_2025::fedpro::CallRequest &  request,
unsigned long  sequenceNumber,
rti1516_2025::fedpro::CallResponse &  response 
)
protected

Connect.

void FederateProxy::connectWithConfigurationRequest ( const rti1516_2025::fedpro::CallRequest &  request,
unsigned long  sequenceNumber,
rti1516_2025::fedpro::CallResponse &  response 
)
protected

Connect.

void FederateProxy::connectWithCredentialsRequest ( const rti1516_2025::fedpro::CallRequest &  request,
unsigned long  sequenceNumber,
rti1516_2025::fedpro::CallResponse &  response 
)
protected

Connect.

bool FederateProxy::convertFomModule ( rti1516_2025::fedpro::FomModule const &  inMod,
std::wstring &  outMod 
) const
protected
void FederateProxy::convertFomModules ( rti1516_2025::fedpro::FomModuleSet const &  inMods,
std::vector< std::wstring > &  outMods 
) const
protected
static FederateProxy* FederateProxy::create ( DtTcpMsgSocket *  msgSocket,
unsigned long long  sessionId 
)
static
void FederateProxy::createFederationExecution ( const rti1516_2025::fedpro::CallRequest &  request,
unsigned long  sequenceNumber,
rti1516_2025::fedpro::CallResponse &  response 
)
protected

Create Federation.

void FederateProxy::createFederationExecutionWithMIMAndTimeRequest ( const rti1516_2025::fedpro::CallRequest &  request,
unsigned long  sequenceNumber,
rti1516_2025::fedpro::CallResponse &  response 
)
protected

Create Federation.

void FederateProxy::createFederationExecutionWithMIMRequest ( const rti1516_2025::fedpro::CallRequest &  request,
unsigned long  sequenceNumber,
rti1516_2025::fedpro::CallResponse &  response 
)
protected

Create Federation.

void FederateProxy::createFederationExecutionWithModulesAndTimeRequest ( const rti1516_2025::fedpro::CallRequest &  request,
unsigned long  sequenceNumber,
rti1516_2025::fedpro::CallResponse &  response 
)
protected

Create Federation.

void FederateProxy::createFederationExecutionWithModulesRequest ( const rti1516_2025::fedpro::CallRequest &  request,
unsigned long  sequenceNumber,
rti1516_2025::fedpro::CallResponse &  response 
)
protected

Create Federation.

void FederateProxy::createFederationExecutionWithTimeRequest ( const rti1516_2025::fedpro::CallRequest &  request,
unsigned long  sequenceNumber,
rti1516_2025::fedpro::CallResponse &  response 
)
protected

Create Federation.

virtual rti1516_2025::AttributeHandle FederateProxy::decodeAttributeHandle ( rti1516_2025::VariableLengthData const &  encodedValue) const
protectedvirtual
virtual rti1516_2025::DimensionHandle FederateProxy::decodeDimensionHandle ( rti1516_2025::VariableLengthData const &  encodedValue) const
protectedvirtual
virtual rti1516_2025::FederateHandle FederateProxy::decodeFederateHandle ( rti1516_2025::VariableLengthData const &  encodedValue) const
protectedvirtual
virtual rti1516_2025::InteractionClassHandle FederateProxy::decodeInteractionClassHandle ( rti1516_2025::VariableLengthData const &  encodedValue) const
protectedvirtual
virtual rti1516_2025::MessageRetractionHandle FederateProxy::decodeMessageRetractionHandle ( rti1516_2025::VariableLengthData const &  encodedValue) const
protectedvirtual
virtual rti1516_2025::ObjectClassHandle FederateProxy::decodeObjectClassHandle ( rti1516_2025::VariableLengthData const &  encodedValue) const
protectedvirtual
virtual rti1516_2025::ObjectInstanceHandle FederateProxy::decodeObjectInstanceHandle ( rti1516_2025::VariableLengthData const &  encodedValue) const
protectedvirtual
virtual rti1516_2025::ParameterHandle FederateProxy::decodeParameterHandle ( rti1516_2025::VariableLengthData const &  encodedValue) const
protectedvirtual
virtual rti1516_2025::RegionHandle FederateProxy::decodeRegionHandle ( rti1516_2025::VariableLengthData const &  encodedValue) const
protectedvirtual
void FederateProxy::deleteObjectInstance ( const rti1516_2025::fedpro::CallRequest &  request,
unsigned long  sequenceNumber,
rti1516_2025::fedpro::CallResponse &  response 
)
protected
void FederateProxy::destroyFederationExecution ( const rti1516_2025::fedpro::CallRequest &  request,
unsigned long  sequenceNumber,
rti1516_2025::fedpro::CallResponse &  response 
)
protected
void FederateProxy::disconnect ( const rti1516_2025::fedpro::CallRequest &  request,
unsigned long  sequenceNumber,
rti1516_2025::fedpro::CallResponse &  response 
)
protected
char* FederateProxy::enumAsString ( Status  status) const
void FederateProxy::getAttributeHandle ( const rti1516_2025::fedpro::CallRequest &  request,
unsigned long  sequenceNumber,
rti1516_2025::fedpro::CallResponse &  response 
)
protected
void FederateProxy::getInteractionClassHandle ( const rti1516_2025::fedpro::CallRequest &  request,
unsigned long  sequenceNumber,
rti1516_2025::fedpro::CallResponse &  response 
)
protected
void FederateProxy::getObjectClassHandle ( const rti1516_2025::fedpro::CallRequest &  request,
unsigned long  sequenceNumber,
rti1516_2025::fedpro::CallResponse &  response 
)
protected
void FederateProxy::getParameterHandle ( const rti1516_2025::fedpro::CallRequest &  request,
unsigned long  sequenceNumber,
rti1516_2025::fedpro::CallResponse &  response 
)
protected
void FederateProxy::handleException ( rti1516_2025::Exception const &  ex,
rti1516_2025::fedpro::CallResponse &  response 
)
protected
void FederateProxy::handleMalformedRequest ( rti1516_2025::fedpro::CallResponse &  response,
rti1516_2025::fedpro::CallRequest const &  request,
char const *  serviceCall 
)
protected
void FederateProxy::handleUnknownException ( rti1516_2025::fedpro::CallResponse &  response,
char const *  serviceCall 
)
protected
void FederateProxy::handleUnrecognizedRequest ( rti1516_2025::fedpro::CallResponse &  response,
rti1516_2025::fedpro::CallRequest const &  request,
char const *  serviceCall 
)
protected
bool FederateProxy::initialize ( )
bool FederateProxy::isConnected ( ) const
bool FederateProxy::isJoined ( ) const
void FederateProxy::joinFederationExecution ( const rti1516_2025::fedpro::CallRequest &  request,
unsigned long  sequenceNumber,
rti1516_2025::fedpro::CallResponse &  response 
)
protected

Join Federation.

unsigned long FederateProxy::lastRecievedMessage ( ) const
inline
void FederateProxy::listFederationExecutionMembers ( const rti1516_2025::fedpro::CallRequest &  request,
unsigned long  sequenceNumber,
rti1516_2025::fedpro::CallResponse &  response 
)
protected
void FederateProxy::listFederationExecutions ( const rti1516_2025::fedpro::CallRequest &  request,
unsigned long  sequenceNumber,
rti1516_2025::fedpro::CallResponse &  response 
)
protected
unsigned long FederateProxy::oldestSentMessage ( ) const
inline
void FederateProxy::print ( )
void FederateProxy::processCallbackResponse ( FedProSess::DtCallResponseMessage *  message)
protected
void FederateProxy::processCallRequest ( FedProSess::DtCallRequestMessage *  message)
protected
void FederateProxy::processMessage ( FedProSess::DtFedproMessage *  message)
protected
void FederateProxy::publishInteractionClass ( const rti1516_2025::fedpro::CallRequest &  request,
unsigned long  sequenceNumber,
rti1516_2025::fedpro::CallResponse &  response 
)
protected
void FederateProxy::publishObjectClassAttributes ( const rti1516_2025::fedpro::CallRequest &  request,
unsigned long  sequenceNumber,
rti1516_2025::fedpro::CallResponse &  response 
)
protected
int FederateProxy::readAndProcess ( )
void FederateProxy::reconnect ( DtTcpMsgSocket *  msgSocket,
unsigned long  lastReceived 
)
void FederateProxy::reconnectFailed ( DtTcpMsgSocket *  msgSocket)
void FederateProxy::registerObjectInstanceWithName ( const rti1516_2025::fedpro::CallRequest &  request,
unsigned long  sequenceNumber,
rti1516_2025::fedpro::CallResponse &  response 
)
protected
int FederateProxy::resendMessage ( FedProSess::DtFedproMessage *  message)
void FederateProxy::reserveObjectName ( const rti1516_2025::fedpro::CallRequest &  request,
unsigned long  sequenceNumber,
rti1516_2025::fedpro::CallResponse &  response 
)
protected
void FederateProxy::resignFederationExecution ( const rti1516_2025::fedpro::CallRequest &  request,
unsigned long  sequenceNumber,
rti1516_2025::fedpro::CallResponse &  response 
)
protected
void FederateProxy::resignReset ( )
rti1516_2025::RTIambassador* FederateProxy::rtiAmb ( )
void FederateProxy::sendInteraction ( const rti1516_2025::fedpro::CallRequest &  request,
unsigned long  sequenceNumber,
rti1516_2025::fedpro::CallResponse &  response 
)
protected
int FederateProxy::sendMessage ( FedProSess::DtFedproMessage &  message)
int FederateProxy::sendMessage ( FedProSess::DtFedproMessage *  message)
void FederateProxy::sendResponse ( unsigned long  sequenceNumber,
const rti1516_2025::fedpro::CallResponse &  response 
)
protected
unsigned long long FederateProxy::sessionId ( ) const
inline
void FederateProxy::setDisconnected ( )
DtTcpMsgSocket* FederateProxy::socket ( )
inline
Status FederateProxy::status ( ) const
void FederateProxy::subscribeInteractionClass ( const rti1516_2025::fedpro::CallRequest &  request,
unsigned long  sequenceNumber,
rti1516_2025::fedpro::CallResponse &  response 
)
protected
void FederateProxy::subscribeObjectClassAttributes ( const rti1516_2025::fedpro::CallRequest &  request,
unsigned long  sequenceNumber,
rti1516_2025::fedpro::CallResponse &  response 
)
protected
void FederateProxy::terminate ( FedProSess::DtSessionTerminatedMessage::SessionStatus  status)
void FederateProxy::updateAttributeValues ( const rti1516_2025::fedpro::CallRequest &  request,
unsigned long  sequenceNumber,
rti1516_2025::fedpro::CallResponse &  response 
)
protected

Member Data Documentation

std::map<int, CallRequestFunction> FederateProxy::myCallRequestFunctions
protected
MAKRti::DtClock FederateProxy::myClock
protected
std::vector<char> FederateProxy::myDataBuff
protected
DtUniquePtr<FederateAmbassadorProxy> FederateProxy::myFederateAmbassador
protected
rti1516_2025::FederateHandle FederateProxy::myFederateHandle
protected
std::string FederateProxy::myFederateName
protected
std::string FederateProxy::myFederateType
protected
FedProSess::DtHeartbeatResponseMessage FederateProxy::myHeartbeatResponseMessage
protected
bool FederateProxy::myIsRtiConnected
protected
std::string FederateProxy::myJoinedFederation
protected
unsigned long FederateProxy::myLastReceivedMessageNumber
protected
std::map<unsigned long, FedProSess::DtFedproMessage*> FederateProxy::myMessageBuffer
protected
DtUniquePtr<rti1516_2025::RTIambassador> FederateProxy::myRtiAmbassador
protected
unsigned long FederateProxy::mySequenceNumber
protected
unsigned long long FederateProxy::mySessionId
protected
DtTcpMsgSocket* FederateProxy::mySocket
protected
Status FederateProxy::myStatus
protected
DtUniquePtr<rti1516_2025::LogicalTimeFactory> FederateProxy::myTimeFactory
protected
rti1516_2025::VariableLengthData FederateProxy::myVarData
protected
rti1516_2025::RTIambassadorFactory FederateProxy::theRtiAmbFactory
The documentation for this class was generated from the following file:
Document ID: Generated on Sun Jul 20 16:15:30 EDT 2025 from SVN revision 277985
Copyright © 2005-2025 MAK Technologies Inc. All Rights Reserved (www.mak.com)