ownershipmanagement.cc

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

AttributeHandleSet*
OwnershipManagement::
attributeOwnershipRealeaseResponse(ObjectHandle theObject,
                                   AttributeHandle *attribArray,
                                   UShort attribArraySize,
                                   TypeException &e)
{
    NetworkMessage req, rep ;

    req.type = m_ATTRIBUTE_OWNERSHIP_RELEASE_RESPONSE ;
    req.federation = fm->_numero_federation ;
    req.federate = fm->federate ;
    req.object = theObject ;
    req.handleArraySize = attribArraySize ;

    D.Out(pdDebug, "RELEASE_RESPONSE Object %u handleArraySize %u",
          theObject, req.handleArraySize);

    for (int i = 0 ; i < attribArraySize ; i++) {
        req.handleArray[i] = attribArray[i] ;
    }


    comm->sendMessage(&req);

    comm->waitMessage(&rep, m_ATTRIBUTE_OWNERSHIP_RELEASE_RESPONSE,
                      req.federate);

    e = rep.exception ;

    if (e == e_NO_EXCEPTION) {
        AttributeHandleSet *AttributeSet ;
        AttributeSet=AttributeHandleSetFactory::create(rep.handleArraySize);

        for (int i = 0 ; i < rep.handleArraySize ; i++) {
            AttributeSet->add(rep.handleArray[i]);
        }

        return(AttributeSet);
    }
    else
        return NULL ;
}

// ----------------------------------------------------------------------------
//! cancelAttributeOwnershipAcquisition.
void
OwnershipManagement::
cancelattributeOwnershipAcquisition(ObjectHandle theObject,
                                    AttributeHandle *attribArray,
                                    UShort attribArraySize,
                                    TypeException &e)
{
    NetworkMessage req, rep ;

    req.type = m_CANCEL_ATTRIBUTE_OWNERSHIP_ACQUISITION ;
    req.federation = fm->_numero_federation ;
    req.federate = fm->federate ;
    req.object = theObject ;
    req.handleArraySize = attribArraySize ;

    for (int i = 0 ; i < attribArraySize ; i++)
        req.handleArray[i] = attribArray[i] ;

    D.Out(pdDebug, "CANCEL_ACQUISITION Federate %u ", fm->federate);

    comm->sendMessage(&req);

    comm->waitMessage(&rep, m_CANCEL_ATTRIBUTE_OWNERSHIP_ACQUISITION,
                      req.federate);

    e = rep.exception ;
}

// ----------------------------------------------------------------------------
//! informAttributeOwnership.
void
OwnershipManagement::informAttributeOwnership(ObjectHandle theObject,
                                              AttributeHandle theAttribute,
                                              FederateHandle theOwner,
                                              TypeException &)
{
    Message req, rep ;

    req.type = INFORM_ATTRIBUTE_OWNERSHIP ;
    req.object = theObject ;
    req.attribute = theAttribute ;
    req.federate = theOwner ;

    comm->requestFederateService(&req, &rep);
}

// ----------------------------------------------------------------------------
//! attributeIsNotOwned.
void
OwnershipManagement::attributeIsNotOwned(ObjectHandle theObject,
                                         AttributeHandle theAttribute,
                                         FederateHandle,
                                         TypeException &)
{
    Message req, rep ;

    req.type = ATTRIBUTE_IS_NOT_OWNED ;
    req.object = theObject ;
    req.attribute = theAttribute ;
    // req.FederateHandle = theOwner ;

    comm->requestFederateService(&req, &rep);
}

// ----------------------------------------------------------------------------
//! attributeOwnershipUnavailable.
void
OwnershipManagement::
attributeOwnershipUnavailable(ObjectHandle theObject,
                              AttributeHandle *attribArray,
                              UShort attribArraySize,
                              FederateHandle,
                              TypeException &)
{
    Message req, rep ;

    req.type = ATTRIBUTE_OWNERSHIP_UNAVAILABLE ;
    req.object = theObject ;

    req.handleArraySize = attribArraySize ;
    D.Out(pdDebug, "OWNERSHIP_UNAVAILABLE Object %u handleArraySize %u",
          theObject, req.handleArraySize);
    for (int i = 0 ; i < attribArraySize ; i++) {
        req.handleArray[i] = attribArray[i] ;
        D.Out(pdDebug, "Object %u Attribute %u", theObject, req.handleArray[i]);
    }

    comm->requestFederateService(&req, &rep);
}

// ----------------------------------------------------------------------------
//! attributeOwnershipAcquisitionNotification.
void
OwnershipManagement::
attributeOwnershipAcquisitionNotification(ObjectHandle theObject,
                                          AttributeHandle *attribArray,
                                          UShort attribArraySize,
                                          FederateHandle,
                                          TypeException &)
{
    Message req, rep ;

    req.type = ATTRIBUTE_OWNERSHIP_ACQUISITION_NOTIFICATION ;
    req.object = theObject ;

    req.handleArraySize = attribArraySize ;
    D.Out(pdDebug, "ACQUISITION_NOTIFICATION Object %u handleArraySize %u",
          theObject, req.handleArraySize);
    for (int i = 0 ; i < attribArraySize ; i++) {
        req.handleArray[i] = attribArray[i] ;
        D.Out(pdDebug, "Object %u Attribute %u", theObject, req.handleArray[i]);
    }

    comm->requestFederateService(&req, &rep);
}

// ----------------------------------------------------------------------------
//! requestAttributeOwnershipAssumption.
void
OwnershipManagement::
requestAttributeOwnershipAssumption(ObjectHandle theObject,
                                    AttributeHandle *attribArray,
                                    UShort attribArraySize,
                                    FederateHandle,
                                    char *theTag,
                                    TypeException &)
{
    Message req, rep ;

    req.type = REQUEST_ATTRIBUTE_OWNERSHIP_ASSUMPTION ;
    req.object = theObject ;

    req.handleArraySize = attribArraySize ;
    D.Out(pdDebug, "OWNERSHIP_ASSUMPTION Object %u handleArraySize %u",
          theObject, req.handleArraySize);
    for (int i = 0 ; i < attribArraySize ; i++) {
        req.handleArray[i] = attribArray[i] ;
        D.Out(pdDebug, "Object %u Attribute %u", theObject, req.handleArray[i]);
    }

    req.setTag(theTag);

    comm->requestFederateService(&req, &rep);
}

// ----------------------------------------------------------------------------
//! requestAttributeOwnershipRelease.
void
OwnershipManagement::
requestAttributeOwnershipRelease(ObjectHandle theObject,
                                 AttributeHandle *attribArray,
                                 UShort attribArraySize,
                                 char *theTag,
                                 TypeException &)
{
    Message req, rep ;

    req.type = REQUEST_ATTRIBUTE_OWNERSHIP_RELEASE ;
    req.object = theObject ;

    req.handleArraySize = attribArraySize ;
    D.Out(pdDebug, "OWNERSHIP_RELEASE Object %u handleArraySize %u",
          theObject, req.handleArraySize);
    for (int i = 0 ; i < attribArraySize ; i++) {
        req.handleArray[i] = attribArray[i] ;
        D.Out(pdDebug, "Object %u Attribute %u", theObject, req.handleArray[i]);
    }

    req.setTag(theTag);

    comm->requestFederateService(&req, &rep);
}

// ----------------------------------------------------------------------------
//! attributeOwnershipDivestitureNotification.
void
OwnershipManagement::
attributeOwnershipDivestitureNotification(ObjectHandle theObject,
                                          AttributeHandle *attribArray,
                                          UShort attribArraySize,
                                          TypeException &)
{
    Message req, rep ;

    req.type = ATTRIBUTE_OWNERSHIP_DIVESTITURE_NOTIFICATION ;
    req.object = theObject ;

    req.handleArraySize = attribArraySize ;
    D.Out(pdDebug, "DIVESTITURE_NOTIFICATION Object %u handleArraySize %u",
          theObject, req.handleArraySize);
    for (int i = 0 ; i < attribArraySize ; i++) {
        req.handleArray[i] = attribArray[i] ;
        D.Out(pdDebug, "Object %u Attribut %u", theObject, req.handleArray[i]);
    }

    comm->requestFederateService(&req, &rep);
}

// ----------------------------------------------------------------------------
//! confirmattributeOwnershipAcquisitionCancellation.
void
OwnershipManagement::
confirmAttributeOwnershipAcquisitionCancellation(ObjectHandle theObject,
                                                 AttributeHandle *attribArray,
                                                 UShort attribArraySize,
                                                 TypeException &)
{
    Message req ;

    req.type = CONFIRM_ATTRIBUTE_OWNERSHIP_ACQUISITION_CANCELLATION ;
    req.object = theObject ;

    req.handleArraySize = attribArraySize ;
    D.Out(pdDebug,
          "CONFIRM_ACQUISITION_CANCELLATION Object %u handleArraySize %u",
          theObject, req.handleArraySize);
    for (int i = 0 ; i < attribArraySize ; i++) {
        req.handleArray[i] = attribArray[i] ;
        D.Out(pdDebug, "Object %u Attribute %u", theObject, req.handleArray[i]);
    }

    Message rep ;
    comm->requestFederateService(&req, &rep);
}

}} // namespace certi/rtia

// $Id: OwnershipManagement.cc,v 3.5 2003/02/19 15:45:23 breholee Exp $