X-Git-Url: http://review.tizen.org/git/?a=blobdiff_plain;f=service%2Fnotification%2Fsrc%2Fprovider%2FNSProviderInterface.c;h=02697ab575237b1e27eb26db434e886cbe83fc97;hb=3c093548382bb2542c87a67e6e5fa32552c29cb3;hp=6c9331fb1163a4ad9d7ce6ebfdc9d3cbad6e7bd2;hpb=6703e6843a1b644b4d2b124474589ba81c112a48;p=platform%2Fupstream%2Fiotivity.git

diff --git a/service/notification/src/provider/NSProviderInterface.c b/service/notification/src/provider/NSProviderInterface.c
index 6c9331f..02697ab 100644
--- a/service/notification/src/provider/NSProviderInterface.c
+++ b/service/notification/src/provider/NSProviderInterface.c
@@ -1,367 +1,514 @@
-//******************************************************************
-//
-// Copyright 2016 Samsung Electronics All Rights Reserved.
-//
-//-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=
-//
-// Licensed under the Apache License, Version 2.0 (the "License");
-// you may not use this file except in compliance with the License.
-// You may obtain a copy of the License at
-//
-//      http://www.apache.org/licenses/LICENSE-2.0
-//
-// Unless required by applicable law or agreed to in writing, software
-// distributed under the License is distributed on an "AS IS" BASIS,
-// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-// See the License for the specific language governing permissions and
-// limitations under the License.
-//
-//-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=
-
-#include "NSProviderInterface.h"
-#include "NSProviderScheduler.h"
-#include "NSProviderListener.h"
-#include "NSProviderSubscription.h"
-#include "NSProviderNotification.h"
-#include "NSProviderCallbackResponse.h"
-#include "NSStorageAdapter.h"
-#include "NSProviderMemoryCache.h"
-#include "NSProviderTopic.h"
-#include "oic_malloc.h"
-#include "oic_string.h"
-#include "cautilinterface.h"
-#include "NSProviderSystem.h"
-#include "oic_time.h"
-
-bool initProvider = false;
-
-pthread_mutex_t nsInitMutex;
-
-void initializeMutex()
-{
-    static pthread_mutex_t initMutex = PTHREAD_MUTEX_INITIALIZER;
-    nsInitMutex = initMutex;
-}
-
-NSResult NSStartProvider(NSProviderConfig config)
-{
-    NS_LOG(DEBUG, "NSStartProvider - IN");
-
-    initializeMutex();
-
-    pthread_mutex_lock(&nsInitMutex);
-
-    if (!initProvider)
-    {
-        NS_LOG(DEBUG, "Init Provider");
-        initProvider = true;
-        NSInitProviderInfo(config.userInfo);
-        NSSetSubscriptionAccessPolicy(config.policy);
-        NSRegisterSubscribeRequestCb(config.subRequestCallback);
-        NSRegisterSyncCb(config.syncInfoCallback);
-        CARegisterNetworkMonitorHandler((CAAdapterStateChangedCB)NSProviderAdapterStateListener,
-                (CAConnectionStateChangedCB)NSProviderConnectionStateListener);
-
-        NSSetList();
-        NSInitScheduler();
-        NSStartScheduler();
-
-        NSPushQueue(DISCOVERY_SCHEDULER, TASK_START_PRESENCE, NULL);
-        NSPushQueue(DISCOVERY_SCHEDULER, TASK_REGISTER_RESOURCE, NULL);
-    }
-    else
-    {
-        NS_LOG(DEBUG, "Already started Notification Provider");
-    }
-    pthread_mutex_unlock(&nsInitMutex);
-
-    NS_LOG(DEBUG, "NSStartProvider - OUT");
-    return NS_OK;
-}
-
-void NSSetList()
-{
-    NS_LOG(DEBUG, "NSSetList - IN");
-
-    pthread_mutexattr_init(&NSCacheMutexAttr);
-    int pthreadResult = pthread_mutexattr_settype(&NSCacheMutexAttr, PTHREAD_MUTEX_RECURSIVE);
-    pthread_mutex_init(&NSCacheMutex, &NSCacheMutexAttr);
-
-    NSInitSubscriptionList();
-    NSInitMessageList();
-    NSInitTopicList();
-    NS_LOG(DEBUG, "NSSetList - OUT");
-}
-
-void NSDestroyList()
-{
-    NSStorageDestroy(consumerSubList);
-    NSStorageDestroy(messageList);
-    NSStorageDestroy(consumerTopicList);
-    NSStorageDestroy(registeredTopicList);
-
-    pthread_mutex_destroy(&NSCacheMutex);
-    pthread_mutexattr_destroy(&NSCacheMutexAttr);
-}
-
-NSResult NSStopProvider()
-{
-    NS_LOG(DEBUG, "NSStopProvider - IN");
-    pthread_mutex_lock(&nsInitMutex);
-
-    if(initProvider)
-    {
-        NSPushQueue(DISCOVERY_SCHEDULER, TASK_STOP_PRESENCE, NULL);
-        NSDeinitProviderInfo();
-        NSUnRegisterResource();
-        NSRegisterSubscribeRequestCb((NSSubscribeRequestCallback)NULL);
-        NSRegisterSyncCb((NSProviderSyncInfoCallback)NULL);
-        NSStopScheduler();
-        NSDestroyList();
-
-        initProvider = false;
-    }
-
-    pthread_mutex_unlock(&nsInitMutex);
-    NS_LOG(DEBUG, "NSStopProvider - OUT");
-    return NS_OK;
-}
-
-NSResult NSProviderEnableRemoteService(char *serverAddress)
-{
-    NS_LOG(DEBUG, "NSProviderEnableRemoteService - IN");
-    pthread_mutex_lock(&nsInitMutex);
-
-if(!initProvider)
-    {
-        NS_LOG(DEBUG, "Provider service has not been started yet");
-        pthread_mutex_unlock(&nsInitMutex);
-        return NS_FAIL;
-    }
-    NS_LOG(DEBUG, "Check the remote server login");
-    NS_LOG_V(DEBUG, "Remote server address: %s", serverAddress);
-#ifdef RD_CLIENT
-    NS_LOG(DEBUG, "Request to publish resource");
-    NSPushQueue(DISCOVERY_SCHEDULER, TASK_PUBLISH_RESOURCE, serverAddress);
-#endif
-
-    pthread_mutex_unlock(&nsInitMutex);
-    NS_LOG(DEBUG, "NSProviderEnableRemoteService - OUT");
-    return NS_OK;
-}
-
-NSResult NSProviderDisableRemoteService(char *serverAddress)
-{
-    NS_LOG(DEBUG, "NSProviderDisableRemoteService - IN");
-    pthread_mutex_lock(&nsInitMutex);
-
-    if(!initProvider)
-    {
-        NS_LOG(DEBUG, "Provider service has not been started yet");
-        return NS_FAIL;
-    }
-    NS_LOG_V(DEBUG, "Remote server address: %s", serverAddress);
-#ifdef RD_CLIENT
-    NS_LOG(DEBUG, "Delete remote server info");
-    NSDeleteRemoteServerAddress(serverAddress);
-#endif
-
-    pthread_mutex_unlock(&nsInitMutex);
-    NS_LOG(DEBUG, "NSProviderDisableRemoteService - OUT");
-    return NS_OK;
-}
-
-NSResult NSSendMessage(NSMessage *msg)
-{
-    NS_LOG(DEBUG, "NSSendNotification - IN");
-
-    pthread_mutex_lock(&nsInitMutex);
-
-    if(msg == NULL)
-    {
-        NS_LOG(ERROR, "Msg is NULL");
-        pthread_mutex_unlock(&nsInitMutex);
-        return NS_ERROR;
-    }
-
-    NSMessage * newMsg = NSDuplicateMessage(msg);
-    NSPushQueue(NOTIFICATION_SCHEDULER, TASK_SEND_NOTIFICATION, newMsg);
-
-    pthread_mutex_unlock(&nsInitMutex);
-
-    NS_LOG(DEBUG, "NSSendNotification - OUT");
-    return NS_OK;
-}
-
-NSResult NSProviderSendSyncInfo(uint64_t messageId, NSSyncType type)
-{
-    NS_LOG(DEBUG, "NSProviderReadCheck - IN");
-    pthread_mutex_lock(&nsInitMutex);
-
-    NSSyncInfo * syncInfo = (NSSyncInfo *)OICMalloc(sizeof(NSSyncInfo));
-    OICStrcpy(syncInfo->providerId, UUID_STRING_SIZE, NSGetProviderInfo()->providerId);
-    syncInfo->messageId = messageId;
-    syncInfo->state = type;
-    NSPushQueue(NOTIFICATION_SCHEDULER, TASK_SEND_READ, syncInfo);
-
-    pthread_mutex_unlock(&nsInitMutex);
-    NS_LOG(DEBUG, "NSProviderReadCheck - OUT");
-    return NS_OK;
-}
-
-NSResult NSAcceptSubscription(NSConsumer *consumer, bool accepted)
-{
-    NS_LOG(DEBUG, "NSAccept - IN");
-
-    pthread_mutex_lock(&nsInitMutex);
-
-    NSConsumer * newConsumer = NSDuplicateConsumer(consumer);
-    if(accepted)
-    {
-        NS_LOG(DEBUG, "accepted is true - ALLOW");
-        NSPushQueue(SUBSCRIPTION_SCHEDULER, TASK_SEND_ALLOW, newConsumer);
-    }
-    else
-    {
-        NS_LOG(DEBUG, "accepted is false - DENY");
-        NSPushQueue(SUBSCRIPTION_SCHEDULER, TASK_SEND_DENY, newConsumer);
-    }
-
-    pthread_mutex_unlock(&nsInitMutex);
-    NS_LOG(DEBUG, "NSAccept - OUT");
-    return NS_OK;
-}
-
-NSMessage * NSCreateMessage()
-{
-    NS_LOG(DEBUG, "NSCreateMessage - IN");
-    pthread_mutex_lock(&nsInitMutex);
-
-    NSMessage * msg = NSInitializeMessage();
-    OICStrcpy(msg->providerId, UUID_STRING_SIZE, NSGetProviderInfo()->providerId);
-
-    pthread_mutex_unlock(&nsInitMutex);
-    NS_LOG(DEBUG, "NSCreateMessage - OUT");
-    return msg;
-}
-
-NSTopicLL * NSProviderGetConsumerTopics(char *consumerId)
-{
-    NS_LOG(DEBUG, "NSProviderGetConsumerTopics - IN");
-    pthread_mutex_lock(&nsInitMutex);
-
-    if(!consumerId)
-    {
-        NS_LOG(DEBUG, "consumer id should be set");
-        pthread_mutex_unlock(&nsInitMutex);
-        return NS_FAIL;
-    }
-
-    NSTopicLL * topics = NSProviderGetConsumerTopicsCacheData(registeredTopicList,
-            consumerTopicList, consumerId);
-
-    pthread_mutex_unlock(&nsInitMutex);
-    return topics;
-}
-
-NSTopicLL * NSProviderGetTopics()
-{
-    NS_LOG(DEBUG, "NSProviderGetTopics - IN");
-    pthread_mutex_lock(&nsInitMutex);
-
-    NSTopicLL * topics = NSProviderGetTopicsCacheData(registeredTopicList);
-
-    pthread_mutex_unlock(&nsInitMutex);
-    NS_LOG(DEBUG, "NSProviderGetTopics - OUT");
-
-    return topics;
-}
-
-NSResult NSProviderAddTopic(char *topicName)
-{
-    NS_LOG(DEBUG, "NSProviderAddTopics - IN");
-    pthread_mutex_lock(&nsInitMutex);
-
-    if(!topicName)
-    {
-        pthread_mutex_unlock(&nsInitMutex);
-        NS_LOG(DEBUG, "topic Name should be set");
-        return NS_FAIL;
-    }
-
-    NSPushQueue(TOPIC_SCHEDULER, TASK_ADD_TOPIC, OICStrdup(topicName));
-
-    pthread_mutex_unlock(&nsInitMutex);
-    NS_LOG(DEBUG, "NSProviderAddTopics - OUT");
-    return NS_OK;
-}
-
-NSResult NSProviderDeleteTopic(char *topicName)
-{
-    NS_LOG(DEBUG, "NSProviderDeleteTopics - IN");
-    pthread_mutex_lock(&nsInitMutex);
-
-    if(!topicName)
-    {
-        pthread_mutex_unlock(&nsInitMutex);
-        NS_LOG(DEBUG, "topic Name should be set");
-        return NS_FAIL;
-    }
-
-    NSPushQueue(TOPIC_SCHEDULER, TASK_DELETE_TOPIC, topicName);
-
-    pthread_mutex_unlock(&nsInitMutex);
-    NS_LOG(DEBUG, "NSProviderDeleteTopics - OUT");
-    return NS_OK;
-}
-
-NSResult NSProviderSelectTopic(char *consumerId, char *topicName)
-{
-    NS_LOG(DEBUG, "NSProviderSelectTopics - IN");
-    pthread_mutex_lock(&nsInitMutex);
-
-    if(!consumerId || !topicName)
-    {
-        pthread_mutex_unlock(&nsInitMutex);
-        NS_LOG(DEBUG, "consumer id should be set for topic subscription");
-        return NS_FAIL;
-    }
-
-    NSCacheTopicSubData * topicSubData =
-            (NSCacheTopicSubData *) OICMalloc(sizeof(NSCacheTopicSubData));
-
-    OICStrcpy(topicSubData->id, NS_UUID_STRING_SIZE, consumerId);
-    topicSubData->topicName = OICStrdup(topicName);
-
-    NSPushQueue(TOPIC_SCHEDULER, TASK_SUBSCRIBE_TOPIC, (void *)topicSubData);
-
-    pthread_mutex_unlock(&nsInitMutex);
-    NS_LOG(DEBUG, "NSProviderSelectTopics - OUT");
-    return NS_OK;
-}
-
-NSResult NSProviderUnselectTopic(char *consumerId, char *topicName)
-{
-    NS_LOG(DEBUG, "NSProviderUnselectTopics - IN");
-    pthread_mutex_lock(&nsInitMutex);
-
-    if(!consumerId || !topicName)
-    {
-        NS_LOG(DEBUG, "consumer id should be set for topic subscription");
-        pthread_mutex_unlock(&nsInitMutex);
-        return NS_FAIL;
-    }
-
-    NSCacheTopicSubData * topicSubData =
-            (NSCacheTopicSubData *) OICMalloc(sizeof(NSCacheTopicSubData));
-
-    OICStrcpy(topicSubData->id, NS_UUID_STRING_SIZE, consumerId);
-    topicSubData->topicName = OICStrdup(topicName);
-
-    NSPushQueue(TOPIC_SCHEDULER, TASK_UNSUBSCRIBE_TOPIC, (void *)topicSubData);
-
-    pthread_mutex_unlock(&nsInitMutex);
-    NS_LOG(DEBUG, "NSProviderUnselectTopics - OUT");
-    return NS_OK;
-}
-
+//******************************************************************
+//
+// Copyright 2016 Samsung Electronics All Rights Reserved.
+//
+//-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=
+//
+// Licensed under the Apache License, Version 2.0 (the "License");
+// you may not use this file except in compliance with the License.
+// You may obtain a copy of the License at
+//
+//      http://www.apache.org/licenses/LICENSE-2.0
+//
+// Unless required by applicable law or agreed to in writing, software
+// distributed under the License is distributed on an "AS IS" BASIS,
+// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+// See the License for the specific language governing permissions and
+// limitations under the License.
+//
+//-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=
+
+#include "NSProviderInterface.h"
+#include "NSProviderScheduler.h"
+#include "NSProviderListener.h"
+#include "NSProviderSubscription.h"
+#include "NSProviderNotification.h"
+#include "NSProviderCallbackResponse.h"
+#include "NSProviderMemoryCache.h"
+#include "NSProviderTopic.h"
+#include "oic_malloc.h"
+#include "oic_string.h"
+#include "cautilinterface.h"
+#include "NSProviderSystem.h"
+#include "oic_time.h"
+#include <pthread.h>
+
+bool initProvider = false;
+
+pthread_mutex_t nsInitMutex;
+pthread_cond_t nstopicCond;
+
+void initializeMutex()
+{
+    static pthread_mutex_t initMutex = PTHREAD_MUTEX_INITIALIZER;
+    nsInitMutex = initMutex;
+}
+
+void NSInitialize()
+{
+    NS_LOG(DEBUG, "NSSetList - IN");
+
+    pthread_mutexattr_init(&NSCacheMutexAttr);
+    pthread_mutexattr_settype(&NSCacheMutexAttr, PTHREAD_MUTEX_RECURSIVE);
+    pthread_mutex_init(&NSCacheMutex, &NSCacheMutexAttr);
+    pthread_cond_init(&nstopicCond, NULL);
+
+    NSInitSubscriptionList();
+    NSInitTopicList();
+    NS_LOG(DEBUG, "NSSetList - OUT");
+}
+
+void NSDeinitailize()
+{
+    NSProviderStorageDestroy(consumerSubList);
+    NSProviderStorageDestroy(consumerTopicList);
+    NSProviderStorageDestroy(registeredTopicList);
+
+    pthread_mutex_destroy(&NSCacheMutex);
+    pthread_mutexattr_destroy(&NSCacheMutexAttr);
+    pthread_cond_destroy(&nstopicCond);
+}
+
+NSResult NSStartProvider(NSProviderConfig config)
+{
+    NS_LOG(DEBUG, "NSStartProvider - IN");
+
+    initializeMutex();
+
+    pthread_mutex_lock(&nsInitMutex);
+
+    if (!initProvider)
+    {
+        NS_LOG(DEBUG, "Init Provider");
+        initProvider = true;
+        NSInitProviderInfo(config.userInfo);
+        NSSetSubscriptionAccessPolicy(config.subControllability);
+        NSRegisterSubscribeRequestCb(config.subRequestCallback);
+        NSRegisterSyncCb(config.syncInfoCallback);
+        CARegisterNetworkMonitorHandler((CAAdapterStateChangedCB)NSProviderAdapterStateListener,
+                (CAConnectionStateChangedCB)NSProviderConnectionStateListener);
+
+        NS_LOG(DEBUG, "Check secured build option..");
+#ifdef SECURED
+        NS_LOG(DEBUG, "Built with SECURED");
+
+        if (!config.resourceSecurity)
+        {
+            NS_LOG(DEBUG, "Resource Security Off");
+        }
+
+        NSSetResourceSecurity(config.resourceSecurity);
+#endif
+
+        NSInitialize();
+        NSInitScheduler();
+        NSStartScheduler();
+
+        NSPushQueue(DISCOVERY_SCHEDULER, TASK_START_PRESENCE, NULL);
+        NSPushQueue(DISCOVERY_SCHEDULER, TASK_REGISTER_RESOURCE, NULL);
+    }
+    else
+    {
+        NS_LOG(DEBUG, "Already started Notification Provider");
+    }
+    pthread_mutex_unlock(&nsInitMutex);
+
+    NS_LOG(DEBUG, "NSStartProvider - OUT");
+    return NS_OK;
+}
+
+NSResult NSStopProvider()
+{
+    NS_LOG(DEBUG, "NSStopProvider - IN");
+    pthread_mutex_lock(&nsInitMutex);
+
+    if (initProvider)
+    {
+        CAUnregisterNetworkMonitorHandler((CAAdapterStateChangedCB)NSProviderAdapterStateListener,
+                (CAConnectionStateChangedCB)NSProviderConnectionStateListener);
+        NSPushQueue(DISCOVERY_SCHEDULER, TASK_STOP_PRESENCE, NULL);
+        NSRegisterSubscribeRequestCb((NSSubscribeRequestCallback)NULL);
+        NSRegisterSyncCb((NSProviderSyncInfoCallback)NULL);
+        NSUnRegisterResource();
+        NSDeinitProviderInfo();
+        NSStopScheduler();
+        NSDeinitailize();
+
+        initProvider = false;
+    }
+
+    pthread_mutex_unlock(&nsInitMutex);
+    NS_LOG(DEBUG, "NSStopProvider - OUT");
+    return NS_OK;
+}
+
+NSResult NSProviderEnableRemoteService(char *serverAddress)
+{
+#if (defined WITH_CLOUD)
+    NS_LOG(DEBUG, "NSProviderEnableRemoteService - IN");
+    pthread_mutex_lock(&nsInitMutex);
+
+    if (!initProvider || !serverAddress)
+    {
+        NS_LOG(DEBUG, "Provider service has not been started yet");
+        pthread_mutex_unlock(&nsInitMutex);
+        return NS_FAIL;
+    }
+
+    NS_LOG_V(INFO_PRIVATE, "Remote server address: %s", serverAddress);
+    NS_LOG(DEBUG, "Request to publish resource");
+    NSPushQueue(DISCOVERY_SCHEDULER, TASK_PUBLISH_RESOURCE, serverAddress);
+
+    pthread_mutex_unlock(&nsInitMutex);
+    NS_LOG(DEBUG, "NSProviderEnableRemoteService - OUT");
+    return NS_OK;
+#else
+    (void) serverAddress;
+#endif
+    NS_LOG_V(INFO_PRIVATE, "Not logged in remote server: %s", serverAddress);
+    return NS_FAIL;
+}
+
+NSResult NSProviderDisableRemoteService(char *serverAddress)
+{
+#if (defined WITH_CLOUD)
+    NS_LOG(DEBUG, "NSProviderDisableRemoteService - IN");
+    pthread_mutex_lock(&nsInitMutex);
+
+    if (!initProvider || !serverAddress)
+    {
+        NS_LOG(DEBUG, "Provider service has not been started yet");
+        pthread_mutex_unlock(&nsInitMutex);
+        return NS_FAIL;
+    }
+
+    NS_LOG_V(INFO_PRIVATE, "Remote server address: %s", serverAddress);
+
+    NS_LOG(DEBUG, "Delete remote server info");
+    NSDeleteRemoteServerAddress(serverAddress);
+
+    pthread_mutex_unlock(&nsInitMutex);
+    NS_LOG(DEBUG, "NSProviderDisableRemoteService - OUT");
+    return NS_OK;
+#else
+    (void) serverAddress;
+#endif
+    NS_LOG_V(INFO_PRIVATE, "Not logged in remote server : %s", serverAddress);
+    return NS_FAIL;
+}
+
+#ifdef WITH_MQ
+NSResult NSProviderSubscribeMQService(const char * serverAddress, const char * topicName)
+{
+    NS_LOG(DEBUG, "NSProviderSubscribeMQService - IN");
+    pthread_mutex_lock(&nsInitMutex);
+
+    if (!initProvider || !serverAddress || !topicName)
+    {
+        NS_LOG(DEBUG, "Provider service has not been started yet or set the server "
+                "address and topicName");
+        pthread_mutex_unlock(&nsInitMutex);
+        return NS_FAIL;
+    }
+
+    NSMQTopicAddress * topicAddr = (NSMQTopicAddress *)OICMalloc(sizeof(NSMQTopicAddress));
+
+    if (!topicAddr)
+    {
+        NS_LOG(DEBUG, "fail to memory allocate");
+        pthread_mutex_unlock(&nsInitMutex);
+        return NS_FAIL;
+    }
+
+    topicAddr->serverAddr = NSGetQueryAddress(serverAddress);
+    topicAddr->topicName = OICStrdup(topicName);
+
+    NS_LOG_V(DEBUG, "input Topic Name : %s", topicAddr->topicName);
+
+    NSPushQueue(SUBSCRIPTION_SCHEDULER, TASK_MQ_REQ_SUBSCRIBE, (void *) topicAddr);
+
+    pthread_mutex_unlock(&nsInitMutex);
+    NS_LOG(DEBUG, "NSProviderSubscribeMQService - OUT");
+    return NS_OK;
+}
+#endif
+
+NSResult NSSendMessage(NSMessage * msg)
+{
+    NS_LOG(DEBUG, "NSSendNotification - IN");
+
+    pthread_mutex_lock(&nsInitMutex);
+
+    if (!initProvider || msg == NULL)
+    {
+        NS_LOG(ERROR, "Msg is NULL");
+        pthread_mutex_unlock(&nsInitMutex);
+        return NS_FAIL;
+    }
+
+    NSMessage * newMsg = NSDuplicateMessage(msg);
+    NSPushQueue(NOTIFICATION_SCHEDULER, TASK_SEND_NOTIFICATION, newMsg);
+
+    pthread_mutex_unlock(&nsInitMutex);
+
+    NS_LOG(DEBUG, "NSSendNotification - OUT");
+    return NS_OK;
+}
+
+NSResult NSProviderSendSyncInfo(uint64_t messageId, NSSyncType type)
+{
+    NS_LOG(DEBUG, "NSProviderReadCheck - IN");
+    pthread_mutex_lock(&nsInitMutex);
+
+    NSSyncInfo * syncInfo = (NSSyncInfo *)OICMalloc(sizeof(NSSyncInfo));
+
+    if (!initProvider || !syncInfo)
+    {
+        NS_LOG(ERROR, "Provider is not started");
+        NSOICFree(syncInfo);
+        pthread_mutex_unlock(&nsInitMutex);
+        return NS_FAIL;
+    }
+
+    OICStrcpy(syncInfo->providerId, UUID_STRING_SIZE, NSGetProviderInfo()->providerId);
+    syncInfo->messageId = messageId;
+    syncInfo->state = type;
+    NSPushQueue(NOTIFICATION_SCHEDULER, TASK_SEND_READ, syncInfo);
+
+    pthread_mutex_unlock(&nsInitMutex);
+    NS_LOG(DEBUG, "NSProviderReadCheck - OUT");
+    return NS_OK;
+}
+
+NSResult NSAcceptSubscription(const char * consumerId, bool accepted)
+{
+    NS_LOG(DEBUG, "NSAccept - IN");
+    pthread_mutex_lock(&nsInitMutex);
+
+    if(!initProvider || !consumerId || consumerId[0] == '\0' || NSGetPolicy() == NS_POLICY_CONSUMER)
+    {
+        NS_LOG(ERROR, "Provider is not started or consumerId is NULL or NS Policy is Consumer");
+        pthread_mutex_unlock(&nsInitMutex);
+        return NS_FAIL;
+    }
+
+    char * newConsumerId = OICStrdup(consumerId);
+    if (accepted)
+    {
+        NS_LOG(DEBUG, "accepted is true - ALLOW");
+        NSPushQueue(SUBSCRIPTION_SCHEDULER, TASK_SEND_ALLOW, newConsumerId);
+    }
+    else
+    {
+        NS_LOG(DEBUG, "accepted is false - DENY");
+        NSPushQueue(SUBSCRIPTION_SCHEDULER, TASK_SEND_DENY, newConsumerId);
+    }
+
+    pthread_mutex_unlock(&nsInitMutex);
+    NS_LOG(DEBUG, "NSAccept - OUT");
+    return NS_OK;
+}
+
+NSMessage * NSCreateMessage()
+{
+    NS_LOG(DEBUG, "NSCreateMessage - IN");
+    pthread_mutex_lock(&nsInitMutex);
+
+    NSMessage * msg = NSInitializeMessage();
+
+    OICStrcpy(msg->providerId, UUID_STRING_SIZE, NSGetProviderInfo()->providerId);
+
+    pthread_mutex_unlock(&nsInitMutex);
+    NS_LOG(DEBUG, "NSCreateMessage - OUT");
+    return msg;
+}
+
+NSTopicLL * NSProviderGetConsumerTopics(const char * consumerId)
+{
+    NS_LOG(DEBUG, "NSProviderGetConsumerTopics - IN");
+    pthread_mutex_lock(&nsInitMutex);
+
+    if(!initProvider || !consumerId || consumerId[0] == '\0')
+    {
+        NS_LOG(DEBUG, "Provider is not started or consumer id should be set");
+        pthread_mutex_unlock(&nsInitMutex);
+        return NULL;
+    }
+
+    NSTopicSync topicSync;
+    topicSync.consumerId = OICStrdup(consumerId);
+    topicSync.topics = NULL;
+    topicSync.condition = &nstopicCond;
+    topicSync.mutex = &nsInitMutex;
+
+    NSPushQueue(TOPIC_SCHEDULER, TAST_GET_CONSUMER_TOPICS, &topicSync);
+    pthread_cond_wait(topicSync.condition, &nsInitMutex);
+    NSOICFree(topicSync.consumerId);
+
+    pthread_mutex_unlock(&nsInitMutex);
+    NS_LOG(DEBUG, "NSProviderGetConsumerTopics - OUT");
+    return topicSync.topics;
+}
+
+NSTopicLL * NSProviderGetTopics()
+{
+    NS_LOG(DEBUG, "NSProviderGetTopics - IN");
+    pthread_mutex_lock(&nsInitMutex);
+
+    if (!initProvider)
+    {
+        NS_LOG(ERROR, "Provider is not started");
+        pthread_mutex_unlock(&nsInitMutex);
+        return NULL;
+    }
+
+    NSTopicSync topicSync;
+    topicSync.consumerId = NULL;
+    topicSync.topics = NULL;
+    topicSync.condition = &nstopicCond;
+    topicSync.mutex = &nsInitMutex;
+
+    NSPushQueue(TOPIC_SCHEDULER, TASK_GET_TOPICS, &topicSync);
+    pthread_cond_wait(topicSync.condition, &nsInitMutex);
+
+    pthread_mutex_unlock(&nsInitMutex);
+    NS_LOG(DEBUG, "NSProviderGetTopics - OUT");
+    return topicSync.topics;
+}
+
+NSResult NSProviderRegisterTopic(const char * topicName)
+{
+    NS_LOG(DEBUG, "NSProviderAddTopics - IN");
+    pthread_mutex_lock(&nsInitMutex);
+
+    if(!initProvider || !topicName || topicName[0] == '\0')
+    {
+        pthread_mutex_unlock(&nsInitMutex);
+        NS_LOG(DEBUG, "Provider is not started or topic Name should be set");
+        return NS_FAIL;
+    }
+
+    NSTopicSyncResult topicSyncResult;
+    topicSyncResult.topicData = (void *) OICStrdup(topicName);
+    topicSyncResult.condition = &nstopicCond;
+    topicSyncResult.result = NS_OK;
+    topicSyncResult.mutex = &nsInitMutex;
+
+    NSPushQueue(TOPIC_SCHEDULER, TASK_REGISTER_TOPIC, &topicSyncResult);
+    pthread_cond_wait(topicSyncResult.condition, &nsInitMutex);
+    if(topicSyncResult.result != NS_OK)
+    {
+        pthread_mutex_unlock(&nsInitMutex);
+        return NS_FAIL;
+    }
+
+    pthread_mutex_unlock(&nsInitMutex);
+    NS_LOG(DEBUG, "NSProviderAddTopics - OUT");
+    return NS_OK;
+}
+
+NSResult NSProviderUnregisterTopic(const char * topicName)
+{
+    NS_LOG(DEBUG, "NSProviderDeleteTopics - IN");
+    pthread_mutex_lock(&nsInitMutex);
+
+    if(!initProvider || !topicName || topicName[0] == '\0')
+    {
+        pthread_mutex_unlock(&nsInitMutex);
+        NS_LOG(DEBUG, "Provider is not started or topic Name should be set");
+        return NS_FAIL;
+    }
+
+    NSTopicSyncResult topicSyncResult;
+    topicSyncResult.topicData = (void *) OICStrdup(topicName);
+    topicSyncResult.condition = &nstopicCond;
+    topicSyncResult.result = NS_OK;
+    topicSyncResult.mutex = &nsInitMutex;
+
+    NSPushQueue(TOPIC_SCHEDULER, TASK_UNREGISTER_TOPIC, &topicSyncResult);
+    pthread_cond_wait(topicSyncResult.condition, &nsInitMutex);
+    if (topicSyncResult.result != NS_OK)
+    {
+        pthread_mutex_unlock(&nsInitMutex);
+        return NS_FAIL;
+    }
+    NSOICFree(topicSyncResult.topicData);
+
+    pthread_mutex_unlock(&nsInitMutex);
+    NS_LOG(DEBUG, "NSProviderDeleteTopics - OUT");
+    return NS_OK;
+}
+
+NSResult NSProviderSetConsumerTopic(const char * consumerId, const char * topicName)
+{
+    NS_LOG(DEBUG, "NSProviderSelectTopics - IN");
+    pthread_mutex_lock(&nsInitMutex);
+
+    NSCacheTopicSubData * topicSubData =
+            (NSCacheTopicSubData *) OICMalloc(sizeof(NSCacheTopicSubData));
+
+    if (!initProvider || !consumerId || consumerId[0] == '\0' || !topicName || topicName[0] == '\0'
+            || !NSGetPolicy() || !topicSubData)
+    {
+        NS_LOG(DEBUG, "provider is not started or "
+                "consumer id should be set for topic subscription or "
+                "Configuration must set to true.");
+        NSOICFree(topicSubData);
+        topicSubData = NULL;
+        pthread_mutex_unlock(&nsInitMutex);
+        return NS_FAIL;
+    }
+
+    OICStrcpy(topicSubData->id, NS_UUID_STRING_SIZE, consumerId);
+    topicSubData->topicName = OICStrdup(topicName);
+
+    NSTopicSyncResult topicSyncResult;
+    topicSyncResult.topicData = (void *) topicSubData;
+    topicSyncResult.condition = &nstopicCond;
+    topicSyncResult.result = NS_FAIL;
+    topicSyncResult.mutex = &nsInitMutex;
+
+    NSPushQueue(TOPIC_SCHEDULER, TASK_SUBSCRIBE_TOPIC, (void *)&topicSyncResult);
+    pthread_cond_wait(topicSyncResult.condition, &nsInitMutex);
+
+    pthread_mutex_unlock(&nsInitMutex);
+    NS_LOG(DEBUG, "NSProviderSelectTopics - OUT");
+    return topicSyncResult.result;
+}
+
+NSResult NSProviderUnsetConsumerTopic(const char * consumerId, const char * topicName)
+{
+    NS_LOG(DEBUG, "NSProviderUnselectTopics - IN");
+    pthread_mutex_lock(&nsInitMutex);
+
+    NSCacheTopicSubData * topicSubData =
+            (NSCacheTopicSubData *) OICMalloc(sizeof(NSCacheTopicSubData));
+
+    if (!initProvider || !consumerId || consumerId[0] == '\0' || !topicName || topicName[0] == '\0'
+            || !NSGetPolicy() || !topicSubData)
+    {
+        NS_LOG(DEBUG, "provider is not started or "
+                "consumer id should be set for topic subscription or "
+                "Configuration must set to true.");
+        NSOICFree(topicSubData);
+        topicSubData = NULL;
+        pthread_mutex_unlock(&nsInitMutex);
+        return NS_FAIL;
+    }
+
+    OICStrcpy(topicSubData->id, NS_UUID_STRING_SIZE, consumerId);
+    topicSubData->topicName = OICStrdup(topicName);
+
+    NSTopicSyncResult topicSyncResult;
+    topicSyncResult.topicData = (void *) topicSubData;
+    topicSyncResult.condition = &nstopicCond;
+    topicSyncResult.result = NS_FAIL;
+    topicSyncResult.mutex = &nsInitMutex;
+
+    NSPushQueue(TOPIC_SCHEDULER, TASK_UNSUBSCRIBE_TOPIC, (void *)&topicSyncResult);
+    pthread_cond_wait(topicSyncResult.condition, &nsInitMutex);
+
+    pthread_mutex_unlock(&nsInitMutex);
+    NS_LOG(DEBUG, "NSProviderUnselectTopics - OUT");
+    return topicSyncResult.result;
+}