GigEInterface.h

Go to the documentation of this file.

 
#ifndef GIGEINTERFACE_H
#define GIGEINTERFACE_H
 
#include "CommandInterface.h"
#include "GigE.h"
#include "RegisterFile.h"
#include <sys/types.h>
#include <sys/socket.h>
#include <netinet/in.h>
#include <netdb.h>
#include <cstdint>
#include <time.h>
 
#include "PayloadSetter.h"
 
namespace SocCamera
{
    class tcGigEInterface : public tcCommandInterface, public tcPayloadSetter
    {
    public:
        tcGigEInterface(tcIOChannel *apChannel, tcSensorBoard *apSensor);
 
        virtual ~tcGigEInterface();
 
        virtual void* run();
 
 
        void getInput(std::string* /*apStringOutput*/) {}
        std::string parseInput(std::string& /*arStringOutput*/) { return std::string(); }
        void respond(std::string /*ahResponse*/) {}
        void finish (std::string& /*arOriginalBuffer*/) {}
 
        tcRegisterFile* mpRegisterFile; //Registers are stored in network byte order
 
        static const char *getCommandName (uint16_t cmd);
        static const char *getStatusName  (GEV_STATUS status);
 
        virtual void update_payload_size(const uint32_t payload_size);
 
    private:
        void   pump_messages ();
        int    send_ack      (const void *pbuf, int len, sockaddr_in *psockaddr);
 
        void sync_net(bool init_cfg_reg = false);
        void sync_hdw();
        void sync_xml();
        void sync_user_name();
 
    private:
        uint32_t* createDiscoveryAckPacket  (int &len, GEV_STATUS status, uint16_t ackid);
        uint32_t* createReadRegAckPacket    (int &len, GEV_STATUS status, uint16_t ackid, uint32_t address, uint32_t nvalue);
        uint32_t* createWriteRegAckPacket   (int &len, GEV_STATUS status, uint16_t ackid);
        uint32_t* createReadMemAckPacket    (int &len, GEV_STATUS status, uint16_t ackid, uint32_t address, uint16_t numbytes, uint8_t* data);
        uint32_t* createWriteMemAckPacket   (int &len, GEV_STATUS status, uint16_t ackid);
        uint32_t* createForceIpAckPacket    (int &len, GEV_STATUS status, uint16_t ackid);
 
        GEV_STATUS execWriteRegCmd (uint32_t address, uint32_t nvalue);
        GEV_STATUS execWriteMemCmd (uint32_t address, const uint8_t* data, uint32_t numbytes);
        GEV_STATUS execForceIpCmd  (uint32_t ipaddr, uint32_t snmask, uint32_t gwaddr);
 
        void releaseAccess   ();
 
        bool is_access_client (const sockaddr_in &sa)   { return (m_AccessControlled && sa.sin_addr.s_addr == mnAccessingClientIP && sa.sin_port == mnAccessingClientPort); }
        bool is_access_controlled ()                    { return m_AccessControlled; }
        bool is_access_exclusive  ()                    { return m_AccessExclusive; }
 
        sockaddr_in     si_me;
        sockaddr_in     si_other;
        sockaddr_in     si_broadcast;
 
        uint8_t         maGVCPBuffer[GVCP_MAX_DATAGRAM_SIZE];
        int             mnSockfd;
        uint16_t        mnPreviousAckID;
        GEV_STATUS      mePreviousStatus;
        int             mnPacketLength;
        struct timespec mnPreviousTime;
        unsigned int    mnHeartBeatTimer;
        uint16_t        mnWriteMemIndex;
 
        bool            m_AccessControlled;
        bool            m_AccessExclusive ;
        in_addr_t       mnAccessingClientIP;
        in_port_t       mnAccessingClientPort;
 
        uint8_t m_macaddr[6];
    };
 
};
#endif // GIGEINTERFACE_H