188 for (
int i = 0; !this->is_open() && i != MAXIMUM_FILE_NUMBER; ++i) {
194 <<
"_" << cal.getYear() <<
'-' <<
FILL(2,
'0') << cal.getMonth() <<
'-' <<
FILL(2,
'0') << cal.getDay()
204 this->
open(os.str().c_str());
206 catch(
const exception& error) {}
228 return (sizeL0 > 0 ||
243 if (
object.is_open())
244 out <<
object.getFile()->GetName();
250 return out <<
object.sizeL0 <<
'/'
251 <<
object.sizeL1 <<
'/'
252 <<
object.sizeL2 <<
'/'
253 <<
object.sizeSN <<
'/';
290 const std::string& server,
291 const std::string& hostname,
297 const std::string&
path) :
302 buffer_size(buffer_size),
310 current_slice_index = -1;
321 if (c_buffer.is_open()) {
323 JNoticeStream(logger) <<
"Close circular buffer " << c_buffer;
332 virtual void actionInit(
int length,
const char* buffer)
override
334 JDebugStream(logger) <<
"actionInit() " << std::string(buffer,length);
340 if (serversocket.is_valid()) {
341 serversocket->shutdown();
346 catch(
const std::exception& error) {
347 JErrorStream(logger) <<
"Error \"" << error.what() <<
"\"; trigger ev_error.";
357 JDebugStream(logger) <<
"actionConfigure() " << endl << std::string(buffer,length);
370 properties[
"dataWriter"] = hostname;
371 properties[
"numberOfFramesPerSlice"] = frames_per_slice = 1;
374 properties[
"queueSize"] = maxQueueSize = (totalCPURAM -
GIGABYTE);
375 properties[
"queueDepth"] = maxQueueDepth = 20;
376 properties[
"frameIndex"] = maximal_frame_index = 100000;
379 properties[
"JDataFilter"] = dataFilters;
380 properties[
"DataQueue"] = dataQueues;
381 properties[
"path"] =
path;
382 properties[
"c_sizeL0"] = c_buffer.sizeL0;
383 properties[
"c_sizeL1"] = c_buffer.sizeL1;
384 properties[
"c_sizeL2"] = c_buffer.sizeL2;
385 properties[
"c_sizeSN"] = c_buffer.sizeSN;
388 properties.
read(
string(buffer, length));
390 catch(
const exception& error) {
397 setClockInterval(
update_s * 1000000LL);
399 hostname =
trim(hostname);
404 throw JException(
"Undefined data writer host name.");
406 maximum_frames_per_slice = frames_per_slice;
410 if (dataFilters.empty()) {
411 JNoticeStream(logger) <<
"No DataFilters in process list, or no process list. "
412 <<
"Assuming that this process is the only process on this CPU and setting parameters accordingly.";
415 sort(dataFilters.begin(), dataFilters.end(), processIndexSorter);
417 unsigned int numberOfDataFiltersOnThisMachine = 0;
425 notice <<
"My IP addresses:";
434 JDebugStream(logger) <<
"Test IP address \"" << i->hostname <<
"\" " << (find(IP.begin(), IP.end(), i->hostname) != IP.end());
436 if (find(IP.begin(), IP.end(), i->hostname) != IP.end()) {
438 numberOfDataFiltersOnThisMachine++;
440 if (i->port == this->port) {
446 if (numberOfDataFiltersOnThisMachine == 0) {
447 JNoticeStream(logger) <<
"Zero data filters on this machine according to process list (if it exists). "
448 <<
"Assuming one datafilter on this machine.";
449 numberOfDataFiltersOnThisMachine = 1;
452 if (thisProcess == dataFilters.end()) {
453 JErrorStream(logger) <<
"This process cannot be found in the process list. Why do I exist?";
456 if (thisProcess != dataFilters.end() && thisProcess->index !=
getName()) {
457 JErrorStream(logger) <<
"Mismatch between given process names: "
459 <<
", but in the process list I am referred to as " << thisProcess->index;
462 if (dataFilters.begin() == thisProcess || dataFilters.empty()) {
466 if (maxQueueSize > (totalCPURAM-
GIGABYTE)/(numberOfDataFiltersOnThisMachine)) {
468 maxQueueSize = (totalCPURAM-
GIGABYTE)/(numberOfDataFiltersOnThisMachine);
470 JNoticeStream(logger) <<
"Maximum queue size is too large given the number of processes on this machine. "
471 <<
"Queue size reduced to "
472 << maxQueueSize <<
" bytes." ;
487 JNoticeStream(logger) <<
"This data filter process will report.";
488 JNoticeStream(logger) <<
"Number of modules: " << (*moduleRouter)->size();
491 JNoticeStream(logger) <<
"Update period [s]: " << getClockInterval();
503 if (buildL1.get() == NULL) {
JErrorStream(logger) <<
"Failed to allocate buildL1."; }
504 if (buildL2.get() == NULL) {
JErrorStream(logger) <<
"Failed to allocate buildL2."; }
505 if (buildSN.get() == NULL) {
JErrorStream(logger) <<
"Failed to allocate buildSN."; }
506 if (buildNB.get() == NULL) {
JErrorStream(logger) <<
"Failed to allocate buildSN."; }
513 if (c_buffer.is_enabled()) {
515 if (!c_buffer.is_open()) {
519 if (c_buffer.is_open()) {
521 JNoticeStream(logger) <<
"Created circular buffer " << c_buffer;
527 JErrorStream (logger) <<
"Failed to create circular buffer in directory <" <<
path <<
">; disable functionality.";
534 JNoticeStream(logger) <<
"Continue using circular buffer " << c_buffer;
544 if (c_buffer.is_open()) {
561 current_slice_index = -1;
566 numberOfTimeslicesProcessed = 0;
567 numberOfIncompleteTimeslicesProcessed = 0;
569 number_of_packets_received = 0;
570 number_of_packets_discarded = 0;
571 number_of_bytes_received = 0;
574 minFrameNumber = numeric_limits<int>::max();
575 maxFrameNumber = numeric_limits<int>::min();
581 logErrorRun .reset();
582 logErrorDetector .reset();
583 logErrorIndex .reset();
584 logErrorIncomplete.reset();
605 if (!timeslices.empty()) {
607 JNoticeStream(logger) <<
"Flushing " << timeslices.size() <<
" slices.";
620 timeslices.swap(buffer);
627 current_slice_index = -1;
640 virtual void actionStop(
int length,
const char* buffer)
override
650 if (serversocket.is_valid()) {
651 serversocket->shutdown();
654 serversocket.reset();
658 virtual void actionQuit(
int length,
const char* buffer)
override
666 if (serversocket.is_valid()) {
667 mask.
set(*serversocket);
670 for (JChannelList_t::const_iterator channel = channelList.begin(); channel != channelList.end(); ++channel) {
671 if (!channel->isReady()) {
672 mask.
set(channel->getFileDescriptor());
682 for (JChannelList_t::iterator channel = channelList.begin(); channel != channelList.end(); ) {
686 if (mask.
has(channel->getFileDescriptor())) {
690 if (channel->isReady()) {
692 number_of_packets_received += 1;
693 number_of_reads += channel->getCounter();
694 number_of_bytes_received += channel->size();
698 updateFrameQueue(channel);
702 JErrorStream(logErrorRun) <<
"Receiving data while not running.";
704 number_of_packets_discarded += 1;
712 catch(
const exception& error) {
714 JNoticeStream(logger) <<
"Disconnecting channel " << channel->getFileDescriptor() <<
' ' << error.what();
718 channel = channelList.erase(channel);
723 if (serversocket.is_valid()) {
725 if (mask.
has(*serversocket)) {
729 socket.
accept(serversocket->getFileDescriptor());
744 if (!timeslices.empty() && (timeslices.front().size() >= frames_per_slice ||
745 timeslices.size() >= maxQueueDepth ||
752 minFrameNumber = min(minFrameNumber, pending_slice.
getFrameIndex());
753 maxFrameNumber = max(maxFrameNumber, pending_slice.
getFrameIndex());
755 if (pending_slice.size() > frames_per_slice) {
757 JErrorStream(logger) <<
"More frames in timeslice than expected "
758 << pending_slice.size() <<
" > " << frames_per_slice;
760 if (pending_slice.size() <= maximum_frames_per_slice) {
762 JErrorStream(logger) <<
"Adjusting expected frames per timeslice to " << pending_slice.size();
764 frames_per_slice = pending_slice.size();
768 if (!pending_slice.empty()) {
772 processTimeSlice(pending_slice);
776 numberOfTimeslicesProcessed += 1;
780 if (pending_slice.size() < frames_per_slice) {
782 numberOfIncompleteTimeslicesProcessed += 1;
784 JErrorStream(logErrorIncomplete) <<
"Timeout -> processed incomplete timeslice: "
786 <<
"Size of timeslice = " << pending_slice.size() <<
';'
787 <<
"Queue depth = " << timeslices.size() <<
';'
790 if (!timeslices.empty()) {
792 JErrorStream(logger) <<
"Adjusting expected frames per timeslice from " << frames_per_slice <<
" to " << pending_slice.size();
794 frames_per_slice = pending_slice.size();
799 timeslices.pop_front();
831 if (preamble.getLength() != channel->size()) {
833 JErrorStream(logErrorRun) <<
"Size of received data does not match size reported by preamble: "
834 <<
"preamble.getLength() = " << preamble.getLength() <<
';'
835 <<
"channel->size(): " << channel->size() <<
';';
837 number_of_packets_discarded += 1;
844 JErrorStream(logErrorRun) <<
"Run number " << header.getRunNumber()
846 <<
" -> Dropping frame.";
848 number_of_packets_discarded += 1;
853 if (header.getFrameIndex() <= current_slice_index) {
855 JErrorStream(logErrorIndex) <<
"Frame index " << header.getFrameIndex() <<
" <= " << current_slice_index
856 <<
" -> Dropping frame.";
858 number_of_packets_discarded += 1;
860 if (frames_per_slice < maximum_frames_per_slice) {
864 JErrorStream(logErrorIndex) <<
"Increase number of frames expected to: " << frames_per_slice;
870 if (current_slice_index != -1 && header.getFrameIndex() > current_slice_index + maximal_frame_index) {
872 JErrorStream(logErrorIndex) <<
"Frame index " << header.getFrameIndex() <<
" > " << current_slice_index + maximal_frame_index
873 <<
" -> Dropping frame.";
875 number_of_packets_discarded += 1;
882 while (timesliceIterator != timeslices.end() && timesliceIterator->getFrameIndex() < header.getFrameIndex()) {
886 if (timesliceIterator != timeslices.end() && timesliceIterator->getFrameIndex() == header.getFrameIndex()) {
894 timesliceIterator = timeslices.insert(timesliceIterator,
JDAQTimesliceL0());
896 timesliceIterator->setDAQChronometer(header.getDAQChronometer());
903 in >>
static_cast<JDAQFrame&
>(*(timesliceIterator->rbegin()));
932 c_buffer.is_enabled()) {
934 timesliceRouter->configure(timeslice);
943 for (JDAQTimesliceL0::const_iterator frame = timeslice.begin(); frame != timeslice.end(); ++frame) {
945 if (moduleRouter->hasModule(frame->getModuleID())) {
952 <<
"module = " << frame->getModuleID() <<
";"
953 <<
"discard and dump";
955 timesliceTX.push_back(*frame);
960 const JModule& module = moduleRouter->getModule(frame->getModuleID());
961 JSuperFrame2D_t& buffer = JSuperFrame2D_t::demultiplex(*frame, module);
977 if (buffer.begin() != __end) {
980 frame->getModuleIdentifier(),
985 (*buildL1)(buffer.begin(), __end , back_inserter(zbuf));
987 (*buildNB)(buffer.begin() , __end, zbuf, back_inserter(*timesliceNB.rbegin()));
994 frame->getModuleIdentifier(),
997 (*buildL1)(*timesliceL0.rbegin(), back_inserter(*timesliceL1.rbegin()));
1002 frame->getModuleIdentifier(),
1005 (*buildL2)(buffer, *timesliceL1.rbegin(), back_inserter(*timesliceL2.rbegin()));
1010 frame->getModuleIdentifier(),
1013 (*buildSN)(buffer, *timesliceL1.rbegin(), back_inserter(*timesliceSN.rbegin()));
1017 JErrorStream(logErrorDetector) <<
"No detector information for module " << frame->getModuleID();
1021 if (!timesliceTX.empty()) {
1022 this->put(timesliceTX);
1031 for (JTriggerInput::const_iterator hit = trigger_input.begin(); hit != trigger_input.
end(); ++hit) {
1052 (*trigger3DMuon) (trigger_input, back_inserter(trigger_output));
1053 (*trigger3DShower)(trigger_input, back_inserter(trigger_output));
1054 (*triggerMXShower)(trigger_input, timesliceL0, back_inserter(trigger_output));
1058 for (JTriggerOutput::const_iterator event = trigger_output.begin();
event != trigger_output.end(); ++event) {
1062 if (this->put(
object)) {
1063 numberOfEvents += 1;
1067 if (
parameters.writeL1() || c_buffer.sizeL1 > 0) {
1071 if (
parameters.writeL1) { this->put(
object); }
1072 if (c_buffer.sizeL1 > 0) { c_buffer.put(
object); }
1075 if (
parameters.writeL2() || c_buffer.sizeL2 > 0) {
1079 if (
parameters.writeL2) { this->put(
object); }
1080 if (c_buffer.sizeL2 > 0) { c_buffer.put(
object); }
1083 if (
parameters.writeSN() || c_buffer.sizeSN > 0) {
1087 if (
parameters.writeSN) { this->put(
object); }
1088 if (c_buffer.sizeSN > 0) { c_buffer.put(
object); }
1091 if (
parameters.writeL0() || c_buffer.sizeL0 > 0) {
1093 if (
parameters.writeL0) { this->put(timeslice); }
1094 if (c_buffer.sizeL0 > 0) { c_buffer.put(timeslice); }
1098 }
catch(
const exception& error) {
1099 JErrorStream(logger) <<
"Error = " << error.what() <<
";"
1102 <<
"time slice not correctly processed!";
1114 const double T_us = (double) timer.usec_wall;
1116 JNoticeStream(logger) <<
"Elapsed real (wall) time [s] " << T_us / 1e6;
1117 JNoticeStream(logger) <<
"Elapsed user CPU time [s] " << (double) timer.usec_ucpu/ 1e6;
1118 JNoticeStream(logger) <<
"Elapsed system CPU time [s] " << (double) timer.usec_scpu/ 1e6;
1120 JNoticeStream(logger) <<
"Elapsed real time per time slice [ms] " << Qt.getMean() * 1.0e-3 <<
" +/- " << Qt.getDeviation() * 1.0e-3;
1122 catch(
const std::exception&) {}
1123 JNoticeStream(logger) <<
"Number of packets received/discarded " << number_of_packets_received <<
"/" << number_of_packets_discarded;
1124 JNoticeStream(logger) <<
"Number of events/MB sent " << numberOfEvents <<
"/" << numberOfBytes/1e6;
1126 if (number_of_packets_received > 0) {
1127 JNoticeStream(logger) <<
"Number of reads/packet " << (double) number_of_reads / (
double) number_of_packets_received;
1131 JNoticeStream(logger) <<
"Current number of frames per slice expected: " << frames_per_slice;
1133 JNoticeStream(logger) <<
"Number of timeslices processed total/incomplete " << numberOfTimeslicesProcessed <<
"/" << numberOfIncompleteTimeslicesProcessed;
1135 if (numberOfTimeslicesProcessed > 0) {
1136 JNoticeStream(logger) <<
"Real time per timeslice [ms] " << timer.usec_wall / 1000 / numberOfTimeslicesProcessed;
1137 JNoticeStream(logger) <<
"User CPU time per timeslice [ms] " << timer.usec_ucpu / 1000 / numberOfTimeslicesProcessed;
1138 JNoticeStream(logger) <<
"System CPU time per timeslice [ms] " << timer.usec_scpu / 1000 / numberOfTimeslicesProcessed;
1141 const double processedSlicesTime_us = numberOfTimeslicesProcessed *
getFrameTime() / 1000;
1142 const double processedDetectorTime_us = (maxFrameNumber - minFrameNumber) *
getFrameTime() / 1000;
1144 if (processedSlicesTime_us > 0) {
1145 JNoticeStream(logger) <<
"Performance factor (inaccurate estimate): " << T_us / processedSlicesTime_us;
1147 if (processedDetectorTime_us > 0) {
1148 JNoticeStream(logger) <<
"Performance factor whole detector (inaccurate estimate): " << T_us / processedDetectorTime_us;
1164 using namespace std;
1166 JDebugStream(logger) <<
"Received message <" << tag.
toString() <<
"> \"" << string(buffer, length) <<
"\"";
1170 if (c_buffer.is_open()) {
1172 JNoticeStream(logger) <<
"Close circular buffer " << c_buffer;
1177 if (c_buffer.is_enabled()) {
1181 if (c_buffer.is_open()) {
1183 JNoticeStream(logger) <<
"Created circular buffer " << c_buffer;
1189 JErrorStream (logger) <<
"Failed to create circular buffer in directory <" <<
path <<
">; disable functionality.";
1203 static const int MAXIMUM_FILE_NUMBER = 100;
1222 datawriter->put(
object);
1228 catch(
const std::exception& error) {
1322 using namespace std;
1323 using namespace JPP;
1324 using namespace KM3NETDAQ;
1340 JParser<> zap(
"Application for real-time filtering of data.");
1345 zap[
'u'] =
make_field(client_name) =
"JDataFilter";
1355 catch(
const exception& error) {
1356 FATAL(error.what() << endl);
virtual void actionRunning() override
This method is repeatedly called when this client machine is in state Running and the clock interval ...
Message logger with time scheduler.
Utility class to parse command line options.
void processTimeSlice(const JDAQTimesliceL0 ×lice)
Process time slice.
int getSizeOfPacket(const KM3NETDAQ::JDAQAbstractPreamble &preamble)
Get size of packeet.
void open(const std::string &path, const JTag &tag)
Open file.
bool read(const JEquation &equation)
Read equation.
JTriggerMask_t getTriggerMask(const unsigned int bit)
Convert trigger bit to trigger mask.
int main(int argc, char *argv[])
ROOT TTree parameter settings of various packages.
then JLigiers sh continue fi cat driver txt<< EOFprocess dfilter $HOST1 ssh\$HOST\$"JDataFilter -H \$SERVER\$ -M \$LOGGER\$ -d $DEBUG &";enterevent ev_init{RC_CMD%< ev_init.txt > from me< ev_init.txt > event ev_configure
Data structure for a composite optical module.
JSinglePointer< JTriggerNB > triggerNB
static bool processIndexSorter(const JDAQProcess &first, const JDAQProcess &second)
Sort DAQ process by index.
std::list< JDAQTimesliceL0 > timeslices
buffer with pending time slice data
long long int numberOfTimeslicesProcessed
JBuildL2< hit_type > JBuildL2_t
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.
JMessageScheduler logErrorIndex
JSuperFrame2D< hit_type > JSuperFrame2D_t
JSocketInputChannel< JDAQAbstractPreamble > JSocketInputChannel_t
Long64_t sizeL1
Number of L1 time slices.
JTag getUniqueTag(const std::string &hostname, const std::string &name)
Get unique tag of run control client.
static const JNET::JTag RC_DFILTER
Router for direct addressing of module data in detector data structure.
JDataFilter(const std::string &name, const std::string &server, const std::string &hostname, JLogger *logger, const int level, const int port, const int backlog, const int buffer_size, const std::string &path)
Constructor.
Interface for logging messages.
Message logging based on ControlHost.
Utility class to parse parameter values.
JSinglePointer< JServerSocket > serversocket
server for data queue connections
unsigned int maximum_frames_per_slice
ROOT TTree object output.
JMessageScheduler logErrorIncomplete
*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
JTriggerParameters parameters
Main class for real-time filtering of data.
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.
Basic data structure for time and time over threshold information of hit.
long long int number_of_packets_discarded
int getRunNumber() const
Get run number.
T * open(const std::string &file_name)
Open file.
Utility class to parse parameter values.
static const JChecksum checksum
Function object to perform check-sum of raw data.
then echo The file $DIR KM3NeT_00000001_00000000 root already please rename or remove it first
void disable()
Disable writing.
int getFrameIndex() const
Get frame index.
JBuildL1< hit_type > JBuildL1_t
1-dimensional frame with time calibrated data from one optical module.
JCircularBuffer_t()
Default constructor.
JCircularBuffer_t c_buffer
JTimeRange getTimeRange(const Evt &event)
Get time range (i.e. time between earliest and latest hit) of Monte Carlo event.
void typeout()
Report status to message logger.
bool is_enabled() const
Check whether writing of data is enabled.
Basic data structure for L0 hit.
std::string index
index in process list
do cat driver txt<< EOFevent ev_configure{RC_EVT%< ev_configure.txt > RC_DWRT path
JSuperFrame1D< hit_type > JSuperFrame1D_t
std::string trim(const std::string &buffer)
Trim string.
JSinglePointer< JBuildL2_t > buildL2
int getLength() const
Get length.
JSinglePointer< JTriggerMXShower > triggerMXShower
JSinglePointer< JBuildL1_t > buildL1
int getFileDescriptor() const
Get file descriptor.
long long int totalCPURAM
JTimeslice< hit_type > JTimeslice_t
JSinglePointer< JTrigger3DShower > trigger3DShower
Scheduling of actions via fixed latency intervals.
void accept(const int server)
Accept connection from a server.
double getMaximalDistance(const JDetector &detector)
Get maximal distance between modules in detector.
I/O formatting auxiliaries.
virtual void actionContinue(int length, const char *buffer) override
long long int numberOfBytes
Auxiliary class for itemization of process list.
std::vector< JDAQProcess > dataFilters
void merge(const JMatch_t &match)
Merge events.
std::vector< JSocketInputChannel_t > JChannelList_t
friend std::ostream & operator<<(std::ostream &out, const JCircularBuffer_t &object)
Write circular buffer to output stream.
static const JLocalTime getLocalTime
Function object to get local time in micro seconds.
#define make_field(A,...)
macro to convert parameter to JParserTemplateElement object
Router for fast addressing of hits in KM3NETDAQ::JDAQTimeslice data structure as a function of the op...
double getFrameTime()
Get frame time duration.
do set_variable OUTPUT_DIRECTORY $WORKDIR T
int getRunNumber(const std::string &file_name)
Get run number for given file name of data taking run.
JMessageScheduler logErrorDetector
static const size_t buffer_size
Auxiliary class for method select.
Auxiliary class for CPU timing and usage.
JSinglePointer< JBuildL2_t > buildSN
const JDAQChronometer & getDAQChronometer() const
Get DAQ chronometer.
long long int numberOfIncompleteTimeslicesProcessed
Auxiliary class to build JDAQEvent for a triggered event.
void updateFrameQueue(const JChannelList_t::const_iterator channel)
Update queue with data frames.
JTreeWriter object output.
JSinglePointer< JBuildL2_t > buildNB
virtual void actionEnter() override
Interface methods for actions corresponding to state transitions.
Level specific message streamers.
long long int number_of_packets_received
static const long long int MEGABYTE
Number of bytes in a kilo-byte.
const JPosition3D & getPosition() const
Get position.
Simple data structure for the DAQ preamble required for a correct calculation of the object size for ...
virtual void actionQuit(int length, const char *buffer) override
Long64_t sizeSN
Number of SN time slices.
Auxiliary class for all subscription.
int port
server socket port
static void reset()
Reset counter of unique instance of this class object.
General purpose messaging.
Auxiliary data structure for sequence of same character.
long long int localtime_t
Type definition of local time.
void setReceiveBufferSize(const int size)
Set receive buffer size.
std::string hostname
host name of data server
unsigned int maxQueueDepth
JControlHostObjectOutput< JDAQTypes_t > JControlHost_t
std::vector< JDAQProcess > dataQueues
long long int maxQueueSize
virtual void actionStart(int length, const char *buffer) override
bool put(const T &object)
Auxiliary method to send object to data server.
std::string toString() const
Convert tag to string.
std::vector< value_type >::iterator iterator
virtual void actionReset(int length, const char *buffer) override
virtual void actionExit() override
JSinglePointer< JTimesliceRouter > timesliceRouter
static const long long int GIGABYTE
Number of bytes in a mega-byte.
Auxiliary class to build JDAQTimeslice for L1 timeslice.
JChannelList_t channelList
connections to data queue
Control unit client base class.
Auxililary class to get date and time.
Utility class to parse command line options.
static const JNET::JTag RC_ALERT
Implemenation of object output through ControlHost.
virtual void actionSelect(const JFileDescriptorMask &mask) override
Action method following last select call.
void applyHighRateVeto(const double rate_Hz)
Apply high-rate veto.
std::vector< std::string > getListOfIPaddresses()
Get list of IP address (decimal-dot notation).
unsigned long long int getRAM()
Get RAM of this CPU.
Long64_t sizeL0
Number of L0 time slices.
JSinglePointer< JTrigger3DMuon > trigger3DMuon
JSinglePointer< JControlHost_t > datawriter
controlhost of data server (to which data writer should be connected)
void setNonBlocking(const bool on)
Set non-blocking of I/O.
JMessageScheduler logErrorRun
virtual bool enter(const JArgs &args)
Enter the state machine.
virtual void actionTagged(const JTag &tag, int length, const char *buffer) override
Tagged action to handle alerts.
JSinglePointer< JModuleRouter > moduleRouter
std::string path
directory for writing circular buffer
2-dimensional frame with time calibrated data from one optical module.
JSocketInputChannel< JPrefix_t > JSocketInputChannel_t
const char * getName()
Get ROOT name of given data type.
static const JNET::JTag RC_CMD
void setKeepAlive(const bool on)
Set keep alive of socket.
long long int number_of_bytes_received
virtual void actionStop(int length, const char *buffer) override
do set_variable DETECTOR_TXT $WORKDIR detector
KM3NeT DAQ constants, bit handling, etc.
virtual void actionInit(int length, const char *buffer) override
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
Match of two events considering overlap in time.
size_t getSizeof(const JDAQEvent &object)
Get size of object.
virtual void actionPause(int length, const char *buffer) override
Hostname and IP address functions.
Long64_t sizeL2
Number of L2 time slices.
Data frame of one optical module.
long long int number_of_reads
long long int numberOfEvents
unsigned int frames_per_slice
Timeslice data structure for L0 data.
Basic data structure for L1 hit.
virtual void setSelect(JFileDescriptorMask &mask) const override
Set the file descriptor mask for the select call.
virtual void actionConfigure(int length, const char *buffer) override
Time slice with calibrated data.
bool putObject(TDirectory *dir, const T &object)
Write object to ROOT directory.