Collaboration diagram for NSMCommunicator:

[legend]

Public Member Functions
	NSMCommunicator (const std::string &host="", int port=-1)

	NSMCommunicator (NSMcontext *nsmc)

void	init (const NSMNode &node, const std::string &host, int port)

void	setCallback (NSMCallback *callback)

void	callContext ()

int	getId () const

void	setId (int id)

NSMMessage &	getMessage ()

const NSMMessage &	getMessage () const

void	setMessage (const NSMMessage &msg)

const NSMNode &	getNode () const

int	getNodeIdByName (const std::string &name)

int	getNodePidByName (const std::string &name)

const std::string &	getHostName ()

int	getPort ()

NSMCallback &	getCallback ()

bool	isConnected (const std::string &node)

const std::string	getNodeNameById (int id)

void	pushQueue (const NSMMessage &msg)

bool	hasQueue () const

NSMMessage	popQueue ()

Static Public Member Functions
static NSMCommunicator &	select (double sec)

static NSMCommunicator &	connected (const std::string &node)

static NSMCommunicatorList &	get ()

static bool	send (const NSMMessage &msg)

Private Types
typedef std::vector< NSMCommunicator * >	NSMCommunicatorList

Private Member Functions
NSMcontext *	getContext ()

bool	sendRequest (const NSMMessage &msg)

Private Attributes
int	m_id

NSMcontext *	m_nsmc

NSMCallback *	m_callback

NSMMessage	m_message

std::string	m_host

int	m_port

NSMNode	m_node

std::queue< NSMMessage >	m_msg_q

Static Private Attributes
static NSMCommunicatorList	g_comm

static Mutex	g_mutex

static Mutex	g_mutex_select

Friends
class	NSMData

Detailed Description

Definition at line 32 of file NSMCommunicator.h.

Member Typedef Documentation

◆ NSMCommunicatorList

typedef std::vector<NSMCommunicator*> NSMCommunicatorList

private

Definition at line 34 of file NSMCommunicator.h.

Constructor & Destructor Documentation

◆ NSMCommunicator() [1/2]

NSMCommunicator	(	const std::string &	host = `""`,
		int	port = `-1`
	)

Definition at line 140 of file NSMCommunicator.cc.

{
  m_id = -1;
  m_nsmc = NULL;
  m_callback = NULL;
  m_host = host;
  m_port = port;
}

◆ NSMCommunicator() [2/2]

NSMCommunicator ( NSMcontext * nsmc )

explicit

Definition at line 149 of file NSMCommunicator.cc.

{
  m_nsmc = nsmc;
  m_id = m_nsmc->nodeid;
  m_callback = NULL;
}

◆ ~NSMCommunicator()

~NSMCommunicator ( )

inline

Definition at line 52 of file NSMCommunicator.h.

52{}

Member Function Documentation

◆ connected()

NSMCommunicator & connected ( const std::string & node )

static

Definition at line 96 of file NSMCommunicator.cc.

{
  for (NSMCommunicatorList::iterator it = g_comm.begin();
       it != g_comm.end(); ++it) {
    NSMCommunicator& com(*(*it));
    if (com.isConnected(node)) return com;
  }
  throw (NSMNotConnectedException("No connection for " + node));
}

◆ get()

static NSMCommunicatorList & get ( )

inlinestatic

Definition at line 41 of file NSMCommunicator.h.

41{ return g_comm; }

◆ getCallback()

NSMCallback & getCallback ( )

Definition at line 182 of file NSMCommunicator.cc.

{
  if (m_callback) {
    return *m_callback;
  }
  throw (std::out_of_range("No callback was registered"));
}

◆ getContext()

NSMcontext * getContext ( )

inlineprivate

Definition at line 85 of file NSMCommunicator.h.

85{ return m_nsmc; }

◆ getHostName()

const std::string & getHostName ( )

inline

Definition at line 75 of file NSMCommunicator.h.

75{ return m_host; }

◆ getId()

int getId ( ) const

inline

Definition at line 63 of file NSMCommunicator.h.

63{ return m_id; }

◆ getMessage() [1/2]

NSMMessage & getMessage ( )

inline

Definition at line 65 of file NSMCommunicator.h.

65{ return m_message; }

◆ getMessage() [2/2]

const NSMMessage & getMessage ( ) const

inline

Definition at line 66 of file NSMCommunicator.h.

66{ return m_message; }

◆ getNode()

const NSMNode & getNode ( ) const

inline

Definition at line 68 of file NSMCommunicator.h.

68{ return m_node; }

◆ getNodeIdByName()

int getNodeIdByName ( const std::string & name )

Definition at line 208 of file NSMCommunicator.cc.

{
#if NSM_PACKAGE_VERSION >= 1914
  b2nsm_context(m_nsmc);
  return b2nsm_nodeid(name.c_str());
#else
  return -1;
#endif
}

◆ getNodeNameById()

const std::string getNodeNameById ( int id )

Definition at line 218 of file NSMCommunicator.cc.

{
  const char* name = nsmlib_nodename(m_nsmc, id);
  if (name == NULL) return "";
  return name;
}

◆ getNodePidByName()

int getNodePidByName ( const std::string & name )

Definition at line 225 of file NSMCommunicator.cc.

{
#if NSM_PACKAGE_VERSION >= 1914
  b2nsm_context(m_nsmc);
  return b2nsm_nodepid(name.c_str());
#else
  return -1;
#endif
}

◆ getPort()

int getPort ( )

inline

Definition at line 76 of file NSMCommunicator.h.

76{ return m_port; }

◆ hasQueue()

bool hasQueue ( ) const

inline

Definition at line 81 of file NSMCommunicator.h.

81{ return !m_msg_q.empty(); }

◆ init()

void init	(	const NSMNode &	node,
		const std::string &	host,
		int	port
	)

Definition at line 156 of file NSMCommunicator.cc.

{
#if NSM_PACKAGE_VERSION >= 1914
  LockGuard lockGuard(g_mutex);
  if (host.size() > 0) m_host = host;
  if (port > 0) m_port = port;
  if (node.getName().size() == 0) {
    throw (NSMHandlerException("Error during init2 (nodename is empty)"));
  }
  m_nsmc = b2nsm_init2(node.getName().c_str(), 0, host.c_str(), port, port);
  if (m_nsmc == NULL) {
    m_id = -1;
    throw (NSMHandlerException("Error during init2 (%s=>%s:%d): %s",
                               node.getName().c_str(), host.c_str(),
                               m_port, b2nsm_strerror()));
  }
  g_comm.push_back(this);
  nsmlib_usesig(m_nsmc, 0);
  m_id = m_nsmc->nodeid;
  m_node = node;
#else
#warning "Wrong version of nsm2. try source daq/slc/extra/nsm2/export.sh"
#endif
}

◆ isConnected()

bool isConnected ( const std::string & node )

Definition at line 235 of file NSMCommunicator.cc.

{
  bool is_online = getNodeIdByName(node) >= 0 &&
                   getNodePidByName(node) > 0;
  return is_online;
}

◆ popQueue()

NSMMessage popQueue ( )

Definition at line 242 of file NSMCommunicator.cc.

{
  NSMMessage msg = m_msg_q.front();
  m_msg_q.pop();
  return msg;
}

◆ pushQueue()

void pushQueue ( const NSMMessage & msg )

inline

Definition at line 80 of file NSMCommunicator.h.

80{ m_msg_q.push(msg); }

◆ select()

NSMCommunicator & select ( double sec )

static

Definition at line 50 of file NSMCommunicator.cc.

{
  fd_set fds;
  int ret;
  FD_ZERO(&fds);
  int highest = 0;
  LockGuard lockGuard(g_mutex_select);
  for (NSMCommunicatorList::iterator it = g_comm.begin();
       it != g_comm.end(); ++it) {
    NSMCommunicator& com(*(*it));
    if (com.m_nsmc != NULL) {
      FD_SET(com.m_nsmc->sock, &fds);
      if (highest < com.m_nsmc->sock)
        highest = com.m_nsmc->sock;
    }
  }
  while (true) {
    errno = 0;
    if (usec >= 0) {
      double s = 0;
      double us = modf(usec, &s);
      timeval t = {(long)s, (long)(us * 1000000)};
      ret = ::select(highest + 1, &fds, NULL, NULL, &t);
    } else {
      ret = ::select(highest + 1, &fds, NULL, NULL, NULL);
    }
    if (ret != -1 || (errno != EINTR && errno != EAGAIN)) break;
  }
  if (ret < 0) {
    throw (NSMHandlerException("Failed to select"));
  }
  for (NSMCommunicatorList::iterator it = g_comm.begin();
       it != g_comm.end(); ++it) {
    NSMCommunicator& com(*(*it));
    if (com.m_nsmc != NULL) {
      if (FD_ISSET(com.m_nsmc->sock, &fds)) {
        com.m_message.read(com.m_nsmc);
        com.m_message.setRequestName();
        b2nsm_context(com.m_nsmc);
        return com;
      }
    }
  }
  throw (TimeoutException("NSMCommunicator::select was timed out"));
}

◆ send()

bool send ( const NSMMessage & msg )

static

Definition at line 106 of file NSMCommunicator.cc.

{
  bool sent = false;
#if NSM_PACKAGE_VERSION >= 1914
  bool alive = false;
  LockGuard lockGuard(g_mutex);
  std::string emsg;
  for (NSMCommunicatorList::iterator it = g_comm.begin();
       it != g_comm.end(); ++it) {
    NSMCommunicator& com(*(*it));
    const char* node = msg.getNodeName();
    if (com.isConnected(node)) {
      alive = true;
      const char* req = msg.getRequestName();
      if (node != NULL && req != NULL &&
          strlen(node) > 0 && strlen(req) > 0) {
        b2nsm_context(com.m_nsmc);
        if (b2nsm_sendany(node, req, msg.getNParams(), (int*)msg.getParams(),
                          msg.getLength(), msg.getData(), NULL) < 0) {
          emsg = b2nsm_strerror();
        }
        sent = true;
      }
    }
  }
  if (alive && !sent) {
    throw (NSMHandlerException("Failed to send request: " + emsg));
  }
#else
#warning "Wrong version of nsm2. try source daq/slc/extra/nsm2/export.sh"
#endif
  return sent;
}

◆ setCallback()

void setCallback ( NSMCallback * callback )

Definition at line 190 of file NSMCommunicator.cc.

{
  b2nsm_context(m_nsmc);
  if (callback != NULL) {
    m_callback = callback;
    NSMCallback::NSMCommandList& req_v(callback->getCommandList());
    for (NSMCallback::NSMCommandList::iterator it = req_v.begin();
         it != req_v.end(); ++it) {
      NSMCommand& command(*it);
      if (b2nsm_callback(command.getLabel(), NULL) < 0) {
        m_id = -1;
        throw (NSMHandlerException("Failed to register callback (%s)",
                                   command.getLabel()));
      }
    }
  }
}

◆ setId()

void setId ( int id )

inline

Definition at line 64 of file NSMCommunicator.h.

64{ m_id = id; }

◆ setMessage()

void setMessage ( const NSMMessage & msg )

Definition at line 249 of file NSMCommunicator.cc.

{
  m_message = msg;
}

Friends And Related Function Documentation

◆ NSMData

friend class NSMData

friend

Definition at line 36 of file NSMCommunicator.h.

Member Data Documentation

◆ g_comm

NSMCommunicatorList g_comm

staticprivate

Definition at line 45 of file NSMCommunicator.h.

◆ g_mutex

Mutex g_mutex

staticprivate

Definition at line 46 of file NSMCommunicator.h.

◆ g_mutex_select

Mutex g_mutex_select

staticprivate

Definition at line 47 of file NSMCommunicator.h.

◆ m_callback

NSMCallback* m_callback

private

Definition at line 93 of file NSMCommunicator.h.

◆ m_host

std::string m_host

private

Definition at line 95 of file NSMCommunicator.h.

◆ m_id

int m_id

private

Definition at line 91 of file NSMCommunicator.h.

◆ m_message

NSMMessage m_message

private

Definition at line 94 of file NSMCommunicator.h.

◆ m_msg_q

std::queue<NSMMessage> m_msg_q

private

Definition at line 98 of file NSMCommunicator.h.

◆ m_node

NSMNode m_node

private

Definition at line 97 of file NSMCommunicator.h.

◆ m_nsmc

NSMcontext* m_nsmc

private

Definition at line 92 of file NSMCommunicator.h.

◆ m_port

int m_port

private

Definition at line 96 of file NSMCommunicator.h.

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

daq/slc/nsm/include/NSMCommunicator.h
daq/slc/nsm/src/NSMCommunicator.cc

Public Member Functions

Static Public Member Functions

Private Types

Private Member Functions

Private Attributes

Static Private Attributes

Friends

Detailed Description

Member Typedef Documentation

◆ NSMCommunicatorList

Constructor & Destructor Documentation

◆ NSMCommunicator() [1/2]

◆ NSMCommunicator() [2/2]

◆ ~NSMCommunicator()

Member Function Documentation

◆ connected()

◆ get()

◆ getCallback()

◆ getContext()

◆ getHostName()

◆ getId()

◆ getMessage() [1/2]

◆ getMessage() [2/2]

◆ getNode()

◆ getNodeIdByName()

◆ getNodeNameById()

◆ getNodePidByName()

◆ getPort()

◆ hasQueue()

◆ init()

◆ isConnected()

◆ popQueue()

◆ pushQueue()

◆ select()

◆ send()

◆ setCallback()

◆ setId()

◆ setMessage()

Friends And Related Function Documentation

◆ NSMData

Member Data Documentation

◆ g_comm

◆ g_mutex

◆ g_mutex_select

◆ m_callback

◆ m_host

◆ m_id

◆ m_message

◆ m_msg_q

◆ m_node

◆ m_nsmc

◆ m_port