X-Git-Url: https://git.stg.codes/stg.git/blobdiff_plain/5ff8211bdcd5f110621c0ff01fa0854b5e6d9762..8582d7dfe21e7225d4a715501d70c2649268228f:/projects/stargazer/services_impl.h diff --git a/projects/stargazer/services_impl.h b/projects/stargazer/services_impl.h index 2bb9c879..8a66f63d 100644 --- a/projects/stargazer/services_impl.h +++ b/projects/stargazer/services_impl.h @@ -18,58 +18,56 @@ * Author : Maxim Mamontov */ -#ifndef SERVICES_IMPL_H -#define SERVICES_IMPL_H - -#include - -#include -#include -#include +#pragma once #include "stg/services.h" #include "stg/service_conf.h" #include "stg/locker.h" -#include "stg/store.h" #include "stg/noncopyable.h" #include "stg/logger.h" -class ADMIN; +#include +#include +#include +#include + +namespace STG +{ -class SERVICES_IMPL : private NONCOPYABLE, public SERVICES { -public: - SERVICES_IMPL(STORE * st); - virtual ~SERVICES_IMPL() {} +struct Admin; +struct Store; - int Add(const SERVICE_CONF & service, const ADMIN * admin); - int Del(const std::string & name, const ADMIN * admin); - int Change(const SERVICE_CONF & service, const ADMIN * admin); - bool Find(const std::string & name, SERVICE_CONF * service); - bool Exists(const std::string & name) const; - const std::string & GetStrError() const { return strError; } +class ServicesImpl : public Services { + public: + explicit ServicesImpl(Store* st); - size_t Count() const { return data.size(); } + int Add(const ServiceConf& service, const Admin* admin) override; + int Del(const std::string& name, const Admin* admin) override; + int Change(const ServiceConf& service, const Admin* admin) override; + bool Find(const std::string& name, ServiceConf* service) const override; + bool Find(const std::string& name, ServiceConfOpt* service) const override; + bool Exists(const std::string& name) const override; + const std::string& GetStrError() const override { return strError; } - int OpenSearch() const; - int SearchNext(int, SERVICE_CONF * service) const; - int CloseSearch(int) const; + size_t Count() const override { return data.size(); } -private: - SERVICES_IMPL(const SERVICES_IMPL & rvalue); - SERVICES_IMPL & operator=(const SERVICES_IMPL & rvalue); + int OpenSearch() const override; + int SearchNext(int, ServiceConf* service) const override; + int CloseSearch(int) const override; - typedef list::iterator srv_iter; - typedef list::const_iterator const_srv_iter; + private: + typedef std::vector::iterator iterator; + typedef std::vector::const_iterator const_iterator; - bool Read(); + bool Read(); - std::list data; - STORE * store; - STG_LOGGER & WriteServLog; - mutable std::map searchDescriptors; - mutable unsigned int handle; - mutable pthread_mutex_t mutex; - std::string strError; + std::vector data; + Store* store; + Logger& WriteServLog; + mutable std::map searchDescriptors; + mutable unsigned int handle; + mutable std::mutex mutex; + std::string strError; }; -#endif +}