rtiambassador.cc

certi-SHM-3.0.tar 不错的开源的分布式方针软件 大家多多支持 他是linux

           ConcurrentAccessAttempted,
           SaveInProgress, //not implemented
           RestoreInProgress, //not implemented
           RTIinternalError,
           UnimplementedService) //CERTI
{
    throw UnimplementedService();
}

// ----------------------------------------------------------------------------
//! Request Federation Save (not implemented)
void
RTIambassador::requestFederationSave(const char */*label*/)
    throw (FederateNotExecutionMember,
           ConcurrentAccessAttempted,
           SaveInProgress, //not implemented
           RestoreInProgress, //not implemented
           RTIinternalError,
           UnimplementedService) //CERTI
{
    throw UnimplementedService();
}

// ----------------------------------------------------------------------------
//! Federate Save Begun (not implemented).
void
RTIambassador::federateSaveBegun()
    throw (
           SaveNotInitiated,
           FederateNotExecutionMember,
           ConcurrentAccessAttempted,
           RestoreInProgress, //not implemented
           RTIinternalError,
           UnimplementedService) //CERTI
{
    throw UnimplementedService();
}

// ----------------------------------------------------------------------------
//! Federate Save Complete (not implemented)
void
RTIambassador::federateSaveComplete()
    throw (SaveNotInitiated,
           FederateNotExecutionMember,
           ConcurrentAccessAttempted,
           RestoreInProgress, //not implemented
           RTIinternalError,
           UnimplementedService) //CERTI
{
    throw UnimplementedService();
}

// ----------------------------------------------------------------------------
// Federate Save Not Complete (not implemented)
void
RTIambassador::federateSaveNotComplete()
    throw (SaveNotInitiated,
           FederateNotExecutionMember,
           ConcurrentAccessAttempted,
           RestoreInProgress, //not implemented
           RTIinternalError,
           UnimplementedService) //CERTI
{
    throw UnimplementedService();
}

// ----------------------------------------------------------------------------
//! Request Restore (not implemented)
void
RTIambassador::requestFederationRestore(const char */*label*/)
    throw (SpecifiedSaveLabelDoesNotExist, //CERTI
           FederateNotExecutionMember,
           ConcurrentAccessAttempted,
           SaveInProgress, //not implemented
           RestoreInProgress, //not implemented
           RTIinternalError,
           UnimplementedService) //CERTI
{
    throw UnimplementedService();
}

// ----------------------------------------------------------------------------
//! Restore Complete (not implemented)
void
RTIambassador::federateRestoreComplete()
    throw (UnknownLabel,
           RestoreNotRequested,
           RTICannotRestore,
           FederateNotExecutionMember,
           ConcurrentAccessAttempted,
           SaveInProgress, //not implemented
           RTIinternalError,
           UnimplementedService) //CERTI
{
    throw UnimplementedService();
}

// ----------------------------------------------------------------------------
//! Federate Restore Not Complete (not implemented).
void
RTIambassador::federateRestoreNotComplete()
    throw (UnknownLabel,
           RestoreNotRequested,
           FederateNotExecutionMember,
           RTICannotRestore,
           ConcurrentAccessAttempted,
           SaveInProgress, //not implemented
           RTIinternalError,
           UnimplementedService) //CERTI
{
    throw UnimplementedService();
}

// ===========================================================================
// DECLARATION MANAGEMENT
// ===========================================================================

// ----------------------------------------------------------------------------
// Publish Object Class
void
RTIambassador::publishObjectClass(ObjectClassHandle theClass,
                                  const AttributeHandleSet& attributeList)
    throw (ObjectClassNotDefined,
           AttributeNotDefined,
           OwnershipAcquisitionPending, //not implemented
           FederateNotExecutionMember,
           ConcurrentAccessAttempted,
           SaveInProgress, //not implemeted
           RestoreInProgress, //not implemented
           SecurityError, //CERTI
           RTIinternalError)
{
    Message req, rep ;
    CAttributeHandleValuePairSet *attributeList_aux ;
    attributeList_aux = new CAttributeHandleValuePairSet(attributeList);
    CAttributeHandleValuePair *tmp ;

    // Envoyer la requete au RTI
    req.type = PUBLISH_OBJECT_CLASS ;
    req.objectClass = theClass ;
    req.handleArraySize = attributeList_aux->_size ;

    for (int i = 0 ; i < attributeList_aux->_size ; i++) {
        tmp = attributeList_aux->getIeme(i);
        req.handleArray[i] = tmp->_attrib ;
    }

    executeService(&req, &rep);
}

// ----------------------------------------------------------------------------
// UnPublish Object Class
void
RTIambassador::unpublishObjectClass(ObjectClassHandle theClass)
    throw (ObjectClassNotDefined,
           ObjectClassNotPublished, //not implemented
           OwnershipAcquisitionPending, //not implemented
           FederateOwnsAttributes, //CERTI
           FederateNotExecutionMember,
           ConcurrentAccessAttempted,
           SaveInProgress, //not implemeted
           RestoreInProgress, //not implemented
           SecurityError, //CERTI
           RTIinternalError)
{
    Message req, rep ;

    // envoyer la requete au RTI
    req.type = UNPUBLISH_OBJECT_CLASS ;
    req.objectClass = theClass ;
    executeService(&req, &rep);
}


// ----------------------------------------------------------------------------
// Publish Interaction Class
void
RTIambassador::publishInteractionClass(InteractionClassHandle theInteraction)
    throw (InteractionClassNotDefined,
           FederateNotExecutionMember,
           ConcurrentAccessAttempted,
           SaveInProgress, //not implemented
           RestoreInProgress, //not implemented
           SecurityError, //RTI
           RTIinternalError)
{
    Message req, rep ;

    // envoyer la requete au RTI
    req.type = PUBLISH_INTERACTION_CLASS ;
    req.interactionClass = theInteraction ;
    executeService(&req, &rep);
}

// ----------------------------------------------------------------------------
// Publish Interaction Class
void
RTIambassador::unpublishInteractionClass(InteractionClassHandle theInteraction)
    throw (InteractionClassNotDefined,
           InteractionClassNotPublished, //not implemented
           FederateNotExecutionMember,
           ConcurrentAccessAttempted,
           SaveInProgress, //not implemented
           RestoreInProgress, //not implemented
           SecurityError, //RTI
           RTIinternalError)
{
    Message req, rep ;

    // envoyer la requete au RTI
    req.type = UNPUBLISH_INTERACTION_CLASS ;
    req.interactionClass = theInteraction ;
    executeService(&req, &rep);
}

// ----------------------------------------------------------------------------
// Subscribe Object Class Attribute
void
RTIambassador::
subscribeObjectClassAttributes(ObjectClassHandle theClass,
                               const AttributeHandleSet& attributeList,
                               Boolean /*active*/)
    throw (ObjectClassNotDefined,
           AttributeNotDefined,
           FederateNotExecutionMember,
           ConcurrentAccessAttempted,
           SaveInProgress, //not implemented
           RestoreInProgress, //not implemented
           SecurityError, //RTI
           RTIinternalError)
{
    Message req, rep ;
    CAttributeHandleValuePairSet *attributeList_aux ;
    attributeList_aux = new CAttributeHandleValuePairSet(attributeList);
    CAttributeHandleValuePair *tmp ;

    // envoyer la requete au RTI
    req.type = SUBSCRIBE_OBJECT_CLASS_ATTRIBUTE ;
    req.objectClass = theClass ;
    req.handleArraySize = attributeList_aux->_size ;

    for (int i = 0 ; i < attributeList_aux->_size ; i++) {
        tmp = attributeList_aux->getIeme(i);
        req.handleArray[i] = tmp->_attrib ;
    }

    executeService(&req, &rep);
}

// ----------------------------------------------------------------------------
// UnSubscribe Object Class Attribute
void
RTIambassador::unsubscribeObjectClass(ObjectClassHandle theClass)
    throw (ObjectClassNotDefined,
           ObjectClassNotSubscribed, //not implemented
           FederateNotExecutionMember,
           ConcurrentAccessAttempted,
           SaveInProgress, //not implemented
           RestoreInProgress, //not implemented
           SecurityError, //RTI
           RTIinternalError)
{
    Message req, rep ;

    // envoyer la requete au RTI
    req.type = UNSUBSCRIBE_OBJECT_CLASS_ATTRIBUTE ;
    req.objectClass = theClass ;
    executeService(&req, &rep);
}


// ----------------------------------------------------------------------------
// Subscribe Interaction Class
void
RTIambassador::subscribeInteractionClass(InteractionClassHandle theClass,
                                         Boolean /*active*/)
    throw (InteractionClassNotDefined,
           FederateNotExecutionMember,
           ConcurrentAccessAttempted,
           FederateLoggingServiceCalls, //not implemented
           SaveInProgress, //not implemented
           RestoreInProgress, //not implemented
           SecurityError, //RTI
           RTIinternalError)
{
    Message req, rep ;

    // envoyer la requete au RTI
    req.type = SUBSCRIBE_INTERACTION_CLASS ;
    req.interactionClass = theClass ;
    executeService(&req, &rep);
}

// ----------------------------------------------------------------------------
// UnSubscribe Interaction Class
void
RTIambassador::unsubscribeInteractionClass(InteractionClassHandle theClass)
    throw (InteractionClassNotDefined,
           InteractionClassNotSubscribed, //not implemented
           FederateNotExecutionMember,
           ConcurrentAccessAttempted,
           SaveInProgress, //not implemented
           RestoreInProgress, //not implemented
           SecurityError, //RTI
           RTIinternalError)
{
    Message req, rep ;

    // envoyer la requete au RTI
    req.type = UNSUBSCRIBE_INTERACTION_CLASS ;
    req.interactionClass = theClass ;
    executeService(&req, &rep);
}

// ===========================================================================
// OBJECT MANAGEMENT
// ===========================================================================

// ----------------------------------------------------------------------------
// Register Object
ObjectHandle
RTIambassador::registerObjectInstance(ObjectClassHandle theClass,
                                      const char *theObjectName)
    throw (ObjectClassNotDefined,
           ObjectClassNotPublished,
           InvalidObjectHandle, //RTI
           ObjectAlreadyRegistered,
           FederateNotExecutionMember,
           ConcurrentAccessAttempted,
           SaveInProgress, //not implemented
           RestoreInProgress, //not implemented
           RTIinternalError)
{
    Message req, rep ;

    // envoyer la requete au RTI
    req.type = REGISTER_OBJECT ;
    req.setName((char *) theObjectName);
    req.objectClass = theClass ;
    executeService(&req, &rep);

    return rep.object ;
}

// ----------------------------------------------------------------------------
ObjectHandle
RTIambassador::registerObjectInstance(ObjectClassHandle theClass)
    throw (ObjectClassNotDefined,
           ObjectClassNotPublished,
           InvalidObjectHandle, //RTI
           ObjectAlreadyRegistered,
           FederateNotExecutionMember,
           ConcurrentAccessAttempted,
           SaveInProgress, //not implemented
           RestoreInProgress, //not implemented
           RTIinternalError)
{
    Message req, rep ;

    // envoyer la requete au RTI
    req.type = REGISTER_OBJECT ;
    req.setName("\0");
    req.objectClass = theClass ;

    executeService(&req, &rep);

    return rep.object ;
}

// ----------------------------------------------------------------------------
// Update Attribute Values
EventRetractionHandle
RTIambassador::
updateAttributeValues(ObjectHandle theObject,
                      const AttributeHandleValuePairSet& theAttributes,
                      const FedTime& theTime,
                      const char *theTag)
    throw (ObjectNotKnown,
           AttributeNotDefined,
           AttributeNotOwned,
           InvalidFederationTime,
           FederateNotExecutionMember,
           ConcurrentAccessAttempted,
           SaveInProgress, //not implemented
           RestoreInProgress, //not implemented
           RTIinternalError)
{
    ULong longueur ;
    Message req, rep ;

    CAttributeHandleValuePairSet *theAttributes_aux ;
    theAttributes_aux = new CAttributeHandleValuePairSet(theAttributes);

    CAttributeHandleValuePair *tmp ;

    // Envoyer la requete au RTI
    req.type = UPDATE_ATTRIBUTE_VALUES ;
    req.object = (ObjectHandle) theObject ;
    req.date = (FederationTime) ((RTIfedTime&) theTime).getTime();
    req.setTag(theTag);
    req.handleArraySize = theAttributes_aux->_size ;

    for (int i = 0 ; i < theAttributes_aux->_size ; i++) {
        tmp = theAttributes_aux->getIeme(i);
        req.handleArray[i] = tmp->_attrib ;