28 #ifndef NIDAS_CORE_DSMSERVICE_H
29 #define NIDAS_CORE_DSMSERVICE_H
35 namespace nidas {
namespace core {
41 class SampleIOProcessor;
97 virtual
void cancel() throw();
101 virtual
int join() throw();
103 static const std::
string getClassName(const xercesc::DOMElement* node,
105 throw(nidas::util::InvalidParameterException);
108 throw(nidas::util::InvalidParameterException);
virtual void printClock(std::ostream &)
Definition: DSMService.h:120
const std::string & getName() const
Definition: DSMService.h:58
std::list< SampleInput * > _inputs
Definition: DSMService.h:136
virtual void interrupt()
Definition: DSMService.cc:92
virtual int join()
Definition: DSMService.cc:128
virtual const std::list< SampleIOProcessor * > & getProcessors() const
Definition: DSMService.h:78
virtual void setDSMServer(DSMServer *val)
Definition: DSMService.cc:81
nidas::util::Thread::SchedPolicy _threadPolicy
Definition: DSMService.h:142
nidas::util::Mutex _subThreadMutex
Definition: DSMService.h:134
int _threadPriority
Definition: DSMService.h:144
Interface of an object that can be instantiated from a DOM element, via the fromDOMElement method...
Definition: DOMable.h:51
virtual void cancel()
Definition: DSMService.cc:110
std::list< IOChannel * > _ochans
Definition: DSMService.h:140
virtual DSMServer * getDSMServer() const
Definition: DSMService.h:65
DSMService(const std::string &name)
Constructor.
Definition: DSMService.cc:43
std::set< nidas::util::Thread * > _subThreads
Definition: DSMService.h:132
nidas::util::Thread::SchedPolicy getSchedPolicy() const
Definition: DSMService.h:110
Class for iterating over the Processors of a DSMServer or DSMConfig.
Definition: NidsIterators.h:149
A channel for Input or Output of data.
Definition: IOChannel.h:64
void fromDOMElement(const xercesc::DOMElement *node)
Initialize myself from a xercesc::DOMElement.
Definition: DSMService.cc:205
Definition: Exception.h:35
virtual ~DSMService()
Definition: DSMService.cc:50
const std::list< SampleInput * > & getInputs() const
Definition: DSMService.h:83
ProcessorIterator getProcessorIterator() const
Definition: DSMService.cc:76
Interface of a processor of samples.
Definition: SampleIOProcessor.h:49
virtual int checkSubThreads()
Definition: DSMService.cc:149
virtual void schedule(bool optionalProcessing)=0
schedule this service to run.
virtual void connect(SampleInput *)=0
A provider of services to a DSM.
Definition: DSMServer.h:50
int getSchedPriority() const
Definition: DSMService.h:115
static const std::string getClassName(const xercesc::DOMElement *node, const Project *)
Definition: DSMService.cc:179
Base class for a service, as built from a <service> XML tag.
Definition: DSMService.h:47
virtual void printStatus(std::ostream &, float)
Definition: DSMService.h:122
DSMServer * _server
Definition: DSMService.h:130
std::string _name
Definition: DSMService.h:128
std::list< SampleIOProcessor * > _processors
Definition: DSMService.h:138
void addSubThread(nidas::util::Thread *)
Definition: DSMService.cc:86
virtual void addProcessor(SampleIOProcessor *proc)
Add a processor to this RawSampleService.
Definition: DSMService.h:73