/afs/cern.ch/work/a/aaltunda/public/www/CMSSW_5_3_14/src/EventFilter/Utilities/src/BUFUInterface.cc

Go to the documentation of this file.

/*
 * BUFUInterface.cc
 *
 *  Created on: Aug 16, 2011
 *      Author: aspataru
 */

#include "EventFilter/Utilities/interface/BUFUInterface.h"

#define BUFU_VERBOSE
//#define BUFU_DEBUG

using namespace evf;

// initialize instance_ to 0
BUFUInterface* evf::BUFUInterface::instance_ = 0;

//______________________________________________________________________________
BUFUInterface::~BUFUInterface() {
        // delete instance_;
        instance_ = 0;
}

//______________________________________________________________________________
BUFUInterface* BUFUInterface::instance() {
        if (instance_ == 0) {
                instance_ = new BUFUInterface();
        }
        return instance_;

}

//______________________________________________________________________________
BUFUInterface* BUFUInterface::forceNewInstance() {
        return new BUFUInterface();
}

//______________________________________________________________________________
bool BUFUInterface::registerBU(BaseBU* bu, Logger log) {
        bool succeeded = false;
        if (bu != 0) {
                bu_ = bu;
                buLogger_ = log;
                buConn_ = true;
                succeeded = true;

#ifdef BUFU_VERBOSE
                LOG4CPLUS_INFO(buLogger_, "BU registered to BUFU interface!");
                if (directConnection()) {
                        LOG4CPLUS_INFO(buLogger_, "BU and FU : DIRECTLY CONNECTED!");
                }
#endif

        }
        return succeeded;
}

//______________________________________________________________________________
bool BUFUInterface::registerFU(BaseFU* fu, Logger log) {
        bool succeeded = false;
        if (fu != 0) {
                fu_ = fu;
                fuLogger_ = log;
                fuConn_ = true;
                succeeded = true;

#ifdef BUFU_VERBOSE
                LOG4CPLUS_INFO(fuLogger_, "FU registered to BUFU interface!");
                if (directConnection()) {
                        LOG4CPLUS_INFO(buLogger_, "BU and FU : DIRECTLY CONNECTED!");
                }
#endif

        }
        return succeeded;
}

//______________________________________________________________________________
void BUFUInterface::allocate(const UIntVec_t& fuResourceIds,
                xdaq::ApplicationDescriptor* fuAppDesc) {

        // direct connection -> method call
        if (directConnection()) {

                bu_->DIRECT_BU_ALLOCATE(fuResourceIds, fuAppDesc);

#ifdef BUFU_DEBUG
                std::cout << "ALLOCATE FU->BU message sent directly!" << std::endl;
#endif
        }

        // no connection -> line protocol
        else {
                // call FU to build I2O allocate message and send it
                fu_->buildAndSendAllocate(fuResourceIds);

#ifdef BUFU_DEBUG
                std::cout << "ALLOCATE FU->BU message sent through I2O!" << std::endl;
#endif
        }

}

//______________________________________________________________________________
void BUFUInterface::discard(UInt_t buResourceId) {

        // direct connection -> method call
        if (directConnection()) {

                bu_->DIRECT_BU_DISCARD(buResourceId);

#ifdef BUFU_DEBUG
                std::cout << "DISCARD FU->BU message sent directly!" << std::endl;
#endif
        }

        // no connection -> line protocol
        else {
                // call FU to build I2O discard and send it
                fu_->buildAndSendDiscard(buResourceId);

#ifdef BUFU_DEBUG
                std::cout << "DISCARD FU->BU message sent through I2O!" << std::endl;
#endif
        }

}

//______________________________________________________________________________
void BUFUInterface::take(xdaq::ApplicationDescriptor* fuAppDesc,
                toolbox::mem::Reference* bufRef) {

        // direct connection -> method call
        if (directConnection()) {

                fu_->I2O_FU_TAKE_Callback(bufRef);

#ifdef BUFU_DEBUG
                std::cout << "TAKE BU->FU message sent directly!" << std::endl;
#endif
        }

        // no connection -> line protocol
        else {
                bu_->postI2OFrame(fuAppDesc, bufRef);

#ifdef BUFU_DEBUG
                std::cout << "TAKE BU->FU message sent through I2O!" << std::endl;
#endif
        }

}

//______________________________________________________________________________
BUFUInterface::BUFUInterface() :
        bu_(0), fu_(0), /*buLogger_(0), fuLogger_(0),*/ buConn_(false), fuConn_(false) {

}