EvtBuffer Class Reference

Public Member Functions
	EvtBuffer (int id)
bool	write (int *buf, int nbyte)
bool	writable ()
int *	buffer ()
void	read (Writer &writer)
void	lock ()
void	unlock ()
void	signal ()

Private Attributes
int	m_id
int *	m_evtbuf
Mutex	m_mutex
Cond	m_cond
bool	m_writable
bool	m_readable

Detailed Description

Definition at line 39 of file stevtserver.cc.

Constructor & Destructor Documentation

EvtBuffer()

EvtBuffer ( int  id )

inline

Definition at line 42 of file stevtserver.cc.

    {
      m_id = id;
      m_evtbuf = new int[NWORD_BUFFER];
      m_writable = true;
      m_readable = false;
    }

Member Function Documentation

buffer()

int * buffer ( )

inline

Definition at line 75 of file stevtserver.cc.

    {
      m_writable = false;
      m_readable = true;
      return m_evtbuf;
    }

lock()

void lock ( )

inline

Definition at line 101 of file stevtserver.cc.

{ m_mutex.lock(); }

read()

void read ( Writer &  writer )

inline

Definition at line 81 of file stevtserver.cc.

    {
      m_mutex.lock();
      while (true) {
        if (!m_readable) {
          m_cond.wait(m_mutex);
        } else {
          //int evtno = m_evtbuf[4];
          //LogFile::info("write %d %d", m_id, evtno);
          writer.write(m_evtbuf, m_evtbuf[0] * 4);
          m_writable = true;
          m_readable = false;
          g_mutex.lock();
          g_cond.signal();
          g_mutex.unlock();
          break;
        }
      }
      m_mutex.unlock();
    }

signal()

void signal ( )

inline

Definition at line 103 of file stevtserver.cc.

{ m_cond.signal(); }

unlock()

void unlock ( )

inline

Definition at line 102 of file stevtserver.cc.

{ m_mutex.unlock(); }

writable()

bool writable ( )

inline

Definition at line 65 of file stevtserver.cc.

    {
      m_mutex.lock();
      bool succeded = false;
      if (m_writable) {
        succeded = true;
      }
      m_mutex.unlock();
      return succeded;
    }

write()

bool write ( int *  buf, int  nbyte  )

inline

Definition at line 51 of file stevtserver.cc.

    {
      m_mutex.lock();
      bool succeded = false;
      if (m_writable) {
        memcpy(m_evtbuf, buf, nbyte);
        m_cond.signal();
        m_writable = false;
        m_readable = true;
        succeded = true;
      }
      m_mutex.unlock();
      return succeded;
    }

Member Data Documentation

m_cond

Cond m_cond

private

Definition at line 109 of file stevtserver.cc.

m_evtbuf

int* m_evtbuf

private

Definition at line 107 of file stevtserver.cc.

m_id

int m_id

private

Definition at line 106 of file stevtserver.cc.

m_mutex

Mutex m_mutex

private

Definition at line 108 of file stevtserver.cc.

m_readable

bool m_readable

private

Definition at line 111 of file stevtserver.cc.

m_writable

bool m_writable

private

Definition at line 110 of file stevtserver.cc.

---

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

• daq/storage/tools/stevtserver.cc