\r
NSInitSubscriptionList();\r
NSInitMessageList();\r
+ NSInitTopicList();\r
NS_LOG(DEBUG, "NSSetList - OUT");\r
}\r
\r
{\r
NSStorageDestroy(consumerSubList);\r
NSStorageDestroy(messageList);\r
+ NSStorageDestroy(consumerTopicList);\r
\r
pthread_mutex_destroy(&NSCacheMutex);\r
pthread_mutexattr_destroy(&NSCacheMutexAttr);\r
NS_LOG(DEBUG, "NSProviderSetTopics - IN");\r
pthread_mutex_lock(&nsInitMutex);\r
\r
- NSInitTopicStorage();\r
-\r
- NSPushQueue(TOPIC_SCHEDULER, TASK_REGISTER_TOPICS, topicList);\r
+ NSPushQueue(TOPIC_SCHEDULER, TASK_REGISTER_TOPICS, consumerTopicList);\r
\r
pthread_mutex_unlock(&nsInitMutex);\r
NS_LOG(DEBUG, "NSProviderSetTopics - OUT");\r
\r
static bool isTopicList = false;\r
\r
-NSResult NSInitTopicStorage()\r
+NSResult NSInitTopicList()\r
{\r
NS_LOG(DEBUG, "NSInitTopicList - IN");\r
\r
return NS_FAIL;\r
}\r
\r
- topicStorage = NSStorageCreate();\r
- topicStorage->cacheType = NS_PROVIDER_CACHE_TOPIC;\r
+ consumerTopicList = NSStorageCreate();\r
+ consumerTopicList->cacheType = NS_PROVIDER_CACHE_TOPIC;\r
isTopicList = true;\r
\r
NS_LOG(DEBUG, "NSInitTopicList - OUT");\r
element->data = (void*) topicData;\r
element->next = NULL;\r
\r
- if(NSStorageWrite(topicStorage, element) != NS_OK)\r
+ if(NSStorageWrite(consumerTopicList, element) != NS_OK)\r
{\r
NS_LOG(DEBUG, "fail to write cache");\r
}\r
#include "NSProviderResource.h"\r
#include "NSProviderSubscription.h"\r
\r
-NSCacheList * topicStorage;\r
+NSCacheList * consumerTopicList;\r
\r
-NSResult NSInitTopicStorage();\r
+NSResult NSInitTopicList();\r
NSTopicList * NSGetTopics(char *consumerId);\r
\r
bool NSIsTopicSubscribed(char *consumerId, char *topic);\r