TerminalServer.h

Go to the documentation of this file.

#ifndef GCP_UTIL_TERMINALSERVER_H
#define GCP_UTIL_TERMINALSERVER_H

#include <list>
#include <string>
#include <stdio.h>

#include "gcp/util/common/FdSet.h"
#include "gcp/util/common/LogFile.h"
#include "gcp/util/common/NetTermHandler.h"
#include "gcp/util/common/Runnable.h"
#include "gcp/util/common/SignalTaskMsg.h"
#include "gcp/util/common/Vector.h"

namespace gcp {
  namespace util {
    
    class Port;
    class SignalTask;
    class SerialClient;
    class TcpClient;
    class TcpListener;
    
    class TerminalServer : public Runnable {
      
    public:
      
      enum {
    CR = '\r',
    LF = '\n',
      };
      
      TerminalServer(unsigned baudRate, std::string serialPort, bool spawnThread=false);
      
      TerminalServer(std::string ipAddress, unsigned port, bool spawnThread=false);
      
      virtual ~TerminalServer();
      
      void listen(unsigned port, unsigned nClients = 5);
      
      void listenToStdin(bool listen);
      
      void log(bool log);
      
      void strip(std::string strip);
      
      void dontStrip(std::string dontStrip);
      
      void stripUnprintable(bool strip);
      
      void append(std::string append);
      
      void setLogFilePrefix(const std::string& prefix);
      
      void setLogFileDirectory(const std::string& dir);
      
      static RUN_FN(runFn);
      
      void run();
      
    private:
      
      bool hammering_;
      bool waitingToHammer_;
      
      std::list<std::string> hammers_;
      
      std::list<std::string>::iterator hammerStep_;
      
      TimeVal timeVal_;
      
      struct timeval* timeOut_;
      
      bool pending_;
      
      SignalTask* signalTask_;
      
      bool stop_;
      
      std::string strip_;
      
      std::string append_;
      
      TcpListener* listener_;
      
      TcpClient* tcpipPort_;
      SerialClient* serialPort_;
      Port* port_;
      
      FILE* file_;
      
      LogFile logFile_;
      
      FdSet fdSet_;
      
      bool listeningToStdin_;
      
      std::list<NetTermHandler*> clients_;
      
      void initMembers();
      
      void setTcpIp(std::string host, unsigned port);
      
      void setSerial(unsigned baudRate, std::string portName);
      
      void sendShutdownMsg();
      
      void acceptConnection();
      
      void readFromPort();
      
      void readFromStdin();
      
      void writeToStdout(std::string& line);
      
    public:
      void writeToPort(std::string& line);
      void writeToPort(Vector<unsigned char>& bytes);
      
    private:
      void checkClients();
      
      void readFromClient(NetTermHandler* client);
      
      static SIGNALTASK_HANDLER_FN(shutDown);
      
      void initPort();
      
      void openFile(std::string fileName);
      
      void readFromFile();
      
      bool parseCommand(std::string line);
      
      void initHammer();
      
      void stepHammer();
      
    }; // End class TerminalServer
    
  } // End namespace util
} // End namespace gcp



#endif // End #ifndef GCP_UTIL_TERMINALSERVER_H