AntennaConsumerNormal.h

Go to the documentation of this file.

#ifndef GCP_ASSEMBLER_ANTENNACONSUMERNORMAL_H
#define GCP_ASSEMBLER_ANTENNACONSUMERNORMAL_H

#include "gcp/util/common/NetCommHandler.h"
#include "gcp/util/common/TimeVal.h"
#include "gcp/mediator/specific/AntennaConsumer.h"

namespace gcp {
  
  namespace util {
    class TcpListener;
    class NetAntennaDataFrameHandler;
  }
  
namespace mediator {
    
    class Scanner;
    
    class AntennaConsumerNormal :
      public AntennaConsumer {
      public:
      
      AntennaConsumerNormal(Scanner* parent);
      
      virtual ~AntennaConsumerNormal();
      
      private:
      
      friend class Scanner;
      
      Scanner* parent_;
      
      static AntennaConsumerNormal* consumer_;

      int nAntenna_;
      
      gcp::util::TcpListener* listener_;
      
      gcp::util::NetCommHandler temporaryHandler_; 
      
      std::vector<gcp::util::NetAntennaDataFrameHandler*> connectedHandlers_; 
      
      gcp::util::TimeVal startTime_;
      gcp::util::TimeVal timer_;
      struct timeval* timeOut_;

      void connectTcpIp();
      
      void serviceMsgQ();
      
      void listen(bool listenVar);
      
      void initializeConnection();

      void terminateConnection(gcp::util::NetHandler* str);

      void terminateConnection(gcp::util::NetCommHandler* str);

      void finalizeConnection();
      
      void sendGreetingMsg();

      bool timedOut();
      
      static NET_READ_HANDLER(netMsgReadHandler);

      static NET_SEND_HANDLER(netMsgSentHandler);

      static NET_ERROR_HANDLER(netMsgErrorHandler);

      static NET_READ_HANDLER(netAntennaDataFrameReadHandler);

      static NET_ERROR_HANDLER(netAntennaDataFrameErrorHandler);

    }; // End class AntennaConsumerNormal
    
} // End namespace mediator
} // End namespace gcp



#endif // End #ifndef GCP_ASSEMBLER_ANTENNACONSUMERNORMAL_H