DataClientProxy.hpp

Go to the documentation of this file.

#ifndef __HCE_DATA_CLIENT_PROXY_INCLUDED__
#define __HCE_DATA_CLIENT_PROXY_INCLUDED__

#include <iostream>
#include <sstream>

#include "Handler.hpp"
#include "DataNodeOptions.hpp"

namespace HCE {
  namespace handlers {

    class DataClientProxy: public HCE::handlers::Handler, protected HCE::handlers::DataNodeOptions {
      public:
        DataClientProxy(std::string name, zmq::context_t& ctx, const std::string& clientIdentity, std::string connectionString, int64_t startedAt,
            unsigned char logPriority, const std::string& iniFile="");
        virtual ~DataClientProxy();

      protected:
        int initialize(void);
        void deinitialize(void);
        void* process(void);

        void handleExternalMessage(void);
        void handleInternalMessage(void);
        void handleRouteMessage(void);
        void processControlMessage(zmsg& msg);
        void processDataMessage(zmsg& msg);

        std::string processAdminCommands(std::string& command, std::string& parameters);
        void rebuildDataClientSocket(void);
        void heartbit(void);
        void sendHeartbeat(void);
        void externalConnectionRefresh(void);
        std::string getPropertyInformation(void);

        zmq::socket_t* _inprocProxySock;
        zmq::socket_t* _inprocReducerOutSock;
        zmq::socket_t* _dataClientSock;
        bool _dataClientSockConnected = false;

        TimeoutShiftCounter _shiftCounter;

        std::vector<ClientWorkerItem> _clientsQueue;

        void setHeartbeatAt(int64_t heartbeatAt);
        int64_t getHeartbeatAt(void);

        void setHeartbeatedAt(int64_t heartbeatedAt);
        int64_t getHeartbeatedAt(void);

        void setStatRequests(unsigned int statRequests);
        unsigned int getStatRequests(void);

        void setStatResponses(unsigned int statResponses);
        unsigned int getStatResponses(void);
    };

  }
}

#endif /* __HCE_DATA_CLIENT_PROXY_INCLUDED__ */