service/notification/src/provider/NSProviderInterface.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 "NSProviderInterface.h"\r
  22 #include "NSProviderScheduler.h"\r
  23 #include "NSProviderListener.h"\r
  24 #include "NSProviderSubscription.h"\r
  25 #include "NSProviderNotification.h"\r
  26 #include "NSProviderCallbackResponse.h"\r
  27 #include "NSStorageAdapter.h"\r
  28 #include "NSProviderMemoryCache.h"\r
  29 #include "oic_malloc.h"\r
  30 #include "oic_string.h"\r
  31 #include "cautilinterface.h"\r
  32 #include "NSProviderSystem.h"\r
  33 #include "oic_time.h"\r
  34 \r
  35 bool initProvider = false;\r
  36 \r
  37 pthread_mutex_t nsInitMutex;\r
  38 \r
  39 void initializeMutex()\r
  40 {\r
  41     static pthread_mutex_t initMutex = PTHREAD_MUTEX_INITIALIZER;\r
  42     nsInitMutex = initMutex;\r
  43 }\r
  44 \r
  45 NSResult NSStartProvider(NSAccessPolicy policy, NSSubscribeRequestCallback subscribeRequestCb,\r
  46         NSProviderSyncInfoCallback syncCb)\r
  47 {\r
  48     NS_LOG(DEBUG, "NSStartProvider - IN");\r
  49 \r
  50     initializeMutex();\r
  51 \r
  52     pthread_mutex_lock(&nsInitMutex);\r
  53 \r
  54     if (!initProvider)\r
  55     {\r
  56         NS_LOG(DEBUG, "Init Provider");\r
  57         initProvider = true;\r
  58         NSInitProviderInfo();\r
  59         NSSetSubscriptionAccessPolicy(policy);\r
  60         NSRegisterSubscribeRequestCb(subscribeRequestCb);\r
  61         NSRegisterSyncCb(syncCb);\r
  62         CARegisterNetworkMonitorHandler((CAAdapterStateChangedCB)NSProviderAdapterStateListener,\r
  63                 (CAConnectionStateChangedCB)NSProviderConnectionStateListener);\r
  64 \r
  65         NSSetList();\r
  66         NSInitScheduler();\r
  67         NSStartScheduler();\r
  68 \r
  69         NSPushQueue(DISCOVERY_SCHEDULER, TASK_START_PRESENCE, NULL);\r
  70         NSPushQueue(DISCOVERY_SCHEDULER, TASK_REGISTER_RESOURCE, NULL);\r
  71     }\r
  72     else\r
  73     {\r
  74         NS_LOG(DEBUG, "Already started Notification Provider");\r
  75     }\r
  76     pthread_mutex_unlock(&nsInitMutex);\r
  77 \r
  78     NS_LOG(DEBUG, "NSStartProvider - OUT");\r
  79     return NS_OK;\r
  80 }\r
  81 \r
  82 void NSSetList()\r
  83 {\r
  84     NS_LOG(DEBUG, "NSSetList - IN");\r
  85     pthread_mutex_init(&NSCacheMutex, NULL);\r
  86     NSInitSubscriptionList();\r
  87     NSInitMessageList();\r
  88     NS_LOG(DEBUG, "NSSetList - OUT");\r
  89 }\r
  90 \r
  91 NSResult NSStopProvider()\r
  92 {\r
  93     NS_LOG(DEBUG, "NSStopProvider - IN");\r
  94     pthread_mutex_lock(&nsInitMutex);\r
  95 \r
  96     if(initProvider)\r
  97     {\r
  98         NSDeinitProviderInfo();\r
  99         NSUnRegisterResource();\r
 100         NSRegisterSubscribeRequestCb((NSSubscribeRequestCallback)NULL);\r
 101         NSRegisterSyncCb((NSProviderSyncInfoCallback)NULL);\r
 102         NSStopScheduler();\r
 103         NSStorageDestroy(consumerSubList);\r
 104         NSStorageDestroy(messageList);\r
 105 \r
 106         initProvider = false;\r
 107     }\r
 108 \r
 109     pthread_mutex_unlock(&nsInitMutex);\r
 110     NS_LOG(DEBUG, "NSStopProvider - OUT");\r
 111     return NS_OK;\r
 112 }\r
 113 \r
 114 NSResult NSProviderEnableRemoteService(char *serverAddress)\r
 115 {\r
 116     NS_LOG(DEBUG, "NSProviderEnableRemoteService - IN");\r
 117     pthread_mutex_lock(&nsInitMutex);\r
 118  \r
 119     if(!initProvider)\r
 120     {\r
 121         NS_LOG(DEBUG, "Provider service has not been started yet");\r
 122         return NS_FAIL;\r
 123     }\r
 124 \r
 125     NS_LOG_V(DEBUG, "Remote server address: %s", serverAddress);\r
 126     NSPushQueue(DISCOVERY_SCHEDULER, TASK_PUBLISH_RESOURCE, serverAddress);\r
 127 \r
 128     pthread_mutex_unlock(&nsInitMutex);\r
 129     NS_LOG(DEBUG, "NSProviderEnableRemoteService - OUT");\r
 130     return NS_OK;\r
 131 }\r
 132 \r
 133 NSResult NSProviderDisableRemoteService(char *serverAddress)\r
 134 {\r
 135     NS_LOG(DEBUG, "NSProviderDisableRemoteService - IN");\r
 136     pthread_mutex_lock(&nsInitMutex);\r
 137 \r
 138     if(!initProvider)\r
 139     {\r
 140         NS_LOG(DEBUG, "Provider service has not been started yet");\r
 141         return NS_FAIL;\r
 142     }\r
 143     NS_LOG_V(DEBUG, "Remote server address: %s", serverAddress);\r
 144 \r
 145     pthread_mutex_unlock(&nsInitMutex);\r
 146     NS_LOG(DEBUG, "NSProviderDisableRemoteService - OUT");\r
 147     return NS_OK;\r
 148 }\r
 149 \r
 150 NSResult NSSendMessage(NSMessage *msg)\r
 151 {\r
 152     NS_LOG(DEBUG, "NSSendNotification - IN");\r
 153 \r
 154     pthread_mutex_lock(&nsInitMutex);\r
 155 \r
 156     if(msg == NULL)\r
 157     {\r
 158         NS_LOG(ERROR, "Msg is NULL");\r
 159         pthread_mutex_unlock(&nsInitMutex);\r
 160         return NS_ERROR;\r
 161     }\r
 162 \r
 163     NSMessage * newMsg = NSDuplicateMessage(msg);\r
 164     NSPushQueue(NOTIFICATION_SCHEDULER, TASK_SEND_NOTIFICATION, newMsg);\r
 165 \r
 166     pthread_mutex_unlock(&nsInitMutex);\r
 167 \r
 168     NS_LOG(DEBUG, "NSSendNotification - OUT");\r
 169     return NS_OK;\r
 170 }\r
 171 \r
 172 NSResult NSProviderSendSyncInfo(uint64_t messageId, NSSyncType type)\r
 173 {\r
 174     NS_LOG(DEBUG, "NSProviderReadCheck - IN");\r
 175     pthread_mutex_lock(&nsInitMutex);\r
 176 \r
 177     NSSyncInfo * syncInfo = (NSSyncInfo *)OICMalloc(sizeof(NSSyncInfo));\r
 178     OICStrcpy(syncInfo->providerId, UUID_STRING_SIZE, NSGetProviderInfo()->providerId);\r
 179     syncInfo->messageId = messageId;\r
 180     syncInfo->state = type;\r
 181     NSPushQueue(NOTIFICATION_SCHEDULER, TASK_SEND_READ, syncInfo);\r
 182 \r
 183     pthread_mutex_unlock(&nsInitMutex);\r
 184     NS_LOG(DEBUG, "NSProviderReadCheck - OUT");\r
 185     return NS_OK;\r
 186 }\r
 187 \r
 188 NSResult NSAccept(NSConsumer *consumer, bool accepted)\r
 189 {\r
 190     NS_LOG(DEBUG, "NSAccept - IN");\r
 191 \r
 192     pthread_mutex_lock(&nsInitMutex);\r
 193 \r
 194     NSConsumer * newConsumer = NSDuplicateConsumer(consumer);\r
 195 \r
 196     if(accepted)\r
 197     {\r
 198         NS_LOG(DEBUG, "accepted is true - ALLOW");\r
 199         NSPushQueue(SUBSCRIPTION_SCHEDULER, TASK_SEND_ALLOW, newConsumer);\r
 200     }\r
 201     else\r
 202     {\r
 203         NS_LOG(DEBUG, "accepted is false - DENY");\r
 204         NSPushQueue(SUBSCRIPTION_SCHEDULER, TASK_SEND_DENY, newConsumer);\r
 205     }\r
 206 \r
 207     pthread_mutex_unlock(&nsInitMutex);\r
 208     NS_LOG(DEBUG, "NSAccept - OUT");\r
 209     return NS_OK;\r
 210 }\r
 211 \r
 212 NSMessage * NSCreateMessage()\r
 213 {\r
 214     NS_LOG(DEBUG, "NSCreateMessage - IN");\r
 215     pthread_mutex_lock(&nsInitMutex);\r
 216 \r
 217     NSMessage * msg = NSInitializeMessage();\r
 218     OICStrcpy(msg->providerId, UUID_STRING_SIZE, NSGetProviderInfo()->providerId);\r
 219 \r
 220     pthread_mutex_unlock(&nsInitMutex);\r
 221     NS_LOG(DEBUG, "NSCreateMessage - OUT");\r
 222     return msg;\r
 223 }\r