Admin.hpp

Go to the documentation of this file.

#ifndef __HCE_ADMIN_INCLUDED__
#define __HCE_ADMIN_INCLUDED__

#include <sstream>
#include <map>

#include "Handler.hpp"

namespace HCE {
  namespace handlers {

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

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

        void handleInternalMessage(void);
        void handleExternalMessage(void);

        void processDataMessage(zmsg& msg);

        void processControlMessageInproc(zmsg& msg);
        void processDataMessageInproc(zmsg& msg);
        void registerClientInproc(const std::string& identity);

        unsigned char processAdminRequest(zmsg& msg);
        static std::vector<std::string> parseAdminRequest(const std::string& command);
        std::string processAdminCommands(std::string& command, std::string& parameters);

        std::string getPropertyInformation(void);

        void setStatRequestsTotal(unsigned int statRequestsTotal);
        unsigned int getStatRequestsTotal(void);

        zmq::socket_t* _adminServerSock;

        std::vector<ClientWorkerItem> _queueInproc;
        ClientsQueueManager* _clientsManagerInproc;
    };
  }
}

#endif /* __HCE_ADMIN_INCLUDED__ */