28 #ifndef NIDAS_DYNLD_RAWSAMPLESERVICE_H
29 #define NIDAS_DYNLD_RAWSAMPLESERVICE_H
68 void printStatus(std::ostream& ostr,
float deltat)
throw();
206 std::map<nidas::core::SampleInput*,Worker*>
_workers;
208 std::map<nidas::core::SampleInput*,const nidas::core::DSMConfig*>
_dsms;
void connect(nidas::core::SampleInput *)
Definition: RawSampleService.cc:175
RawSampleService & operator=(const RawSampleService &)
Assignment not supported.
A RawSampleService reads raw Samples from a socket connection and sends the samples to one or more Sa...
Definition: RawSampleService.h:48
unsigned int _procLateSampleCacheSize
Definition: RawSampleService.h:232
nidas::core::SampleInput * _input
Definition: RawSampleService.h:196
unsigned int _rawLateSampleCacheSize
Definition: RawSampleService.h:230
std::map< void *, size_t > _nsampsLast
Saved between calls to printStatus in order to compute data rates.
Definition: RawSampleService.h:215
void fromDOMElement(const xercesc::DOMElement *node)
Initialize myself from a xercesc::DOMElement.
Definition: RawSampleService.cc:579
void setProcSorterLength(float val)
Set the length of the SampleSorter of processed Samples, in seconds.
Definition: RawSampleService.h:97
unsigned int getProcLateSampleCacheSize() const
Get the size of the late sample cache in the processed sample sorter.
Definition: RawSampleService.h:165
std::map< nidas::core::SampleInput *, const nidas::core::DSMConfig * > _dsms
Definition: RawSampleService.h:208
void printStatus(std::ostream &ostr, float deltat)
Definition: RawSampleService.cc:409
void schedule(bool optionalProcessing)
schedule this service to run.
Definition: RawSampleService.cc:83
unsigned int getRawLateSampleCacheSize() const
Get the size of the late sample cache in the raw sample sorter.
Definition: RawSampleService.h:146
void setRawSorterLength(float val)
Set the length of the SampleSorter of raw Samples, in seconds.
Definition: RawSampleService.h:81
std::map< nidas::core::SampleInput *, Worker * > _workers
Keep track of the Worker for each SampleInput.
Definition: RawSampleService.h:206
Worker & operator=(const Worker &)
No assignment.
RawSampleService()
Definition: RawSampleService.cc:63
nidas::core::SamplePipeline * _pipeline
Definition: RawSampleService.h:182
RawSampleService * _svc
Definition: RawSampleService.h:195
void setProcLateSampleCacheSize(unsigned int val)
Cache this number of samples with potentially anomalous, late time tags in the processed sample sorte...
Definition: RawSampleService.h:175
Worker(RawSampleService *svc, nidas::core::SampleInput *input)
Definition: RawSampleService.cc:282
size_t _procHeapMax
Definition: RawSampleService.h:228
void disconnect(nidas::core::SampleInput *)
Definition: RawSampleService.cc:247
void interrupt()
Definition: RawSampleService.cc:158
Definition: Exception.h:35
void printClock(std::ostream &ostr)
Definition: RawSampleService.cc:397
~RawSampleService()
Definition: RawSampleService.cc:73
float _procSorterLength
Definition: RawSampleService.h:224
Worker thread that is run when a SampleInputConnection is established.
Definition: RawSampleService.h:187
float getProcSorterLength() const
Get the length of the SampleSorter of processed Samples, in seconds.
Definition: RawSampleService.h:89
size_t _rawHeapMax
Definition: RawSampleService.h:226
void setProcHeapMax(size_t val)
Set the size of in bytes of the processed SampleSorter.
Definition: RawSampleService.h:137
int run()
The method which will run in its own thread.
Definition: RawSampleService.cc:301
void interrupt()
Interrupt this thread.
Definition: RawSampleService.cc:293
size_t getProcHeapMax() const
Get the size of in bytes of the processed SampleSorter.
Definition: RawSampleService.h:127
float getRawSorterLength() const
Get the length of the SampleSorter of raw Samples, in seconds.
Definition: RawSampleService.h:73
void setRawLateSampleCacheSize(unsigned int val)
Cache this number of samples with potentially anomalous, late time tags in the raw sample sorter...
Definition: RawSampleService.h:156
SamplePipeline sorts samples that are coming from one or more inputs.
Definition: SamplePipeline.h:79
~Worker()
Definition: RawSampleService.cc:288
float _rawSorterLength
Definition: RawSampleService.h:222
size_t getRawHeapMax() const
Get the size of in bytes of the raw SampleSorter.
Definition: RawSampleService.h:107
A C++ wrapper for a POSIX mutex.
Definition: ThreadSupport.h:154
Base class for a service, as built from a <service> XML tag.
Definition: DSMService.h:47
std::map< void *, long long > _nbytesLast
Saved between calls to printStatus in order to compute sample rates.
Definition: RawSampleService.h:220
Definition: InvalidParameterException.h:35
nidas::util::Mutex _workerMutex
Definition: RawSampleService.h:210
void setRawHeapMax(size_t val)
Set the size of in bytes of the raw SampleSorter.
Definition: RawSampleService.h:117