om::OnMonProdIPC Class Reference

Inheritance diagram for om::OnMonProdIPC:

Public Member Functions
	OnMonProdIPC (int m, const char *hdl)
int	HandleRequests ()
void	PostResources (unsigned int run, unsigned int subrun, unsigned int event)
TH1F *	RequestTH1F (const char *n)
TH2F *	RequestTH2F (const char *n)
int	RequestHistoList (std::list< std::string > &hlist)
int	RequestCurrentWatchList (std::vector< int > &db, std::vector< int > &dcm, std::vector< int > &feb, std::vector< int > &pix)
int	RequestAddToWatchList (int db, int dcm, int feb, int pix)
int	RequestRemoveFromWatchList (int db, int dcm, int feb, int pix)
void	ResetAllLocks ()

Public Attributes
int	fMode
	Client or server? More...
int	fShmId
	ID of shared memory segment. More...
key_t *	fKey
	Shared memory key. More...
char	fShmHdl [kHdlSz]
	Shared memory handle. More...
void *	fShm
	Pointer to shared segment. More...
struct IPCBlock *	fIPC
	Pointer to struct. More...

Static Public Attributes
static const int	kHdlSz = sizeof(key_t)+1

Private Member Functions
TH1F *	FindTH1F (const char *nm)
TH2F *	FindTH2F (const char *nm)
void	HistoList (std::list< std::string > &hlist)
void	AddToWatchList (int db, int dcm, int feb, int pix)
void	RemoveFromWatchList (int db, int dcm, int feb, int pix)
void	CurrentWatchList (std::vector< int > &db, std::vector< int > &dcm, std::vector< int > &feb, std::vector< int > &pix)

Detailed Description

A class that knows how to serve monitoring histograms

Definition at line 48 of file OnMonProd_module.cc.

Constructor & Destructor Documentation

OnMonProdIPC::OnMonProdIPC	(	int	m,
		const char *	hdl
	)

Definition at line 119 of file OnMonProd_module.cc.

: om::IPC(m, hdl) { }

Member Function Documentation

void OnMonProdIPC::AddToWatchList ( int  db, int  dcm, int  feb, int  pix  )

privatevirtual

Reimplemented from om::IPC.

Definition at line 129 of file OnMonProd_module.cc.

References om::WatchListManager::Add(), and om::WatchListManager::Instance().

                                                                   {
  WatchListManager::Instance().Add(db, dcm, feb, pix);
}

void OnMonProdIPC::CurrentWatchList ( std::vector< int > &  db, std::vector< int > &  dcm, std::vector< int > &  feb, std::vector< int > &  pix  )

privatevirtual

Reimplemented from om::IPC.

Definition at line 135 of file OnMonProd_module.cc.

References om::WatchListManager::GetList(), and om::WatchListManager::Instance().

                                                         {
  WatchListManager::Instance().GetList(db, dcm, feb, pix);
}

TH1F * OnMonProdIPC::FindTH1F ( const char *  nm )

privatevirtual

Reimplemented from om::IPC.

Definition at line 120 of file OnMonProd_module.cc.

References om::HistoSet::FindTH1F(), and om::HistoSet::Instance().

                                           {
  return HistoSet::Instance().FindTH1F(nm);
}

TH2F * OnMonProdIPC::FindTH2F ( const char *  nm )

privatevirtual

Reimplemented from om::IPC.

Definition at line 123 of file OnMonProd_module.cc.

References om::HistoSet::FindTH2F(), and om::HistoSet::Instance().

                                           {
  return HistoSet::Instance().FindTH2F(nm);
}

int IPC::HandleRequests ( )

inherited

Method for server application check to see if there are any requests pending

Definition at line 516 of file IPC.cxx.

References om::IPC::HandleChangeWatchList(), om::IPC::HandleCurrentWatchListRequests(), om::IPC::HandleHistogramRequests(), and om::IPC::HandleHistoListRequests().

Referenced by om::OnMonProd::analyze().

{
  int ok1 = this->HandleHistogramRequests();
  int ok2 = this->HandleHistoListRequests();
  int ok3 = this->HandleChangeWatchList();
  int ok4 = this->HandleCurrentWatchListRequests();
  if (ok1==1 && ok2==1 && ok3==1 && ok4==1) return 1;
  return 0;
}

void OnMonProdIPC::HistoList ( std::list< std::string > &  hlist )

privatevirtual

Reimplemented from om::IPC.

Definition at line 126 of file OnMonProd_module.cc.

References om::HistoSet::GetNames(), and om::HistoSet::Instance().

                                                      {
  HistoSet::Instance().GetNames(hlist);
}

void IPC::PostResources ( unsigned int  run, unsigned int  subrun, unsigned int  event  )

inherited

Post information about producer resource usage

Definition at line 528 of file IPC.cxx.

References om::ProducerResources::fCLOCK, om::ProducerResources::fCPU, om::ProducerResources::fEvent, om::IPC::fIPC, om::ProducerResources::fPID, om::IPCBlock::fProcessResources, om::ProducerResources::fRSIZE, om::ProducerResources::fRun, om::ProducerResources::fSTIME, om::ProducerResources::fSubrun, om::ProducerResources::fUTIME, updateRunHistoryTables::run, and getGoodRuns4SAM::subrun.

Referenced by om::OnMonProd::analyze().

{
  fIPC->fProcessResources.fRun    = run;
  fIPC->fProcessResources.fSubrun = subrun;
  fIPC->fProcessResources.fEvent  = event;

  struct rusage r;
  getrusage(RUSAGE_SELF, &r);

  fIPC->fProcessResources.fPID    = getpid();
  fIPC->fProcessResources.fSTIME  = r.ru_stime.tv_sec;
  fIPC->fProcessResources.fUTIME  = r.ru_utime.tv_sec;
  fIPC->fProcessResources.fCPU    = 0;
  fIPC->fProcessResources.fRSIZE  = r.ru_maxrss;  
  fIPC->fProcessResources.fCLOCK  = time(NULL);
  
}

void OnMonProdIPC::RemoveFromWatchList ( int  db, int  dcm, int  feb, int  pix  )

privatevirtual

Reimplemented from om::IPC.

Definition at line 132 of file OnMonProd_module.cc.

References om::WatchListManager::Instance(), and om::WatchListManager::Remove().

                                                                        {
  WatchListManager::Instance().Remove(db, dcm, feb, pix);
}

int IPC::RequestAddToWatchList ( int  db, int  dcm, int  feb, int  pix  )

inherited

Client tells server to add item to the watchlist db, dcm, feb, pix = hardware to be added

Parameters

sel	= selected item to be removed

Returns

1 if aok

Definition at line 346 of file IPC.cxx.

References om::cerr, febshutoff_auto::db, febshutoff_auto::dcm, allTimeWatchdog::endl, om::ChangeWatchList::fAddOrRemove, om::IPCBlock::fChangeWatchList, om::ChangeWatchList::fClientLock, om::ChangeWatchList::fDB, om::ChangeWatchList::fDCM, APDHVSetting::feb, om::ChangeWatchList::fFEB, om::IPC::fIPC, om::IPC::fMode, om::ChangeWatchList::fPIX, om::ChangeWatchList::fRequestPending, om::ChangeWatchList::fServerLock, MECModelEnuComparisons::i, om::kIPC_SERVER, kSleep, and kWait.

Referenced by om::WatchListBox::HandleAddToList().

{
  // only the clients can request changes to the watchlist
  if (fMode==kIPC_SERVER) {
    std::cerr << __FILE__ << ":" << __LINE__ 
              << " Server used as client." << std::endl;
    abort();
  }

  //
  // Wait for any locks to clear then set our own client lock
  //
  unsigned int i;
  for (i=0; i<kWait; ++i) {
    if ( (fIPC->fChangeWatchList.fClientLock     == 0) &&
         (fIPC->fChangeWatchList.fServerLock     == 0) &&
         (fIPC->fChangeWatchList.fRequestPending == 0) ) break;
    usleep(kSleep);
  }
  if (i==kWait) {
    std::cerr << __FILE__ << ":" << __LINE__ 
              << " Time out waiting for client lock, server "
              << "lock, and pending requests."
              << std::endl;
    return 0;
  }

  fIPC->fChangeWatchList.fClientLock  = 1;
  fIPC->fChangeWatchList.fAddOrRemove = 0;
  fIPC->fChangeWatchList.fDB  = db;
  fIPC->fChangeWatchList.fDCM = dcm;
  fIPC->fChangeWatchList.fFEB = feb;
  fIPC->fChangeWatchList.fPIX = pix;

  //
  // Submit a request to the server and wait for a response
  //
  fIPC->fChangeWatchList.fRequestPending = 1;
  for (i=0; i<kWait; ++i) {
    if (fIPC->fChangeWatchList.fRequestPending==0) break;
    usleep(kSleep);
  }
  if (i==kWait) {
    std::cerr << __FILE__ << ":" << __LINE__ 
              << " Time out waiting for request to be satisfied." 
              << std::endl;
    fIPC->fChangeWatchList.fClientLock = 0;
    return 0;
  }

  fIPC->fChangeWatchList.fClientLock = 0;
  return 1;
}

int IPC::RequestCurrentWatchList ( std::vector< int > &  db, std::vector< int > &  dcm, std::vector< int > &  feb, std::vector< int > &  pix  )

inherited

Client call to request the current watchlist

Definition at line 284 of file IPC.cxx.

References om::cerr, allTimeWatchdog::endl, om::WatchList::fClientLock, om::WatchList::fDB, om::WatchList::fDCM, om::WatchList::fFEB, om::IPC::fIPC, om::IPC::fMode, om::WatchList::fN, om::WatchList::fPIX, om::WatchList::fRequestPending, om::WatchList::fServerLock, om::IPCBlock::fWatchList, MECModelEnuComparisons::i, om::kIPC_SERVER, kSleep, and kWait.

{
  if (fMode==kIPC_SERVER) {
    std::cerr << __FILE__ << ":" << __LINE__ 
              << " Server used as client." << std::endl;
    abort();
  }

  //
  // Wait for any locks to clear then set our own client lock
  //
  unsigned int i;
  for (i=0; i<kWait; ++i) {
    if ( (fIPC->fWatchList.fClientLock    ==0) &&
         (fIPC->fWatchList.fServerLock    ==0) &&
         (fIPC->fWatchList.fRequestPending==0)) break;
    usleep(kSleep);
  }
  if (i==kWait) {
    std::cerr << __FILE__ << ":" << __LINE__ 
              << " Time out waiting for client lock, server "
              << "lock, and pending requests."
              << std::endl;
    return 0;
  }

  fIPC->fWatchList.fClientLock     = 1;
  fIPC->fWatchList.fRequestPending = 1;
  fIPC->fWatchList.fClientLock     = 0;  

  for (i=0; i<kWait; ++i) {
    if (fIPC->fWatchList.fRequestPending==0) break;
    usleep(kSleep);
  }
  if (i==kWait) {
    std::cerr << __FILE__ << ":" << __LINE__ 
              << " Time out waiting for request to be satisfied."
              << std::endl;
    fIPC->fWatchList.fRequestPending = 0;
    return 0;
  }

  //
  // With the request satisfied by the server, fill the list
  //
  fIPC->fWatchList.fClientLock = 1;
  for(i=0; i<fIPC->fWatchList.fN; ++i) {
    db .push_back(fIPC->fWatchList.fDB [i]);
    dcm.push_back(fIPC->fWatchList.fDCM[i]);
    feb.push_back(fIPC->fWatchList.fFEB[i]);
    pix.push_back(fIPC->fWatchList.fPIX[i]);
  }
  fIPC->fWatchList.fClientLock = 0;
  
  return 1;
}

int IPC::RequestHistoList ( std::list< std::string > &  hlist )

inherited

Client call to request the histogram list

Definition at line 225 of file IPC.cxx.

References om::cerr, allTimeWatchdog::endl, om::HistogramList::fClientLock, om::IPCBlock::fHistoList, om::IPC::fIPC, om::IPC::fMode, om::HistogramList::fN, om::HistogramList::fName, om::HistogramList::fRequestPending, om::HistogramList::fServerLock, MECModelEnuComparisons::i, om::kIPC_SERVER, kSleep, and kWait.

Referenced by om::HistoSHM::GetHistogramList().

{
  if (fMode==kIPC_SERVER) {
    std::cerr << __FILE__ << ":" << __LINE__ 
              << " Server used as client." << std::endl;
    abort();
  }

  //
  // Wait for any locks to clear then set our own client lock
  //
  unsigned int i;
  for (i=0; i<kWait; ++i) {
    if ( (fIPC->fHistoList.fClientLock    ==0) &&
         (fIPC->fHistoList.fServerLock    ==0) &&
         (fIPC->fHistoList.fRequestPending==0)) break;
    usleep(kSleep);
  }
  if (i==kWait) {
    std::cerr << __FILE__ << ":" << __LINE__ 
              << " Time out waiting for client lock, server "
              << "lock, and pending requests."
              << std::endl;
    return 0;
  }

  fIPC->fHistoList.fClientLock     = 1;
  fIPC->fHistoList.fRequestPending = 1;
  fIPC->fHistoList.fClientLock     = 0;  

  for (i=0; i<kWait; ++i) {
    if (fIPC->fHistoList.fRequestPending==0) break;
    usleep(kSleep);
  }
  if (i==kWait) {
    std::cerr << __FILE__ << ":" << __LINE__ 
              << " Time out waiting for request to be satisfied."
              << std::endl;
    fIPC->fHistoList.fRequestPending = 0;
    return 0;
  }

  //
  // With the request satisfied by the server, fill the list
  //
  fIPC->fHistoList.fClientLock = 1;
  for (i=0; i<fIPC->fHistoList.fN; ++i) {
    hlist.push_back(fIPC->fHistoList.fName[i]);
  }
  fIPC->fHistoList.fClientLock = 0;
  
  return 1;
}

int IPC::RequestRemoveFromWatchList ( int  db, int  dcm, int  feb, int  pix  )

inherited

Definition at line 402 of file IPC.cxx.

References om::cerr, febshutoff_auto::db, febshutoff_auto::dcm, allTimeWatchdog::endl, om::ChangeWatchList::fAddOrRemove, om::IPCBlock::fChangeWatchList, om::ChangeWatchList::fClientLock, om::ChangeWatchList::fDB, om::ChangeWatchList::fDCM, APDHVSetting::feb, om::ChangeWatchList::fFEB, om::IPC::fIPC, om::IPC::fMode, om::ChangeWatchList::fPIX, om::ChangeWatchList::fRequestPending, om::ChangeWatchList::fServerLock, MECModelEnuComparisons::i, om::kIPC_SERVER, kSleep, and kWait.

{
  // only the clients can request changes to the watchlist
  if (fMode==kIPC_SERVER) {
    std::cerr << __FILE__ << ":" << __LINE__ 
              << " Server used as client." << std::endl;
    abort();
  }

  //
  // Wait for any locks to clear then set our own client lock
  //
  unsigned int i;
  for (i=0; i<kWait; ++i) {
    if ( (fIPC->fChangeWatchList.fClientLock     == 0) &&
         (fIPC->fChangeWatchList.fServerLock     == 0) &&
         (fIPC->fChangeWatchList.fRequestPending == 0) ) break;
    usleep(kSleep);
  }
  if (i==kWait) {
    std::cerr << __FILE__ << ":" << __LINE__ 
              << " Time out waiting for client lock, server "
              << "lock, and pending requests."
              << std::endl;
    return 0;
  }

  fIPC->fChangeWatchList.fClientLock  = 1;
  fIPC->fChangeWatchList.fAddOrRemove = 1;
  fIPC->fChangeWatchList.fDB  = db;
  fIPC->fChangeWatchList.fDCM = dcm;
  fIPC->fChangeWatchList.fFEB = feb;
  fIPC->fChangeWatchList.fPIX = pix;

  //
  // Submit a request to the server and wait for a response
  //
  fIPC->fChangeWatchList.fRequestPending = 1;
  for (i=0; i<kWait; ++i) {
    if (fIPC->fChangeWatchList.fRequestPending==0) break;
    usleep(kSleep);
  }
  if (i==kWait) {
    std::cerr << __FILE__ << ":" << __LINE__ 
              << " Time out waiting for request to be satisfied." 
              << std::endl;
    fIPC->fChangeWatchList.fClientLock = 0;
    return 0;
  }

  fIPC->fChangeWatchList.fClientLock = 0;
  return 1;
}

TH1F * IPC::RequestTH1F ( const char *  n )

inherited

Client calls to request a histogram from the server.

Parameters

n	- name of histogram to retrieve

Returns

A new histogram. Called takes ownership

Definition at line 109 of file IPC.cxx.

References om::cerr, allTimeWatchdog::endl, om::ProducerHistogram::fClientLock, om::IPCBlock::fHistogram, om::IPC::fIPC, om::IPC::fMode, om::ProducerHistogram::fRequestPending, om::ProducerHistogram::fServerLock, make_syst_table_plots::h, MECModelEnuComparisons::i, om::kIPC_SERVER, kSleep, kWait, om::IPC::Request(), and om::IPC::UnpackTH1F().

Referenced by om::HistoSHM::GetTH1FCopy().

{
  if (fMode==kIPC_SERVER) {
    std::cerr << __FILE__ << ":" << __LINE__ 
              << " Server used as client." << std::endl;
    abort();
  }

  //
  // Wait for any locks to clear then set our own client lock
  //
  unsigned int i;
  for (i=0; i<kWait; ++i) {
    if ( (fIPC->fHistogram.fClientLock    ==0) &&
         (fIPC->fHistogram.fServerLock    ==0) &&
         (fIPC->fHistogram.fRequestPending==0)) break;
    usleep(kSleep);
  }
  if (i==kWait) {
    std::cerr << __FILE__ << ":" << __LINE__ 
              << " Time out waiting for client lock, server lock, "
              << "and pending requests. " << std::endl;
    return 0;
  }

  fIPC->fHistogram.fClientLock = 1;
  
  //
  // Submit a request to the server and wait for a response
  //
  this->Request(n, "TH1F");
  for (i=0; i<kWait; ++i) {
    if (fIPC->fHistogram.fRequestPending==0) break;
    usleep(kSleep);
  }
  if (i==kWait) {
    std::cerr << __FILE__ << ":" << __LINE__ 
              << " Time out waiting for request to be satisfied." 
              << std::endl;
    fIPC->fHistogram.fClientLock = 0;
    return 0;
  }

  //
  // With the request satisfied by the server, make a TH1F for
  // return. Now that we are done with the data in the shared memory
  // segment, release the lock we have on it.
  //
  TH1F* h = this->UnpackTH1F();
  fIPC->fHistogram.fClientLock = 0;

  return h;
}

TH2F * IPC::RequestTH2F ( const char *  n )

inherited

Definition at line 165 of file IPC.cxx.

References om::cerr, allTimeWatchdog::endl, om::ProducerHistogram::fClientLock, om::IPCBlock::fHistogram, om::IPC::fIPC, om::IPC::fMode, om::ProducerHistogram::fRequestPending, om::ProducerHistogram::fServerLock, make_syst_table_plots::h, MECModelEnuComparisons::i, om::kIPC_SERVER, kSleep, kWait, om::IPC::Request(), and om::IPC::UnpackTH2F().

Referenced by om::HistoSHM::GetTH2FCopy().

{
  if (fMode==kIPC_SERVER) {
    std::cerr << __FILE__ << ":" << __LINE__ 
              << " Server used as client." << std::endl;
    abort();
  }

  //
  // Wait for any locks to clear then set our own client lock
  //
  unsigned int i;
  for (i=0; i<kWait; ++i) {
    if ( (fIPC->fHistogram.fClientLock    ==0) &&
         (fIPC->fHistogram.fServerLock    ==0) &&
         (fIPC->fHistogram.fRequestPending==0)) break;
    usleep(kSleep);
  }
  if (i==kWait) {
    std::cerr << __FILE__ << ":" << __LINE__ 
              << " Time out waiting for client lock, server lock, "
              << "and pending requests. " 
              << std::endl;
    return 0;
  }

  fIPC->fHistogram.fClientLock = 1;
  
  //
  // Submit a request to the server and wait for a response
  //
  this->Request(n, "TH2F");
  for (i=0; i<kWait; ++i) {
    if (fIPC->fHistogram.fRequestPending==0) break;
    usleep(kSleep);
  }
  if (i==kWait) {
    std::cerr << __FILE__ << ":" << __LINE__ 
              << " Time out waiting for request to be satisfied."
              << std::endl;
    fIPC->fHistogram.fClientLock = 0;
    return 0;
  }

  //
  // With the request satisfied by the server, make a TH1F for
  // return. Now that we are done with the data in the shared memory
  // segment, release the lock we have on it.
  //
  TH2F* h = this->UnpackTH2F();
  fIPC->fHistogram.fClientLock = 0;

  return h;
}

void IPC::ResetAllLocks ( )

inherited

For "emergency use" only. Clear all locks in the event they get stuck.

Definition at line 843 of file IPC.cxx.

References om::IPCBlock::fChangeWatchList, om::HistogramList::fClientLock, om::WatchList::fClientLock, om::ProducerHistogram::fClientLock, om::ChangeWatchList::fClientLock, om::IPCBlock::fHistogram, om::IPCBlock::fHistoList, om::ProducerHistogram::fHistoOK, om::IPC::fIPC, om::HistogramList::fRequestPending, om::WatchList::fRequestPending, om::ProducerHistogram::fRequestPending, om::ChangeWatchList::fRequestPending, om::HistogramList::fServerLock, om::WatchList::fServerLock, om::ProducerHistogram::fServerLock, om::ChangeWatchList::fServerLock, and om::IPCBlock::fWatchList.

Referenced by om::MenuBar::ResetLocks().

{
  fIPC->fHistoList.fClientLock     = 0;
  fIPC->fHistoList.fServerLock     = 0;
  fIPC->fHistoList.fRequestPending = 0;
  
  fIPC->fHistogram.fClientLock     = 0;
  fIPC->fHistogram.fServerLock     = 0;
  fIPC->fHistogram.fRequestPending = 0;
  fIPC->fHistogram.fHistoOK        = 0;
  
  fIPC->fWatchList.fClientLock     = 0;
  fIPC->fWatchList.fServerLock     = 0;
  fIPC->fWatchList.fRequestPending = 0;
  
  fIPC->fChangeWatchList.fClientLock     = 0;
  fIPC->fChangeWatchList.fServerLock     = 0;
  fIPC->fChangeWatchList.fRequestPending = 0;
}

Member Data Documentation

struct IPCBlock* om::IPC::fIPC

inherited

Pointer to struct.

Definition at line 151 of file IPC.h.

Referenced by om::HistoSHM::GetStatus(), om::IPC::HandleChangeWatchList(), om::IPC::HandleCurrentWatchListRequests(), om::IPC::HandleHistogramRequests(), om::IPC::HandleHistoListRequests(), om::IPC::IPC(), om::IPC::PostResources(), om::IPC::Publish1DHistogram(), om::IPC::Publish2DHistogram(), om::IPC::Request(), om::IPC::RequestAddToWatchList(), om::IPC::RequestCurrentWatchList(), om::IPC::RequestHistoList(), om::IPC::RequestRemoveFromWatchList(), om::IPC::RequestTH1F(), om::IPC::RequestTH2F(), om::IPC::ResetAllLocks(), om::IPC::UnpackTH1F(), om::IPC::UnpackTH2F(), and om::IPC::~IPC().

key_t* om::IPC::fKey

inherited

Shared memory key.

Definition at line 148 of file IPC.h.

Referenced by om::IPC::IPC().

int om::IPC::fMode

inherited

Client or server?

Definition at line 146 of file IPC.h.

Referenced by om::IPC::HandleChangeWatchList(), om::IPC::HandleCurrentWatchListRequests(), om::IPC::HandleHistogramRequests(), om::IPC::HandleHistoListRequests(), om::IPC::IPC(), om::IPC::RequestAddToWatchList(), om::IPC::RequestCurrentWatchList(), om::IPC::RequestHistoList(), om::IPC::RequestRemoveFromWatchList(), om::IPC::RequestTH1F(), om::IPC::RequestTH2F(), and om::IPC::~IPC().

void* om::IPC::fShm

inherited

Pointer to shared segment.

Definition at line 150 of file IPC.h.

Referenced by om::IPC::IPC(), and om::IPC::~IPC().

char om::IPC::fShmHdl[kHdlSz]

inherited

Shared memory handle.

Definition at line 149 of file IPC.h.

Referenced by om::HistoSHM::GetStatus(), and om::IPC::IPC().

int om::IPC::fShmId

inherited

ID of shared memory segment.

Definition at line 147 of file IPC.h.

Referenced by om::IPC::IPC(), and om::IPC::~IPC().

const int om::IPC::kHdlSz = sizeof(key_t)+1

staticinherited

Definition at line 145 of file IPC.h.

Referenced by om::IPC::IPC().

---

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

• /cvmfs/nova-development.opensciencegrid.org/novasoft/releases/N21-01-26/OnlineMonitoring/producer/OnMonProd_module.cc