|
|
|
#include <SMProxy.h>
Public Member Functions | |
| UInt_t | sendDataEvent (UInt_t fuResourceId, UInt_t runNumber, UInt_t evtNumber, UInt_t outModId, UInt_t fuProcessId, UInt_t fuGuid, UChar_t *data, UInt_t dataSize) throw (evf::Exception) |
| UInt_t | sendDqmEvent (UInt_t fuDqmId, UInt_t runNumber, UInt_t evtAtUpdate, UInt_t folderId, UInt_t fuProcessId, UInt_t fuGuid, UChar_t *data, UInt_t dataSize) throw (evf::Exception) |
| UInt_t | sendErrorEvent (UInt_t fuResourceId, UInt_t runNumber, UInt_t evtNumber, UInt_t fuProcessId, UInt_t fuGuid, UChar_t *data, UInt_t dataSize) throw (evf::Exception) |
| UInt_t | sendInitMessage (UInt_t fuResourceId, UInt_t outModId, UInt_t fuProcessId, UInt_t fuGuid, UChar_t *data, UInt_t dataSize, UInt_t nExpectedEPs) throw (evf::Exception) |
| SMProxy (xdaq::ApplicationDescriptor *fuAppDesc, xdaq::ApplicationDescriptor *smAppDesc, xdaq::ApplicationContext *fuAppContext, toolbox::mem::Pool *i2oPool) | |
| virtual | ~SMProxy () |
Private Member Functions | |
| MemRef_t * | createFragmentChain (UShort_t i2oFunctionCode, UInt_t headerSize, UChar_t *data, UInt_t dataSize, UInt_t &totalSize) throw (evf::Exception) |
Private Attributes | |
| UInt_t | dataHeaderSize_ |
| UInt_t | dqmHeaderSize_ |
| xdaq::ApplicationContext * | fuAppContext_ |
| xdaq::ApplicationDescriptor * | fuAppDesc_ |
| std::string | fuClassName_ |
| std::string | fuUrl_ |
| toolbox::mem::Pool * | i2oPool_ |
| UInt_t | initHeaderSize_ |
| Logger | log_ |
| xdaq::ApplicationDescriptor * | smAppDesc_ |
| SMProxy::SMProxy | ( | xdaq::ApplicationDescriptor * | fuAppDesc, |
| xdaq::ApplicationDescriptor * | smAppDesc, | ||
| xdaq::ApplicationContext * | fuAppContext, | ||
| toolbox::mem::Pool * | i2oPool | ||
| ) |
Definition at line 34 of file SMProxy.cc.
References fuAppDesc_, fuClassName_, fuUrl_, and MAX_I2O_SM_URLCHARS.
:
log_(fuAppContext->getLogger()), fuAppDesc_(fuAppDesc),
smAppDesc_(smAppDesc), fuAppContext_(fuAppContext),
i2oPool_(i2oPool),
initHeaderSize_(sizeof(I2O_SM_PREAMBLE_MESSAGE_FRAME)),
dataHeaderSize_(sizeof(I2O_SM_DATA_MESSAGE_FRAME)),
dqmHeaderSize_(sizeof(I2O_SM_DQM_MESSAGE_FRAME)) {
fuUrl_ = fuAppDesc_->getContextDescriptor()->getURL();
if (fuUrl_.size() >= MAX_I2O_SM_URLCHARS)
fuUrl_ = fuUrl_.substr(0, MAX_I2O_SM_URLCHARS - 1);
fuClassName_ = fuAppDesc_->getClassName();
if (fuClassName_.size() >= MAX_I2O_SM_URLCHARS)
fuClassName_ = fuClassName_.substr(0, MAX_I2O_SM_URLCHARS - 1);
}
| SMProxy::~SMProxy | ( | ) | [virtual] |
Definition at line 53 of file SMProxy.cc.
{
}
| MemRef_t * SMProxy::createFragmentChain | ( | UShort_t | i2oFunctionCode, |
| UInt_t | headerSize, | ||
| UChar_t * | data, | ||
| UInt_t | dataSize, | ||
| UInt_t & | totalSize | ||
| ) | throw (evf::Exception) [private] |
Definition at line 188 of file SMProxy.cc.
References filterCSVwithJSON::copy, data, _I2O_SM_MULTIPART_MESSAGE_FRAME::dataSize, alignCSCRings::e, Exception, _I2O_SM_MULTIPART_MESSAGE_FRAME::frameCount, _I2O_SM_MULTIPART_MESSAGE_FRAME::hltClassName, _I2O_SM_MULTIPART_MESSAGE_FRAME::hltInstance, _I2O_SM_MULTIPART_MESSAGE_FRAME::hltLocalId, _I2O_SM_MULTIPART_MESSAGE_FRAME::hltTid, _I2O_SM_MULTIPART_MESSAGE_FRAME::hltURL, i, I2O_MAX_SIZE, lumiQueryAPI::msg, _I2O_SM_MULTIPART_MESSAGE_FRAME::numFrames, and _I2O_SM_MULTIPART_MESSAGE_FRAME::originalSize.
{
totalSize = 0;
UInt_t fragmentDataSizeMax = I2O_MAX_SIZE - headerSize;
UInt_t fragmentCount = (dataSize / fragmentDataSizeMax);
if (dataSize % fragmentDataSizeMax)
++fragmentCount;
UInt_t currentPosition = 0;
UInt_t remainingDataSize = dataSize;
MemRef_t *head(0);
MemRef_t *tail(0);
try {
for (UInt_t iFragment = 0; iFragment < fragmentCount; iFragment++) {
UInt_t fragmentDataSize = fragmentDataSizeMax;
UInt_t fragmentSize = fragmentDataSize + headerSize;
if (remainingDataSize < fragmentDataSizeMax) {
fragmentDataSize = remainingDataSize;
fragmentSize = fragmentDataSize + headerSize;
if (fragmentSize & 0x7)
fragmentSize = ((fragmentSize >> 3) + 1) << 3;
}
// allocate the fragment buffer from the pool
toolbox::mem::Reference *bufRef =
toolbox::mem::getMemoryPoolFactory()->getFrame(i2oPool_,
fragmentSize);
// set up pointers to the allocated message buffer
I2O_MESSAGE_FRAME *stdMsg;
I2O_PRIVATE_MESSAGE_FRAME *pvtMsg;
I2O_SM_MULTIPART_MESSAGE_FRAME *msg;
stdMsg = (I2O_MESSAGE_FRAME*) bufRef->getDataLocation();
pvtMsg = (I2O_PRIVATE_MESSAGE_FRAME*) stdMsg;
msg = (I2O_SM_MULTIPART_MESSAGE_FRAME*) stdMsg;
stdMsg->VersionOffset = 0;
stdMsg->MsgFlags = 0; // normal message (not multicast)
stdMsg->MessageSize = fragmentSize >> 2;
stdMsg->Function = I2O_PRIVATE_MESSAGE;
stdMsg->InitiatorAddress = i2o::utils::getAddressMap()->getTid(
fuAppDesc_);
stdMsg->TargetAddress = i2o::utils::getAddressMap()->getTid(
smAppDesc_);
pvtMsg->XFunctionCode = i2oFunctionCode;
pvtMsg->OrganizationID = XDAQ_ORGANIZATION_ID;
msg->dataSize = fragmentDataSize;
msg->hltLocalId = fuAppDesc_->getLocalId();
msg->hltInstance = fuAppDesc_->getInstance();
msg->hltTid = i2o::utils::getAddressMap()->getTid(fuAppDesc_);
msg->numFrames = fragmentCount;
msg->frameCount = iFragment;
msg->originalSize = dataSize;
for (UInt_t i = 0; i < fuUrl_.size(); i++)
msg->hltURL[i] = fuUrl_[i];
msg->hltURL[fuUrl_.size()] = '\0';
for (UInt_t i = 0; i < fuClassName_.size(); i++)
msg->hltClassName[i] = fuClassName_[i];
msg->hltClassName[fuClassName_.size()] = '\0';
if (iFragment == 0) {
head = bufRef;
tail = bufRef;
} else {
tail->setNextReference(bufRef);
tail = bufRef;
}
if (fragmentDataSize != 0) {
UChar_t* targetAddr = (UChar_t*) msg + headerSize;
std::copy(data + currentPosition,
data + currentPosition + fragmentDataSize, targetAddr);
}
bufRef->setDataSize(fragmentSize);
remainingDataSize -= fragmentDataSize;
currentPosition += fragmentDataSize;
totalSize += fragmentSize;
} // for (iFragment ...)
} catch (toolbox::mem::exception::Exception& e) {
if (0 != head)
head->release();
totalSize = 0;
string errmsg = "Failed to allocate buffer reference.";
LOG4CPLUS_FATAL(log_, errmsg);
XCEPT_RETHROW(evf::Exception, errmsg, e);
} catch (xdaq::exception::ApplicationDescriptorNotFound& e) {
if (0 != head)
head->release();
totalSize = 0;
string errmsg = "Failed to get tid.";
LOG4CPLUS_FATAL(log_, errmsg);
XCEPT_RETHROW(evf::Exception, errmsg, e);
}
return head;
}
| UInt_t SMProxy::sendDataEvent | ( | UInt_t | fuResourceId, |
| UInt_t | runNumber, | ||
| UInt_t | evtNumber, | ||
| UInt_t | outModId, | ||
| UInt_t | fuProcessId, | ||
| UInt_t | fuGuid, | ||
| UChar_t * | data, | ||
| UInt_t | dataSize | ||
| ) | throw (evf::Exception) |
Definition at line 91 of file SMProxy.cc.
References data, alignCSCRings::e, _I2O_SM_DATA_MESSAGE_FRAME::eventID, Exception, _I2O_SM_DATA_MESSAGE_FRAME::fuGUID, _I2O_SM_DATA_MESSAGE_FRAME::fuProcID, I2O_SM_DATA, lumiQueryAPI::msg, _I2O_SM_DATA_MESSAGE_FRAME::outModID, _I2O_SM_DATA_MESSAGE_FRAME::rbBufferID, _I2O_SM_DATA_MESSAGE_FRAME::runID, and convertSQLiteXML::runNumber.
Referenced by evf::IPCMethod::sendDataEvent().
{
UInt_t totalSize = 0;
MemRef_t* bufRef = createFragmentChain(I2O_SM_DATA, dataHeaderSize_, data,
dataSize, totalSize);
I2O_SM_DATA_MESSAGE_FRAME *msg;
MemRef_t* next = bufRef;
do {
msg = (I2O_SM_DATA_MESSAGE_FRAME*) next->getDataLocation();
msg->rbBufferID = fuResourceId;
msg->runID = runNumber;
msg->eventID = evtNumber;
msg->outModID = outModId;
msg->fuProcID = fuProcessId;
msg->fuGUID = fuGuid;
} while ((next = next->getNextReference()));
try {
fuAppContext_->postFrame(bufRef, fuAppDesc_, smAppDesc_);
} catch (xdaq::exception::Exception &e) {
string errmsg = "Failed to post DATA Message.";
LOG4CPLUS_FATAL(log_, errmsg);
XCEPT_RETHROW(evf::Exception, errmsg, e);
}
return totalSize;
}
| UInt_t SMProxy::sendDqmEvent | ( | UInt_t | fuDqmId, |
| UInt_t | runNumber, | ||
| UInt_t | evtAtUpdate, | ||
| UInt_t | folderId, | ||
| UInt_t | fuProcessId, | ||
| UInt_t | fuGuid, | ||
| UChar_t * | data, | ||
| UInt_t | dataSize | ||
| ) | throw (evf::Exception) |
Send DQM Event message to SM
Definition at line 153 of file SMProxy.cc.
References data, alignCSCRings::e, _I2O_SM_DQM_MESSAGE_FRAME::eventAtUpdateID, Exception, _I2O_SM_DQM_MESSAGE_FRAME::folderID, _I2O_SM_DQM_MESSAGE_FRAME::fuGUID, _I2O_SM_DQM_MESSAGE_FRAME::fuProcID, I2O_SM_DQM, lumiQueryAPI::msg, _I2O_SM_DQM_MESSAGE_FRAME::rbBufferID, _I2O_SM_DQM_MESSAGE_FRAME::runID, and convertSQLiteXML::runNumber.
Referenced by evf::IPCMethod::sendDqmEvent().
{
UInt_t totalSize = 0;
MemRef_t* bufRef = createFragmentChain(I2O_SM_DQM, dqmHeaderSize_, data,
dataSize, totalSize);
I2O_SM_DQM_MESSAGE_FRAME *msg;
MemRef_t* next = bufRef;
do {
msg = (I2O_SM_DQM_MESSAGE_FRAME*) next->getDataLocation();
msg->rbBufferID = fuDqmId;
msg->runID = runNumber;
msg->eventAtUpdateID = evtAtUpdate;
msg->folderID = folderId;
msg->fuProcID = fuProcessId;
msg->fuGUID = fuGuid;
} while ((next = next->getNextReference()));
try {
fuAppContext_->postFrame(bufRef, fuAppDesc_, smAppDesc_);
} catch (xdaq::exception::Exception &e) {
string errmsg = "Failed to post DQM Message.";
LOG4CPLUS_FATAL(log_, errmsg);
XCEPT_RETHROW(evf::Exception, errmsg, e);
}
return totalSize;
}
| UInt_t SMProxy::sendErrorEvent | ( | UInt_t | fuResourceId, |
| UInt_t | runNumber, | ||
| UInt_t | evtNumber, | ||
| UInt_t | fuProcessId, | ||
| UInt_t | fuGuid, | ||
| UChar_t * | data, | ||
| UInt_t | dataSize | ||
| ) | throw (evf::Exception) |
Send Error Event message to SM
Definition at line 122 of file SMProxy.cc.
References data, alignCSCRings::e, _I2O_SM_DATA_MESSAGE_FRAME::eventID, Exception, _I2O_SM_DATA_MESSAGE_FRAME::fuGUID, _I2O_SM_DATA_MESSAGE_FRAME::fuProcID, I2O_SM_ERROR, lumiQueryAPI::msg, _I2O_SM_DATA_MESSAGE_FRAME::outModID, _I2O_SM_DATA_MESSAGE_FRAME::rbBufferID, _I2O_SM_DATA_MESSAGE_FRAME::runID, and convertSQLiteXML::runNumber.
Referenced by evf::IPCMethod::sendErrorEvent().
{
UInt_t totalSize = 0;
MemRef_t* bufRef = createFragmentChain(I2O_SM_ERROR, dataHeaderSize_, data,
dataSize, totalSize);
I2O_SM_DATA_MESSAGE_FRAME *msg;
MemRef_t* next = bufRef;
do {
msg = (I2O_SM_DATA_MESSAGE_FRAME*) next->getDataLocation();
msg->rbBufferID = fuResourceId;
msg->runID = runNumber;
msg->eventID = evtNumber;
msg->outModID = 0xffffffff;
msg->fuProcID = fuProcessId;
msg->fuGUID = fuGuid;
} while ((next = next->getNextReference()));
try {
fuAppContext_->postFrame(bufRef, fuAppDesc_, smAppDesc_);
} catch (xdaq::exception::Exception &e) {
string errmsg = "Failed to post ERROR Message.";
LOG4CPLUS_FATAL(log_, errmsg);
XCEPT_RETHROW(evf::Exception, errmsg, e);
}
return totalSize;
}
| UInt_t SMProxy::sendInitMessage | ( | UInt_t | fuResourceId, |
| UInt_t | outModId, | ||
| UInt_t | fuProcessId, | ||
| UInt_t | fuGuid, | ||
| UChar_t * | data, | ||
| UInt_t | dataSize, | ||
| UInt_t | nExpectedEPs | ||
| ) | throw (evf::Exception) |
Send Init message to SM
Definition at line 62 of file SMProxy.cc.
References data, alignCSCRings::e, Exception, _I2O_SM_PREAMBLE_MESSAGE_FRAME::fuGUID, _I2O_SM_PREAMBLE_MESSAGE_FRAME::fuProcID, I2O_SM_PREAMBLE, lumiQueryAPI::msg, _I2O_SM_PREAMBLE_MESSAGE_FRAME::nExpectedEPs, _I2O_SM_PREAMBLE_MESSAGE_FRAME::outModID, and _I2O_SM_PREAMBLE_MESSAGE_FRAME::rbBufferID.
Referenced by evf::IPCMethod::sendInitMessage().
{
UInt_t totalSize = 0;
MemRef_t* bufRef = createFragmentChain(I2O_SM_PREAMBLE, initHeaderSize_,
data, dataSize, totalSize);
I2O_SM_PREAMBLE_MESSAGE_FRAME *msg;
MemRef_t* next = bufRef;
do {
msg = (I2O_SM_PREAMBLE_MESSAGE_FRAME*) next->getDataLocation();
msg->rbBufferID = fuResourceId;
msg->outModID = outModId;
msg->fuProcID = fuProcessId;
msg->fuGUID = fuGuid;
msg->nExpectedEPs = nExpectedEPs;
} while ((next = next->getNextReference()));
try {
fuAppContext_->postFrame(bufRef, fuAppDesc_, smAppDesc_);
} catch (xdaq::exception::Exception &e) {
string msg = "Failed to post INIT Message.";
XCEPT_RETHROW(evf::Exception, msg, e);
}
return totalSize;
}
UInt_t evf::SMProxy::dataHeaderSize_ [private] |
UInt_t evf::SMProxy::dqmHeaderSize_ [private] |
xdaq::ApplicationContext* evf::SMProxy::fuAppContext_ [private] |
xdaq::ApplicationDescriptor* evf::SMProxy::fuAppDesc_ [private] |
std::string evf::SMProxy::fuClassName_ [private] |
std::string evf::SMProxy::fuUrl_ [private] |
toolbox::mem::Pool* evf::SMProxy::i2oPool_ [private] |
UInt_t evf::SMProxy::initHeaderSize_ [private] |
Logger evf::SMProxy::log_ [private] |
xdaq::ApplicationDescriptor* evf::SMProxy::smAppDesc_ [private] |
1.7.3