diff options
Diffstat (limited to 'src/3rd_party-static/message_broker/include/CMessageBrokerRegistry.hpp')
-rw-r--r-- | src/3rd_party-static/message_broker/include/CMessageBrokerRegistry.hpp | 113 |
1 files changed, 0 insertions, 113 deletions
diff --git a/src/3rd_party-static/message_broker/include/CMessageBrokerRegistry.hpp b/src/3rd_party-static/message_broker/include/CMessageBrokerRegistry.hpp deleted file mode 100644 index 001f978bbf..0000000000 --- a/src/3rd_party-static/message_broker/include/CMessageBrokerRegistry.hpp +++ /dev/null @@ -1,113 +0,0 @@ -#ifndef CMESSAGEBROKERREGISTRY_H -#define CMESSAGEBROKERREGISTRY_H - -#include <map> -#include <vector> -#include <iostream> -#include <string> -#include "utils/lock.h" - -/** - * \namespace NsMessageBroker - * \brief MessageBroker related functions. - */ -namespace NsMessageBroker -{ - - /** - * \class CMessageBrokerRegistry - * \brief Singletone CMessageBrokerRegistry class implementation. - */ - class CMessageBrokerRegistry - { - public: - /** - * \brief Singletone instantiator. - * \return pointer to CMessageBroker instance - */ - static CMessageBrokerRegistry* getInstance(); - - /** - * \brief Destructor. - */ - ~CMessageBrokerRegistry(); - - /** - * \brief adds controller to the registry. - * \param fd file descriptor of controller. - * \param name name of controller. - * \return false if already exist. - */ - bool addController(int fd, std::string name); - - /** - * \brief deletes controller from the registry. - * \param name name of controller. - */ - void deleteController(std::string name); - - /** - * \brief Remove all controllers by descriptor - * \param fd descriptor - */ - void removeControllersByDescriptor(const int fd); - - /** - * \brief Remove all subscribers by descriptor - * \param fd descriptor - */ - void removeSubscribersByDescriptor(const int fd); - - /** - * \brief adds notification subscriber to the registry. - * \param fd file descriptor of controller. - * \param name name of property which should be observed. - * \return false if already exist. - */ - bool addSubscriber(int fd, std::string name); - - /** - * \brief deletes notification subscriber from the registry. - * \param fd file descriptor of controller. - * \param name name of property which should be observed. - */ - void deleteSubscriber(int fd, std::string name); - - /** - * \brief gets controller fd from the registry by name. - * \param name name of controller. - * \return file descriptor of controller. - */ - int getDestinationFd(std::string name); - - /** - * \brief gets subscribers fd's. - * \param name name of property. - * \param result vector for results. - * \return count of subscribers. - */ - int getSubscribersFd(std::string name, std::vector<int>& result); - private: - /** - * \brief Constructor. - */ - CMessageBrokerRegistry(); - - /** - * \brief Map to store controllers information like ComponentName:socketFd. - * For example PhoneController:1080 - */ - std::map <std::string, int> mControllersList; - sync_primitives::Lock mControllersListLock; - - /** - * \brief Map to store subscribers information like ComponentName.PropertyName:socketFd:. - * For example PhoneController.onPhoneBookChanged:1080 - */ - std::multimap <std::string, int> mSubscribersList; - sync_primitives::Lock mSubscribersListLock; - }; -} /* namespace NsMessageBroker */ - -#endif // CMESSAGEBROKERREGISTRY_H - |