---

edm::FUShmOutputModule Class Reference

#include <EventFilter/Modules/src/FUShmOutputModule.h>

List of all members.

Public Member Functions
void	doOutputEvent (EventMsgBuilder const &eventMessage)
void	doOutputHeader (InitMsgBuilder const &initMessage)
	FUShmOutputModule (edm::ParameterSet const &ps)
void	start ()
void	stop ()
	~FUShmOutputModule ()
Private Attributes
evf::FUShmBuffer *	shmBuffer_
Static Private Attributes
static uint32	fuGuidValue_ = 0
static bool	fuIdsInitialized_ = false
	Initialize the static variables for the filter unit identifiers.
static uint32	fuProcId_ = 0

---

Detailed Description

Definition at line 48 of file FUShmOutputModule.h.

---

Constructor & Destructor Documentation

edm::FUShmOutputModule::FUShmOutputModule

(

edm::ParameterSet const &

ps

)

Definition at line 44 of file FUShmOutputModule.cc.

References lat::endl(), FDEBUG, fuGuidValue_, fuIdsInitialized_, fuProcId_, L, and edm::Guid::toString().

00044                                                                :
00045     shmBuffer_(0)
00046   {
00047     FDEBUG(9) << "FUShmOutputModule: constructor" << endl;
00048 
00049     if (! fuIdsInitialized_) {
00050       fuIdsInitialized_ = true;
00051 
00052       edm::Guid guidObj(true);
00053       std::string guidString = guidObj.toString();
00054       //std::cout << "EventOutput GUID string = " << guidString << std::endl;
00055 
00056       uLong crc = crc32(0L, Z_NULL, 0);
00057       Bytef* buf = (Bytef*)guidString.data();
00058       crc = crc32(crc, buf, guidString.length());
00059       fuGuidValue_ = crc;
00060 
00061       fuProcId_ = getpid();
00062       //std::cout << "EventOutput GUID value = 0x" << std::hex << fuGuidValue_ << std::dec
00063       //          << " for PID = " << fuProcId_ << std::endl;
00064     }
00065   }
  

edm::FUShmOutputModule::~FUShmOutputModule

(

)

Definition at line 67 of file FUShmOutputModule.cc.

References SM_SharedMemoryHandle::detachShmBuffer(), lat::endl(), and FDEBUG.

  {
    FDEBUG(9) << "FUShmOutputModule: FUShmOutputModule destructor" << endl;
    sm_sharedmemory.detachShmBuffer();
    //shmdt(shmBuffer_);
  }

---

Member Function Documentation

void edm::FUShmOutputModule::doOutputEvent

(

EventMsgBuilder const &

eventMessage

)

Definition at line 97 of file FUShmOutputModule.cc.

References lat::endl(), FDEBUG, fuGuidValue_, fuProcId_, SM_SharedMemoryHandle::getShmBuffer(), shmBuffer_, size, EventMsgBuilder::size(), EventMsgBuilder::startAddress(), and evf::FUShmBuffer::writeRecoEventData().

  {
    if(!shmBuffer_) edm::LogError("FUShmOutputModule") 
      << " Invalid shared memory buffer at first event"
      << " Make sure you configure the ResourceBroker before the FUEventProcessor! "
      << " No event is sent - this is fatal! Should throw here";
    else
    {
      unsigned char* buffer = (unsigned char*) eventMessage.startAddress();
      unsigned int size = eventMessage.size();
      EventMsgView eventView(eventMessage.startAddress());
      unsigned int runid = eventView.run();
      unsigned int eventid = eventView.event();
      unsigned int outModId = eventView.outModId();
      FDEBUG(10) << "FUShmOutputModule: event size = " << size << std::endl;
      //bool ret = shmBuffer_->writeRecoEventData(runid, eventid, outModId, buffer, size);
      bool ret = sm_sharedmemory.getShmBuffer()->writeRecoEventData(runid, eventid, outModId, fuProcId_, fuGuidValue_, buffer, size);
      if(!ret) edm::LogError("FUShmOutputModule") << " Error with writing data to ShmBuffer";
    }
  }

void edm::FUShmOutputModule::doOutputHeader

(

InitMsgBuilder const &

initMessage

)

Definition at line 74 of file FUShmOutputModule.cc.

References lat::endl(), FDEBUG, fuGuidValue_, fuProcId_, SM_SharedMemoryHandle::getShmBuffer(), InitMsgView::outputModuleId(), shmBuffer_, InitMsgBuilder::size(), size, InitMsgBuilder::startAddress(), and evf::FUShmBuffer::writeRecoInitMsg().

  {
    //if(!shmBuffer_) shmBuffer_ = evf::FUShmBuffer::getShmBuffer();
    if(!shmBuffer_) shmBuffer_ = sm_sharedmemory.getShmBuffer();
    if(!shmBuffer_) edm::LogError("FUShmOutputModule") 
      << " Error getting shared memory buffer for INIT. " 
      << " Make sure you configure the ResourceBroker before the FUEventProcessor! "
      << " No INIT is sent - this is probably fatal!";
    if(shmBuffer_)
    {
      unsigned char* buffer = (unsigned char*) initMessage.startAddress();
      unsigned int size = initMessage.size();
      FDEBUG(10) << "writing out INIT message with size = " << size << std::endl;
      // no method in InitMsgBuilder to get the output module id, recast
      InitMsgView dummymsg(buffer);
      uint32 dmoduleId = dummymsg.outputModuleId();

      //bool ret = shmBuffer_->writeRecoInitMsg(dmoduleId, buffer, size);
      bool ret = sm_sharedmemory.getShmBuffer()->writeRecoInitMsg(dmoduleId, fuProcId_, fuGuidValue_, buffer, size);
      if(!ret) edm::LogError("FUShmOutputModule") << " Error writing preamble to ShmBuffer";
    }
  }

void edm::FUShmOutputModule::start

(

void

)

Definition at line 118 of file FUShmOutputModule.cc.

References SM_SharedMemoryHandle::getShmBuffer(), and shmBuffer_.

  {
    //shmBuffer_ = evf::FUShmBuffer::getShmBuffer();
    shmBuffer_ = sm_sharedmemory.getShmBuffer();
    if(0==shmBuffer_) 
      edm::LogError("FUShmOutputModule")<<"Failed to attach to shared memory";
  }

void edm::FUShmOutputModule::stop

(

)

Definition at line 126 of file FUShmOutputModule.cc.

References SM_SharedMemoryHandle::detachShmBuffer(), lat::endl(), FDEBUG, and shmBuffer_.

  {
    FDEBUG(9) << "FUShmOutputModule: sending terminate run" << std::endl;
    if(0!=shmBuffer_){
      sm_sharedmemory.detachShmBuffer();
      //shmdt(shmBuffer_);
      shmBuffer_ = 0;
    }
  }

---

Member Data Documentation

uint32 edm::FUShmOutputModule::fuGuidValue_ = 0 [static, private]

Definition at line 66 of file FUShmOutputModule.h.

Referenced by doOutputEvent(), doOutputHeader(), and FUShmOutputModule().

bool edm::FUShmOutputModule::fuIdsInitialized_ = false [static, private]

Initialize the static variables for the filter unit identifiers.

Definition at line 64 of file FUShmOutputModule.h.

Referenced by FUShmOutputModule().

uint32 edm::FUShmOutputModule::fuProcId_ = 0 [static, private]

Definition at line 65 of file FUShmOutputModule.h.

Referenced by doOutputEvent(), doOutputHeader(), and FUShmOutputModule().

evf::FUShmBuffer* edm::FUShmOutputModule::shmBuffer_ [private]

Definition at line 62 of file FUShmOutputModule.h.

Referenced by doOutputEvent(), doOutputHeader(), start(), and stop().

---

The documentation for this class was generated from the following files:

• EventFilter/Modules/src/FUShmOutputModule.h
• EventFilter/Modules/src/FUShmOutputModule.cc

---