Public Member Functions
	ProcessController (RCCallback *callback)

bool	init (const std::string &parname, int nodeid=0)

void	clear ()

bool	load (int timeout)

bool	start (int expno, int runno)

bool	pause ()

bool	resume ()

bool	stop ()

bool	abort (unsigned int timeout=60)

const std::string &	getName ()

const std::string &	getParName ()

const std::string &	getExecutable ()

RunInfoBuffer &	getInfo ()

RCCallback *	getCallback ()

const Process &	getProcess () const

Process &	getProcess ()

void	setCallback (RCCallback *callback)

void	setName (const std::string &name)

void	setExecutable (const std::string &exe)

void	addArgument (const std::string &arg)

void	addArgument (const char *format,...)

template<typename T >
void	addArgument (T arg)

void	clearArguments ()

bool	isAlive () const

bool	waitReady (int timeout)

void	lock ()

void	unlock ()

Private Attributes
RunInfoBuffer	m_info

std::string	m_name

std::string	m_parname

RCCallback *	m_callback

std::string	m_exename

std::vector< std::string >	m_arg_v

Process	m_process

Mutex	m_mutex

std::string	m_message

PThread	m_th_log

PThread	m_th_process

int	m_iopipe [2]

Friends
class	ProcessSubmitter

Detailed Description

Definition at line 28 of file ProcessController.h.

Constructor & Destructor Documentation

◆ ProcessController() [1/2]

ProcessController ( )

inline

Definition at line 33 of file ProcessController.h.

    {
      m_callback = NULL;
    }

◆ ProcessController() [2/2]

ProcessController ( RCCallback * callback )

inline

Definition at line 37 of file ProcessController.h.

    {
      m_callback = callback;
    }

◆ ~ProcessController()

~ProcessController ( )

inline

Definition at line 41 of file ProcessController.h.

    {
      m_info.close();
    }

Member Function Documentation

◆ abort()

bool abort ( unsigned int timeout = 60 )

Definition at line 123 of file ProcessController.cc.

{
  m_info.clear();
  m_process.kill(SIGINT);
 
  bool sigintWasSuccessful = false;
  for (unsigned int timer = 0; timer < timeout; ++timer) {
    if (not m_process.isAlive()) {
      sigintWasSuccessful = true;
      break;
    } else {
      usleep(1000000);
    }
  }
 
  if (sigintWasSuccessful) {
    LogFile::debug("Process successfully killed with SIGINT.");
  } else {
    LogFile::warning("Process could not be killed with SIGINT, sending SIGABRT.");
    m_process.kill(SIGABRT);
  }
 
  if (m_callback != NULL)
    m_callback->set(m_parname + ".pid", -1);
  m_process.wait();
  m_th_log.cancel();
  m_th_process.cancel();
  close(m_iopipe[1]);
  close(m_iopipe[0]);
  return true;
}

◆ addArgument() [1/2]

void addArgument	(	const char *	format,
			...
	)

Definition at line 173 of file ProcessController.cc.

{
  va_list ap;
  static char ss[1024];
  va_start(ap, format);
  vsprintf(ss, format, ap);
  va_end(ap);
  m_arg_v.push_back(ss);
}

◆ addArgument() [2/2]

void addArgument ( const std::string & arg )

inline

Definition at line 73 of file ProcessController.h.

73{ m_arg_v.push_back(arg); }

◆ clear()

void clear ( )

Definition at line 39 of file ProcessController.cc.

{
  m_info.clear();
}

◆ clearArguments()

void clearArguments ( )

inline

Definition at line 77 of file ProcessController.h.

77{ m_arg_v = std::vector<std::string>(); }

◆ getCallback()

RCCallback * getCallback ( )

inline

Definition at line 67 of file ProcessController.h.

67{ return m_callback; }

◆ getExecutable()

const std::string & getExecutable ( )

inline

Definition at line 65 of file ProcessController.h.

65{ return m_exename; }

◆ getInfo()

RunInfoBuffer & getInfo ( )

inline

Definition at line 66 of file ProcessController.h.

66{ return m_info; }

◆ getName()

const std::string & getName ( )

inline

Definition at line 63 of file ProcessController.h.

63{ return m_name; }

◆ getParName()

const std::string & getParName ( )

inline

Definition at line 64 of file ProcessController.h.

64{ return m_parname; }

◆ getProcess() [1/2]

Process & getProcess ( )

inline

Definition at line 69 of file ProcessController.h.

69{ return m_process; }

◆ getProcess() [2/2]

const Process & getProcess ( ) const

inline

Definition at line 68 of file ProcessController.h.

68{ return m_process; }

◆ init()

bool init	(	const std::string &	parname,
		int	nodeid = `0`
	)

Definition at line 27 of file ProcessController.cc.

{
  m_name = StringUtil::tolower(m_callback->getNode().getName());
  m_parname = parname;
  LogFile::open(m_name + "_" + m_parname);
  if (!m_info.open(m_name + "_" + m_parname, nodeid, true)) {
    return false;
  }
  m_callback->add(new NSMVHandlerInt(m_parname + ".pid", true, false, 0), false, false);
  return true;
}

◆ isAlive()

bool isAlive ( ) const

inline

Definition at line 78 of file ProcessController.h.

78{ return m_process.isAlive(); }

◆ load()

bool load ( int timeout )

Definition at line 52 of file ProcessController.cc.

{
  m_info.clear();
  m_process.cancel();
  m_process.kill(SIGABRT);
  if (pipe(m_iopipe) < 0) {
    perror("pipe");
    return false;
  }
  m_process = Process(new ProcessSubmitter(this, m_iopipe));
  m_th_log = PThread(new LogListener(this, m_iopipe));
  m_th_process = PThread(new ProcessListener(this));
  //close(iopipe[1]);
  if (timeout > 0) {
    if (!m_info.waitReady(timeout)) {
      throw (RCHandlerException("Failed to boot " + m_parname));
    }
  }
  m_callback->set(m_parname + ".pid", m_process.get_id());
  return true;
}

◆ lock()

void lock ( )

inline

Definition at line 82 of file ProcessController.h.

82{ m_mutex.lock(); }

◆ pause()

bool pause ( )

Definition at line 101 of file ProcessController.cc.

{
  GenericLockGuard<RunInfoBuffer> lockGuard(m_info);
  if (m_info.isRunning()) {
    m_info.setState(RunInfoBuffer::PAUSED);
  } else {
    LogFile::warning("Process is not running. Pause request was ignored.");
  }
  return true;
}

◆ resume()

bool resume ( )

Definition at line 112 of file ProcessController.cc.

{
  GenericLockGuard<RunInfoBuffer> lockGuard(m_info);
  if (m_info.isPaused()) {
    m_info.setState(RunInfoBuffer::RUNNING);
  } else {
    LogFile::warning("Process is not paused. Resume request was ignored.");
  }
  return true;
}

◆ setCallback()

void setCallback ( RCCallback * callback )

inline

Definition at line 70 of file ProcessController.h.

70{ m_callback = callback; }

◆ setExecutable()

void setExecutable ( const std::string & exe )

inline

Definition at line 72 of file ProcessController.h.

72{ m_exename = exe; }

◆ setName()

void setName ( const std::string & name )

inline

Definition at line 71 of file ProcessController.h.

71{ m_name = name; }

◆ start()

bool start	(	int	expno,
		int	runno
	)

Definition at line 74 of file ProcessController.cc.

{
  GenericLockGuard<RunInfoBuffer> lockGuard(m_info);
  m_info.setExpNumber(expno);
  m_info.setRunNumber(runno);
  m_info.setSubNumber(0);
  /*
  if (m_info.getState() != RunInfoBuffer::RUNNING) {
    throw (RCHandlerException(m_parname + " is not running"));
  }
  */
  return true;
}

◆ stop()

bool stop ( )

Definition at line 88 of file ProcessController.cc.

{
  GenericLockGuard<RunInfoBuffer> lockGuard(m_info);
  m_info.setExpNumber(0);
  m_info.setRunNumber(0);
  m_info.setSubNumber(0);
  m_info.setInputCount(0);
  m_info.setInputNBytes(0);
  m_info.setOutputCount(0);
  m_info.setOutputNBytes(0);
  return true;
}

◆ unlock()

void unlock ( )

inline

Definition at line 83 of file ProcessController.h.

83{ m_mutex.unlock(); }

◆ waitReady()

bool waitReady ( int timeout )

Definition at line 44 of file ProcessController.cc.

{
  if (!m_info.waitReady(timeout)) {
    return false;
  }
  return true;
}

Friends And Related Function Documentation

◆ ProcessSubmitter

friend class ProcessSubmitter

friend

Definition at line 30 of file ProcessController.h.

Member Data Documentation

◆ m_arg_v

std::vector<std::string> m_arg_v

private

Definition at line 91 of file ProcessController.h.

◆ m_callback

RCCallback* m_callback

private

Definition at line 89 of file ProcessController.h.

◆ m_exename

std::string m_exename

private

Definition at line 90 of file ProcessController.h.

◆ m_info

RunInfoBuffer m_info

private

Definition at line 86 of file ProcessController.h.

◆ m_iopipe

int m_iopipe[2]

private

Definition at line 97 of file ProcessController.h.

◆ m_message

std::string m_message

private

Definition at line 94 of file ProcessController.h.

◆ m_mutex

Mutex m_mutex

private

Definition at line 93 of file ProcessController.h.

◆ m_name

std::string m_name

private

Definition at line 87 of file ProcessController.h.

◆ m_parname

std::string m_parname

private

Definition at line 88 of file ProcessController.h.

◆ m_process

Process m_process

private

Definition at line 92 of file ProcessController.h.

◆ m_th_log

PThread m_th_log

private

Definition at line 95 of file ProcessController.h.

◆ m_th_process

PThread m_th_process

private

Definition at line 96 of file ProcessController.h.

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

daq/slc/readout/include/ProcessController.h
daq/slc/readout/src/ProcessController.cc

Public Member Functions

Private Attributes

Friends

Detailed Description

Constructor & Destructor Documentation

◆ ProcessController() [1/2]

◆ ProcessController() [2/2]

◆ ~ProcessController()

Member Function Documentation

◆ abort()

◆ addArgument() [1/2]

◆ addArgument() [2/2]

◆ clear()

◆ clearArguments()

◆ getCallback()

◆ getExecutable()

◆ getInfo()

◆ getName()

◆ getParName()

◆ getProcess() [1/2]

◆ getProcess() [2/2]

◆ init()

◆ isAlive()

◆ load()

◆ lock()

◆ pause()

◆ resume()

◆ setCallback()

◆ setExecutable()

◆ setName()

◆ start()

◆ stop()

◆ unlock()

◆ waitReady()

Friends And Related Function Documentation

◆ ProcessSubmitter

Member Data Documentation

◆ m_arg_v

◆ m_callback

◆ m_exename

◆ m_info

◆ m_iopipe

◆ m_message

◆ m_mutex

◆ m_name

◆ m_parname

◆ m_process

◆ m_th_log

◆ m_th_process