| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/common/src/ |
| H A D | notification_chain.cpp | 46 listenerChain->DecObjRef(listenerChain); in RegisterListener()
55 listener->DecObjRef(listener); in RegisterListener()
57 listenerChain->DecObjRef(listenerChain); in RegisterListener()
62 listenerChain->DecObjRef(listenerChain); in RegisterListener()
110 DecObjRef(this); in UnRegisterEventType()
121 listenerChain->DecObjRef(listenerChain); in NotifyEvent()
132 RefObject::DecObjRef(listenerChain); in EmptyListener()
220 listener->DecObjRef(listener); in NotifyListeners()
311 listenerChain_->DecObjRef(listenerChain_); in SetOwner()
|
| H A D | ref_object.cpp | 168 void RefObject::DecObjRef(const RefObject *obj) in DecObjRef() function in DistributedDB::RefObject
193 obj->DecObjRef(obj); in KillAndDecObjRef()
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/ |
| H A D | communicator_proxy.cpp | 29 RefObject::DecObjRef(mainComm_); in ~CommunicatorProxy()
35 RefObject::DecObjRef(devCommMap_[iter.first].second); in ~CommunicatorProxy()
99 RefObject::DecObjRef(tempMap[iter.first]); in Activate()
123 RefObject::DecObjRef(targetCommunicator); in GetCommunicatorMtuSize()
154 RefObject::DecObjRef(targetCommunicator); in GetTimeout()
187 RefObject::DecObjRef(targetCommunicator); in GetRemoteCommunicatorVersion()
217 RefObject::DecObjRef(targetCommunicator); in SendMessage()
249 RefObject::DecObjRef(devCommMap_[dev->first].second); in SetEqualCommunicator()
260 RefObject::DecObjRef(devCommMap_[target].second); in SetEqualCommunicator()
|
| H A D | sync_state_machine.cpp | 48 RefObject::DecObjRef(communicator_); in ~SyncStateMachine()
114 RefObject::DecObjRef(this->syncContext_); in Abort()
118 RefObject::DecObjRef(syncContext_); in Abort()
246 RefObject::DecObjRef(syncContext_); in StartSaveDataNotify()
250 RefObject::DecObjRef(syncContext_); in StartSaveDataNotify()
254 [this]() { RefObject::DecObjRef(syncContext_); }, in StartSaveDataNotify()
320 RefObject::DecObjRef(syncContext_); in StartFeedDogForSync()
324 RefObject::DecObjRef(syncContext_); in StartFeedDogForSync()
328 [this]() { RefObject::DecObjRef(syncContext_); }, in StartFeedDogForSync()
461 RefObject::DecObjRef(syncContext_); in StartFeedDogForGetData()
[all …]
|
| H A D | sync_engine.cpp | 150 RefObject::DecObjRef(executor); in Close()
257 RefObject::DecObjRef(comProxy); in InitInnerSource()
348 RefObject::DecObjRef(context); in AddSyncOperForContext()
395 RefObject::DecObjRef(context); in ScheduleTaskOut()
652 RefObject::DecObjRef(this); in GetSyncTaskContext()
1100 RefObject::DecObjRef(executor); in RemoteQuery()
1112 RefObject::DecObjRef(executor); in NotifyConnectionClosed()
1123 RefObject::DecObjRef(executor); in NotifyUserChange()
1208 RefObject::DecObjRef(executor); in HandleRemoteExecutorMsg()
1254 RefObject::DecObjRef(iter); in TimeChange()
[all …]
|
| H A D | remote_executor.cpp | 111 RefObject::DecObjRef(this); in ReceiveMessage()
114 RefObject::DecObjRef(this); in ReceiveMessage()
408 RefObject::DecObjRef(this); in RemoteQueryInner()
413 RefObject::DecObjRef(this); in RemoteQueryInner()
527 RefObject::DecObjRef(this); in SendRequestMessage()
531 RefObject::DecObjRef(this); in SendRequestMessage()
623 RefObject::DecObjRef(this); in StartTimer()
626 RefObject::DecObjRef(this); in StartTimer()
656 RefObject::DecObjRef(this); in TimeoutCallBack()
660 RefObject::DecObjRef(this); in TimeoutCallBack()
[all …]
|
| H A D | sync_task_context.cpp | 97 RefObject::DecObjRef(this); in AddSyncTarget()
100 RefObject::DecObjRef(this); in AddSyncTarget()
106 RefObject::DecObjRef(this); in AddSyncTarget()
109 RefObject::DecObjRef(this); in AddSyncTarget()
317 … int ret = RuntimeContext::GetInstance()->ScheduleTask([this]() { RefObject::DecObjRef(this); }); in StartTimer()
323 RefObject::DecObjRef(this); in StartTimer()
501 RefObject::DecObjRef(context); in CommErrHandlerFunc()
564 DecObjRef(this); in TimeOut()
568 DecObjRef(this); in TimeOut()
640 RefObject::DecObjRef(syncOperation_); in ClearSyncOperation()
|
| H A D | generic_syncer.cpp | 217 RefObject::DecObjRef(engine); in PrepareSync()
229 RefObject::DecObjRef(operation); in PrepareSync()
336 RefObject::DecObjRef(engine); in QueryAutoSync()
341 RefObject::DecObjRef(engine); in QueryAutoSync()
525 RefObject::DecObjRef(operation); in ClearSyncOperations()
849 RefObject::DecObjRef(engine); in SyncPreCheck()
893 RefObject::DecObjRef(syncEngine_); in Dump()
904 RefObject::DecObjRef(syncEngine_); in DumpSyncerBasicInfo()
925 RefObject::DecObjRef(syncEngine); in RemoteQuery()
1240 RefObject::DecObjRef(syncEngine); in GetTaskCount()
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/singlever/ |
| H A D | single_ver_kv_syncer.cpp | 105 RefObject::DecObjRef(engine); in LocalDataChanged()
114 RefObject::DecObjRef(engine); in LocalDataChanged()
145 RefObject::DecObjRef(syncEngine_); in RemoteDataChanged()
150 RefObject::DecObjRef(syncEngine_); in RemoteDataChanged()
217 RefObject::DecObjRef(syncEngine_); in TriggerSubscribe()
221 RefObject::DecObjRef(syncEngine_); in TriggerSubscribe()
332 RefObject::DecObjRef(engine); in TriggerAddSubscribeAsync()
338 RefObject::DecObjRef(engine); in TriggerAddSubscribeAsync()
|
| H A D | single_ver_syncer.cpp | 39 RefObject::DecObjRef(engine); in RemoteDeviceOffline()
44 RefObject::DecObjRef(engine); in RemoteDeviceOffline()
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/common/src/evloop/src/ |
| H A D | event_impl.cpp | 79 loop_->DecObjRef(loop_); in ~EventImpl()
125 loop->DecObjRef(loop); in AddEvents()
156 loop->DecObjRef(loop); in RemoveEvents()
181 loop->DecObjRef(loop); in SetTimeout()
210 loop->DecObjRef(loop); in Detach()
214 loop->DecObjRef(loop); in Detach()
260 loop_->DecObjRef(loop_); in SetLoop()
|
| H A D | event_loop_impl.cpp | 60 event_->DecObjRef(event_); in ~EventRequest()
202 DecObjRef(this); in Run()
379 event->DecObjRef(event); in RemoveEventObject()
545 event->DecObjRef(event); in DispatchAll()
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/kv/ |
| H A D | generic_kvdb.cpp | 113 DecObjRef(this); in ReleaseDBConnection()
133 data->DecObjRef(data); in CommitNotify()
148 DecObjRef(this); in CorruptNotifyAsync()
158 DecObjRef(this); in CorruptNotify()
294 data->DecObjRef(data); in CommitNotifyAsync()
|
| H A D | sync_able_kvdb.cpp | 426 RefObject::DecObjRef(notify); in NotifyRemotePushFinishedInner()
607 RefObject::DecObjRef(syncer); in Sync()
613 RefObject::DecObjRef(syncer); in Sync()
625 RefObject::DecObjRef(syncer); in SetCloudDB()
637 RefObject::DecObjRef(syncer); in CleanAllWaterMark()
647 RefObject::DecObjRef(cloudSyncer); in GetTaskCount()
674 RefObject::DecObjRef(cloudSyncer); in SetGenCloudVersionCallback()
|
| H A D | kvdb_commit_notify_filterable_data.cpp | 28 genericKvDB_->DecObjRef(genericKvDB_); in ~KvDBCommitNotifyFilterAbleData()
88 genericKvDB_->DecObjRef(genericKvDB_); in SetMyDb()
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/storage/ |
| H A D | distributeddb_relational_remote_query_test.cpp | 204 RefObject::DecObjRef(g_store);
290 RefObject::DecObjRef(g_store);
337 RefObject::DecObjRef(g_store);
399 RefObject::DecObjRef(g_store);
431 RefObject::DecObjRef(g_store);
515 RefObject::DecObjRef(g_store);
568 RefObject::DecObjRef(g_store);
610 RefObject::DecObjRef(g_store);
|
| H A D | distributeddb_relational_get_data_test.cpp | 404 RefObject::DecObjRef(g_store);
447 RefObject::DecObjRef(g_store);
537 RefObject::DecObjRef(g_store);
580 RefObject::DecObjRef(g_store);
649 RefObject::DecObjRef(g_store);
738 RefObject::DecObjRef(g_store);
824 RefObject::DecObjRef(g_store);
890 RefObject::DecObjRef(g_store);
996 RefObject::DecObjRef(g_store);
1658 RefObject::DecObjRef(store);
[all …]
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/multiver/ |
| H A D | multi_ver_sync_state_machine.cpp | 107 RefObject::DecObjRef(communicator_); in SyncStep()
108 RefObject::DecObjRef(context_); in SyncStep()
263 RefObject::DecObjRef(communicator_); in SyncStepInnerLocked()
264 RefObject::DecObjRef(context_); in SyncStepInnerLocked()
317 RefObject::DecObjRef(context_); in CommErrAbort()
553 …nt ret = RuntimeContext::GetInstance()->ScheduleTask([this]() { RefObject::DecObjRef(context_); }); in SyncResponseBegin()
561 RefObject::DecObjRef(context_); in SyncResponseBegin()
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/communicator/src/ |
| H A D | communicator_aggregator.cpp | 94 … RefObject::DecObjRef(commLinker_); // Refcount of linker is 1 when created, here to unref linker in Initialize()
130 RefObject::DecObjRef(commLinker_); // Refcount of linker is 1 when created, here to unref linker in Finalize()
725 }, [this]() { RefObject::DecObjRef(this); }); in RegCallbackToAdapter()
727 RefObject::DecObjRef(this); // Rollback in case reg failed in RegCallbackToAdapter()
734 [this]() { RefObject::DecObjRef(this); }); in RegCallbackToAdapter()
736 RefObject::DecObjRef(this); // Rollback in case reg failed in RegCallbackToAdapter()
749 [this]() { RefObject::DecObjRef(this); }); in RegCallbackToAdapter()
751 RefObject::DecObjRef(this); // Rollback in case reg failed in RegCallbackToAdapter()
1009 RefObject::DecObjRef(this); in TriggerSendData()
1014 RefObject::DecObjRef(this); in TriggerSendData()
[all …]
|
| H A D | communicator_linker.cpp | 46 RefObject::DecObjRef(aggregator_); // The linker no longer rely on CommunicatorAggregator in ~CommunicatorLinker()
271 RefObject::DecObjRef(this); in DetectDistinctValueChange()
275 RefObject::DecObjRef(this); in DetectDistinctValueChange()
391 … RefObject::DecObjRef(this); // ATTENTION: The DecObjRef should be outside entireInfoLockGuard!!! in SendLabelExchange()
451 … RefObject::DecObjRef(this); // ATTENTION: The DecObjRef should be outside entireInfoLockGuard!!! in SendLabelExchangeAck()
459 … RefObject::DecObjRef(this); // ATTENTION: The DecObjRef should be outside entireInfoLockGuard!!! in SendLabelExchangeAck()
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/sqlite/relational/ |
| H A D | sqlite_relational_store_connection.cpp | 255 DecObjRef(this); in SyncToDevice()
259 DecObjRef(this); in SyncToDevice()
264 DecObjRef(this); in SyncToDevice()
451 DecObjRef(this); in Sync()
476 DecObjRef(this); in GetCloudTaskStatus()
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/ |
| H A D | sync_operation.cpp | 41 RefObject::DecObjRef(context_); in ~SyncOperation()
186 RefObject::DecObjRef(this); in Finished()
190 RefObject::DecObjRef(this); in Finished()
238 RefObject::DecObjRef(context_); in SetSyncContext()
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/cloud/ |
| H A D | process_notifier.cpp | 29 RefObject::DecObjRef(syncer_); in ~ProcessNotifier()
114 RefObject::DecObjRef(syncer); in NotifyProcess()
118 RefObject::DecObjRef(syncer); in NotifyProcess()
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/relational/ |
| H A D | relational_store_instance.cpp | 136 RefObject::DecObjRef(db); in GetDataBase()
228 RefObject::DecObjRef(db); // restore the reference increased by the cache. in GetDatabaseConnection()
255 RefObject::DecObjRef(entry.second); in Dump()
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/ |
| H A D | generic_virtual_device.cpp | 153 RefObject::DecObjRef(executor_); in MessageCallback()
166 RefObject::DecObjRef(context); in MessageCallback()
167 RefObject::DecObjRef(communicateHandle); in MessageCallback()
|