service/notification/src/provider/NSProviderMemoryCache.c

   1 //******************************************************************\r
   2 //\r
   3 // Copyright 2016 Samsung Electronics All Rights Reserved.\r
   4 //\r
   5 //-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=\r
   6 //\r
   7 // Licensed under the Apache License, Version 2.0 (the "License");\r
   8 // you may not use this file except in compliance with the License.\r
   9 // You may obtain a copy of the License at\r
  10 //\r
  11 //      http://www.apache.org/licenses/LICENSE-2.0\r
  12 //\r
  13 // Unless required by applicable law or agreed to in writing, software\r
  14 // distributed under the License is distributed on an "AS IS" BASIS,\r
  15 // WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.\r
  16 // See the License for the specific language governing permissions and\r
  17 // limitations under the License.\r
  18 //\r
  19 //-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=\r
  20 \r
  21 #include "NSProviderMemoryCache.h"\r
  22 #include <string.h>\r
  23 \r
  24 NSCacheList * NSStorageCreate()\r
  25 {\r
  26     pthread_mutex_lock(&NSCacheMutex);\r
  27     NSCacheList * newList = (NSCacheList *) OICMalloc(sizeof(NSCacheList));\r
  28     if (!newList)\r
  29     {\r
  30         pthread_mutex_unlock(&NSCacheMutex);\r
  31         return NULL;\r
  32     }\r
  33 \r
  34     newList->head = newList->tail = NULL;\r
  35 \r
  36     pthread_mutex_unlock(&NSCacheMutex);\r
  37     NS_LOG(DEBUG, "NSCacheCreate");\r
  38 \r
  39     return newList;\r
  40 }\r
  41 \r
  42 NSCacheElement * NSStorageRead(NSCacheList * list, const char * findId)\r
  43 {\r
  44     pthread_mutex_lock(&NSCacheMutex);\r
  45 \r
  46     NS_LOG(DEBUG, "NSCacheRead - IN");\r
  47 \r
  48     NSCacheElement * iter = list->head;\r
  49     NSCacheElement * next = NULL;\r
  50     NSCacheType type = list->cacheType;\r
  51 \r
  52     NS_LOG_V(DEBUG, "Find ID - %s", findId);\r
  53 \r
  54     while (iter)\r
  55     {\r
  56         next = iter->next;\r
  57 \r
  58         if (NSProviderCompareIdCacheData(type, iter->data, findId))\r
  59         {\r
  60             NS_LOG(DEBUG, "Found in Cache");\r
  61             pthread_mutex_unlock(&NSCacheMutex);\r
  62             return iter;\r
  63         }\r
  64 \r
  65         iter = next;\r
  66     }\r
  67 \r
  68     NS_LOG(DEBUG, "Not found in Cache");\r
  69     NS_LOG(DEBUG, "NSCacheRead - OUT");\r
  70     pthread_mutex_unlock(&NSCacheMutex);\r
  71 \r
  72     return NULL;\r
  73 }\r
  74 \r
  75 NSResult NSCacheUpdateSubScriptionState(NSCacheList * list, char * id, bool state)\r
  76 {\r
  77     pthread_mutex_lock(&NSCacheMutex);\r
  78 \r
  79     NS_LOG(DEBUG, "NSCacheUpdateSubScriptionState - IN");\r
  80 \r
  81     if (id == NULL)\r
  82     {\r
  83         NS_LOG(DEBUG, "id is NULL");\r
  84         pthread_mutex_unlock(&NSCacheMutex);\r
  85         return NS_ERROR;\r
  86     }\r
  87 \r
  88     NSCacheElement * it = NSStorageRead(list, id);\r
  89 \r
  90     if (it)\r
  91     {\r
  92         NSCacheSubData * itData = (NSCacheSubData *) it->data;\r
  93         if (strcmp(itData->id, id) == 0)\r
  94         {\r
  95             NS_LOG(DEBUG, "Update Data - IN");\r
  96 \r
  97             NS_LOG_V(DEBUG, "currData_ID = %s", itData->id);\r
  98             NS_LOG_V(DEBUG, "currData_MsgObID = %d", itData->messageObId);\r
  99             NS_LOG_V(DEBUG, "currData_SyncObID = %d", itData->syncObId);\r
 100             NS_LOG_V(DEBUG, "currData_Cloud_MsgObID = %d", itData->remote_messageObId);\r
 101             NS_LOG_V(DEBUG, "currData_Cloud_SyncObID = %d", itData->remote_syncObId);\r
 102             NS_LOG_V(DEBUG, "currData_IsWhite = %d", itData->isWhite);\r
 103 \r
 104             NS_LOG_V(DEBUG, "update state = %d", state);\r
 105 \r
 106             itData->isWhite = state;\r
 107 \r
 108             NS_LOG(DEBUG, "Update Data - OUT");\r
 109             pthread_mutex_unlock(&NSCacheMutex);\r
 110             return NS_OK;\r
 111         }\r
 112     }\r
 113     else\r
 114     {\r
 115         NS_LOG(DEBUG, "Not Found Data");\r
 116     }\r
 117 \r
 118     NS_LOG(DEBUG, "NSCacheUpdateSubScriptionState - OUT");\r
 119     pthread_mutex_unlock(&NSCacheMutex);\r
 120     return NS_ERROR;\r
 121 }\r
 122 \r
 123 NSResult NSStorageWrite(NSCacheList * list, NSCacheElement * newObj)\r
 124 {\r
 125     pthread_mutex_lock(&NSCacheMutex);\r
 126 \r
 127     NSCacheType type = list->cacheType;\r
 128 \r
 129     NS_LOG(DEBUG, "NSCacheWrite - IN");\r
 130 \r
 131     if (newObj == NULL)\r
 132     {\r
 133         NS_LOG(DEBUG, "newObj is NULL - IN");\r
 134         pthread_mutex_unlock(&NSCacheMutex);\r
 135         return NS_ERROR;\r
 136     }\r
 137 \r
 138     if (type == NS_PROVIDER_CACHE_SUBSCRIBER)\r
 139     {\r
 140         NS_LOG(DEBUG, "Type is SUBSCRIBER");\r
 141 \r
 142         NSCacheSubData * subData = (NSCacheSubData *) newObj->data;\r
 143         NSCacheElement * it = NSStorageRead(list, subData->id);\r
 144 \r
 145         if (it)\r
 146         {\r
 147             NSCacheSubData * itData = (NSCacheSubData *) it->data;\r
 148 \r
 149             if (strcmp(itData->id, subData->id) == 0)\r
 150             {\r
 151                 NS_LOG(DEBUG, "Update Data - IN");\r
 152 \r
 153                 NS_LOG_V(DEBUG, "currData_ID = %s", itData->id);\r
 154                 NS_LOG_V(DEBUG, "currData_MsgObID = %d", itData->messageObId);\r
 155                 NS_LOG_V(DEBUG, "currData_SyncObID = %d", itData->syncObId);\r
 156                 NS_LOG_V(DEBUG, "currData_Cloud_MsgObID = %d", itData->remote_messageObId);\r
 157                 NS_LOG_V(DEBUG, "currData_Cloud_SyncObID = %d", itData->remote_syncObId);\r
 158                 NS_LOG_V(DEBUG, "currData_IsWhite = %d", itData->isWhite);\r
 159 \r
 160                 NS_LOG_V(DEBUG, "subData_ID = %s", subData->id);\r
 161                 NS_LOG_V(DEBUG, "subData_MsgObID = %d", subData->messageObId);\r
 162                 NS_LOG_V(DEBUG, "subData_SyncObID = %d", subData->syncObId);\r
 163                 NS_LOG_V(DEBUG, "subData_Cloud_MsgObID = %d", subData->remote_messageObId);\r
 164                 NS_LOG_V(DEBUG, "subData_Cloud_SyncObID = %d", subData->remote_syncObId);\r
 165                 NS_LOG_V(DEBUG, "subData_IsWhite = %d", subData->isWhite);\r
 166 \r
 167                 if (subData->messageObId != 0)\r
 168                 {\r
 169                     itData->messageObId = subData->messageObId;\r
 170                 }\r
 171 \r
 172                 if (subData->syncObId != 0)\r
 173                 {\r
 174                     itData->syncObId = subData->syncObId;\r
 175                 }\r
 176 \r
 177                 if (subData->remote_messageObId != 0)\r
 178                 {\r
 179                     itData->remote_messageObId = subData->remote_messageObId;\r
 180                 }\r
 181 \r
 182                 if (subData->remote_syncObId != 0)\r
 183                 {\r
 184                     itData->remote_syncObId = subData->remote_syncObId;\r
 185                     NS_LOG_V(DEBUG, "sync id cached: %d", itData->remote_syncObId);\r
 186                 }\r
 187 \r
 188                 NS_LOG(DEBUG, "Update Data - OUT");\r
 189 \r
 190                 pthread_mutex_unlock(&NSCacheMutex);\r
 191                 return NS_OK;\r
 192             }\r
 193         }\r
 194 \r
 195     }\r
 196     else if(type == NS_PROVIDER_CACHE_REGISTER_TOPIC)\r
 197     {\r
 198         NS_LOG(DEBUG, "Type is REGITSTER TOPIC");\r
 199 \r
 200         NSCacheTopicData * topicData = (NSCacheTopicData *) newObj->data;\r
 201         NSCacheElement * it = NSStorageRead(list, topicData->topicName);\r
 202 \r
 203         if (it)\r
 204         {\r
 205             NS_LOG(DEBUG, "already registered for topic name");\r
 206             pthread_mutex_unlock(&NSCacheMutex);\r
 207             return NS_FAIL;\r
 208         }\r
 209     }\r
 210     else if(type == NS_PROVIDER_CACHE_CONSUMER_TOPIC_NAME)\r
 211     {\r
 212         NS_LOG(DEBUG, "Type is REGITSTER TOPIC");\r
 213 \r
 214         NSCacheTopicSubData * topicData = (NSCacheTopicSubData *) newObj->data;\r
 215         NSCacheElement * it = NSStorageRead(list, topicData->topicName);\r
 216 \r
 217         if (it)\r
 218         {\r
 219             NS_LOG(DEBUG, "already registered for topic name");\r
 220             pthread_mutex_unlock(&NSCacheMutex);\r
 221             return NS_FAIL;\r
 222         }\r
 223     }\r
 224 \r
 225     else if(type == NS_PROVIDER_CACHE_CONSUMER_TOPIC_CID)\r
 226     {\r
 227         NS_LOG(DEBUG, "Type is REGITSTER TOPIC");\r
 228 \r
 229         NSCacheTopicSubData * topicData = (NSCacheTopicSubData *) newObj->data;\r
 230         NSCacheElement * it = NSStorageRead(list, topicData->id);\r
 231 \r
 232         if (it)\r
 233         {\r
 234             NS_LOG(DEBUG, "already registered for topic name");\r
 235             pthread_mutex_unlock(&NSCacheMutex);\r
 236             return NS_FAIL;\r
 237         }\r
 238     }\r
 239 \r
 240 \r
 241     if (list->head == NULL)\r
 242     {\r
 243         NS_LOG(DEBUG, "list->head is NULL, Insert First Data");\r
 244         list->head = list->tail = newObj;\r
 245         pthread_mutex_unlock(&NSCacheMutex);\r
 246         return NS_OK;\r
 247     }\r
 248 \r
 249     list->tail = list->tail->next = newObj;\r
 250     NS_LOG(DEBUG, "list->head is not NULL");\r
 251     pthread_mutex_unlock(&NSCacheMutex);\r
 252     return NS_OK;\r
 253 }\r
 254 \r
 255 NSResult NSStorageDestroy(NSCacheList * list)\r
 256 {\r
 257     NSCacheElement * iter = list->head;\r
 258     NSCacheElement * next = NULL;\r
 259 \r
 260     NSCacheType type = list->cacheType;\r
 261 \r
 262     while (iter)\r
 263     {\r
 264         next = (NSCacheElement *) iter->next;\r
 265 \r
 266         NSProviderDeleteCacheData(type, iter->data);\r
 267         OICFree(iter);\r
 268 \r
 269         iter = next;\r
 270     }\r
 271 \r
 272     OICFree(list);\r
 273 \r
 274     return NS_OK;\r
 275 }\r
 276 \r
 277 bool NSProviderCompareIdCacheData(NSCacheType type, void * data, const char * id)\r
 278 {\r
 279     NS_LOG(DEBUG, "NSProviderCompareIdCacheData - IN");\r
 280 \r
 281     if (data == NULL)\r
 282     {\r
 283         return false;\r
 284     }\r
 285 \r
 286     NS_LOG_V(DEBUG, "Data(compData) = [%s]", id);\r
 287 \r
 288     if (type == NS_PROVIDER_CACHE_SUBSCRIBER)\r
 289     {\r
 290         NSCacheSubData * subData = (NSCacheSubData *) data;\r
 291 \r
 292         NS_LOG_V(DEBUG, "Data(subData) = [%s]", subData->id);\r
 293 \r
 294         if (strcmp(subData->id, id) == 0)\r
 295         {\r
 296             NS_LOG(DEBUG, "SubData is Same");\r
 297             return true;\r
 298         }\r
 299 \r
 300         NS_LOG(DEBUG, "Message Data is Not Same");\r
 301         return false;\r
 302     }\r
 303     else if (type == NS_PROVIDER_CACHE_REGISTER_TOPIC)\r
 304     {\r
 305         NSCacheTopicData * topicData = (NSCacheTopicData *) data;\r
 306 \r
 307         NS_LOG_V(DEBUG, "Data(topicData) = [%s]", topicData->topicName);\r
 308 \r
 309         if (strcmp(topicData->topicName, id) == 0)\r
 310         {\r
 311             NS_LOG(DEBUG, "SubData is Same");\r
 312             return true;\r
 313         }\r
 314 \r
 315         NS_LOG(DEBUG, "Message Data is Not Same");\r
 316         return false;\r
 317     }\r
 318     else if (type == NS_PROVIDER_CACHE_CONSUMER_TOPIC_NAME)\r
 319     {\r
 320         NSCacheTopicSubData * topicData = (NSCacheTopicSubData *) data;\r
 321 \r
 322         NS_LOG_V(DEBUG, "Data(topicData) = [%s]", topicData->topicName);\r
 323 \r
 324         if (strcmp(topicData->topicName, id) == 0)\r
 325         {\r
 326             NS_LOG(DEBUG, "SubData is Same");\r
 327             return true;\r
 328         }\r
 329 \r
 330         NS_LOG(DEBUG, "Message Data is Not Same");\r
 331         return false;\r
 332     }\r
 333     else if (type == NS_PROVIDER_CACHE_CONSUMER_TOPIC_CID)\r
 334     {\r
 335         NSCacheTopicSubData * topicData = (NSCacheTopicSubData *) data;\r
 336 \r
 337         NS_LOG_V(DEBUG, "Data(topicData) = [%s]", topicData->id);\r
 338 \r
 339         if (strcmp(topicData->id, id) == 0)\r
 340         {\r
 341             NS_LOG(DEBUG, "SubData is Same");\r
 342             return true;\r
 343         }\r
 344 \r
 345         NS_LOG(DEBUG, "Message Data is Not Same");\r
 346         return false;\r
 347     }\r
 348 \r
 349 \r
 350     NS_LOG(DEBUG, "NSProviderCompareIdCacheData - OUT");\r
 351     return false;\r
 352 }\r
 353 \r
 354 NSResult NSProviderDeleteCacheData(NSCacheType type, void * data)\r
 355 {\r
 356     if (data == NULL)\r
 357     {\r
 358         return NS_OK;\r
 359     }\r
 360 \r
 361     if (type == NS_PROVIDER_CACHE_SUBSCRIBER)\r
 362     {\r
 363         NSCacheSubData * subData = (NSCacheSubData *) data;\r
 364 \r
 365         (subData->id)[0] = '\0';\r
 366         OICFree(subData);\r
 367 \r
 368         return NS_OK;\r
 369     }\r
 370     else if(type == NS_PROVIDER_CACHE_REGISTER_TOPIC)\r
 371     {\r
 372         NSCacheTopicData * data = (NSCacheTopicData *) data;\r
 373         OICFree(data->topicName);\r
 374     }\r
 375     else if(type == NS_PROVIDER_CACHE_CONSUMER_TOPIC_NAME || NS_PROVIDER_CACHE_CONSUMER_TOPIC_CID)\r
 376     {\r
 377         NSCacheTopicSubData * data = (NSCacheTopicSubData *) data;\r
 378         OICFree(data->topicName);\r
 379     }\r
 380 \r
 381     return NS_OK;\r
 382 }\r
 383 \r
 384 bool NSIsSameObId(NSCacheSubData * data, OCObservationId id)\r
 385 {\r
 386     if (id == data->messageObId || id == data->syncObId || id == data->remote_messageObId ||\r
 387                 id == data->remote_syncObId)\r
 388     {\r
 389         return true;\r
 390     }\r
 391 \r
 392     return false;\r
 393 }\r
 394 \r
 395 NSResult NSProviderDeleteSubDataFromObId(NSCacheList * list, OCObservationId id)\r
 396 {\r
 397     if(!list || !list->head)\r
 398     {\r
 399         NS_LOG(INFO, "list is NULL");\r
 400         return NS_FAIL;\r
 401     }\r
 402 \r
 403     pthread_mutex_lock(&NSCacheMutex);\r
 404     NSCacheElement * prev = list->head;\r
 405     NSCacheElement * del = list->head;\r
 406 \r
 407     NSCacheType type = list->cacheType;\r
 408 \r
 409     bool isDelete = true;\r
 410 \r
 411     while(isDelete)\r
 412     {\r
 413         NSCacheSubData * curr = (NSCacheSubData *)del->data;\r
 414 \r
 415         isDelete = false;\r
 416 \r
 417         if (NSIsSameObId(curr, id))\r
 418         {\r
 419             if (del == list->head) // first object\r
 420             {\r
 421                 if (del == list->tail) // first object (one object)\r
 422                 {\r
 423                     list->tail = del->next;\r
 424                 }\r
 425 \r
 426                 list->head = del->next;\r
 427 \r
 428                 NSProviderDeleteCacheData(type, del->data);\r
 429                 OICFree(del);\r
 430                 isDelete = true;\r
 431             }\r
 432         }\r
 433         else\r
 434         {\r
 435             del = del->next;\r
 436             while (del)\r
 437             {\r
 438                 if (NSIsSameObId(curr, id))\r
 439                 {\r
 440                     if (del == list->tail) // delete object same to last object\r
 441                     {\r
 442                         list->tail = prev;\r
 443                     }\r
 444 \r
 445                     prev->next = del->next;\r
 446                     NSProviderDeleteCacheData(type, del->data);\r
 447                     OICFree(del);\r
 448                     isDelete = true;\r
 449                     break;\r
 450                 }\r
 451 \r
 452                 prev = del;\r
 453                 del = del->next;\r
 454             }\r
 455         }\r
 456     }\r
 457     pthread_mutex_unlock(&NSCacheMutex);\r
 458     return NS_OK;\r
 459 }\r
 460 \r
 461 NSResult NSStorageDelete(NSCacheList * list, const char * delId)\r
 462 {\r
 463     pthread_mutex_lock(&NSCacheMutex);\r
 464     NSCacheElement * prev = list->head;\r
 465     NSCacheElement * del = list->head;\r
 466 \r
 467     NSCacheType type = list->cacheType;\r
 468 \r
 469     if (NSProviderCompareIdCacheData(type, del->data, delId))\r
 470     {\r
 471         if (del == list->head) // first object\r
 472         {\r
 473             if (del == list->tail) // first object (one object)\r
 474             {\r
 475                 list->tail = del->next;\r
 476             }\r
 477 \r
 478             list->head = del->next;\r
 479 \r
 480             NSProviderDeleteCacheData(type, del->data);\r
 481             OICFree(del);\r
 482             pthread_mutex_unlock(&NSCacheMutex);\r
 483             return NS_OK;\r
 484         }\r
 485     }\r
 486 \r
 487     del = del->next;\r
 488     while (del)\r
 489     {\r
 490         if (NSProviderCompareIdCacheData(type, del->data, delId))\r
 491         {\r
 492             if (del == list->tail) // delete object same to last object\r
 493             {\r
 494                 list->tail = prev;\r
 495             }\r
 496 \r
 497             prev->next = del->next;\r
 498             NSProviderDeleteCacheData(type, del->data);\r
 499             OICFree(del);\r
 500             pthread_mutex_unlock(&NSCacheMutex);\r
 501             return NS_OK;\r
 502         }\r
 503 \r
 504         prev = del;\r
 505         del = del->next;\r
 506     }\r
 507     pthread_mutex_unlock(&NSCacheMutex);\r
 508     return NS_FAIL;\r
 509 }\r
 510 \r
 511 NSTopics * NSProviderGetTopicsCacheData(NSCacheList * regTopicList)\r
 512 {\r
 513     NS_LOG(DEBUG, "NSProviderGetTopicsCache - IN");\r
 514     pthread_mutex_lock(&NSCacheMutex);\r
 515 \r
 516     NSCacheElement * iter = regTopicList->head;\r
 517 \r
 518     if(!iter)\r
 519     {\r
 520         pthread_mutex_unlock(&NSCacheMutex);\r
 521         return NULL;\r
 522     }\r
 523 \r
 524     NSTopics * iterTopic = NULL;\r
 525     NSTopics * newTopic = NULL;\r
 526     NSTopics * topics = NULL;\r
 527 \r
 528     while (iter)\r
 529     {\r
 530         NSCacheTopicData * curr = (NSCacheTopicData *) iter->data;\r
 531 \r
 532         newTopic = (NSTopics *) OICMalloc(sizeof(NSTopics));\r
 533         newTopic->state = curr->state;\r
 534         newTopic->next = NULL;\r
 535         newTopic->topicName = OICStrdup(curr->topicName);\r
 536 \r
 537         if(!topics)\r
 538         {\r
 539             iterTopic = topics = newTopic;\r
 540         }\r
 541         else\r
 542         {\r
 543             iterTopic->next = newTopic;\r
 544             iterTopic = newTopic;\r
 545         }\r
 546 \r
 547         iter = iter->next;\r
 548     }\r
 549 \r
 550     pthread_mutex_unlock(&NSCacheMutex);\r
 551     NS_LOG(DEBUG, "NSProviderGetTopicsCache - OUT");\r
 552 \r
 553     return topics;\r
 554 }\r
 555 \r
 556 NSTopics * NSProviderGetConsumerTopicsCacheData(NSCacheList * conTopicList, char *consumerId)\r
 557 {\r
 558     NS_LOG(DEBUG, "NSProviderGetConsumerTopics - IN");\r
 559 \r
 560     pthread_mutex_lock(&NSCacheMutex);\r
 561     NSTopics * topics = NSProviderGetTopics();\r
 562 \r
 563     if(!topics)\r
 564     {\r
 565         pthread_mutex_unlock(&NSCacheMutex);\r
 566         return NULL;\r
 567     }\r
 568 \r
 569     NSCacheElement * iter = conTopicList->head;\r
 570     conTopicList->cacheType = NS_PROVIDER_CACHE_CONSUMER_TOPIC_CID;\r
 571 \r
 572     while(iter)\r
 573     {\r
 574         NSCacheElement * curr = NSStorageRead(iter, consumerId);\r
 575 \r
 576         if(!curr)\r
 577         {\r
 578             NSTopics * topicIter = topics;\r
 579             while(!topicIter)\r
 580             {\r
 581                 NSCacheTopicSubData * topicSubData = (NSCacheTopicSubData *) curr->data;\r
 582                 if(strcmp(topicIter->topicName, topicSubData->topicName) == 0)\r
 583                 {\r
 584                     topicIter->state = NS_TOPIC_SUBSCRIBED;\r
 585                     break;\r
 586                 }\r
 587                 topicIter = topicIter->next;\r
 588             }\r
 589         }\r
 590 \r
 591         iter = iter->next;\r
 592     }\r
 593 \r
 594     conTopicList->cacheType = NS_PROVIDER_CACHE_CONSUMER_TOPIC_NAME;\r
 595     pthread_mutex_unlock(&NSCacheMutex);\r
 596     NS_LOG(DEBUG, "NSProviderGetConsumerTopics - OUT");\r
 597 \r
 598     return topics;\r
 599 }\r