Go to the documentation of this file.
47 const std::string& server,
70 properties[
"datawriter"] = destination =
"localhost";
71 properties[
"inputFile"] = inputFile;
72 properties[
"eventRate_Hz"] = eventRate_Hz = 1.0;
74 properties.
read(
string(buffer, length));
76 destination = destination.
trim();
85 if (eventRate_Hz > 0.0)
86 setClockInterval((
long long int) (1.0e6 / eventRate_Hz));
88 setClockInterval(0ULL);
92 JDebugStream(logger) <<
"Event interval time " << getClockInterval() <<
" us";
119 os << getRunNumber() <<
' ' << parameters;
131 if (timer.usec_wall > 0)
JNoticeStream(logger) <<
"I/O [MB/s] " << numberOfBytes / timer.usec_wall;
132 if (numberOfEvents > 0)
JNoticeStream(logger) <<
"Delay/event [ms] " << getClockDelay() / numberOfEvents / 1000;
144 if (datawriter.is_valid()) {
146 if (!inputFile.hasNext()) {
150 if (inputFile.hasNext()) {
156 event->setRunNumber(getRunNumber());
164 datawriter->PutFullData(
IO_EVENT, out.data(), out.size());
167 numberOfBytes += out.size();
202 int main(
int argc,
char* argv[])
214 JParser<> zap(
"Program for real-time simulation of data.");
224 catch(
const exception &error) {
225 FATAL(error.what() << endl);
Level specific message streamers.
Interface for logging messages.
virtual void actionStop(int length, const char *buffer)
virtual void actionReset(int length, const char *buffer)
JTriggerParameters getTriggerParameters(const JMultipleFileScanner_t &file_list)
Get trigger parameters.
JString & trim()
Trim string.
static const JNET::JTag IO_EVENT
Runcontrol client to simulate data filter(s).
Auxiliary class for CPU timing and usage.
Exception for ControlHost.
Data structure for all trigger parameters.
void run()
Run as run control client following command messages via JNET::JControlHost.
int main(int argc, char *argv[])
JEventGenerator(const std::string &name, const std::string &server, JLogger *logger, const int level)
Constructor.
Utility class to parse command line options.
bool read(const JEquation &equation)
Read equation.
This name space includes all other name spaces (except KM3NETDAQ, KM3NET and ANTARES).
virtual void actionRunning()
This method is repeatedly called when this client machine is in state Running and the clock interval ...
virtual void actionQuit(int length, const char *buffer)
Wrapper class around STL string class.
void clear()
Clear buffer.
JTriggerCounter_t next()
Increment trigger counter.
virtual void actionConfigure(int length, const char *buffer)
long long int numberOfBytes
Message logging based on std::ostream.
static const JNET::JTag RC_EVTGENERATOR
Control unit client base class.
Message logging based on ControlHost.
static void Throw(const bool option)
Enable/disable throw option.
virtual void actionStart(int length, const char *buffer)
static const JNET::JTag IO_TRIGGER_PARAMETERS
JSharedPointer< JControlHost > datawriter
Simple data structure to support I/O of equations (see class JLANG::JEquation).
#define make_field(A,...)
macro to convert parameter to JParserTemplateElement object
Utility class to parse parameter values.
JSUPPORT::JMultipleFileScanner< KM3NETDAQ::JDAQEvent > inputFile
KM3NeT DAQ data structures and auxiliaries.
static const JNET::JTag RC_CMD
std::string getProcessName(const std::string &name, const std::string &process)
Get process name of run control client.
JTRIGGER::JTriggerParameters parameters
virtual bool enter(const JArgs &args)
Enter the state machine.
The template JSharedPointer class can be used to share a pointer to an object.
Byte array binary output.