NetCommHandler.h

Go to the documentation of this file.

#ifndef SZA_UTIL_NETCOMMHANDLER_H
#define SZA_UTIL_NETCOMMHANDLER_H

#include "carma/szautil/AntNum.h"
#include "carma/szautil/NetMsgHandler.h"
#include "carma/szautil/NetCmdHandler.h"

namespace sza {
  namespace util {
    
    class NetCommHandler {
    public:
      
      NetCommHandler();
      
      virtual ~NetCommHandler();

      void attachReadStream(int fd);

      void attachSendStream(int fd);

      void attach(int fd);

      void packNetMsg(NetMsg* msg);

      void packNetCmd(NetCmd* cmd);

      void packRtcNetCmd(sza::array::RtcNetCmd* cmd, 
                         sza::array::NetCmdId opcode);

      sza::util::NetReadStr::NetReadId readNetMsg();

      sza::util::NetSendStr::NetSendId sendNetMsg();

      sza::util::NetReadStr::NetReadId readNetCmd();

      sza::util::NetSendStr::NetSendId sendNetCmd();

      sza::util::NetCmd* getLastReadNetCmd();

      sza::util::NetCmd* getLastSentNetCmd();

      sza::util::NetMsg* getLastReadNetMsg();

      sza::util::NetMsg* getLastSentNetMsg();

      int getReadFd();

      /*
       * Return the fd that our send streams are attached to.
       */
      int getSendFd();

      int getFd();

      NetMsgHandler* getNetMsgHandler();

      NetCmdHandler* getNetCmdHandler();

      inline AntNum::Id getId() {
        return antNum_.getId();
      }

      inline unsigned getIntId() {
        return antNum_.getIntId();
      }

      inline void setId(AntNum::Id id) {
        antNum_.setId(id);
      }

    private:

      int readFd_;
      int sendFd_;
      AntNum antNum_;
      NetMsgHandler netMsgHandler_;
      NetCmdHandler netCmdHandler_;

    }; // End class NetCommHandler
    
  } // End namespace util
} // End namespace sza



#endif // End #ifndef SZA_UTIL_NETCOMMHANDLER_H