#include <BUFUInterface.h>

Public Member Functions
void	allocate (const UIntVec_t &fuResourceIds, xdaq::ApplicationDescriptor *fuAppDesc)

void	discard (UInt_t buResourceId)
	FU->BU DISCARD. More...

bool	registerBU (BaseBU *bu, Logger log)
	register the BU to the interface More...

bool	registerFU (BaseFU *fu, Logger log)
	register the FU to the interface More...

void	take (xdaq::ApplicationDescriptor fuAppDesc, toolbox::mem::Reference bufRef)
	BU->FU TAKE. More...

	~BUFUInterface ()

Static Public Member Functions
static BUFUInterface *	forceNewInstance ()

static BUFUInterface *	instance ()
	returns a pointer to a singleton instance of the interface More...

Private Member Functions
	BUFUInterface ()
	private constructor More...

bool	directConnection () const
	checks if both BU and FU are connected to the interface More...

Private Attributes
BaseBU *	bu_
	pointer to connected BU, using BaseBU interface More...

bool	buConn_
	flags for BU, FU connection More...

Logger	buLogger_
	loggers More...

BaseFU *	fu_
	pointer to connected ResourceBroker(FU), using BaseFU interface More...

bool	fuConn_

Logger	fuLogger_

Static Private Attributes
static BUFUInterface *	instance_ = 0
	pointer to unique instance More...

Detailed Description

Definition at line 17 of file BUFUInterface.h.

Constructor & Destructor Documentation

BUFUInterface::~BUFUInterface ( )

Definition at line 19 of file BUFUInterface.cc.

References instance_.

                               {
     // delete instance_;
     instance_ = 0;
 }

BUFUInterface::BUFUInterface ( )

private

private constructor

Definition at line 155 of file BUFUInterface.cc.

Referenced by forceNewInstance(), and instance().

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

Member Function Documentation

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

FU->BU ALLOCATE the FU application description is required by the BU when registering the requesting FU

Definition at line 79 of file BUFUInterface.cc.

References bu_, evf::BaseFU::buildAndSendAllocate(), gather_cfg::cout, evf::BaseBU::DIRECT_BU_ALLOCATE(), directConnection(), and fu_.

                                               {
 
     // 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
     }
 
 }

bool evf::BUFUInterface::directConnection ( ) const

inlineprivate

checks if both BU and FU are connected to the interface

Definition at line 58 of file BUFUInterface.h.

References buConn_, and fuConn_.

Referenced by allocate(), discard(), registerBU(), registerFU(), and take().

                                          {
         return buConn_ && fuConn_;
     }

void BUFUInterface::discard ( UInt_t buResourceId )

FU->BU DISCARD.

Definition at line 105 of file BUFUInterface.cc.

References bu_, evf::BaseFU::buildAndSendDiscard(), gather_cfg::cout, evf::BaseBU::DIRECT_BU_DISCARD(), directConnection(), and fu_.

                                                {
 
     // 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
     }
 
 }

BUFUInterface * BUFUInterface::forceNewInstance ( )

static

always returns a new instance. used to force I2O communication between BU and FU in the same process

Definition at line 34 of file BUFUInterface.cc.

References BUFUInterface().

                                                {
     return new BUFUInterface();
 }

BUFUInterface * BUFUInterface::instance ( )

static

returns a pointer to a singleton instance of the interface

Definition at line 25 of file BUFUInterface.cc.

References BUFUInterface(), and instance_.

                                        {
     if (instance_ == 0) {
         instance_ = new BUFUInterface();
     }
     return instance_;
 
 }

bool BUFUInterface::registerBU	(	BaseBU *	bu,
		Logger	log
	)

register the BU to the interface

Definition at line 39 of file BUFUInterface.cc.

References bu_, buConn_, buLogger_, directConnection(), create_public_lumi_plots::log, and summarizeEdmComparisonLogfiles::succeeded.

                                                      {
     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
	)

register the FU to the interface

Definition at line 59 of file BUFUInterface.cc.

References buLogger_, directConnection(), fu_, fuConn_, fuLogger_, create_public_lumi_plots::log, and summarizeEdmComparisonLogfiles::succeeded.

                                                      {
     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::take	(	xdaq::ApplicationDescriptor *	fuAppDesc,
		toolbox::mem::Reference *	bufRef
	)

BU->FU TAKE.

Definition at line 130 of file BUFUInterface.cc.

References bu_, gather_cfg::cout, directConnection(), fu_, evf::BaseFU::I2O_FU_TAKE_Callback(), and evf::BaseBU::postI2OFrame().

                                      {
 
     // 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
     }
 
 }