TerminalServer.h

Go to the documentation of this file.

#ifndef SZA_UTIL_TERMINALSERVER_H
#define SZA_UTIL_TERMINALSERVER_H

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

#include "carma/szautil/FdSet.h"
#include "carma/szautil/LogFile.h"
#include "carma/szautil/NetTermHandler.h"
#include "carma/szautil/Runnable.h"
#include "carma/szautil/SignalTaskMsg.h"
#include "carma/szautil/Vector.h"

namespace sza {
  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 sza


#endif // End #ifndef SZA_UTIL_TERMINALSERVER_H