HistMemory Class Reference

Class to manipulate histograms in shared memory. More...

#include <HistMemory.h>

Collaboration diagram for HistMemory:

Classes
struct	Header
	Header information to deseriale the shared memory. More...

Public Member Functions
void	open (const char *path, unsigned int size, const char *mode="")
	Open shared memory. More...
void	init ()
	Initialize the shared memory.
void	serialize ()
	Serialize the shared memory.
std::vector< TH1 * > &	deserialize (Header *header=NULL)
	Deserialize the shared memory. More...
std::vector< TH1 * > &	get ()
	Get the list of the histograms.
TH1 *	add (TH1 *h)
	Add histogram to the list of histograms. More...

Static Public Attributes
static const unsigned int	BUFFER_SIZE = 100000000
	The size of the buffer for shared memory.

Private Attributes
std::string	m_path
	The name of the shared memory.
unsigned int	m_size
	The size of the shared memory.
MsgHandler	m_handler
	The message handler.
int	m_fd
	The file descriptor.
char *	m_body
	The pointer to the body of the message.
char *	m_buf
	The buffer to hold the message.
unsigned int	m_updateid
	The id of the udpate.
SharedMemory	m_memory
	The shared memory to hold the histograms.
MMutex	m_mutex
	The mutex lock for the shared memory.
Header *	m_header
	The header for the message.
std::vector< TH1 * >	m_hist
	The list of the histograms.

Detailed Description

Class to manipulate histograms in shared memory.

Definition at line 29 of file HistMemory.h.

Member Function Documentation

add()

TH1* add ( TH1 *  h )

inline

Add histogram to the list of histograms.

Parameters

h	The histogram to be added.

Definition at line 83 of file HistMemory.h.

    {
      if (h == NULL) return NULL;
      m_hist.push_back(h);
      return h;
    }

deserialize()

std::vector< TH1 * > & deserialize

(

Header *

header = NULL

)

Deserialize the shared memory.

Parameters

header

The Header of the shared memory.

Definition at line 83 of file HistMemory.cc.

{
  m_hist = std::vector<TH1*>();
  m_mutex.lock();
  if (m_header->updateid <= m_updateid) {
    m_mutex.unlock();
    return m_hist;
  }
  if (header != NULL) {
    memcpy(header, m_header, sizeof(Header));
  }
  m_updateid = m_header->updateid;
  memcpy(m_buf, m_body, m_header->nbytes);
  m_mutex.unlock();
 
  for (size_t i = 0; i < m_hist.size(); i++) {
    delete m_hist[i];
  }
 
  EvtMessage* msg = new EvtMessage(m_buf);
  std::vector<TObject*> objlist;
  std::vector<std::string> strlist;
  m_handler.decode_msg(msg, objlist, strlist);
  int nobjs = (msg->header())->reserved[1];
  for (int i = 0; i < nobjs; i++) {
    add((TH1*)objlist[i]->Clone());
  }
  delete msg;
  return m_hist;
}

open()

void open	(	const char *	path,
		unsigned int	size,
		const char *	mode = ""
	)

Open shared memory.

Parameters

path	The name of the shared memory.
size	The size of the shared memory.
mode	The open mode: read or write.

Definition at line 20 of file HistMemory.cc.

---

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

• dqm/analysis/include/HistMemory.h
• dqm/analysis/src/HistMemory.cc