NSMMessage Class Reference

Inheritance diagram for NSMMessage:

Collaboration diagram for NSMMessage:

Public Member Functions
	NSMMessage (const NSMNode &node)
	NSMMessage (const NSMNode &node, const NSMCommand &cmd)
	NSMMessage (const NSMNode &node, const NSMCommand &cmd, int npar, int *pars)
	NSMMessage (const NSMNode &node, const NSMCommand &cmd, int par, const std::string &data)
	NSMMessage (const NSMNode &node, const NSMCommand &cmd, int par)
	NSMMessage (const NSMNode &node, const NSMCommand &cmd, const std::string &data)
	NSMMessage (const NSMNode &node, const NSMVar &var)
	NSMMessage (const NSMNode &node, const DAQLogMessage &log)
	NSMMessage (const NSMNode &node, const DAQLogMessage &log, const NSMCommand &cmd)
	NSMMessage (const NSMNode &node, const NSMData &data)
	NSMMessage (const NSMCommand &cmd)
	NSMMessage (const NSMCommand &cmd, int par)
	NSMMessage (const NSMCommand &cmd, int npar, int *pars)
	NSMMessage (const NSMNode &node, const NSMCommand &cmd, int npar, int *pars, const std::string &data)
	NSMMessage (const NSMCommand &cmd, const std::string &data)
	NSMMessage (const NSMVar &var)
	NSMMessage (const DAQLogMessage &log)
	NSMMessage (const NSMData &data)
	NSMMessage (const NSMMessage &msg)
const NSMMessage &	operator= (const NSMMessage &msg)
void	init ()
void	init (const NSMNode &node, const NSMVar &var)
void	init (const NSMNode &node, const DAQLogMessage &log)
void	init (const NSMNode &node, const DAQLogMessage &log, const NSMCommand &cmd)
void	init (const NSMNode &node, const NSMData &data)
const char *	getRequestName () const
const char *	getNodeName () const
unsigned short	getRequestId () const
unsigned short	getSequenceId () const
unsigned short	getNodeId () const
unsigned short	getNParams () const
int	getParam (int i) const
unsigned int *	getParams ()
const unsigned int *	getParams () const
unsigned int	getLength () const
const char *	getData () const
void	setRequestName (const std::string &name)
void	setRequestName (const NSMCommand &cmd)
void	setRequestName ()
void	setNodeName (const std::string &name)
void	setNodeName (const NSMNode &node)
void	setRequestId (unsigned short id)
void	setSequenceId (unsigned short id)
void	setNodeId (unsigned short id)
void	setNParams (unsigned short id)
void	setParam (int i, unsigned int v)
void	setData (int len, const char *data)
void	setData (const std::string &text)
const NSMVar	getVar ()
NSMMessage	wait (int timeout)
void	push (const NSMMessage &msg)
void	readObject (Reader &) override
void	writeObject (Writer &) const override
size_t	read (NSMcontext *nsmc)
NSMmsg *	getMsg ()

Static Public Attributes
static const unsigned int	DATA_SIZE = NSM_TCPDATSIZ

Private Member Functions
int	try_read (int sock, char *buf, int datalen)

Private Attributes
NSMcontext *	m_nsmc
NSMmsg	m_nsm_msg
Buffer	m_data
std::string	m_nodename
std::string	m_reqname
bool	m_hasobj
NSMVar	m_var

Friends
class	NSMCommunicator

Detailed Description

Definition at line 36 of file NSMMessage.h.

Constructor & Destructor Documentation

NSMMessage() [1/20]

NSMMessage

(

)

Definition at line 117 of file NSMMessage.cc.

{
  init();
}

NSMMessage() [2/20]

NSMMessage ( const NSMNode &  node )

explicit

Definition at line 122 of file NSMMessage.cc.

{
  init();
  m_nodename = node.getName();
}

NSMMessage() [3/20]

NSMMessage	(	const NSMNode &	node,
		const NSMCommand &	cmd
	)

Definition at line 128 of file NSMMessage.cc.

{
  init();
  m_nodename = node.getName();
  m_reqname = cmd.getLabel();
}

NSMMessage() [4/20]

NSMMessage	(	const NSMNode &	node,
		const NSMCommand &	cmd,
		int	npar,
		int *	pars
	)

Definition at line 136 of file NSMMessage.cc.

{
  init();
  m_nodename = node.getName();
  m_reqname = cmd.getLabel();
  m_nsm_msg.npar = npar;
  memcpy(m_nsm_msg.pars, pars, sizeof(int) * npar);
}

NSMMessage() [5/20]

NSMMessage	(	const NSMNode &	node,
		const NSMCommand &	cmd,
		int	par,
		const std::string &	data
	)

Definition at line 160 of file NSMMessage.cc.

{
  init();
  m_nodename = node.getName();
  m_reqname = cmd.getLabel();
  m_nsm_msg.npar = 1;
  m_nsm_msg.pars[0] = par;
  setData(obj);
}

NSMMessage() [6/20]

NSMMessage	(	const NSMNode &	node,
		const NSMCommand &	cmd,
		int	par
	)

Definition at line 189 of file NSMMessage.cc.

{
  init();
  m_nodename = node.getName();
  m_reqname = cmd.getLabel();
  m_nsm_msg.npar = 1;
  m_nsm_msg.pars[0] = par;
}

NSMMessage() [7/20]

NSMMessage	(	const NSMNode &	node,
		const NSMCommand &	cmd,
		const std::string &	data
	)

Definition at line 199 of file NSMMessage.cc.

{
  init();
  m_nodename = node.getName();
  m_reqname = cmd.getLabel();
  setData(data);
}

NSMMessage() [8/20]

NSMMessage	(	const NSMNode &	node,
		const NSMVar &	var
	)

Definition at line 221 of file NSMMessage.cc.

{
  init(node, var);
}

NSMMessage() [9/20]

NSMMessage	(	const NSMNode &	node,
		const DAQLogMessage &	log
	)

Definition at line 231 of file NSMMessage.cc.

{
  init(node, log);
}

NSMMessage() [10/20]

NSMMessage	(	const NSMNode &	node,
		const DAQLogMessage &	log,
		const NSMCommand &	cmd
	)

Definition at line 236 of file NSMMessage.cc.

{
  init(node, log, cmd);
}

NSMMessage() [11/20]

NSMMessage	(	const NSMNode &	node,
		const NSMData &	data
	)

Definition at line 226 of file NSMMessage.cc.

{
  init(node, data);
}

NSMMessage() [12/20]

NSMMessage ( const NSMCommand &  cmd )

explicit

Definition at line 209 of file NSMMessage.cc.

{
  init();
  m_reqname = cmd.getLabel();
}

NSMMessage() [13/20]

NSMMessage	(	const NSMCommand &	cmd,
		int	par
	)

Definition at line 172 of file NSMMessage.cc.

{
  init();
  m_reqname = cmd.getLabel();
  m_nsm_msg.npar = 1;
  m_nsm_msg.pars[0] = par;
}

NSMMessage() [14/20]

NSMMessage	(	const NSMCommand &	cmd,
		int	npar,
		int *	pars
	)

Definition at line 257 of file NSMMessage.cc.

{
  init();
  m_reqname = cmd.getLabel();
  m_nsm_msg.npar = npar;
  memcpy(m_nsm_msg.pars, pars, sizeof(int) * npar);
}

NSMMessage() [15/20]

NSMMessage	(	const NSMNode &	node,
		const NSMCommand &	cmd,
		int	npar,
		int *	pars,
		const std::string &	data
	)

Definition at line 147 of file NSMMessage.cc.

{
  init();
  m_nodename = node.getName();
  m_reqname = cmd.getLabel();
  m_nsm_msg.npar = npar;
  memcpy(m_nsm_msg.pars, pars, sizeof(int) * npar);
  setData(data);
}

NSMMessage() [16/20]

NSMMessage	(	const NSMCommand &	cmd,
		const std::string &	data
	)

Definition at line 181 of file NSMMessage.cc.

{
  init();
  m_reqname = cmd.getLabel();
  setData(data);
}

NSMMessage() [17/20]

NSMMessage ( const NSMVar &  var )

explicit

Definition at line 242 of file NSMMessage.cc.

{
  init(NSMNode(), var);
}

NSMMessage() [18/20]

NSMMessage ( const DAQLogMessage &  log )

explicit

Definition at line 252 of file NSMMessage.cc.

{
  init(NSMNode(), log);
}

NSMMessage() [19/20]

NSMMessage ( const NSMData &  data )

explicit

Definition at line 247 of file NSMMessage.cc.

{
  init(NSMNode(), data);
}

NSMMessage() [20/20]

NSMMessage

(

const NSMMessage &

msg

)

Definition at line 215 of file NSMMessage.cc.

{
  init();
  *this = msg;
}

~NSMMessage()

virtual ~NSMMessage ( )

inlinevirtual

Definition at line 68 of file NSMMessage.h.

{ }

Member Function Documentation

getData()

const char * getData

(

)

const

Definition at line 388 of file NSMMessage.cc.

{
  if (m_nsm_msg.len > 0) return (const char*)m_data.ptr();
  else return NULL;
}

getLength()

unsigned int getLength

(

)

const

Definition at line 383 of file NSMMessage.cc.

{
  return m_nsm_msg.len;
}

getMsg()

NSMmsg * getMsg ( )

inline

Definition at line 119 of file NSMMessage.h.

{ return &m_nsm_msg; }

getNodeId()

unsigned short getNodeId

(

)

const

Definition at line 345 of file NSMMessage.cc.

{
  return m_nsm_msg.node;
}

getNodeName()

const char * getNodeName

(

)

const

Definition at line 326 of file NSMMessage.cc.

{
  if (m_nodename.size() > 0) return m_nodename.c_str();
  if (m_nsmc != NULL)
    return nsmlib_nodename(m_nsmc, m_nsm_msg.node);
  else
    return m_nodename.c_str();
}

getNParams()

unsigned short getNParams

(

)

const

Definition at line 350 of file NSMMessage.cc.

{
  return m_nsm_msg.npar;
}

getParam()

int getParam

(

int

i

)

const

Definition at line 355 of file NSMMessage.cc.

{
  return m_nsm_msg.pars[i];
}

getParams() [1/2]

unsigned int * getParams

(

)

Definition at line 376 of file NSMMessage.cc.

{
  return m_nsm_msg.pars;
}

getParams() [2/2]

const unsigned int * getParams

(

)

const

Definition at line 371 of file NSMMessage.cc.

{
  return m_nsm_msg.pars;
}

getRequestId()

unsigned short getRequestId

(

)

const

Definition at line 335 of file NSMMessage.cc.

{
  return m_nsm_msg.req;
}

getRequestName()

const char * getRequestName

(

)

const

Definition at line 281 of file NSMMessage.cc.

{
  if (m_reqname.size() > 0) return m_reqname.c_str();
  if (m_nsmc != NULL) {
    const char* reqname = nsmlib_reqname(m_nsmc, m_nsm_msg.req);
    if (reqname != NULL) {
      m_reqname = reqname;
    }
    return m_reqname.c_str();
  } else {
    m_reqname = "";
    return m_reqname.c_str();
  }
}

getSequenceId()

unsigned short getSequenceId

(

)

const

Definition at line 340 of file NSMMessage.cc.

{
  return m_nsm_msg.seq;
}

init() [1/5]

void init

(

)

Definition at line 37 of file NSMMessage.cc.

{
  m_nsmc = NULL;
  memset(&m_nsm_msg, 0, sizeof(NSMmsg));
  m_hasobj = false;
}

init() [2/5]

void init	(	const NSMNode &	node,
		const DAQLogMessage &	log
	)

Definition at line 75 of file NSMMessage.cc.

{
  init();
  m_nodename = node.getName();
  m_reqname = NSMCommand::LOG.getLabel();
  setNParams(3);
  setParam(0, (int)log.getPriority());
  setParam(1, log.getDateInt());
  setParam(2, log.getId());
  setData(log.getMessage());
}

init() [3/5]

void init	(	const NSMNode &	node,
		const DAQLogMessage &	log,
		const NSMCommand &	cmd
	)

Definition at line 87 of file NSMMessage.cc.

{
  init();
  m_nodename = node.getName();
  m_reqname = cmd.getLabel();
  setNParams(3);
  setParam(0, (int)log.getPriority());
  setParam(1, log.getDateInt());
  setParam(2, log.getId());
  setData(log.getMessage());
}

init() [4/5]

void init	(	const NSMNode &	node,
		const NSMData &	data
	)

Definition at line 100 of file NSMMessage.cc.

{
  init();
  m_nodename = node.getName();
  m_reqname = NSMCommand::DATASET.getLabel();
  setNParams(2);
  setParam(0, data.getRevision());
  setParam(1, data.getSize());
  std::string s = data.getName() + "\n" + data.getFormat();
  int len = s.size() + 1 + data.getSize();
  m_nsm_msg.len = len;
  m_data = Buffer(len);
  memcpy(m_data.ptr(), s.c_str(), s.size());
  memcpy(m_data.ptr() + s.size() + 1, data.get(), data.getSize());
  m_hasobj = false;
}

init() [5/5]

void init	(	const NSMNode &	node,
		const NSMVar &	var
	)

Definition at line 44 of file NSMMessage.cc.

{
  init();
  m_nodename = node.getName();
  m_reqname = NSMCommand::VSET.getLabel();
  m_nsm_msg.npar = 6;
  m_nsm_msg.pars[0] = (int)var.getType();
  m_nsm_msg.pars[1] = (int)var.getLength();
  m_nsm_msg.pars[2] = var.getNode().size();
  m_nsm_msg.pars[3] = var.getName().size();
  m_nsm_msg.pars[4] = var.getId();
  m_nsm_msg.pars[5] = var.getDate();
  if (var.getType() != NSMVar::NONE) {
    int size = var.getNode().size() + 1 + var.getName().size() + 1 + var.size();
    m_data = Buffer(size);
    char* pdata = (char*)m_data.ptr();
    memset(pdata, 0, size);
    memcpy(pdata, var.getNode().c_str(), var.getNode().size());
    pdata += var.getNode().size();
    *pdata = '\0';
    pdata++;
    memcpy(pdata, var.getName().c_str(), var.getName().size());
    pdata += var.getName().size();
    *pdata = '\0';
    pdata++;
    memcpy(pdata, var.get(), var.size());
    m_hasobj = false;
    m_nsm_msg.len = size;
  }
}

operator=()

const NSMMessage & operator=

(

const NSMMessage &

msg

)

Definition at line 266 of file NSMMessage.cc.

{
  m_nsmc = msg.m_nsmc;
  memcpy(&m_nsm_msg, &(msg.m_nsm_msg), sizeof(m_nsm_msg));
  m_nsm_msg.npar = msg.m_nsm_msg.npar;
  m_nsm_msg.len = msg.m_nsm_msg.len;
  m_nodename = msg.m_nodename;
  m_reqname = msg.m_reqname;
  m_hasobj = msg.m_hasobj;
  //m_data = msg.m_data;
  m_data = Buffer(m_nsm_msg.len);
  memcpy(m_data.ptr(), msg.m_data.ptr(), m_nsm_msg.len);
  return *this;
}

read()

size_t read

(

NSMcontext *

nsmc

)

Definition at line 448 of file NSMMessage.cc.

{
  if (nsmc == NULL) return 0;
  m_nsmc = nsmc;
  int sock = nsmc->sock;
  size_t count = 0;
  int ret = 0;
  NSMtcphead hp;
  int datalen = sizeof(NSMtcphead);
  if ((ret = try_read(sock, (char*)&hp, datalen)) < 0) {
    throw (NSMHandlerException("Failed to read header"));
  }
  count += ret;
  m_nsm_msg.req  = ntohs(hp.req);
  m_nsm_msg.seq  = ntohs(hp.seq);
  m_nsm_msg.node = ntohs(hp.src);
  m_nsm_msg.npar = hp.npar;
  m_nsm_msg.len  = ntohs(hp.len);
  m_nsm_msg.pars[0] = m_nsm_msg.pars[1] = 0;
 
  datalen = sizeof(int32) * m_nsm_msg.npar;
  if (datalen > 0) {
    if ((ret = try_read(sock, (char*)(m_nsm_msg.pars), datalen)) < 0) {
      throw (NSMHandlerException("Failed to read params"));
    }
    count += ret;
    for (int i = 0; i < m_nsm_msg.npar; i++) {
      m_nsm_msg.pars[i] = ntohl(m_nsm_msg.pars[i]);
    }
  }
 
  datalen = m_nsm_msg.len;
  if (datalen > 0) {
    m_data = Buffer(datalen);
    if ((ret = try_read(sock, (char*)m_data.ptr(), datalen)) < 0) {
      throw (NSMHandlerException("Failed to read data"));
    }
    count += ret;
  }
  return count;
}

readObject()

void readObject ( Reader &  reader )

overridevirtual

Implements Serializable.

Definition at line 490 of file NSMMessage.cc.

{
  setRequestName(reader.readString());
  setNodeName(reader.readString());
  setNParams(reader.readInt());
  for (int i = 0; i < getNParams(); i++) {
    setParam(i, reader.readInt());
  }
  size_t len = reader.readInt();
  m_nsm_msg.len = len;
  if (len > 0) {
    m_data = Buffer(len);
    reader.read(m_data.ptr(), len);
  }
}

setData() [1/2]

void setData

(

const std::string &

text

)

Definition at line 429 of file NSMMessage.cc.

{
  setData(text.size() + 1, text.c_str());
}

setData() [2/2]

void setData	(	int	len,
		const char *	data
	)

Definition at line 419 of file NSMMessage.cc.

{
  m_nsm_msg.len = len;
  if (len > 0 && data != NULL) {
    m_data = Buffer(len);
    memcpy(m_data.ptr(), data, len);
  }
  m_hasobj = false;
}

setNodeId()

void setNodeId

(

unsigned short

id

)

Definition at line 404 of file NSMMessage.cc.

{
  m_nsm_msg.node = id;
}

setNodeName() [1/2]

void setNodeName

(

const NSMNode &

node

)

Definition at line 321 of file NSMMessage.cc.

{
  m_nodename = node.getName();
}

setNodeName() [2/2]

void setNodeName

(

const std::string &

name

)

Definition at line 316 of file NSMMessage.cc.

{
  m_nodename = nodename;
}

setNParams()

void setNParams

(

unsigned short

id

)

Definition at line 409 of file NSMMessage.cc.

{
  m_nsm_msg.npar = npar;
}

setParam()

void setParam	(	int	i,
		unsigned int	v
	)

Definition at line 414 of file NSMMessage.cc.

{
  m_nsm_msg.pars[i] = v;
}

setRequestId()

void setRequestId

(

unsigned short

id

)

Definition at line 394 of file NSMMessage.cc.

{
  m_nsm_msg.req = id;
}

setRequestName() [1/3]

void setRequestName

(

)

Definition at line 296 of file NSMMessage.cc.

{
  if (m_nsmc != NULL) {
    const char* reqname = nsmlib_reqname(m_nsmc, m_nsm_msg.req);
    if (reqname != NULL) {
      m_reqname = reqname;
    }
  }
}

setRequestName() [2/3]

void setRequestName

(

const NSMCommand &

cmd

)

Definition at line 311 of file NSMMessage.cc.

{
  m_reqname = cmd.getLabel();
}

setRequestName() [3/3]

void setRequestName

(

const std::string &

name

)

Definition at line 306 of file NSMMessage.cc.

{
  m_reqname = reqname;
}

setSequenceId()

void setSequenceId

(

unsigned short

id

)

Definition at line 399 of file NSMMessage.cc.

{
  m_nsm_msg.seq = id;
}

try_read()

int try_read ( int  sock, char *  buf, int  datalen  )

private

Definition at line 434 of file NSMMessage.cc.

{
  int recvlen = 0;
  while (recvlen < datalen) {
    int ret;
    if ((ret = ::read(sock, buf + recvlen, datalen)) <= 0) {
      if (ret == -1 && errno == EINTR) continue;
      if (ret < 0)  return -1;
    }
    recvlen += ret;
  }
  return recvlen;
}

writeObject()

void writeObject ( Writer &  writer ) const

overridevirtual

Implements Serializable.

Definition at line 506 of file NSMMessage.cc.

{
  writer.writeString(getRequestName());
  writer.writeString(getNodeName());
  writer.writeInt(getNParams());
  for (int i = 0; i < getNParams(); i++) {
    writer.writeInt(getParam(i));
  }
  if (m_hasobj) {
    writer.writeInt(-1);
  } else {
    writer.writeInt(getLength());
  }
  if (getLength() > 0) {
    writer.write(m_data.ptr(), getLength());
  }
}

Friends And Related Function Documentation

NSMCommunicator

friend class NSMCommunicator

friend

Definition at line 38 of file NSMMessage.h.

Member Data Documentation

DATA_SIZE

const unsigned int DATA_SIZE = NSM_TCPDATSIZ

static

Definition at line 41 of file NSMMessage.h.

m_data

Buffer m_data

private

Definition at line 127 of file NSMMessage.h.

m_hasobj

bool m_hasobj

private

Definition at line 130 of file NSMMessage.h.

m_nodename

std::string m_nodename

mutableprivate

Definition at line 128 of file NSMMessage.h.

m_nsm_msg

NSMmsg m_nsm_msg

private

Definition at line 126 of file NSMMessage.h.

m_nsmc

NSMcontext* m_nsmc

mutableprivate

Definition at line 125 of file NSMMessage.h.

m_reqname

std::string m_reqname

mutableprivate

Definition at line 129 of file NSMMessage.h.

m_var

NSMVar m_var

private

Definition at line 131 of file NSMMessage.h.

---

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

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