My Project
|
Public Types | |
enum | CommState { STATE_INIT, STATE_WAIT, STATE_COMM } |
Public Member Functions | |
IersCommunicator (std::string fullPathToOutputFile, unsigned timeOutIntervalInSeconds=0) | |
IersCommunicator (std::string outputDir, std::string outputFileName, unsigned timeOutIntervalInSeconds=0) | |
virtual | ~IersCommunicator () |
void | getIersBulletin () |
void | updateEphemerisFileName (std::string fileName) |
void | addHandler (IERS_HANDLER(*handler), void *args=0) |
void | removeHandler (IERS_HANDLER(*handler)) |
std::string | ephemFileName () |
void | loadFile (std::string name) |
![]() | |
Communicator () | |
virtual | ~Communicator () |
bool | timedOut () |
virtual int | getFd () |
void | run () |
virtual void | processClientMessage () |
void | registerTimeOut () |
![]() | |
SpawnableTask (bool spawn) | |
virtual | ~SpawnableTask () |
![]() | |
void | sendRestartMsg () |
void | sendStopMsg () |
void | sendHeartBeatMsg () |
virtual void | fwdTaskMsg (IersCommunicatorMsg *msg) |
![]() | |
RunnableTask (bool spawnThread) | |
virtual | ~RunnableTask () |
![]() | |
Runnable (bool spawnThread, RUN_FN(*runFn)) | |
Runnable (bool spawnThread, RUN_FN(*runFn), int priority) | |
virtual | ~Runnable () |
void | blockForever () |
void | spawn () |
Additional Inherited Members | |
![]() | |
static | RUN_FN (runFn) |
![]() | |
static | THREAD_START (startUp) |
![]() | |
static const unsigned | COMMAND_TIMEOUT_SEC = 10 |
![]() | |
virtual void | terminateCommSequence (bool error) |
void | enableTimeOut (bool enable) |
void | checkLine () |
virtual void | sendNextString (void) |
void | advanceIterator (bool bufferReset) |
void | checkIterators () |
![]() | |
void | run () |
![]() | |
GenericTask () | |
GenericTask (Thread *thread) | |
virtual | ~GenericTask () |
void | sendTaskMsg (IersCommunicatorMsg *msg) |
void | startThreads (void *arg) |
void | startThread (void *arg, unsigned order) |
unsigned | getMinStartOrder () |
bool | threadsNeedStarting () |
void | cancelThreads () |
void | cancelThread (unsigned order) |
unsigned | getMinCancelOrder () |
bool | threadsNeedCancelling () |
void | pingThreads (void *arg) |
void | raise (std::string name, int sigNo) |
Thread * | getThread (std::string name) |
bool | threadsAreRunning () |
void | shutdownConnection (int fd) |
virtual void | restart (void) |
virtual void | processTaskMsg (bool *stop) |
virtual void | respondToHeartBeat () |
virtual void | installTimer (IersCommunicatorMsg *msg) |
virtual void | installSignal (IersCommunicatorMsg *msg) |
virtual void | enableTimer (IersCommunicatorMsg *msg) |
virtual void | addHandler (IersCommunicatorMsg *msg) |
void | stepCommands () |
![]() | |
virtual void | broadcastReady () |
void | spawn (void *arg) |
![]() | |
static | COMM_PARSER_FN (sendNextString) |
![]() | |
gcp::util::TcpClient * | client_ |
gcp::util::TimeVal | timer_ |
std::list< std::string > | sentStrings_ |
std::list< RcvdStr > | rcvdStrings_ |
std::list< std::string >::iterator | sentStringIter_ |
std::list< RcvdStr >::iterator | rcvdStringIter_ |
std::ostringstream | os_ |
![]() | |
Thread * | thread_ |
std::vector< Thread * > | threads_ |
PipeQ< IersCommunicatorMsg > | msgq_ |
gcp::util::FdSet | fdSet_ |
std::vector< Command * > | commands_ |
struct timeval * | timeOut_ |
TimeVal | commandTimeOut_ |
![]() | |
Thread * | spawnedThread_ |
bool | spawned_ |
RUN_FN * | runFn_ |
IersCommunicator::IersCommunicator | ( | std::string | fullPathToOutputFileName, |
unsigned | timeOutIntervalInSeconds = 0 |
||
) |
....................................................................... Constructor.
IersCommunicator::IersCommunicator | ( | std::string | outputDir, |
std::string | outputFileName, | ||
unsigned | timeOutIntervalInSeconds = 0 |
||
) |
....................................................................... Constructor.
|
virtual |
....................................................................... Destructor.
void IersCommunicator::addHandler | ( | IERS_HANDLER * | fn, |
void * | args = 0 |
||
) |
....................................................................... Public method to add a handler to be called when the ephemeris file is updated
std::string IersCommunicator::ephemFileName | ( | ) |
....................................................................... Return the ephemeris file name
void IersCommunicator::getIersBulletin | ( | ) |
....................................................................... Tell this object to retrieve the ut1utc ephemeris file
void IersCommunicator::loadFile | ( | std::string | name | ) |
....................................................................... Test method to read a ser7.dat format file
void IersCommunicator::updateEphemerisFileName | ( | std::string | file | ) |
....................................................................... Tell this object to update the filename