/data/refman/pasoursint/CMSSW_4_4_5_patch3/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);
  }
  
}