Public Member Functions
	NSMNodeDaemon (NSMCallback callback1, const std::string &host1, int port1, NSMCallback callback2=NULL, const std::string &host2="", int port2=0)

void	add (NSMCallback *callback, const std::string &host, int port)

void	run ()

Private Attributes
int	m_timeout

std::vector< NSMCallback * >	m_callback

Detailed Description

Definition at line 19 of file NSMNodeDaemon.h.

Constructor & Destructor Documentation

◆ NSMNodeDaemon() [1/2]

NSMNodeDaemon ( )

inline

Definition at line 22 of file NSMNodeDaemon.h.

22: m_timeout(0) {}

◆ NSMNodeDaemon() [2/2]

NSMNodeDaemon	(	NSMCallback *	callback1,
		const std::string &	host1,
		int	port1,
		NSMCallback *	callback2 = `NULL`,
		const std::string &	host2 = `""`,
		int	port2 = `0`
	)

inline

Definition at line 23 of file NSMNodeDaemon.h.

      : m_timeout(0)
    {
      add(callback1, host1, port1);
      add(callback2, host2, port2);
    }

◆ ~NSMNodeDaemon()

virtual ~NSMNodeDaemon ( )

inlinevirtual

Definition at line 32 of file NSMNodeDaemon.h.

32{}

Member Function Documentation

◆ add()

void add	(	NSMCallback *	callback,
		const std::string &	host,
		int	port
	)

Definition at line 25 of file NSMNodeDaemon.cc.

{
  try {
    if (callback != NULL && host.size() > 0 && port > 0) {
      NSMCommunicator* com = new NSMCommunicator();
      NSMNode& node(callback->getNode());
      com->init(node, host, port);
      com->setCallback(callback);
      callback->init(*com);
      callback->alloc_open(*com);
      m_timeout = callback->getTimeout();
      if (callback->getLogNode().getName().size() == 0) {
        ConfigFile file("slowcontrol");
        callback->setLogNode(NSMNode(file.get("log.collector")));
      }
      m_callback.push_back(callback);
    }
  } catch (const std::exception& e) {
    LogFile::fatal(e.what());
    exit(1);
  }
}

◆ run()

void run ( )

Definition at line 49 of file NSMNodeDaemon.cc.

{
  NSMCommunicatorList& com_v(NSMCommunicator::get());
  try {
    {
      std::string nodename = com_v[0]->getCallback().getNode().getName();
      std::string filename = ("/tmp/nsmvget." + StringUtil::tolower(nodename));
      std::ifstream fin(filename.c_str());
      std::vector<std::string> nodes, vnames;
      std::string node, vname;
      while (fin >> node >> vname) {
        nodes.push_back(node);
        vnames.push_back(vname);
      }
      ::remove(filename.c_str());
      for (size_t i = 0; i < com_v.size(); i++) {
        NSMCommunicator& com(*com_v[i]);
        for (size_t j = 0; j < nodes.size(); j++) {
          com.getCallback().vget(nodes[j], vnames[j]);
        }
      }
    }
    double t0 = Time().get();
    while (true) {
      try {
        NSMCommunicator& com(NSMCommunicator::select(m_timeout));
        com.getCallback().perform(com);
      } catch (const TimeoutException& e) {}
      for (size_t i = 0; i < com_v.size(); i++) {
        NSMCommunicator& com(*com_v[i]);
        while (com.hasQueue()) {
          com.setMessage(com.popQueue());
          com.getCallback().perform(com);
        }
      }
      double t = Time().get();
      if (t - t0 >= m_timeout) {
        for (size_t i = 0; i < com_v.size(); i++) {
          NSMCommunicator& com(*com_v[i]);
          com.getCallback().timeout(com);
          com.getCallback().alloc_open(com);
        }
        t0 = t;
      }
    }
  } catch (const std::exception& e) {
    LogFile::fatal("NSM node brdge : Caught exception %s\n"
                   "Terminate process...", e.what());
  }
  for (size_t i = 0; i < com_v.size(); i++) {
    NSMCommunicator& com(*com_v[i]);
    com.getCallback().term();
  }
}

Member Data Documentation

◆ m_callback

std::vector<NSMCallback*> m_callback

private

Definition at line 42 of file NSMNodeDaemon.h.

◆ m_timeout

int m_timeout