|
static int | main (int argc, char **argv) throw () |
|
StatsProcess::StatsProcess |
( |
| ) |
|
bool StatsProcess::getFillGaps |
( |
| ) |
const |
|
inline |
References _app, _dsmName, _period, nidas::core::Project::findDSM(), nidas::core::Project::findServers(), nidas::core::NidasApp::getHostName(), nidas::dynld::StatisticsProcessor::getPeriod(), nidas::core::DSMServer::getProcessorIterator(), nidas::core::DSMConfig::getProcessorIterator(), nidas::core::ProcessorIterator::hasNext(), nidas::core::ProcessorIterator::next(), PLOG, and VLOG.
Referenced by listOutputSamples(), and run().
int StatsProcess::listOutputSamples |
( |
| ) |
|
References _configName, _configsXMLName, _startTime, _xmlFileName, nidas::util::Process::expandEnvVars(), nidas::core::Project::fromDOMElement(), nidas::core::ProjectConfigs::getConfig(), nidas::core::Variable::getName(), nidas::core::SampleIOProcessor::getRequestedSampleTags(), nidas::core::SampleIOProcessor::getSampleId(), nidas::core::SampleTag::getSpSId(), getStatisticsProcessor(), nidas::core::SampleTag::getVariables(), ILOG, nidas::core::ProjectConfig::initProject(), nidas::core::ProjectConfigs::parseXML(), nidas::core::parseXMLConfigFile(), PLOG, requireConfigsXML(), nidas::util::UTime::toUsecs(), and nidas::util::Exception::what().
Referenced by main().
int StatsProcess::main |
( |
int |
argc, |
|
|
char ** |
argv |
|
) |
| |
throw | ( | |
| ) | | |
|
static |
int StatsProcess::parseRunstring |
( |
int |
argc, |
|
|
char ** |
argv |
|
) |
| |
References _app, _configName, _daemonMode, _doListOutputSamples, _dsmName, _endTime, _fillGaps, _niceValue, _period, _selectedOutputSampleIds, _sorterLength, _startTime, _xmlFileName, nidas::util::LogContext::active(), nidas::core::NidasAppInputFilesArg::allowFiles, nidas::core::NidasAppInputFilesArg::allowSockets, nidas::core::NidasApp::allowUnrecognized(), nidas::core::NidasAppArgv::argc, nidas::core::NidasAppArgv::argv, nidas::core::NidasAppArg::asBool(), nidas::core::NidasAppArg::asFloat(), nidas::core::NidasAppArg::asInt(), DaemonMode, nidas::core::NidasApp::dataFileNames(), nidas::core::NidasApp::DatasetName, DEFAULT_PORT, DSMName, nidas::core::NidasApp::enableArguments(), nidas::core::NidasApp::EndTime, FilterArg, nidas::core::NidasApp::getEndTime(), nidas::core::NidasApp::getShortHostName(), nidas::core::NidasApp::getStartTime(), nidas::core::NidasAppArg::getValue(), nidas::core::NidasApp::Help, nidas::core::NidasApp::helpRequested(), nidas::core::NidasApp::Hostname, nidas::core::NidasApp::InputFiles, LOG_DEBUG, nidas::core::NidasApp::loggingArgs(), NiceValue, nidas::core::NidasApp::parseArgs(), nidas::core::NidasApp::parseInputs(), Period, nidas::core::NidasAppInputFilesArg::setDefaultInput(), SetDSM, nidas::core::NidasAppArg::setFlags(), nidas::core::NidasApp::socketAddress(), SorterLength, nidas::core::NidasApp::StartTime, nidas::util::UTime::toUsecs(), nidas::core::NidasAppArgv::unparsedArgs(), usage(), USECS_PER_DAY, nidas::core::NidasApp::Version, nidas::core::NidasApp::XmlHeaderFile, and nidas::core::NidasApp::xmlHeaderFile().
Referenced by main().
void StatsProcess::requireConfigsXML |
( |
| ) |
|
|
inline |
int StatsProcess::run |
( |
| ) |
|
throw | ( | |
| ) | | |
References _app, _configName, _configsXMLName, _daemonMode, _datasetName, _dsmName, _endTime, _niceValue, _selectedOutputSampleIds, _sorterLength, _startTime, _xmlFileName, nidas::core::SampleSource::addSampleTag(), nidas::dynld::SampleInputStream::addSampleTag(), nidas::core::FileSet::clone(), nidas::dynld::SampleInputStream::close(), nidas::core::SamplePipeline::connect(), nidas::dynld::StatisticsProcessor::connectSource(), nidas::core::NidasApp::dataFileNames(), nidas::core::SamplePipeline::disconnect(), nidas::dynld::StatisticsProcessor::disconnectSource(), DLOG, nidas::util::Process::expandEnvVars(), FilterArg, nidas::core::Project::findSampleOutputStreamFileSets(), nidas::core::Project::findServerSampleOutputStreamFileSets(), nidas::core::SamplePipeline::flush(), nidas::util::UTime::format(), nidas::core::Project::fromDOMElement(), nidas::core::SampleInputHeader::getArchiveVersion(), nidas::core::ProjectConfig::getBeginTime(), nidas::core::ProjectConfigs::getConfig(), nidas::core::SampleInputHeader::getConfigName(), nidas::core::SampleInputHeader::getConfigVersion(), getDataset(), nidas::core::ProjectConfig::getEndTime(), nidas::core::FileSet::getFileSet(), getFillGaps(), nidas::core::BadSampleFilterArg::getFilter(), nidas::dynld::SampleInputStream::getInputHeader(), nidas::core::SampleIOProcessor::getOutputs(), nidas::core::SamplePipeline::getProcessedSampleSource(), nidas::core::NidasApp::getProcessName(), nidas::core::SampleInputHeader::getProjectName(), nidas::core::DSMSensor::getRawSampleTag(), nidas::util::Socket::getRemoteSocketAddress(), nidas::core::DSMSensor::getSampleTagIterator(), nidas::core::DSMServer::getSensorIterator(), nidas::core::DSMConfig::getSensorIterator(), nidas::core::SampleInputHeader::getSoftwareVersion(), getStatisticsProcessor(), nidas::core::SampleInputHeader::getSystemName(), nidas::core::ProjectConfig::getXMLName(), nidas::core::SensorIterator::hasNext(), nidas::core::SampleTagIterator::hasNext(), ILOG, nidas::core::DSMSensor::init(), nidas::core::ProjectConfig::initProject(), nidas::core::SamplePipeline::interrupt(), nidas::core::NidasApp::interrupted(), nidas::core::SamplePipeline::join(), nidas::core::SensorIterator::next(), nidas::core::SampleTagIterator::next(), nidas::core::ProjectConfigs::parseXML(), nidas::core::parseXMLConfigFile(), PLOG, nidas::dynld::SampleInputStream::readInputHeader(), nidas::dynld::SampleInputStream::readSamples(), nidas::core::SampleOutput::requestConnection(), requireConfigsXML(), nidas::dynld::SampleInputStream::search(), nidas::dynld::StatisticsProcessor::selectRequestedSampleTags(), nidas::dynld::SampleInputStream::setBadSampleFilter(), nidas::core::Project::setConfigName(), nidas::core::Project::setDataset(), nidas::core::BadSampleFilter::setDefaultTimeRange(), nidas::dynld::StatisticsProcessor::setEndTime(), nidas::core::FileSet::setEndTime(), nidas::dynld::StatisticsProcessor::setFillGaps(), nidas::util::Socket::setKeepAliveIdleSecs(), nidas::core::SamplePipeline::setProcHeapMax(), nidas::core::SamplePipeline::setProcSorterLength(), nidas::core::SamplePipeline::setRawHeapMax(), nidas::core::SamplePipeline::setRawSorterLength(), nidas::core::SamplePipeline::setRealTime(), nidas::dynld::StatisticsProcessor::setStartTime(), nidas::core::FileSet::setStartTime(), nidas::core::NidasApp::setupDaemon(), nidas::core::NidasApp::socketAddress(), nidas::util::SocketAddress::toString(), nidas::util::UTime::toUsecs(), nidas::util::Exception::what(), and WLOG.
Referenced by main().
int StatsProcess::usage |
( |
const char * |
argv0 | ) |
|
string StatsProcess::_configName |
|
private |
string StatsProcess::_configsXMLName |
|
private |
bool StatsProcess::_daemonMode |
|
private |
string StatsProcess::_datasetName |
|
private |
bool StatsProcess::_doListOutputSamples |
|
private |
string StatsProcess::_dsmName |
|
private |
bool StatsProcess::_fillGaps |
|
private |
int StatsProcess::_niceValue |
|
private |
int StatsProcess::_period |
|
private |
vector<unsigned int> StatsProcess::_selectedOutputSampleIds |
|
private |
float StatsProcess::_sorterLength |
|
private |
string StatsProcess::_xmlFileName |
|
private |
const int StatsProcess::DEFAULT_PERIOD = 300 |
|
staticprivate |
const int StatsProcess::DEFAULT_PORT = 30000 |
|
staticprivate |
The documentation for this class was generated from the following file: