NSMDataStore Class Reference

Classes
struct	Entry
struct	Header

Public Member Functions
bool	isOpend ()
bool	open (unsigned short max=0)
void	init ()
Entry *	add (unsigned int addr, unsigned int size, unsigned int revision, const std::string &name, const std::string &format, unsigned int rid)
void	unlink ()
Header *	getHeader ()
Entry *	get (const std::string &name)
Entry *	get (unsigned int id)
Entry *	get (unsigned int addr, unsigned int rid)
void	lock ()
void	unlock ()
bool	wait (int second)
void	signal ()

Static Public Member Functions
static NSMDataStore &	getStore ()

Private Attributes
char *	m_buf
Header *	m_header
Entry *	m_entries
SharedMemory	m_mem
MMutex	m_mutex
MCond	m_cond

Static Private Attributes
static NSMDataStore	g_store

Detailed Description

Definition at line 21 of file NSMDataStore.h.

Constructor & Destructor Documentation

NSMDataStore()

NSMDataStore ( )

inlineprivate

Definition at line 51 of file NSMDataStore.h.

    {
      m_buf = NULL;
      m_header = NULL;
      m_entries = NULL;
    }

Member Function Documentation

add()

NSMDataStore::Entry * add	(	unsigned int	addr,
		unsigned int	size,
		unsigned int	revision,
		const std::string &	name,
		const std::string &	format,
		unsigned int	rid
	)

Definition at line 58 of file NSMDataStore.cc.

{
  MLockGuard lockGuard(m_mutex);
  unsigned int n = m_header->nentries;
  for (unsigned int i = 0; i < n; i++) {
    if (m_entries[i].id > 0 && name == m_entries[i].name) {
      return &m_entries[i];
    }
  }
  memset(&m_entries[n], 0, sizeof(Entry));
  m_entries[n].id = n + 1;
  m_entries[n].rid = rid;
  m_entries[n].addr = addr;
  m_entries[n].size = size;
  m_entries[n].revision = revision;
  m_entries[n].utime = (unsigned int)Time().getSecond();
  strcpy(m_entries[n].name, name.c_str());
  strcpy(m_entries[n].format, format.c_str());
  m_header->nentries++;
  return &m_entries[n];
}

get() [1/3]

NSMDataStore::Entry * get

(

const std::string &

name

)

Definition at line 85 of file NSMDataStore.cc.

{
  MLockGuard lockGuard(m_mutex);
  const unsigned int n = m_header->nentries;
  for (unsigned int i = 0; i < n; i++) {
    if (m_entries[i].id > 0 && name == m_entries[i].name) {
      return &m_entries[i];
    }
  }
  return NULL;
}

get() [2/3]

NSMDataStore::Entry * get	(	unsigned int	addr,
		unsigned int	rid
	)

Definition at line 111 of file NSMDataStore.cc.

{
  if (id == 0) return NULL;
  MLockGuard lockGuard(m_mutex);
  const unsigned int n = m_header->nentries;
  for (unsigned int i = 0; i < n; i++) {
    if (m_entries[i].rid > 0 &&
        m_entries[i].addr == (unsigned int)addr &&
        m_entries[i].rid == (unsigned int)id) {
      return &m_entries[i];
    }
  }
  return NULL;
}

get() [3/3]

NSMDataStore::Entry * get

(

unsigned int

id

)

Definition at line 97 of file NSMDataStore.cc.

{
  if (id == 0) return NULL;
  MLockGuard lockGuard(m_mutex);
  const unsigned int n = m_header->nentries;
  for (unsigned int i = 0; i < n; i++) {
    if (m_entries[i].id > 0 &&
        m_entries[i].id == (unsigned int)id) {
      return &m_entries[i];
    }
  }
  return NULL;
}

getHeader()

Header * getHeader ( )

inline

Definition at line 69 of file NSMDataStore.h.

{ return m_header; }

getStore()

static NSMDataStore & getStore ( )

inlinestatic

Definition at line 24 of file NSMDataStore.h.

    {
      return g_store;
    }

init()

void init

(

)

Definition at line 48 of file NSMDataStore.cc.

{
  if (m_header == NULL) return;
  int max = m_header->maxentries;
  memset(m_buf, 0, m_mem.size());
  m_header->maxentries = max;
  m_mutex.init();
  m_cond.init();
}

isOpend()

bool isOpend ( )

inline

Definition at line 59 of file NSMDataStore.h.

{ return m_buf != NULL; }

lock()

void lock ( )

inline

Definition at line 73 of file NSMDataStore.h.

{ m_mutex.lock(); }

open()

bool open

(

unsigned short

max = 0

)

Definition at line 25 of file NSMDataStore.cc.

{
  size_t size = (max > 0) ? m_mutex.size() + m_cond.size() +
                sizeof(Header) + sizeof(Entry) * max : 0;
  if (!m_mem.open("NSMDataStore", size)) {
    return false;
  }
  m_mem.truncate(0);
  char* buf = (char*)m_mem.map();
  m_buf = buf;
  m_mutex = MMutex(buf);
  buf += m_mutex.size();
  m_cond = MCond(buf);
  buf += m_cond.size();
  m_header = reinterpret_cast<Header*>(buf);
  buf += sizeof(Header);
  m_entries = reinterpret_cast<Entry*>(buf);
  if (max > 0) {
    m_header->maxentries = max;
  }
  return true;
}

signal()

void signal ( )

inline

Definition at line 79 of file NSMDataStore.h.

{ m_cond.broadcast(); }

unlink()

void unlink

(

)

Definition at line 127 of file NSMDataStore.cc.

{
  const unsigned int n = m_header->nentries;
  for (unsigned int i = 0; i < n; i++) {
    char* name = m_entries[i].name;
    if (strlen(name) > 0) {
      std::string path = "";
      sockaddr_in sa;
      sa.sin_addr.s_addr = m_entries[i].addr;
      if (m_entries[i].addr > 0) {
        path = StringUtil::form("%s:%s",
                                inet_ntoa(sa.sin_addr), name);
      } else {
        path = StringUtil::form("127.0.0.1:%s", name);
      }
      shm_unlink(path.c_str());
    }
  }
  m_mem.unlink();
}

unlock()

void unlock ( )

inline

Definition at line 74 of file NSMDataStore.h.

{ m_mutex.unlock(); }

wait()

bool wait ( int  second )

inline

Definition at line 75 of file NSMDataStore.h.

    {
      return m_cond.wait(m_mutex, second, 0);
    }

Member Data Documentation

g_store

NSMDataStore g_store

staticprivate

Definition at line 30 of file NSMDataStore.h.

m_buf

char* m_buf

private

Definition at line 82 of file NSMDataStore.h.

m_cond

MCond m_cond

private

Definition at line 87 of file NSMDataStore.h.

m_entries

Entry* m_entries

private

Definition at line 84 of file NSMDataStore.h.

m_header

Header* m_header

private

Definition at line 83 of file NSMDataStore.h.

m_mem

SharedMemory m_mem

private

Definition at line 85 of file NSMDataStore.h.

m_mutex

MMutex m_mutex

private

Definition at line 86 of file NSMDataStore.h.

---

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

• daq/slc/nsm/include/NSMDataStore.h
• daq/slc/nsm/src/NSMDataStore.cc