NSCacheElement * cacheElement = NSStorageRead(ProviderCache, provider->providerId);
NS_VERIFY_NOT_NULL_V(cacheElement);
+
+ pthread_mutex_t * mutex = NSGetCacheMutex();
+ pthread_mutex_lock(mutex);
+
+ NS_VERIFY_NOT_NULL_V(cacheElement);
NSProvider_internal * prov = (NSProvider_internal *)cacheElement->data;
NSProviderConnectionInfo *infos = prov->connection;
while(infos)
infos->isSubscribing = true;
infos = infos->next;
}
+
+ pthread_mutex_unlock(mutex);
}
void NSConsumerHandleRecvProviderChanged(NSMessage * msg)