| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/ |
| H A D | communicator_proxy.cpp | 93 RefObject::IncObjRef(devCommMap_[iter.first].second); in Activate()
118 RefObject::IncObjRef(targetCommunicator); in GetCommunicatorMtuSize()
149 RefObject::IncObjRef(targetCommunicator); in GetTimeout()
182 RefObject::IncObjRef(targetCommunicator); in GetRemoteCommunicatorVersion()
211 RefObject::IncObjRef(targetCommunicator); in SendMessage()
231 RefObject::IncObjRef(mainComm_); in SetMainCommunicator()
262 RefObject::IncObjRef(communicator); in SetEqualCommunicator()
|
| H A D | sync_state_machine.cpp | 62 RefObject::IncObjRef(communicator); in Initialize()
111 RefObject::IncObjRef(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()
446 RefObject::IncObjRef(syncContext_); in StartFeedDogForGetData()
450 RefObject::IncObjRef(syncContext_); in StartFeedDogForGetData()
|
| H A D | sync_engine.cpp | 254 RefObject::IncObjRef(comProxy); in InitInnerSource()
341 RefObject::IncObjRef(context); in AddSyncOperForContext()
458 RefObject::IncObjRef(context); in GetContextForMsg()
474 RefObject::IncObjRef(comProxy); in ScheduleDealMsg()
621 RefObject::IncObjRef(context); in GetSyncTaskContextAndInc()
649 RefObject::IncObjRef(this); in GetSyncTaskContext()
1041 RefObject::IncObjRef(context); in SchemaChange()
1129 RefObject::IncObjRef(remoteExecutor_); in GetAndIncRemoteExector()
1158 RefObject::IncObjRef(communicator); in GetLocalDeviceId()
1174 RefObject::IncObjRef(context); in AbortMachineIfNeed()
[all …]
|
| H A D | sync_task_context.cpp | 94 RefObject::IncObjRef(this); in AddSyncTarget()
103 RefObject::IncObjRef(this); in AddSyncTarget()
313 RefObject::IncObjRef(this); in StartTimer()
496 RefObject::IncObjRef(context); in CommErrHandlerFunc()
561 IncObjRef(this); in TimeOut()
591 RefObject::IncObjRef(syncOperation_); in CopyTargetData()
814 RefObject::IncObjRef(syncOperation_); in GetAndIncSyncOperation()
|
| H A D | generic_syncer.cpp | 214 RefObject::IncObjRef(engine); in PrepareSync()
329 RefObject::IncObjRef(engine); in QueryAutoSync()
362 RefObject::IncObjRef(operation); in AddSyncOperation()
510 RefObject::IncObjRef(item.second); in ClearSyncOperations()
845 RefObject::IncObjRef(engine); in SyncPreCheck()
891 RefObject::IncObjRef(syncEngine_); in Dump()
902 RefObject::IncObjRef(syncEngine_); in DumpSyncerBasicInfo()
919 RefObject::IncObjRef(syncEngine); in RemoteQuery()
1237 RefObject::IncObjRef(syncEngine); in GetTaskCount()
|
| H A D | remote_executor.cpp | 108 RefObject::IncObjRef(this); in ReceiveMessage()
405 RefObject::IncObjRef(this); in RemoteQueryInner()
521 RefObject::IncObjRef(this); in SendRequestMessage()
620 RefObject::IncObjRef(this); in StartTimer()
653 RefObject::IncObjRef(this); in TimeoutCallBack()
693 RefObject::IncObjRef(this); in DoFinished()
839 RefObject::IncObjRef(communicator); in GetAndIncCommunicator()
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/common/src/evloop/src/ |
| H A D | event_impl.cpp | 121 loop->IncObjRef(loop); in AddEvents()
152 loop->IncObjRef(loop); in RemoveEvents()
177 loop->IncObjRef(loop); in SetTimeout()
197 loop->IncObjRef(loop); in Detach()
267 loop->IncObjRef(loop); in SetLoop()
|
| H A D | event_loop_impl.cpp | 42 event->IncObjRef(event); in EventRequest()
53 event->IncObjRef(event); in EventRequest()
171 IncObjRef(this); in Run()
354 event->IncObjRef(event); in AddEventObject()
537 event->IncObjRef(event); in DispatchAll()
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/common/src/ |
| H A D | notification_chain.cpp | 91 IncObjRef(this); in RegisterEventType()
147 listenerChain->IncObjRef(listenerChain); in FindAndGetListenerChainLocked()
201 RefObject::IncObjRef(listener); in BackupListenerSet()
315 listenerChain_->IncObjRef(listenerChain_); in SetOwner()
|
| H A D | ref_object.cpp | 156 void RefObject::IncObjRef(const RefObject *obj) in IncObjRef() function in DistributedDB::RefObject
|
| /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()
133 RefObject::IncObjRef(syncEngine_); in RemoteDataChanged()
201 RefObject::IncObjRef(syncEngine_); in TriggerSubscribe()
327 RefObject::IncObjRef(engine); in TriggerAddSubscribeAsync()
|
| H A D | single_ver_syncer.cpp | 33 RefObject::IncObjRef(syncEngine_); in RemoteDeviceOffline()
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/ |
| H A D | generic_virtual_device.cpp | 151 RefObject::IncObjRef(executor_); in MessageCallback()
157 RefObject::IncObjRef(context_); in MessageCallback()
158 RefObject::IncObjRef(communicateHandle_); in MessageCallback()
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/kv/ |
| H A D | generic_kvdb.cpp | 70 IncObjRef(this); in GetDBConnection()
128 data->IncObjRef(data); in CommitNotify()
153 IncObjRef(this); in CorruptNotify()
|
| H A D | kvdb_manager.cpp | 708 kvDBTmp->IncObjRef(kvDBTmp); in SaveKvDBToCache()
715 kvDBTmp->IncObjRef(kvDBTmp); in SaveKvDBToCache()
723 kvDBTmp->IncObjRef(kvDBTmp); in SaveKvDBToCache()
762 kvDB->IncObjRef(kvDB); in FindAndGetKvDBFromCache()
771 kvDB->IncObjRef(kvDB); in FindAndGetKvDBFromCache()
780 kvDB->IncObjRef(kvDB); in FindAndGetKvDBFromCache()
1036 RefObject::IncObjRef(kvdb->second); in FindKvDB()
1046 RefObject::IncObjRef(entry.second); in Dump()
|
| H A D | kvdb_commit_notify_filterable_data.cpp | 92 genericKvDB_->IncObjRef(genericKvDB_); in SetMyDb()
|
| /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()
267 RefObject::IncObjRef(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()
|
| H A D | communicator_aggregator.cpp | 721 RefObject::IncObjRef(this); // Reference to be hold by adapter in RegCallbackToAdapter()
731 RefObject::IncObjRef(this); // Reference to be hold by adapter in RegCallbackToAdapter()
740 RefObject::IncObjRef(this); // Reference to be hold by adapter in RegCallbackToAdapter()
995 RefObject::IncObjRef(this); in TriggerSendData()
1054 RefObject::IncObjRef(this); in RetrySendTask()
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/sqlite/relational/ |
| H A D | sqlite_relational_store_connection.cpp | 245 IncObjRef(this); in SyncToDevice()
448 IncObjRef(this); in Sync()
473 IncObjRef(this); in GetCloudTaskStatus()
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/cloud/ |
| H A D | process_notifier.cpp | 24 RefObject::IncObjRef(syncer_); in ProcessNotifier()
108 RefObject::IncObjRef(syncer); in NotifyProcess()
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/common/include/ |
| H A D | ref_object.h | 59 static void IncObjRef(const RefObject *obj);
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/relational/ |
| H A D | relational_store_instance.cpp | 84 db->IncObjRef(db); in GetFromCache()
253 RefObject::IncObjRef(entry.second); in Dump()
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/ |
| H A D | sync_operation.cpp | 183 RefObject::IncObjRef(this); in Finished()
240 RefObject::IncObjRef(context); in SetSyncContext()
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/sqlite/ |
| H A D | sqlite_single_ver_natural_store_extend.cpp | 61 RefObject::IncObjRef(this); in StartLifeCycleTimer()
156 RefObject::IncObjRef(storageEngine); in TriggerToMigrateData()
158 RefObject::IncObjRef(this); in TriggerToMigrateData()
|
| /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()
548 RefObject::IncObjRef(context_); in SyncResponseBegin()
|