80 const std::string&
path) :
135 properties[
"path"] =
path;
139 properties.
read(
string(buffer, length));
240 this->buffer.swap(null);
276 istringstream
in(__str__);
297 TFile* out = i->second->GetCurrentFile();
299 if (out != NULL && out->IsOpen()) {
307 in >> preamble >> version >> header;
313 const Int_t nb = i->second->copy(
in);
315 if (nb < (
int)
buffer.size() ||
in.tellg() != (int)
buffer.size()) {
333 << header.getRunNumber()
369 std::ostringstream message;
431 while (!this->empty() && this->begin()->
first < run) {
432 this->erase(this->begin());
444 const_iterator p = this->find(run);
446 return p != this->end() && p->second.is_written;
462 in.clear(std::ios::eofbit);
464 if (in && run != -1) {
468 if (value.
count == 0) {
492 if (p != this->end() && p->second.count != 0 && !p->second.is_written) {
494 file->WriteTObject(&p->second.parameters);
496 p->second.is_written =
true;
513 int main(
int argc,
char* argv[])
517 using namespace KM3NETDAQ;
529 JParser<> zap(
"Application for writing real-time data to disk.");
541 catch(
const exception &error) {
542 FATAL(error.what() << endl);
JDataWriter(const std::string &name, const std::string &server, const std::string &hostname, JLogger *logger, const int level, const std::string &path)
Constructor.
Message logger with time scheduler.
Utility class to parse command line options.
virtual void actionStop(int length, const char *buffer) override
Runcontrol client to write data to disk.
bool read(const JEquation &equation)
Read equation.
std::vector< char > buffer
internal buffer for incoming data
void status(const JMessage_t &message)
int main(int argc, char *argv[])
static const int MAXIMUM_FILE_NUMBER
maximum file number for overwrite protection.
ROOT TTree parameter settings of various packages.
virtual void actionQuit(int length, const char *buffer) override
JDAQStateMachine::ev_configure_event ev_configure
JDAQStateMachine::ev_error_event ev_error
then set_variable PMT_FILE set_variable DAQ_FILE set_variable OUTPUT_FILE set_variable DETECTOR else fatal Wrong number of arguments fi set_variable RUNBYRUN file
std::string getProcessName(const std::string &name, const std::string &process)
Get process name of run control client.
Message logging based on std::ostream.
bool has(const int file_descriptor) const
Has file descriptor.
void set(const int file_descriptor)
Set file descriptor.
void reset(const int run)
Remove all entries before given run.
JMessageScheduler logErrorState
Interface for logging messages.
Message logging based on ControlHost.
Utility class to parse parameter values.
void setClockInterval(const long long int interval_us)
Set interval time.
Auxiliary data structure for I/O of trigger parameters.
std::string hostname
host name of data server
*fatal Wrong number of arguments esac JCookie sh typeset Z DETECTOR typeset Z SOURCE_RUN typeset Z TARGET_RUN set_variable PARAMETERS_FILE $WORKDIR parameters
Simple data structure to support I/O of equations (see class JLANG::JEquation).
static const JNET::JTag IO_TRIGGER_PARAMETERS
JTreeWriter_t writer
TTree writer.
void replaceEvent(const JTag &oldTag, const JTag &newTag, JDAQEvent_t &event)
Replace tag of given event in event table.
JSharedPointer< JControlHost > server
message server
Auxiliary class for a type holder.
void run()
Run as run control client following command messages via JNET::JControlHost.
std::string getFullPath(const std::string &path)
Get full path, i.e. add JEEP::PATHNAME_SEPARATOR if necessary.
bool is_written(const int run) const
Check if trigger parameters have been written for given run.
virtual void setSelect(JFileDescriptorMask &mask) const override
Set the file descriptor mask for the select call.
int getSize() const
Get size.
virtual void actionSelect(const JFileDescriptorMask &mask) override
Action method following last select call.
Utility class to parse parameter values.
virtual bool is_open() const override
Check is file is open.
then echo The file $DIR KM3NeT_00000001_00000000 root already please rename or remove it first
virtual void actionConfigure(int length, const char *buffer) override
long long int numberOfBytes
virtual void actionRunning() override
This method is repeatedly called when this client machine is in state Running and the clock interval ...
Map run number to trigger parameters.
JMessageScheduler logErrorRun
int getDetectorID() const
Get detector identifier.
static JKey_t getKey(JType< T > type)
Get key.
TFile * getFile() const
Get file.
Scheduling of actions via fixed latency intervals.
virtual void actionInit(int length, const char *buffer) override
I/O formatting auxiliaries.
The template JSharedPointer class can be used to share a pointer to an object.
static const JNET::JTag RC_LOG
JMessageScheduler logErrorFile
JSUPPORT::JAutoTreeWriter< JNET::JTag > JTreeWriter_t
Type definition of auto map.
#define make_field(A,...)
macro to convert parameter to JParserTemplateElement object
JValue_t()
Default constructor.
Auxiliary class for method select.
Auxiliary class for CPU timing and usage.
JMessageScheduler logErrorTag
virtual void typeout(const std::string &tag, const std::string &message) override
Report message.
JSubscriptionList & add(const JSubscription &subscription)
Add subscription.
map_type::iterator iterator
Level specific message streamers.
Exception for ControlHost.
JTriggerParameters parameters
trigger parameters
bool putObject(TDirectory &dir, const TObject &object)
Write object to ROOT directory.
char getTokenDelimeter()
Get the token delimeter for command messages.
bool isRunning() const
Check if this client is in runnig state.
virtual void close() override
Close file.
Auxiliary class for all subscription.
virtual void open(const char *file_name) override
Open file.
const JTag & getTag() const
Get tag.
Auxiliary data structure for sequence of same character.
static const JNET::JTag RC_DWRITER
virtual void actionStart(int length, const char *buffer) override
void write(const int run, TFile *file)
Write trigger parameters for given run if not yet done.
std::string toString() const
Convert tag to string.
int getRunNumber() const
Get run number.
void insert()
Insert (list of) data type(s).
void typeout()
Report status of data writing.
const std::string & getFullName() const
Get full name of this run control client.
Control unit client base class.
Utility class to parse command line options.
virtual bool enter(const JArgs &args)
Enter the state machine.
JMessageLogger logger
message logger
static const JNET::JTag RC_CMD
static const JNET::JTag IO_EVENT
virtual void actionReset(int length, const char *buffer) override
KM3NeT DAQ constants, bit handling, etc.
bool is_written
writer status
then fatal Wrong number of arguments fi set_variable DETECTOR $argv[1] set_variable INPUT_FILE $argv[2] eval JPrintDetector a $DETECTOR O IDENTIFIER eval JPrintDetector a $DETECTOR O SUMMARY source JAcoustics sh $DETECTOR_ID CHECK_EXIT_CODE typeset A TRIPODS get_tripods $WORKDIR tripod txt TRIPODS for EMITTER in
JLANG::JSharedPointer< JControlHost > datawriter
static void Throw(const bool option)
Enable/disable throw option.
esac $JPP_BIN JLogger sh $LOGGER until pgrep JGetMessage</dev/null > dev null
unsigned long long usec_wall
bool read(std::istream &in)
Read trigger parameters.