/afs/cern.ch/work/a/aaltunda/public/www/CMSSW_5_3_14/src/EventFilter/ResourceBroker/src/BUProxy.cc

Go to the documentation of this file.

//
// BUProxy
// -------
//


#include "EventFilter/ResourceBroker/interface/BUProxy.h"

#include "toolbox/mem/Reference.h"
#include "toolbox/mem/MemoryPoolFactory.h"
#include "toolbox/mem/exception/Exception.h"

#include "i2o/Method.h"
#include "i2o/utils/AddressMap.h"

#include "xcept/tools.h"

#include "interface/evb/i2oEVBMsgs.h" 
#include "interface/shared/i2oXFunctionCodes.h"

#include <iostream>

using namespace std;
using namespace evf;

// construction/destruction

//______________________________________________________________________________
BUProxy::BUProxy(xdaq::ApplicationDescriptor *fuAppDesc,
                xdaq::ApplicationDescriptor *buAppDesc,
                xdaq::ApplicationContext *fuAppContext, toolbox::mem::Pool *i2oPool) :
        fuAppDesc_(fuAppDesc), buAppDesc_(buAppDesc), fuAppContext_(fuAppContext),
                        i2oPool_(i2oPool) {

}

//______________________________________________________________________________
BUProxy::~BUProxy() {

}

// implementation of member functions

//______________________________________________________________________________
void BUProxy::sendAllocate(const UIntVec_t& fuResourceIds)
                throw (evf::Exception) {
        Logger log = fuAppContext_->getLogger();

        try {
                size_t msgSize = sizeof(I2O_BU_ALLOCATE_MESSAGE_FRAME)
                                + sizeof(BU_ALLOCATE) * (fuResourceIds.size() - 1);

                toolbox::mem::Reference *bufRef =
                                toolbox::mem::getMemoryPoolFactory()->getFrame(i2oPool_,
                                                msgSize);

                I2O_MESSAGE_FRAME *stdMsg;
                I2O_PRIVATE_MESSAGE_FRAME *pvtMsg;
                I2O_BU_ALLOCATE_MESSAGE_FRAME *msg;

                stdMsg = (I2O_MESSAGE_FRAME*) bufRef->getDataLocation();
                pvtMsg = (I2O_PRIVATE_MESSAGE_FRAME*) stdMsg;
                msg = (I2O_BU_ALLOCATE_MESSAGE_FRAME*) stdMsg;

                stdMsg->MessageSize = msgSize >> 2;
                stdMsg->InitiatorAddress = i2o::utils::getAddressMap()->getTid(
                                fuAppDesc_);
                stdMsg->TargetAddress = i2o::utils::getAddressMap()->getTid(buAppDesc_);
                stdMsg->Function = I2O_PRIVATE_MESSAGE;
                stdMsg->VersionOffset = 0;
                stdMsg->MsgFlags = 0; // Point-to-point

                pvtMsg->XFunctionCode = I2O_BU_ALLOCATE;
                pvtMsg->OrganizationID = XDAQ_ORGANIZATION_ID;

                msg->n = fuResourceIds.size();

                for (UInt_t i = 0; i < fuResourceIds.size(); i++) {
                        msg->allocate[i].fuTransactionId = fuResourceIds[i];
                        msg->allocate[i].fset = 1; // IGNORED!!!
                }

                bufRef->setDataSize(msgSize);

                fuAppContext_->postFrame(bufRef, fuAppDesc_, buAppDesc_);
        } catch (toolbox::mem::exception::Exception& e) {
                string errmsg = "Failed to allocate buffer reference.";
                LOG4CPLUS_ERROR(log, errmsg);
                XCEPT_RETHROW(evf::Exception, errmsg, e);
        } catch (xdaq::exception::ApplicationDescriptorNotFound& e) {
                string errmsg = "Failed to get tid.";
                LOG4CPLUS_ERROR(log, errmsg);
                XCEPT_RETHROW(evf::Exception, errmsg, e);
        } catch (xdaq::exception::Exception& e) {
                string errmsg = "Failed to post 'Allocate' message.";
                LOG4CPLUS_ERROR(log, errmsg);
                XCEPT_RETHROW(evf::Exception, errmsg, e);
        }
}

//______________________________________________________________________________
void BUProxy::sendDiscard(UInt_t buResourceId) throw (evf::Exception) {
        Logger log = fuAppContext_->getLogger();

        try {
                size_t msgSize = sizeof(I2O_BU_DISCARD_MESSAGE_FRAME);

                toolbox::mem::Reference *bufRef =
                                toolbox::mem::getMemoryPoolFactory()->getFrame(i2oPool_,
                                                msgSize);

                I2O_MESSAGE_FRAME *stdMsg =
                                (I2O_MESSAGE_FRAME*) bufRef->getDataLocation();
                I2O_PRIVATE_MESSAGE_FRAME *pvtMsg = (I2O_PRIVATE_MESSAGE_FRAME*) stdMsg;
                I2O_BU_DISCARD_MESSAGE_FRAME *msg =
                                (I2O_BU_DISCARD_MESSAGE_FRAME*) stdMsg;

                stdMsg->MessageSize = msgSize >> 2;
                stdMsg->InitiatorAddress = i2o::utils::getAddressMap()->getTid(
                                fuAppDesc_);
                stdMsg->TargetAddress = i2o::utils::getAddressMap()->getTid(buAppDesc_);
                stdMsg->Function = I2O_PRIVATE_MESSAGE;
                stdMsg->VersionOffset = 0;
                stdMsg->MsgFlags = 0; // Point-to-point

                pvtMsg->XFunctionCode = I2O_BU_DISCARD;
                pvtMsg->OrganizationID = XDAQ_ORGANIZATION_ID;

                msg->n = 1;
                msg->buResourceId[0] = buResourceId;

                bufRef->setDataSize(msgSize);

                fuAppContext_->postFrame(bufRef, fuAppDesc_, buAppDesc_);
        } catch (toolbox::mem::exception::Exception& e) {
                string errmsg = "Failed to allocate buffer reference.";
                LOG4CPLUS_ERROR(log, errmsg);
                XCEPT_RETHROW(evf::Exception, errmsg, e);
        } catch (xdaq::exception::ApplicationDescriptorNotFound& e) {
                string errmsg = "Failed to get tid.";
                LOG4CPLUS_ERROR(log, errmsg);
                XCEPT_RETHROW(evf::Exception, errmsg, e);
        } catch (xdaq::exception::Exception &e) {
                string errmsg = "Failed to post 'Discard' message.";
                LOG4CPLUS_ERROR(log, errmsg);
                XCEPT_RETHROW(evf::Exception, errmsg, e);
        }

}