nidas
v1.2-1520
|
Public Member Functions | |
SensorExtract () | |
int | parseRunstring (int argc, char **argv) throw () |
int | run () throw () |
void | sendHeader (dsm_time_t, SampleOutput *) throw (n_u::IOException) |
Method called to write a header to an SampleOutput. More... | |
void | printHeader () |
for debugging. More... | |
Static Public Member Functions | |
static void | sigAction (int sig, siginfo_t *siginfo, void *) |
static void | setupSignals () |
static int | main (int argc, char **argv) throw () |
static int | usage (const char *argv0) |
static void | setDefaults (SampleInputHeader &header) |
static void | sendDefaultHeader (SampleOutput *output) throw (nidas::util::IOException) |
Private Attributes | |
list< string > | inputFileNames |
n_u::auto_ptr< n_u::SocketAddress > | sockAddr |
string | outputFileName |
int | outputFileLength |
SampleInputHeader | header |
set< dsm_sample_id_t > | includeIds |
set< dsm_sample_id_t > | includeDSMIds |
set< dsm_sample_id_t > | excludeIds |
set< int > | excludeDSMIds |
map< dsm_sample_id_t, dsm_sample_id_t > | newIds |
map< int, int > | newDSMIds |
Static Private Attributes | |
static bool | interrupted = false |
SensorExtract::SensorExtract | ( | ) |
|
static |
References parseRunstring(), run(), and setupSignals().
Referenced by main().
int SensorExtract::parseRunstring | ( | int | argc, |
char ** | argv | ||
) | |||
throw | ( | ||
) |
References nidas::util::Inet4Address::getByName(), NIDAS_RAW_DATA_PORT_TCP, port, SET_DSM_ID, SET_SPS_ID, usage(), and nidas::util::Exception::what().
Referenced by main().
void SensorExtract::printHeader | ( | ) |
for debugging.
References nidas::core::SampleInputHeader::getArchiveVersion(), nidas::core::SampleInputHeader::getConfigName(), nidas::core::SampleInputHeader::getConfigVersion(), nidas::core::SampleInputHeader::getProjectName(), nidas::core::SampleInputHeader::getSoftwareVersion(), nidas::core::SampleInputHeader::getSystemName(), and header.
int SensorExtract::run | ( | ) | ||
throw | ( | |||
) |
References nidas::dynld::SampleOutputStream::close(), excludeDSMIds, excludeIds, nidas::dynld::SampleOutputStream::flush(), nidas::core::Sample::freeReference(), GET_DSM_ID, nidas::core::FileSet::getFileSet(), nidas::core::Sample::getId(), nidas::dynld::SampleInputStream::getInputHeader(), nidas::util::Logger::getInstance(), nidas::core::Sample::getTimeTag(), header, includeDSMIds, includeIds, inputFileNames, interrupted, nidas::util::Logger::log(), LOG_WARNING, newDSMIds, newIds, outputFileLength, outputFileName, nidas::dynld::SampleInputStream::readInputHeader(), nidas::dynld::SampleInputStream::readSample(), nidas::dynld::SampleOutputStream::receive(), SET_DSM_ID, nidas::core::FileSet::setFileLengthSecs(), nidas::core::FileSet::setFileName(), nidas::core::SampleOutputBase::setHeaderSource(), nidas::core::Sample::setId(), nidas::dynld::SampleInputStream::setMaxSampleLength(), sockAddr, nidas::util::UTime::toUsecs(), and nidas::util::Exception::what().
Referenced by main().
|
staticinherited |
|
virtual |
Method called to write a header to an SampleOutput.
Derived classes implement as they see fit.
Implements nidas::core::HeaderSource.
|
staticinherited |
References nidas::core::Version::getArchiveVersion(), nidas::core::Project::getInstance(), nidas::core::Version::getSoftwareVersion(), nidas::core::Project::getSystemName(), nidas::core::SampleInputHeader::setArchiveVersion(), nidas::core::SampleInputHeader::setConfigName(), nidas::core::SampleInputHeader::setConfigVersion(), nidas::core::SampleInputHeader::setProjectName(), nidas::core::SampleInputHeader::setSoftwareVersion(), and nidas::core::SampleInputHeader::setSystemName().
|
static |
References sigAction().
|
static |
References interrupted.
Referenced by setupSignals().
|
static |
References NIDAS_RAW_DATA_PORT_TCP.
|
private |
Referenced by run().
|
private |
Referenced by run().
|
private |
Referenced by printHeader(), and run().
|
private |
Referenced by run().
|
private |
Referenced by run().
|
private |
Referenced by run().
|
staticprivate |
Referenced by run(), and sigAction().
|
private |
Referenced by run().
|
private |
Referenced by run().
|
private |
Referenced by run().
|
private |
Referenced by run().
|
private |
Referenced by run().