#include <algorithm>\r
#include "NSProvider.h"\r
#include "NSUtils.h"\r
-#include "NSAcceptedProviders.h"\r
\r
\r
namespace OIC\r
{\r
namespace Service\r
{\r
+ class NSAcceptedProviders;\r
/**\r
* @class NSConsumerService\r
* @brief This class provides a set of C++APIs for Notification Consumer.\r
* get handle of providers accepted.\r
* @return m_acceptedProviders -accepted providers\r
*/\r
- NSAcceptedProviders &getAcceptedProviders();\r
+ NSAcceptedProviders *getAcceptedProviders();\r
\r
private :\r
ProviderDiscoveredCallback m_providerDiscoveredCb;\r
- NSAcceptedProviders m_acceptedProviders;\r
+ NSAcceptedProviders *m_acceptedProviders;\r
\r
private :\r
NSConsumerService();\r
#include "NSConsumerService.h"\r
#include <cstring>\r
#include "NSConsumerInterface.h"\r
+#include "NSAcceptedProviders.h"\r
#include "NSMessage.h"\r
#include "NSCommon.h"\r
#include "NSConstants.h"\r
nsProvider->setProviderState((NSProviderState)state);\r
auto topicLL = NSConsumerGetTopicList(provider->providerId);\r
nsProvider->setTopicList(new NSTopicsList(topicLL));\r
- NSConsumerService::getInstance()->getAcceptedProviders().addProvider(nsProvider);\r
+ NSConsumerService::getInstance()->getAcceptedProviders()->addProvider(nsProvider);\r
if (state == NS_DISCOVERED)\r
{\r
nsProvider->setProviderSubscribedState(NSProviderSubscribedState::DISCOVERED);\r
else if (state == NS_DENY)\r
{\r
oldProvider->setProviderSubscribedState(NSProviderSubscribedState::DENY);\r
- NSConsumerService::getInstance()->getAcceptedProviders().removeProvider(\r
+ NSConsumerService::getInstance()->getAcceptedProviders()->removeProvider(\r
oldProvider->getProviderId());\r
if (changeCallback != NULL)\r
{\r
else if (state == NS_STOPPED)\r
{\r
oldProvider->setProviderSubscribedState(NSProviderSubscribedState::DENY);\r
- NSConsumerService::getInstance()->getAcceptedProviders().removeProvider(\r
+ NSConsumerService::getInstance()->getAcceptedProviders()->removeProvider(\r
oldProvider->getProviderId());\r
NS_LOG(DEBUG, "initiating the State callback : NS_STOPPED");\r
if (changeCallback != NULL)\r
\r
NSMessage nsMessage(message);\r
\r
- if (NSConsumerService::getInstance()->getAcceptedProviders().isAccepted(\r
+ if (NSConsumerService::getInstance()->getAcceptedProviders()->isAccepted(\r
nsMessage.getProviderId()))\r
{\r
auto provider = NSConsumerService::getInstance()->getProvider(\r
\r
NSSyncInfo nsSyncInfo(syncInfo);\r
\r
- if (NSConsumerService::getInstance()->getAcceptedProviders().isAccepted(\r
+ if (NSConsumerService::getInstance()->getAcceptedProviders()->isAccepted(\r
nsSyncInfo.getProviderId()))\r
{\r
auto provider = NSConsumerService::getInstance()->getProvider(\r
NSConsumerService::NSConsumerService()\r
{\r
m_providerDiscoveredCb = NULL;\r
- m_acceptedProviders.removeProviders();\r
+ m_acceptedProviders = new NSAcceptedProviders();\r
}\r
\r
NSConsumerService::~NSConsumerService()\r
{\r
- m_acceptedProviders.removeProviders();\r
+ m_acceptedProviders->removeProviders();\r
+ delete m_acceptedProviders;\r
}\r
\r
NSConsumerService *NSConsumerService::getInstance()\r
NSResult NSConsumerService::start(NSConsumerService::ProviderDiscoveredCallback providerDiscovered)\r
{\r
NS_LOG(DEBUG, "start - IN");\r
- m_acceptedProviders.removeProviders();\r
+ m_acceptedProviders->removeProviders();\r
\r
m_providerDiscoveredCb = providerDiscovered;\r
NSConsumerConfig nsConfig;\r
{\r
NS_LOG(DEBUG, "stop - IN");\r
m_providerDiscoveredCb = NULL;\r
- m_acceptedProviders.removeProviders();\r
+ m_acceptedProviders->removeProviders();\r
\r
NSResult result = (NSResult) NSStopConsumer();\r
NS_LOG(DEBUG, "stop - OUT");\r
\r
std::shared_ptr<NSProvider> NSConsumerService::getProvider(const std::string &id)\r
{\r
- return m_acceptedProviders.getProvider(id);\r
+ return m_acceptedProviders->getProvider(id);\r
}\r
\r
- NSAcceptedProviders &NSConsumerService::getAcceptedProviders()\r
+ NSAcceptedProviders *NSConsumerService::getAcceptedProviders()\r
{\r
return m_acceptedProviders;\r
}\r
#include <cstring>\r
#include "NSConsumerService.h"\r
#include "NSConsumerInterface.h"\r
+#include "NSAcceptedProviders.h"\r
#include "NSConstants.h"\r
#include "NSCommon.h"\r
#include "oic_string.h"\r
\r
bool NSProvider::isValid() const\r
{\r
- if (!NSConsumerService::getInstance()->getAcceptedProviders().isAccepted(getProviderId()))\r
+ if (!NSConsumerService::getInstance()->getAcceptedProviders()->isAccepted(getProviderId()))\r
{\r
NS_LOG(DEBUG, "Invalid Operation with stale reference of Provider. Provider ID doesnot exist");\r
return false;\r
\r
#include <string>\r
#include "NSConsumer.h"\r
-#include "NSAcceptedConsumers.h"\r
#include "NSSyncInfo.h"\r
#include "NSMessage.h"\r
#include "NSUtils.h"\r
{\r
namespace Service\r
{\r
+ class NSAcceptedConsumers;\r
/**\r
* @class NSProviderService\r
* @brief This class provides a set of C++APIs for Notification Provider.\r
* get handle of Consumers accepted.\r
* @return m_acceptedConsumers -accepted Consumers\r
*/\r
- NSAcceptedConsumers &getAcceptedConsumers();\r
+ NSAcceptedConsumers *getAcceptedConsumers();\r
\r
private :\r
ProviderConfig m_config;\r
- NSAcceptedConsumers m_acceptedConsumers;\r
+ NSAcceptedConsumers *m_acceptedConsumers;\r
\r
private:\r
- NSProviderService()\r
- {\r
- m_config.m_subscribeRequestCb = NULL;\r
- m_config.m_syncInfoCb = NULL;\r
- m_acceptedConsumers.removeConsumers();\r
- }\r
+ NSProviderService();\r
~NSProviderService();\r
NSProviderService(const NSProviderService &) = delete;\r
NSProviderService &operator=(const NSProviderService &) = delete;\r
#include "NSConsumer.h"\r
#include <cstring>\r
#include "NSProviderService.h"\r
+#include "NSAcceptedConsumers.h"\r
#include "NSProviderInterface.h"\r
#include "NSConstants.h"\r
#include "oic_string.h"\r
\r
bool NSConsumer::isValid() const\r
{\r
- if (!NSProviderService::getInstance()->getAcceptedConsumers().isAccepted(getConsumerId()))\r
+ if (!NSProviderService::getInstance()->getAcceptedConsumers()->isAccepted(getConsumerId()))\r
{\r
NS_LOG(DEBUG, "Invalid Operation with stale reference of Consumer. Consumer ID doesnot exist");\r
return false;\r
#include <cstring>\r
#include "NSCommon.h"\r
#include "NSProviderInterface.h"\r
+#include "NSAcceptedConsumers.h"\r
#include "NSConsumer.h"\r
#include "NSSyncInfo.h"\r
#include "NSConstants.h"\r
{\r
NS_LOG(DEBUG, "onConsumerSubscribedCallback - IN");\r
std::shared_ptr<NSConsumer> nsConsumer = std::make_shared<NSConsumer>(consumer);\r
- NSProviderService::getInstance()->getAcceptedConsumers().addConsumer(nsConsumer);\r
+ NSProviderService::getInstance()->getAcceptedConsumers()->addConsumer(nsConsumer);\r
if (NSProviderService::getInstance()->getProviderConfig().m_subscribeRequestCb != NULL)\r
{\r
NS_LOG(DEBUG, "initiating the callback for consumer subscribed");\r
return nsMsg;\r
}\r
\r
+ NSProviderService::NSProviderService()\r
+ {\r
+ m_config.m_subscribeRequestCb = NULL;\r
+ m_config.m_syncInfoCb = NULL;\r
+ m_acceptedConsumers = new NSAcceptedConsumers();\r
+ }\r
+\r
NSProviderService::~NSProviderService()\r
{\r
m_config.m_subscribeRequestCb = NULL;\r
m_config.m_syncInfoCb = NULL;\r
- getAcceptedConsumers().removeConsumers();\r
+ m_acceptedConsumers->removeConsumers();\r
+ delete m_acceptedConsumers;\r
}\r
\r
NSProviderService *NSProviderService::getInstance()\r
NSResult NSProviderService::start(NSProviderService::ProviderConfig config)\r
{\r
NS_LOG(DEBUG, "start - IN");\r
- getAcceptedConsumers().removeConsumers();\r
+ m_acceptedConsumers->removeConsumers();\r
\r
m_config = config;\r
NSProviderConfig nsConfig;\r
\r
m_config.m_subscribeRequestCb = NULL;\r
m_config.m_syncInfoCb = NULL;\r
- getAcceptedConsumers().removeConsumers();\r
+ m_acceptedConsumers->removeConsumers();\r
\r
NSResult result = (NSResult) NSStopProvider();\r
NS_LOG(DEBUG, "stop - OUT");\r
\r
std::shared_ptr<NSConsumer> NSProviderService::getConsumer(const std::string &id)\r
{\r
- return m_acceptedConsumers.getConsumer(id);\r
+ return m_acceptedConsumers->getConsumer(id);\r
}\r
\r
- NSAcceptedConsumers &NSProviderService::getAcceptedConsumers()\r
+ NSAcceptedConsumers *NSProviderService::getAcceptedConsumers()\r
{\r
return m_acceptedConsumers;\r
}\r