| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/common/src/ |
| H A D | ref_object.cpp | 22 RefObject::AutoLock::AutoLock(const RefObject *obj, bool unlocked) in AutoLock()
34 void RefObject::AutoLock::Lock() in Lock()
58 RefObject::AutoLock::~AutoLock() in ~AutoLock()
69 RefObject::RefObject() in RefObject() function in DistributedDB::RefObject
74 RefObject::~RefObject() in ~RefObject()
102 bool RefObject::IsKilled() const in IsKilled()
107 void RefObject::KillObj() in KillObj()
118 void RefObject::LockObj() const in LockObj()
156 void RefObject::IncObjRef(const RefObject *obj) in IncObjRef()
168 void RefObject::DecObjRef(const RefObject *obj) in DecObjRef()
[all …]
|
| H A D | time_tick_monitor.cpp | 77 RefObject::KillAndDecObjRef(notifier); in StopTimeTickMonitor()
113 RefObject::KillAndDecObjRef(timeChangedNotifier_); in PrepareNotifierChain()
140 RefObject::IncObjRef(notifier); in TimeTick()
148 RefObject::DecObjRef(notifier); in TimeTick()
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/common/include/ |
| H A D | ref_object.h | 28 class RefObject {
32 explicit AutoLock(const RefObject *obj, bool unlocked = true);
39 const RefObject *refObj_;
43 RefObject();
59 static void IncObjRef(const RefObject *obj);
60 static void DecObjRef(const RefObject *obj);
61 static void KillAndDecObjRef(RefObject *obj);
64 virtual ~RefObject();
70 DISABLE_COPY_ASSIGN_MOVE(RefObject);
|
| H A D | notification_chain.h | 29 class NotificationChain final : public RefObject {
34 class Listener final : public RefObject {
102 class ListenerChain final : public RefObject {
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/ |
| H A D | communicator_proxy.cpp | 29 RefObject::DecObjRef(mainComm_); in ~CommunicatorProxy()
99 RefObject::DecObjRef(tempMap[iter.first]); in Activate()
118 RefObject::IncObjRef(targetCommunicator); in GetCommunicatorMtuSize()
123 RefObject::DecObjRef(targetCommunicator); in GetCommunicatorMtuSize()
149 RefObject::IncObjRef(targetCommunicator); in GetTimeout()
154 RefObject::DecObjRef(targetCommunicator); in GetTimeout()
182 RefObject::IncObjRef(targetCommunicator); in GetRemoteCommunicatorVersion()
187 RefObject::DecObjRef(targetCommunicator); in GetRemoteCommunicatorVersion()
217 RefObject::DecObjRef(targetCommunicator); in SendMessage()
231 RefObject::IncObjRef(mainComm_); in SetMainCommunicator()
[all …]
|
| H A D | sync_state_machine.cpp | 48 RefObject::DecObjRef(communicator_); in ~SyncStateMachine()
62 RefObject::IncObjRef(communicator); in Initialize()
81 RefObject::AutoLock lock(syncContext_); in TimeoutCallback()
111 RefObject::IncObjRef(syncContext_); in Abort()
114 RefObject::DecObjRef(this->syncContext_); in Abort()
118 RefObject::DecObjRef(syncContext_); in Abort()
239 RefObject::IncObjRef(syncContext_); in StartSaveDataNotify()
243 RefObject::IncObjRef(syncContext_); in StartSaveDataNotify()
312 RefObject::IncObjRef(syncContext_); in StartFeedDogForSync()
317 RefObject::IncObjRef(syncContext_); in StartFeedDogForSync()
[all …]
|
| H A D | sync_engine.cpp | 348 RefObject::DecObjRef(context); in AddSyncOperForContext()
395 RefObject::DecObjRef(context); in ScheduleTaskOut()
621 RefObject::IncObjRef(context); in GetSyncTaskContextAndInc()
649 RefObject::IncObjRef(this); in GetSyncTaskContext()
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 | sync_task_context.cpp | 94 RefObject::IncObjRef(this); in AddSyncTarget()
97 RefObject::DecObjRef(this); in AddSyncTarget()
100 RefObject::DecObjRef(this); in AddSyncTarget()
103 RefObject::IncObjRef(this); in AddSyncTarget()
106 RefObject::DecObjRef(this); in AddSyncTarget()
109 RefObject::DecObjRef(this); in AddSyncTarget()
313 RefObject::IncObjRef(this); in StartTimer()
323 RefObject::DecObjRef(this); in StartTimer()
496 RefObject::IncObjRef(context); in CommErrHandlerFunc()
501 RefObject::DecObjRef(context); in CommErrHandlerFunc()
[all …]
|
| H A D | remote_executor.cpp | 108 RefObject::IncObjRef(this); in ReceiveMessage()
111 RefObject::DecObjRef(this); in ReceiveMessage()
114 RefObject::DecObjRef(this); in ReceiveMessage()
405 RefObject::IncObjRef(this); in RemoteQueryInner()
408 RefObject::DecObjRef(this); in RemoteQueryInner()
413 RefObject::DecObjRef(this); in RemoteQueryInner()
521 RefObject::IncObjRef(this); in SendRequestMessage()
527 RefObject::DecObjRef(this); in SendRequestMessage()
620 RefObject::IncObjRef(this); in StartTimer()
653 RefObject::IncObjRef(this); in TimeoutCallBack()
[all …]
|
| H A D | generic_syncer.cpp | 214 RefObject::IncObjRef(engine); in PrepareSync()
217 RefObject::DecObjRef(engine); in PrepareSync()
229 RefObject::DecObjRef(operation); in PrepareSync()
329 RefObject::IncObjRef(engine); in QueryAutoSync()
336 RefObject::DecObjRef(engine); in QueryAutoSync()
341 RefObject::DecObjRef(engine); in QueryAutoSync()
362 RefObject::IncObjRef(operation); in AddSyncOperation()
845 RefObject::IncObjRef(engine); in SyncPreCheck()
849 RefObject::DecObjRef(engine); in SyncPreCheck()
925 RefObject::DecObjRef(syncEngine); in RemoteQuery()
[all …]
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/singlever/ |
| H A D | single_ver_kv_syncer.cpp | 95 RefObject::IncObjRef(engine); in LocalDataChanged()
105 RefObject::DecObjRef(engine); in LocalDataChanged()
114 RefObject::DecObjRef(engine); in LocalDataChanged()
133 RefObject::IncObjRef(syncEngine_); in RemoteDataChanged()
145 RefObject::DecObjRef(syncEngine_); in RemoteDataChanged()
201 RefObject::IncObjRef(syncEngine_); in TriggerSubscribe()
217 RefObject::DecObjRef(syncEngine_); in TriggerSubscribe()
221 RefObject::DecObjRef(syncEngine_); in TriggerSubscribe()
327 RefObject::IncObjRef(engine); in TriggerAddSubscribeAsync()
332 RefObject::DecObjRef(engine); in TriggerAddSubscribeAsync()
[all …]
|
| H A D | single_ver_syncer.cpp | 33 RefObject::IncObjRef(syncEngine_); in RemoteDeviceOffline()
39 RefObject::DecObjRef(engine); in RemoteDeviceOffline()
44 RefObject::DecObjRef(engine); in RemoteDeviceOffline()
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/ |
| H A D | generic_virtual_device.cpp | 61 RefObject::KillAndDecObjRef(context_); in ~GenericVirtualDevice()
71 RefObject::KillAndDecObjRef(executor_); in ~GenericVirtualDevice()
151 RefObject::IncObjRef(executor_); in MessageCallback()
153 RefObject::DecObjRef(executor_); in MessageCallback()
157 RefObject::IncObjRef(context_); in MessageCallback()
158 RefObject::IncObjRef(communicateHandle_); in MessageCallback()
166 RefObject::DecObjRef(context); in MessageCallback()
167 RefObject::DecObjRef(communicateHandle); in MessageCallback()
193 RefObject::AutoLock lockGuard(context_); in StartResponseTask()
233 RefObject::KillAndDecObjRef(operation); in Sync()
[all …]
|
| H A D | distributeddb_mock_sync_module_test.cpp | 95 RefObject::IncObjRef(this); in IncRefCount()
100 RefObject::DecObjRef(this); in DecRefCount()
262 RefObject::KillAndDecObjRef(context); in AbilitySync004()
350 RefObject::KillAndDecObjRef(executor); in MockRemoteQuery002()
819 RefObject::KillAndDecObjRef(context);
1037 RefObject::KillAndDecObjRef(context);
1177 RefObject::KillAndDecObjRef(context);
1208 RefObject::IncObjRef(communicator);
1793 RefObject::KillAndDecObjRef(context);
1986 RefObject::KillAndDecObjRef(engine);
[all …]
|
| H A D | distributeddb_single_ver_msg_schedule_test.cpp | 101 RefObject::KillAndDecObjRef(context);
144 RefObject::KillAndDecObjRef(context);
211 RefObject::KillAndDecObjRef(context);
270 RefObject::KillAndDecObjRef(context);
327 RefObject::KillAndDecObjRef(context);
393 RefObject::KillAndDecObjRef(context);
455 RefObject::KillAndDecObjRef(context);
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/common/src/evloop/src/ |
| H A D | event_impl.cpp | 115 RefObject::AutoLock lockGuard(this); in AddEvents()
146 RefObject::AutoLock lockGuard(this); in RemoveEvents()
171 RefObject::AutoLock lockGuard(this); in SetTimeout()
192 RefObject::AutoLock lockGuard(this); in Detach()
225 RefObject::AutoLock lockGuard(this); in CheckStatus()
257 RefObject::AutoLock lockGuard(this); in SetLoop()
276 RefObject::AutoLock lockGuard(this); in Wait()
282 RefObject::AutoLock lockGuard(this); in Attached()
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/multiver/ |
| H A D | multi_ver_sync_state_machine.cpp | 102 RefObject::IncObjRef(context_); in SyncStep()
103 RefObject::IncObjRef(communicator_); in SyncStep()
107 RefObject::DecObjRef(communicator_); in SyncStep()
108 RefObject::DecObjRef(context_); in SyncStep()
123 RefObject::AutoLock lock(context_); in MessageCallbackCheck()
263 RefObject::DecObjRef(communicator_); in SyncStepInnerLocked()
264 RefObject::DecObjRef(context_); in SyncStepInnerLocked()
317 RefObject::DecObjRef(context_); in CommErrAbort()
444 RefObject::AutoLock lock(context_); in Finish()
548 RefObject::IncObjRef(context_); in SyncResponseBegin()
[all …]
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/communicator/src/ |
| H A D | communicator_linker.cpp | 41 RefObject::IncObjRef(aggregator_); // The linker rely on CommunicatorAggregator in CommunicatorLinker()
46 RefObject::DecObjRef(aggregator_); // The linker no longer rely on CommunicatorAggregator in ~CommunicatorLinker()
267 RefObject::IncObjRef(this); in DetectDistinctValueChange()
271 RefObject::DecObjRef(this); in DetectDistinctValueChange()
275 RefObject::DecObjRef(this); in DetectDistinctValueChange()
324 …RefObject::IncObjRef(this); // SendLabelExchange will only DecRef when total done if no need to se… in TriggerLabelExchangeEvent()
346 …RefObject::IncObjRef(this); // SendLabelExchangeAck will only DecRef when total done if no need to… in TriggerLabelExchangeAckEvent()
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()
|
| H A D | communicator_aggregator.cpp | 721 RefObject::IncObjRef(this); // Reference to be hold by adapter in RegCallbackToAdapter()
725 }, [this]() { RefObject::DecObjRef(this); }); in RegCallbackToAdapter()
727 RefObject::DecObjRef(this); // Rollback in case reg failed in RegCallbackToAdapter()
731 RefObject::IncObjRef(this); // Reference to be hold by adapter in RegCallbackToAdapter()
734 [this]() { RefObject::DecObjRef(this); }); in RegCallbackToAdapter()
749 [this]() { RefObject::DecObjRef(this); }); in RegCallbackToAdapter()
995 RefObject::IncObjRef(this); in TriggerSendData()
1009 RefObject::DecObjRef(this); in TriggerSendData()
1014 RefObject::DecObjRef(this); in TriggerSendData()
1054 RefObject::IncObjRef(this); in RetrySendTask()
[all …]
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/ |
| H A D | sync_operation.cpp | 41 RefObject::DecObjRef(context_); in ~SyncOperation()
183 RefObject::IncObjRef(this); in Finished()
186 RefObject::DecObjRef(this); in Finished()
190 RefObject::DecObjRef(this); in Finished()
236 void SyncOperation::SetSyncContext(RefObject *context) in SetSyncContext()
238 RefObject::DecObjRef(context_); in SetSyncContext()
240 RefObject::IncObjRef(context); in SetSyncContext()
|
| H A D | sync_operation.h | 34 class SyncOperation : public RefObject {
132 void SetSyncContext(RefObject *context);
137 RefObject *context_ = nullptr;
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/kv/ |
| H A D | sync_able_kvdb.cpp | 212 RefObject::KillAndDecObjRef(cloudSyncer_); in StopSyncer()
421 RefObject::IncObjRef(notify); in NotifyRemotePushFinishedInner()
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()
662 RefObject::IncObjRef(cloudSyncer_); in GetAndIncCloudSyncer()
674 RefObject::DecObjRef(cloudSyncer); in SetGenCloudVersionCallback()
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/cloud/ |
| H A D | process_notifier.cpp | 24 RefObject::IncObjRef(syncer_); in ProcessNotifier()
29 RefObject::DecObjRef(syncer_); in ~ProcessNotifier()
108 RefObject::IncObjRef(syncer); in NotifyProcess()
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 | 122 RefObject::KillAndDecObjRef(db); in OpenDatabase()
136 RefObject::DecObjRef(db); in GetDataBase()
228 RefObject::DecObjRef(db); // restore the reference increased by the cache. in GetDatabaseConnection()
253 RefObject::IncObjRef(entry.second); in Dump()
255 RefObject::DecObjRef(entry.second); in Dump()
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/storage/ |
| H A D | distributeddb_storage_subscribe_query_test.cpp | 274 RefObject::KillAndDecObjRef(store);
312 RefObject::KillAndDecObjRef(store);
356 RefObject::KillAndDecObjRef(store);
403 RefObject::KillAndDecObjRef(store);
461 RefObject::KillAndDecObjRef(store);
518 RefObject::KillAndDecObjRef(store);
574 RefObject::KillAndDecObjRef(store);
635 RefObject::KillAndDecObjRef(store);
672 RefObject::KillAndDecObjRef(store);
759 RefObject::KillAndDecObjRef(store);
[all …]
|