KM3NETDAQ::JDataWriter Class Reference

Runcontrol client to write data to disk. More...

Inheritance diagram for KM3NETDAQ::JDataWriter:

Classes
struct	JRunDB
	Map run number to trigger parameters. More...
struct	JValue_t
	Auxiliary data structure for I/O of trigger parameters. More...

Public Member Functions
	JDataWriter (const std::string &name, const std::string &server, const std::string &hostname, JLogger *logger, const int level, const std::string &path)
	Constructor. More...
virtual void	actionInit (int length, const char *buffer)
virtual void	actionConfigure (int length, const char *buffer)
virtual void	actionReset (int length, const char *buffer)
virtual void	actionQuit (int length, const char *buffer)
virtual void	actionStart (int length, const char *buffer)
virtual void	actionStop (int length, const char *buffer)
virtual void	setSelect (JFileDescriptorMask &mask) const
	Set the file descriptor mask for the select call. More...
virtual void	actionSelect (const JFileDescriptorMask &mask)
	Action method following last select call. More...
virtual void	actionRunning ()
	This method is repeatedly called when this client machine is in state Running and the clock interval time is non-zero. More...
void	typeout ()
	Report status of data writing. More...
virtual bool	enter (const JArgs &args)
	Enter the state machine. More...
virtual bool	enter ()
	Enter the state machine. More...
virtual bool	exit ()
	Exit the state machine. More...
const std::string &	getFullName () const
	Get full name of this run control client. More...
const JNET::JTag &	getUniqueTag () const
	Get unique tag of this run control client. More...
int	getEventNumber () const
	Get last event number. More...
bool	isRunning () const
	Check if this client is in runnig state. More...
void	replaceEvent (const JNET::JTag &oldTag, const JNET::JTag &newTag, JDAQEvent_t &event)
	Replace tag of given event in event table. More...
JDAQEvent_t *	findEvent (const JNET::JTag &tag, const std::string &event_name)
	Find event in event table. More...
template<class T >
void	addParameter (const char option, T &parameter)
	Add parameter to parser used in method enter(). More...
template<class T >
void	addParameter (const char option, T &parameter, const T &value)
	Add parameter to parser used in method enter(). More...
long long int	getClockDelay () const
	Get total delay time. More...
const std::string &	getHostname () const
	Get hostname. More...
long long int	getClockInterval () const
	Get interval time. More...
void	setClockInterval (const long long int interval_us)
	Set interval time. More...
void	resetClock ()
	Reset clock. More...
void	setSelect ()
	Set the file descriptor mask for the select call. More...
virtual void	actionInput (int length, const char *buffer)
	This method is called at ev_input. More...
virtual bool	filter (const std::string &tag, int length, const char *buffer)
	Filter message. More...
void	run ()
	Run as run control client following command messages via JNET::JControlHost. More...
void	run (const int port)
	Run for ever. More...
void	run (std::istream &in)
	Run client with commands from input stream (e.g for debugging). More...

Public Attributes
JMeta	meta
	meta data More...

Static Public Attributes
static const int	MAXIMUM_FILE_NUMBER = 100
	maximum file number for overwrite protection. More...
static const int	TIMEOUT_S = 1
	time out of update [s] More...

Protected Attributes
JSharedPointer< JControlHost >	server
	message server More...
JMessageLogger	logger
	message logger More...

Private Attributes
JLANG::JSharedPointer < JControlHost >	datawriter
std::string	path
JEEP::JTimer	timer
Long64_t	numberOfEvents
long long int	numberOfBytes
JMessageScheduler	logErrorRun
JMessageScheduler	logErrorFile
JMessageScheduler	logErrorTag
JMessageScheduler	logErrorState
std::string	hostname
	host name of data server More...
JTreeWriter_t	writer
	TTree writer. More...
std::vector< char >	buffer
	internal buffer for incoming data More...
JRunDB	run_db

Detailed Description

Runcontrol client to write data to disk.

In state running, this application will write ROOT formatted data from the data filters to disk.

Definition at line 59 of file JDataWriter.cc.

Constructor & Destructor Documentation

KM3NETDAQ::JDataWriter::JDataWriter ( const std::string &  name, const std::string &  server, const std::string &  hostname, JLogger *  logger, const int  level, const std::string &  path  )

inline

Constructor.

Parameters

name	name of client
server	name of command message server
hostname	name of data server
logger	pointer to logger
level	debug level
path	default path

Definition at line 73 of file JDataWriter.cc.

                                       :
      JDAQClient(name, server, logger, level),
      datawriter(),
      path      (path),
      hostname  (hostname)
    {
      replaceEvent(RC_CMD, RC_DWRITER, ev_configure);

      JControlHost::Throw(true);

      // map ControlHost tag to TTree writer.

      writer.insert<JDAQTypes_t>();
    }

Member Function Documentation

virtual void KM3NETDAQ::JDataWriter::actionInit ( int  length, const char *  buffer  )

inlinevirtual

Definition at line 94 of file JDataWriter.cc.

    {
      using namespace std;
      using namespace JPP;

      // start server

      try {

        datawriter.reset(new JControlHost(hostname));

        JSubscriptionList buffer;

        for (JTreeWriter_t::iterator i = writer.begin(); i != writer.end(); ++i) {
          buffer.add(JSubscriptionAll(i->first));
        }
        
        buffer.add(JSubscriptionAll(IO_TRIGGER_PARAMETERS));

        datawriter->Subscribe(buffer);
        datawriter->SendMeAlways();

        JNoticeStream(logger) << "Established connection to " << hostname;
      }
      catch(const JControlHostException& exception) {
        JErrorStream(logger) << exception;
      }
    }

virtual void KM3NETDAQ::JDataWriter::actionConfigure ( int  length, const char *  buffer  )

inlinevirtual

Definition at line 124 of file JDataWriter.cc.

    {
      using namespace std;

      long long int logger_s =  5;
      long long int update_s = 10;

      JProperties properties(JEquationParameters("=", ";", "", ""));

      properties["path"]     = path;
      properties["update_s"] = update_s;
      properties["logger_s"] = logger_s;
      
      properties.read(string(buffer, length));
      
      if (path     == "") path     = "./";
      if (update_s <=  0) update_s = 1;
      if (logger_s <=  0) logger_s = 1;

      setClockInterval(update_s * 1000000LL);

      JDebugStream(logger) << "Path <" << path << ">";
      JDebugStream(logger) << "Update period [s] " << update_s;

      logErrorRun   = JMessageScheduler(logger, JTimekeeper(logger_s * 1000000LL));
      logErrorFile  = JMessageScheduler(logger, JTimekeeper(logger_s * 1000000LL));
      logErrorTag   = JMessageScheduler(logger, JTimekeeper(logger_s * 1000000LL));
      logErrorState = JMessageScheduler(logger, JTimekeeper(logger_s * 1000000LL));

      numberOfEvents = 0;
      numberOfBytes  = 0;
    }

virtual void KM3NETDAQ::JDataWriter::actionReset ( int  length, const char *  buffer  )

inlinevirtual

Definition at line 158 of file JDataWriter.cc.

    {
      datawriter.reset();
    }

virtual void KM3NETDAQ::JDataWriter::actionQuit ( int  length, const char *  buffer  )

inlinevirtual

Definition at line 164 of file JDataWriter.cc.

    {}

virtual void KM3NETDAQ::JDataWriter::actionStart ( int  length, const char *  buffer  )

inlinevirtual

Definition at line 168 of file JDataWriter.cc.

    {
      using namespace std;
      using namespace JPP;

      JNoticeStream(logger) << string(buffer, length);

      ostringstream os;

      for (int i = 0; !writer.is_open() && i != MAXIMUM_FILE_NUMBER; ++i) {

        os.str("");

        os << path << '/' 
           << "KM3NeT" 
           << "_"  << setw(8) << setfill('0') << getDetectorID() 
           << "_"  << setw(8) << setfill('0') << getRunNumber();

        if (i != 0) {
          os << "_" << i;
        }

        os << ".root";

        try {
          writer.open(os.str().c_str());
        }
        catch(JException& exception) {
          JErrorStream(logger) << exception;
        }
      }

      if (writer.is_open())
        JNoticeStream(logger) << "Output file "     << os.str();
      else
        JErrorStream (logger) << "File not opened " << os.str();

      numberOfEvents = 0;
      numberOfBytes  = 0;

      putObject(writer.getFile(), meta);

      timer.reset();

      logErrorRun  .reset();
      logErrorFile .reset();
      logErrorTag  .reset();
      logErrorState.reset();

      run_db.reset(getRunNumber());
    }

virtual void KM3NETDAQ::JDataWriter::actionStop ( int  length, const char *  buffer  )

inlinevirtual

Definition at line 221 of file JDataWriter.cc.

    {
      typeout();

      if (timer.usec_wall > 0) {
        JNoticeStream(logger) << "I/O "  << (int) (numberOfBytes / timer.usec_wall) << " MB/s";
      }

      if (!run_db.is_written(getRunNumber())) {
        JErrorStream(logger) << "No trigger parameters written for run " << getRunNumber();
      }
        
      writer.close();

      // Release resources.
      
      std::vector<char> null;

      this->buffer.swap(null);
    }

virtual void KM3NETDAQ::JDataWriter::setSelect ( JFileDescriptorMask &  mask ) const

inlinevirtual

Set the file descriptor mask for the select call.

This implementation does nothing but may be redefined by the derived class.

Parameters

mask	file descriptor mask

Reimplemented from KM3NETDAQ::JDAQClient.

Definition at line 243 of file JDataWriter.cc.

    {
      if (datawriter.is_valid()) {
        mask.set(*datawriter);
      }
    }

virtual void KM3NETDAQ::JDataWriter::actionSelect ( const JFileDescriptorMask &  mask )

inlinevirtual

Action method following last select call.

This implementation does nothing but may be redefined by the derived class.

Parameters

mask	file descriptor mask

Reimplemented from KM3NETDAQ::JDAQClient.

Definition at line 251 of file JDataWriter.cc.

    {
      using namespace std;
      using namespace JPP;

      if (datawriter.is_valid() && mask.has(*datawriter)) {
              
        try {
          
          JPrefix prefix;
          
          datawriter->WaitHead(prefix);
          
          timer.start();
          
          buffer.resize(prefix.getSize());
          
          datawriter->GetFullData(buffer.data(), buffer.size());

          
          if (prefix.getTag() == IO_TRIGGER_PARAMETERS) {

            const string __str__(buffer.data(), buffer.size());
            
            istringstream in(__str__);

            if (!run_db.read(in)) {

              JErrorStream(logger) << "Fatal error reading trigger parameters " << __str__;

              ev_error();
            }
          }

          
          if (isRunning()) {

            // Write trigger parameters for current run if not yet done
            
            run_db.write(getRunNumber(), writer.getFile());

            JTreeWriter_t::iterator i = writer.find(prefix.toString());
            
            if (i != writer.end()) {
              
              TFile* out = i->second->GetCurrentFile();
              
              if (out != NULL && out->IsOpen()) {
                
                JDAQPreamble preamble;
                JDAQHeader   header;
              
                JByteArrayReader in(buffer.data(), buffer.size());
                
                in >> preamble >> header;
                
                in.seekg(0);   // rewind
                
                if (header.getRunNumber() == getRunNumber()) {
                  
                  const Int_t nb = i->second->copy(in);

                  if (nb < (int) buffer.size() || in.tellg() != (int) buffer.size()) {
                    JWarningStream(logger) << "Inconsistency at copy of " 
                                           << prefix.toString() << ' ' 
                                           << buffer.size()     << ' ' 
                                           << in.tellg()        << ' ' 
                                           << nb;
                  }

                  if (prefix.getTag() == IO_EVENT)
                    numberOfEvents += 1;
                  numberOfBytes    += buffer.size();
                
                  if (prefix.getTag() == IO_EVENT && numberOfEvents == 1) {
                    typeout();
                  }
                  
                } else {
                  JErrorStream(logErrorRun) << "Inconsistent run number " 
                                            << header.getRunNumber() 
                                            << " != " 
                                            << getRunNumber();
                }
              } else {
                JErrorStream(logErrorFile) << "Output file not open";
              }
            } else {
              if (prefix.getTag() != IO_TRIGGER_PARAMETERS) {
                JErrorStream(logErrorTag) << "Unknown tag <" << prefix.toString() << ">, no data written";
              }
            }       
          } else {
            JErrorStream(logErrorState) << "Not in running state <" << prefix.toString() << ">, no data written";
          }

          timer.stop();
        }
        catch(const JControlHostException& exception) {
          JErrorStream(logger) << exception;
        }
      }
    }

virtual void KM3NETDAQ::JDataWriter::actionRunning ( )

inlinevirtual

This method is repeatedly called when this client machine is in state Running and the clock interval time is non-zero.

This implementation does nothing but may be redefined by the derived class. Care has to be taken so that the time needed to execute this method should be less than the specified clock interval time (see method setClockInterval()).

Reimplemented from KM3NETDAQ::JDAQClient.

Definition at line 356 of file JDataWriter.cc.

    {
      typeout();
    }

void KM3NETDAQ::JDataWriter::typeout ( )

inline

Report status of data writing.

Definition at line 365 of file JDataWriter.cc.

    {
      std::ostringstream message;

      message << getFullName()  << KM3NETDAQ::getTokenDelimeter() << numberOfBytes  << ' ' << numberOfEvents;
      
      logger.typeout(RC_LOG, message.str());
      logger.status(message.str());
    }

virtual bool KM3NETDAQ::JDAQClient::enter ( const JArgs &  args )

inlinevirtualinherited

Enter the state machine.

This overloaded method enter reproduces the constructor. All necessary input is parsed from the list of arguments. In case of an error, the state machine is not entered.

Parameters

args	array of command line arguments

Definition at line 143 of file JDAQClient.hh.

    {
      using namespace std;

      string  server;
      string  logger;
      int     level;
      bool    use_cout;

      try {
        
        parser['H'] = make_field(server)    = "localhost";
        parser['M'] = make_field(logger)    = "localhost";
        parser['d'] = make_field(level)     = 0;
        parser['c'] = make_field(use_cout);
        
        if (parser.read(args) != 0) {
          return false;
        }
      }
      catch(const exception &error) {
        cerr << error.what() << endl;
        return false;
      }

      try {

        JLogger* out = NULL;

        if (use_cout)
          out = new JStreamLogger(cout);
        else
          out = new JControlHostLogger(logger);
        
        this->logger = JMessageLogger(out, getName(), level);

        this->server.reset(new JControlHost(server));

        return enter();
      } 
      catch(const JControlHostException& error) {
        cerr << error << endl;
        return false;
      }
    }

virtual bool KM3NETDAQ::JDAQClient::enter ( )

inlinevirtualinherited

Enter the state machine.

This method activates the subscription to JNET::JControlHost messages. In case of an error, the state machine is not entered.

Reimplemented in KM3NETDAQ::JDAQDriver.

Definition at line 195 of file JDAQClient.hh.

    {
      using namespace std;

      if (server.is_valid() && logger.is_valid()) {

        try {
          
          server->Subscribe(getSubscription(eventTable));
          server->SendMeAlways();
          server->MyId(getFullName());
          
          return CHSM::machine::enter();
        }
        catch(const JControlHostException& error) {
          JErrorStream(logger) << error;
        }

      } else {
        cerr << "Message server or logger not properly initialised." << endl;
      }

      return false;
    }

virtual bool KM3NETDAQ::JDAQClient::exit ( )

inlinevirtualinherited

Exit the state machine.

This method releases the various resources.

Definition at line 225 of file JDAQClient.hh.

    {
      try { 
        if (server.is_valid()) server.reset(NULL);
      }
      catch(const JControlHostException& error) {
      }

      try {
        if (logger.is_valid()) logger.reset(NULL);
      }
      catch(const JControlHostException& error) {
      }

      return CHSM::machine::exit();
    }

const std::string& KM3NETDAQ::JDAQClient::getFullName ( ) const

inlineinherited

Get full name of this run control client.

Returns

full name

Definition at line 248 of file JDAQClient.hh.

    {
      return full_name;
    }

const JNET::JTag& KM3NETDAQ::JDAQClient::getUniqueTag ( ) const

inlineinherited

Get unique tag of this run control client.

Returns

unique tag

Definition at line 259 of file JDAQClient.hh.

    {
      return unique_tag;
    }

int KM3NETDAQ::JDAQClient::getEventNumber ( ) const

inlineinherited

Get last event number.

Returns

event number

Definition at line 270 of file JDAQClient.hh.

    {
      return event_number;
    }

bool KM3NETDAQ::JDAQClient::isRunning ( ) const

inlineinherited

Check if this client is in runnig state.

Returns

true if running; else false

Definition at line 281 of file JDAQClient.hh.

    {
      return Main.RunControl.Operational.Running.active();
    }

void KM3NETDAQ::JDAQClient::replaceEvent ( const JNET::JTag &  oldTag, const JNET::JTag &  newTag, JDAQEvent_t &  event  )

inlineinherited

Replace tag of given event in event table.

Parameters

oldTag	old tag
newTag	new tag
event	event

Definition at line 294 of file JDAQClient.hh.

    {
      eventTable.replace(oldTag, newTag, event);
    }

JDAQEvent_t* KM3NETDAQ::JDAQClient::findEvent ( const JNET::JTag &  tag, const std::string &  event_name  )

inlineinherited

Find event in event table.

Parameters

tag	tag
event_name	event name

Returns

pointer to event or NULL

Definition at line 309 of file JDAQClient.hh.

    {
      JEventTable::const_iterator i = eventTable.find(tag, event_name);
            
      if (i != eventTable.end())
        return i->second;
      else
        return NULL;
    }

template<class T >

void KM3NETDAQ::JDAQClient::addParameter ( const char  option, T &  parameter  )

inlineinherited

Add parameter to parser used in method enter().

Parameters

option	option
parameter	parameter

Definition at line 327 of file JDAQClient.hh.

    {
      parser[option] = make_field(parameter);
    }

template<class T >

void KM3NETDAQ::JDAQClient::addParameter ( const char  option, T &  parameter, const T &  value  )

inlineinherited

Add parameter to parser used in method enter().

Parameters

option	option
parameter	parameter
value	default value

Definition at line 341 of file JDAQClient.hh.

    {
      parser[option] = make_field(parameter) = value;
    }

long long int KM3NETDAQ::JDAQClient::getClockDelay ( ) const

inlineinherited

Get total delay time.

Returns

delay time [us]

Definition at line 352 of file JDAQClient.hh.

    {
      return clock.getDelay();
    }

const std::string& KM3NETDAQ::JDAQClient::getHostname ( ) const

inlineinherited

Get hostname.

Returns

host name

Definition at line 363 of file JDAQClient.hh.

    {
      return hostname;
    }

long long int KM3NETDAQ::JDAQClient::getClockInterval ( ) const

inlineinherited

Get interval time.

Returns

interval time [us]

Definition at line 374 of file JDAQClient.hh.

    {
      return clock.getInterval();
    }

void KM3NETDAQ::JDAQClient::setClockInterval ( const long long int  interval_us )

inlineinherited

Set interval time.

Parameters

interval_us

interval time [us]

Definition at line 385 of file JDAQClient.hh.

    {
      clock.setInterval(interval_us);
    }

void KM3NETDAQ::JDAQClient::resetClock ( )

inlineinherited

Reset clock.

Definition at line 394 of file JDAQClient.hh.

    {
      clock.reset();
    }

void KM3NETDAQ::JDAQClient::setSelect ( )

inlineinherited

Set the file descriptor mask for the select call.

Definition at line 403 of file JDAQClient.hh.

    {
      select.reset();
      
      setSelect(select.getReaderMask());

      select.setReaderMask(*server);
    }

virtual void KM3NETDAQ::JDAQClient::actionInput ( int  length, const char *  buffer  )

inlinevirtualinherited

This method is called at ev_input.

Parameters

length	length of data
buffer	pointer to data

Reimplemented in AcousticDataFilter.

Definition at line 450 of file JDAQClient.hh.

    {
      using namespace std;

      JProperties properties(JEquationParameters("=", ";", "", ""), 1);

      int level = this->logger.getLevel();

      properties["debug"] = level;

      properties.read(string(buffer, length));

      this->logger.setLevel(level);
    }

virtual bool KM3NETDAQ::JDAQClient::filter ( const std::string &  tag, int  length, const char *  buffer  )

inlinevirtualinherited

Filter message.

The filter method can be overloaded so that a specific action is made before the corresponding message is processed by the state machine. The message is ignored if true is returned, else it is normally processed.

Parameters

tag	tag
length	number of characters
buffer	message

Returns

skip message or not

Definition at line 477 of file JDAQClient.hh.

    {
      return false;
    }

void KM3NETDAQ::JDAQClient::run ( )

inlineinherited

Run as run control client following command messages via JNET::JControlHost.

This method can be called once the state machine is entered. It returns when the state machine is exited. If the clock interval is non-zero, the method actionRunning() is repeatedly called when this client machine is in state Running. The file descriptor mask can be set to interrupt the timeout of the select call and clock method wait() in this calling sequence (see methods setSelect() and actionSelect()).

Definition at line 493 of file JDAQClient.hh.

    {
      using namespace std;

      while (active()) {

        try {

          setSelect();

          if (select(JTimeval(TIMEOUT_S,0)) > 0) {
            
            if (select.hasReaderMask(*server)) {
              update();
            }
            
            actionSelect(select.getReaderMask());

          } else {

            continue;
          }


          if (isRunning() && clock.getInterval() != 0LL) {

            long long int numberOfCalls = 0;
            
            clock.reset();
            
            do {
              
              ++numberOfCalls;
              
              setSelect();

              if (clock.wait(select.getReaderMask())) {
                
                if (select.hasReaderMask(*server)) {
                  update();
                }

                actionSelect(select.getReaderMask());

              } else {

                try {
                  actionRunning();
                }
                catch(const exception& error) {
                  logger.error(error.what());
                }             
              }

            } while (isRunning());
            
            if (numberOfCalls != 0) {
              JNoticeStream(logger) << "Delay per call " << clock.getDelay() / numberOfCalls / 1000 << " ms";
            }
          }
        }
        catch(const exception& error) {
          JErrorStream(logger) << "method run(): " << error.what();
        }
      }
    }

void KM3NETDAQ::JDAQClient::run ( const int  port )

inlineinherited

Run for ever.

This method can be used when the run control client is started before the run control (e.g. at boot time of the host processor). This method should be called before the state machine is entered. It launches a server which accepts a JNET::JControlHost connection from a designated application e.g. the JDAQClientStarter.cc program. The state machine is entered using the available data in the JNET::JControlHost message. After the state machine is exited, it accepts a new a JNET::JControlHost connection.

Parameters

port	port number

Definition at line 573 of file JDAQClient.hh.

    {
      JControlHostServer server(port);

      for ( ; ; ) {

        JControlHost* ps = server.AcceptClient();
        
        ps->Connected();

        JNET::JPrefix prefix;

        ps->WaitHead(prefix);

        const int length = prefix.getSize();

        char* buffer = new char[length];
        
        ps->GetFullData(buffer, length);        
        ps->PutFullData(prefix.toString(), buffer, length);

        delete ps;

        enter(JArgs(std::string(buffer, length)));

        delete [] buffer;
        
        run();

        exit();
      }
    }

void KM3NETDAQ::JDAQClient::run ( std::istream &  in )

inlineinherited

Run client with commands from input stream (e.g for debugging).

Example input format:

<tag> <event name>[#data];
<tag> <event name>[#data];

Parameters

in	input stream

Definition at line 618 of file JDAQClient.hh.

    {
      using std::string;

      string tag;
      string buffer;

      while (in >> tag && getline(in, buffer, ';')) {
        update(tag, buffer.length(), buffer.data());
      }
    }

Member Data Documentation

JMeta KM3NETDAQ::JDataWriter::meta

meta data

Definition at line 375 of file JDataWriter.cc.

const int KM3NETDAQ::JDataWriter::MAXIMUM_FILE_NUMBER = 100

static

maximum file number for overwrite protection.

Definition at line 377 of file JDataWriter.cc.

JLANG::JSharedPointer<JControlHost> KM3NETDAQ::JDataWriter::datawriter

private

Definition at line 381 of file JDataWriter.cc.

std::string KM3NETDAQ::JDataWriter::path

private

Definition at line 382 of file JDataWriter.cc.

JEEP::JTimer KM3NETDAQ::JDataWriter::timer

private

Definition at line 384 of file JDataWriter.cc.

Long64_t KM3NETDAQ::JDataWriter::numberOfEvents

private

Definition at line 385 of file JDataWriter.cc.

long long int KM3NETDAQ::JDataWriter::numberOfBytes

private

Definition at line 386 of file JDataWriter.cc.

JMessageScheduler KM3NETDAQ::JDataWriter::logErrorRun

private

Definition at line 388 of file JDataWriter.cc.

JMessageScheduler KM3NETDAQ::JDataWriter::logErrorFile

private

Definition at line 389 of file JDataWriter.cc.

JMessageScheduler KM3NETDAQ::JDataWriter::logErrorTag

private

Definition at line 390 of file JDataWriter.cc.

JMessageScheduler KM3NETDAQ::JDataWriter::logErrorState

private

Definition at line 391 of file JDataWriter.cc.

std::string KM3NETDAQ::JDataWriter::hostname

private

host name of data server

Definition at line 393 of file JDataWriter.cc.

JTreeWriter_t KM3NETDAQ::JDataWriter::writer

private

TTree writer.

Definition at line 394 of file JDataWriter.cc.

std::vector<char> KM3NETDAQ::JDataWriter::buffer

private

internal buffer for incoming data

Definition at line 395 of file JDataWriter.cc.

JRunDB KM3NETDAQ::JDataWriter::run_db

private

Definition at line 500 of file JDataWriter.cc.

const int KM3NETDAQ::JDAQClient::TIMEOUT_S = 1

staticinherited

time out of update [s]

Definition at line 631 of file JDAQClient.hh.

JSharedPointer<JControlHost> KM3NETDAQ::JDAQClient::server

protectedinherited

message server

Definition at line 635 of file JDAQClient.hh.

JMessageLogger KM3NETDAQ::JDAQClient::logger

protectedinherited

message logger

Definition at line 636 of file JDAQClient.hh.

---

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

• JDataWriter.cc