|
My Project
|
Public Member Functions | |
| TipperCommunicator (gcp::util::FdSet *fdSet, std::string host) | |
| int | getFtpCommFd () |
| int | getFtpDataFd () |
| TipperCommunicator (std::string host, unsigned timeOutIntervalInSeconds=0) | |
| void | getTipperLog () |
| void | initialize (std::string host) |
| virtual | ~TipperCommunicator () |
| void | initiateGetTipperLogCommSequence () |
| void | concatenateString (std::ostringstream &os) |
| void | processTipperLog () |
Public Member Functions inherited from gcp::util::Communicator | |
| Communicator () | |
| virtual | ~Communicator () |
| bool | timedOut () |
| virtual int | getFd () |
| void | run () |
| virtual void | processClientMessage () |
| void | registerTimeOut () |
Public Member Functions inherited from gcp::util::SpawnableTask< TipperCommunicatorMsg > | |
| SpawnableTask (bool spawn) | |
| virtual | ~SpawnableTask () |
Public Member Functions inherited from gcp::util::GenericTask< TipperCommunicatorMsg > | |
| void | sendRestartMsg () |
| void | sendStopMsg () |
| void | sendHeartBeatMsg () |
| virtual void | fwdTaskMsg (TipperCommunicatorMsg *msg) |
Public Member Functions inherited from gcp::util::RunnableTask | |
| RunnableTask (bool spawnThread) | |
| virtual | ~RunnableTask () |
Public Member Functions inherited from gcp::util::Runnable | |
| Runnable (bool spawnThread, RUN_FN(*runFn)) | |
| Runnable (bool spawnThread, RUN_FN(*runFn), int priority) | |
| virtual | ~Runnable () |
| void | blockForever () |
| void | spawn () |
Additional Inherited Members | |
Static Public Member Functions inherited from gcp::util::RunnableTask | |
| static | RUN_FN (runFn) |
Static Public Member Functions inherited from gcp::util::Runnable | |
| static | THREAD_START (startUp) |
Static Public Attributes inherited from gcp::util::Communicator | |
| static const unsigned | COMMAND_TIMEOUT_SEC = 10 |
Protected Member Functions inherited from gcp::util::Communicator | |
| void | enableTimeOut (bool enable) |
| void | checkLine () |
| virtual void | sendNextString (void) |
| void | advanceIterator (bool bufferReset) |
| void | checkIterators () |
Protected Member Functions inherited from gcp::util::SpawnableTask< TipperCommunicatorMsg > | |
| void | run () |
Protected Member Functions inherited from gcp::util::GenericTask< TipperCommunicatorMsg > | |
| GenericTask () | |
| GenericTask (Thread *thread) | |
| virtual | ~GenericTask () |
| void | sendTaskMsg (TipperCommunicatorMsg *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 (TipperCommunicatorMsg *msg) |
| virtual void | installSignal (TipperCommunicatorMsg *msg) |
| virtual void | enableTimer (TipperCommunicatorMsg *msg) |
| virtual void | addHandler (TipperCommunicatorMsg *msg) |
| void | stepCommands () |
Protected Member Functions inherited from gcp::util::Runnable | |
| virtual void | broadcastReady () |
| void | spawn (void *arg) |
Static Protected Member Functions inherited from gcp::util::Communicator | |
| static | COMM_PARSER_FN (sendNextString) |
Protected Attributes inherited from gcp::util::Communicator | |
| 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_ |
Protected Attributes inherited from gcp::util::GenericTask< TipperCommunicatorMsg > | |
| Thread * | thread_ |
| std::vector< Thread * > | threads_ |
| PipeQ< TipperCommunicatorMsg > | msgq_ |
| gcp::util::FdSet | fdSet_ |
| std::vector< Command * > | commands_ |
| struct timeval * | timeOut_ |
| TimeVal | commandTimeOut_ |
Protected Attributes inherited from gcp::util::Runnable | |
| Thread * | spawnedThread_ |
| bool | spawned_ |
| RUN_FN * | runFn_ |
| TipperCommunicator::TipperCommunicator | ( | gcp::util::FdSet * | fdSet, |
| std::string | host | ||
| ) |
....................................................................... Constructor.
| TipperCommunicator::TipperCommunicator | ( | std::string | host, |
| unsigned | timeOutIntervalInSeconds = 0 |
||
| ) |
....................................................................... Constructor.
|
virtual |
....................................................................... Destructor.
| int TipperCommunicator::getFtpCommFd | ( | ) |
....................................................................... Return a reference to the fd corresonding to the comms link with the FTP server
| int TipperCommunicator::getFtpDataFd | ( | ) |
....................................................................... Return a reference to the fd corresonding to the data link with the FTP server
| void TipperCommunicator::getTipperLog | ( | ) |
....................................................................... Tell this object to retrieve the tipper log
| void TipperCommunicator::initialize | ( | std::string | host | ) |
....................................................................... Initialize pertinent members of this class to sensible defaults
| void TipperCommunicator::initiateGetTipperLogCommSequence | ( | ) |
....................................................................... Initiate sending commands to the server.
| void TipperCommunicator::processTipperLog | ( | ) |
....................................................................... Process a tipper log received from a remote server