#include <RTIambPrivateRefs.hh>
Public Member Functions | |
RTIambPrivateRefs () | |
~RTIambPrivateRefs () | |
void | processException (Message *) |
Process exception from received message. | |
void | executeService (Message *requete, Message *reponse) |
void | sendTickRequestStop () |
void | callFederateAmbassador (Message *msg) throw (RTI::RTIinternalError) |
void | leave (const char *msg) throw (RTI::RTIinternalError) |
Public Attributes | |
pid_t | pid_RTIA |
pid associated with rtia fork (private). | |
RTI::FederateAmbassador * | fed_amb |
Federate Ambassador reference for module calls. | |
bool | is_reentrant |
used to prevent reentrant calls (see tick() and executeService()). | |
RootObject * | _theRootObj |
SocketUN * | socketUn |
MessageBuffer | msgBufSend |
MessageBuffer | msgBufReceive |
Definition at line 33 of file RTIambPrivateRefs.hh.
Definition at line 36 of file RTIambPrivateRefs.cc.
References _theRootObj, fed_amb, is_reentrant, pid_RTIA, and socketUn.
~RTIambPrivateRefs | ( | ) |
void processException | ( | Message * | msg | ) |
Process exception from received message.
When a message is received from RTIA, it can contains an exception. This exception is processed by this module and a new exception is thrown.
Definition at line 140 of file RTIambPrivateRefs.cc.
References D, certi::e_ArrayIndexOutOfBounds, certi::e_AsynchronousDeliveryAlreadyDisabled, certi::e_AsynchronousDeliveryAlreadyEnabled, certi::e_AttributeAcquisitionWasNotRequested, certi::e_AttributeAlreadyBeingAcquired, certi::e_AttributeAlreadyBeingDivested, certi::e_AttributeAlreadyOwned, certi::e_AttributeDivestitureWasNotRequested, certi::e_AttributeNotDefined, certi::e_AttributeNotKnown, certi::e_AttributeNotOwned, certi::e_AttributeNotPublished, certi::e_AttributeNotSubscribed, certi::e_ConcurrentAccessAttempted, certi::e_CouldNotDiscover, certi::e_CouldNotOpenFED, certi::e_CouldNotOpenRID, certi::e_CouldNotRestore, certi::e_DeletePrivilegeNotHeld, certi::e_ErrorReadingFED, certi::e_ErrorReadingRID, certi::e_EventNotKnown, certi::e_FederateAlreadyExecutionMember, certi::e_FederateAlreadyPaused, certi::e_FederateDoesNotExist, certi::e_FederateInternalError, certi::e_FederateNameAlreadyInUse, certi::e_FederateNotExecutionMember, certi::e_FederateNotPaused, certi::e_FederateNotPublishing, certi::e_FederateNotSubscribing, certi::e_FederateOwnsAttributes, certi::e_FederatesCurrentlyJoined, certi::e_FederateWasNotAskedToReleaseAttribute, certi::e_FederationAlreadyPaused, certi::e_FederationExecutionAlreadyExists, certi::e_FederationExecutionDoesNotExist, certi::e_FederationNotPaused, certi::e_FederationTimeAlreadyPassed, certi::e_IDsupplyExhausted, certi::e_InteractionClassNotDefined, certi::e_InteractionClassNotKnown, certi::e_InteractionClassNotPublished, certi::e_InteractionParameterNotDefined, certi::e_InteractionParameterNotKnown, certi::e_InvalidDivestitureCondition, certi::e_InvalidExtents, certi::e_InvalidFederationTime, certi::e_InvalidFederationTimeDelta, certi::e_InvalidLookahead, certi::e_InvalidObjectHandle, certi::e_InvalidOrderingHandle, certi::e_InvalidResignAction, certi::e_InvalidRetractionHandle, certi::e_InvalidRoutingSpace, certi::e_InvalidTransportationHandle, certi::e_MemoryExhausted, certi::e_NameNotFound, certi::e_NO_EXCEPTION, certi::e_NoPauseRequested, certi::e_NoResumeRequested, certi::e_ObjectAlreadyRegistered, certi::e_ObjectClassNotDefined, certi::e_ObjectClassNotKnown, certi::e_ObjectClassNotPublished, certi::e_ObjectClassNotSubscribed, certi::e_ObjectNotKnown, certi::e_RegionNotKnown, certi::e_RestoreInProgress, certi::e_RestoreNotRequested, certi::e_RTIinternalError, certi::e_SaveInProgress, certi::e_SaveNotInitiated, certi::e_SecurityError, certi::e_SpaceNotDefined, certi::e_SpecifiedSaveLabelDoesNotExist, certi::e_TimeAdvanceAlreadyInProgress, certi::e_TimeAdvanceWasNotInProgress, certi::e_TooManyIDsRequested, certi::e_UnableToPerformSave, certi::e_UnimplementedService, certi::e_UnknownLabel, certi::e_ValueCountExceeded, certi::e_ValueLengthExceeded, Message::getExceptionReason(), Message::getExceptionType(), PrettyDebug::Out(), pdDebug, and pdExcept.
Referenced by RTI::RTIambassador::__tick_kernel(), and executeService().
Definition at line 61 of file RTIambPrivateRefs.cc.
References D, G, msgBufReceive, msgBufSend, PrettyDebug::Out(), pdDebug, pdGendoc, processException(), Message::receive(), Message::send(), socketUn, and Message::type.
Referenced by RTI::RTIambassador::associateRegionForUpdates(), RTI::RTIambassador::attributeOwnershipAcquisition(), RTI::RTIambassador::attributeOwnershipAcquisitionIfAvailable(), RTI::RTIambassador::attributeOwnershipReleaseResponse(), RTI::RTIambassador::cancelAttributeOwnershipAcquisition(), RTI::RTIambassador::cancelNegotiatedAttributeOwnershipDivestiture(), RTI::RTIambassador::changeAttributeOrderType(), RTI::RTIambassador::changeAttributeTransportationType(), RTI::RTIambassador::changeInteractionOrderType(), RTI::RTIambassador::changeInteractionTransportationType(), RTI::RTIambassador::createFederationExecution(), RTI::RTIambassador::createRegion(), RTI::RTIambassador::deleteObjectInstance(), RTI::RTIambassador::deleteRegion(), RTI::RTIambassador::destroyFederationExecution(), RTI::RTIambassador::disableAsynchronousDelivery(), RTI::RTIambassador::disableAttributeRelevanceAdvisorySwitch(), RTI::RTIambassador::disableAttributeScopeAdvisorySwitch(), RTI::RTIambassador::disableClassRelevanceAdvisorySwitch(), RTI::RTIambassador::disableInteractionRelevanceAdvisorySwitch(), RTI::RTIambassador::disableTimeConstrained(), RTI::RTIambassador::disableTimeRegulation(), RTI::RTIambassador::enableAsynchronousDelivery(), RTI::RTIambassador::enableAttributeRelevanceAdvisorySwitch(), RTI::RTIambassador::enableAttributeScopeAdvisorySwitch(), RTI::RTIambassador::enableClassRelevanceAdvisorySwitch(), RTI::RTIambassador::enableInteractionRelevanceAdvisorySwitch(), RTI::RTIambassador::enableTimeConstrained(), RTI::RTIambassador::enableTimeRegulation(), RTI::RTIambassador::federateRestoreComplete(), RTI::RTIambassador::federateRestoreNotComplete(), RTI::RTIambassador::federateSaveBegun(), RTI::RTIambassador::federateSaveComplete(), RTI::RTIambassador::federateSaveNotComplete(), RTI::RTIambassador::flushQueueRequest(), RTI::RTIambassador::getAttributeHandle(), RTI::RTIambassador::getAttributeName(), RTI::RTIambassador::getAttributeRoutingSpaceHandle(), RTI::RTIambassador::getDimensionHandle(), RTI::RTIambassador::getDimensionName(), RTI::RTIambassador::getInteractionClassHandle(), RTI::RTIambassador::getInteractionClassName(), RTI::RTIambassador::getInteractionRoutingSpaceHandle(), RTI::RTIambassador::getObjectClass(), RTI::RTIambassador::getObjectClassHandle(), RTI::RTIambassador::getObjectClassName(), RTI::RTIambassador::getObjectInstanceHandle(), RTI::RTIambassador::getObjectInstanceName(), RTI::RTIambassador::getOrderingHandle(), RTI::RTIambassador::getOrderingName(), RTI::RTIambassador::getParameterHandle(), RTI::RTIambassador::getParameterName(), RTI::RTIambassador::getRoutingSpaceHandle(), RTI::RTIambassador::getRoutingSpaceName(), RTI::RTIambassador::getTransportationHandle(), RTI::RTIambassador::getTransportationName(), RTI::RTIambassador::isAttributeOwnedByFederate(), RTI::RTIambassador::joinFederationExecution(), RTI::RTIambassador::localDeleteObjectInstance(), RTI::RTIambassador::modifyLookahead(), RTI::RTIambassador::negotiatedAttributeOwnershipDivestiture(), RTI::RTIambassador::nextEventRequest(), RTI::RTIambassador::nextEventRequestAvailable(), RTI::RTIambassador::notifyAboutRegionModification(), RTI::RTIambassador::publishInteractionClass(), RTI::RTIambassador::publishObjectClass(), RTI::RTIambassador::queryAttributeOwnership(), RTI::RTIambassador::queryFederateTime(), RTI::RTIambassador::queryLBTS(), RTI::RTIambassador::queryLookahead(), RTI::RTIambassador::queryMinNextEventTime(), RTI::RTIambassador::registerFederationSynchronizationPoint(), RTI::RTIambassador::registerObjectInstance(), RTI::RTIambassador::registerObjectInstanceWithRegion(), RTI::RTIambassador::requestClassAttributeValueUpdate(), RTI::RTIambassador::requestClassAttributeValueUpdateWithRegion(), RTI::RTIambassador::requestFederationRestore(), RTI::RTIambassador::requestFederationSave(), RTI::RTIambassador::requestObjectAttributeValueUpdate(), RTI::RTIambassador::resignFederationExecution(), RTI::RTIambassador::retract(), RTI::RTIambassador::sendInteraction(), RTI::RTIambassador::sendInteractionWithRegion(), RTI::RTIambassador::subscribeInteractionClass(), RTI::RTIambassador::subscribeInteractionClassWithRegion(), RTI::RTIambassador::subscribeObjectClassAttributes(), RTI::RTIambassador::subscribeObjectClassAttributesWithRegion(), RTI::RTIambassador::synchronizationPointAchieved(), RTI::RTIambassador::timeAdvanceRequest(), RTI::RTIambassador::timeAdvanceRequestAvailable(), RTI::RTIambassador::unassociateRegionForUpdates(), RTI::RTIambassador::unconditionalAttributeOwnershipDivestiture(), RTI::RTIambassador::unpublishInteractionClass(), RTI::RTIambassador::unpublishObjectClass(), RTI::RTIambassador::unsubscribeInteractionClass(), RTI::RTIambassador::unsubscribeInteractionClassWithRegion(), RTI::RTIambassador::unsubscribeObjectClass(), RTI::RTIambassador::unsubscribeObjectClassWithRegion(), RTI::RTIambassador::updateAttributeValues(), and RTI::RTIambassador::~RTIambassador().
void sendTickRequestStop | ( | ) |
Definition at line 105 of file RTIambPrivateRefs.cc.
References G, msgBufReceive, msgBufSend, PrettyDebug::Out(), pdGendoc, Message::receive(), Message::send(), socketUn, and Message::type.
Referenced by RTI::RTIambassador::__tick_kernel().
void callFederateAmbassador | ( | Message * | msg | ) | throw (RTI::RTIinternalError) |
Definition at line 588 of file RTIambPrivateRefs.cc.
References RTI::FederateAmbassador::announceSynchronizationPoint(), RTI::FederateAmbassador::attributeIsNotOwned(), RTI::FederateAmbassador::attributeOwnershipAcquisitionNotification(), RTI::FederateAmbassador::attributeOwnershipDivestitureNotification(), RTI::FederateAmbassador::attributeOwnershipUnavailable(), CATCH_FEDERATE_AMBASSADOR_EXCEPTIONS, RTI::FederateAmbassador::confirmAttributeOwnershipAcquisitionCancellation(), RTI::FederateAmbassador::discoverObjectInstance(), fed_amb, RTI::FederateAmbassador::federationNotRestored(), RTI::FederateAmbassador::federationRestoreBegun(), RTI::FederateAmbassador::federationRestored(), RTI::FederateAmbassador::federationSaved(), RTI::FederateAmbassador::federationSynchronized(), G, informAttributeOwnership(), RTI::FederateAmbassador::initiateFederateRestore(), RTI::FederateAmbassador::initiateFederateSave(), leave(), PrettyDebug::Out(), pdGendoc, RTI::FederateAmbassador::provideAttributeValueUpdate(), RTI::FederateAmbassador::receiveInteraction(), RTI::FederateAmbassador::reflectAttributeValues(), RTI::FederateAmbassador::removeObjectInstance(), requestAttributeOwnershipAssumption(), RTI::FederateAmbassador::requestAttributeOwnershipRelease(), RTI::FederateAmbassador::requestFederationRestoreFailed(), RTI::FederateAmbassador::requestFederationRestoreSucceeded(), RTI::FederateAmbassador::startRegistrationForObjectClass(), RTI::FederateAmbassador::stopRegistrationForObjectClass(), RTI::FederateAmbassador::synchronizationPointRegistrationSucceeded(), RTI::FederateAmbassador::timeAdvanceGrant(), RTI::FederateAmbassador::timeConstrainedEnabled(), RTI::FederateAmbassador::timeRegulationEnabled(), RTI::FederateAmbassador::turnInteractionsOff(), and RTI::FederateAmbassador::turnInteractionsOn().
Referenced by RTI::RTIambassador::__tick_kernel().
void leave | ( | const char * | msg | ) | throw (RTI::RTIinternalError) |
pid_t pid_RTIA |
pid associated with rtia fork (private).
Definition at line 49 of file RTIambPrivateRefs.hh.
Referenced by RTI::RTIambassador::RTIambassador(), and RTIambPrivateRefs().
Federate Ambassador reference for module calls.
Definition at line 52 of file RTIambPrivateRefs.hh.
Referenced by callFederateAmbassador(), RTI::RTIambassador::joinFederationExecution(), and RTIambPrivateRefs().
bool is_reentrant |
used to prevent reentrant calls (see tick() and executeService()).
Definition at line 55 of file RTIambPrivateRefs.hh.
Referenced by RTI::RTIambassador::RTIambassador(), and RTIambPrivateRefs().
Definition at line 59 of file RTIambPrivateRefs.hh.
Referenced by RTI::RTIambassador::__tick_kernel(), executeService(), RTI::RTIambassador::RTIambassador(), RTIambPrivateRefs(), sendTickRequestStop(), and ~RTIambPrivateRefs().
Definition at line 60 of file RTIambPrivateRefs.hh.
Referenced by RTI::RTIambassador::__tick_kernel(), executeService(), and sendTickRequestStop().
Definition at line 60 of file RTIambPrivateRefs.hh.
Referenced by RTI::RTIambassador::__tick_kernel(), executeService(), and sendTickRequestStop().