| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/common/src/evloop/src/ |
| H A D | event_loop_impl.cpp | 159 if (IsKilled()) { in Run()
259 if (IsKilled()) { in SendRequestToLoop()
278 if (IsKilled()) { // pre-check in QueueRequest()
438 if (!IsKilled()) { in ProcessRequest()
481 if (IsKilled()) { in ProcessRequest()
530 if (IsKilled()) { in DispatchAll()
557 if (!IsKilled()) { in CleanLoop()
|
| H A D | event_impl.cpp | 92 if (IsKilled()) { in SetAction()
226 if (IsKilled()) { in CheckStatus()
357 if (!IsKilled()) { in Dispatch()
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/common/src/ |
| H A D | notification_chain.cpp | 70 if (IsKilled()) { in RegisterEventType()
163 if (IsKilled()) { in RegisterListener()
211 if (IsKilled()) { in NotifyListeners()
253 if (onEvent_ && !IsKilled()) { in NotifyListener()
271 if (IsKilled()) { in EnterEventAction()
|
| H A D | ref_object.cpp | 102 bool RefObject::IsKilled() const in IsKilled() function in DistributedDB::RefObject
110 if (!IsKilled()) { in KillObj()
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/ |
| H A D | sync_engine.cpp | 330 if (!IsKilled()) { in AddSyncOperForContext()
337 if (context->IsKilled()) { // LCOV_EXCL_BR_LINE in AddSyncOperForContext()
443 if (context->IsKilled()) { in GetContextForMsg()
448 if (IsKilled()) { in GetContextForMsg()
617 if (context->IsKilled()) { // LCOV_EXCL_BR_LINE in GetSyncTaskContextAndInc()
661 if (IsKilled()) { in ExecSyncTask()
666 if ((status == SyncTaskContext::RUNNING) || context->IsKilled()) { in ExecSyncTask()
1038 if (context == nullptr || context->IsKilled()) { // LCOV_EXCL_BR_LINE in SchemaChange()
1171 if (context == nullptr || context->IsKilled()) { // LCOV_EXCL_BR_LINE in AbortMachineIfNeed()
|
| H A D | sync_target.cpp | 58 if ((operation != nullptr) && !operation->IsKilled()) { in SetSyncOperation()
|
| H A D | sync_task_context.cpp | 256 if ((tmpOperation != nullptr) && tmpOperation->IsKilled()) { in MoveToNextTarget()
456 if (IsKilled()) { in IncUsedCount()
|
| H A D | sync_state_machine.cpp | 82 if (syncContext_->IsKilled()) { in TimeoutCallback()
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/ |
| H A D | sync_operation.cpp | 85 if (IsKilled()) { in SetStatus()
111 if (IsKilled()) { in SetUnfinishedDevStatus()
166 if (IsKilled() || isFinished_) { in Finished()
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/kv/ |
| H A D | sync_able_kvdb_connection.cpp | 138 if (IsKilled()) { in PragmaSyncAction()
176 if (!IsKilled() && onComplete) { in OnSyncComplete()
182 if (!IsKilled()) { in OnSyncComplete()
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/sqlite/relational/ |
| H A D | sqlite_relational_store_connection.cpp | 240 if (IsKilled()) { in SyncToDevice()
443 if (IsKilled()) { in Sync()
466 if (IsKilled()) { in GetCloudTaskStatus()
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/singlever/ |
| H A D | single_ver_sync_target.cpp | 37 if ((operation != nullptr) && !operation->IsKilled()) { in SetSyncOperation()
|
| H A D | single_ver_sync_state_machine.cpp | 260 if (context_->IsKilled()) { in AbortInner()
980 if (context_->IsKilled()) { in MessageCallbackPre()
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/common/include/ |
| H A D | ref_object.h | 51 bool IsKilled() const;
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/ |
| H A D | virtual_communicator.cpp | 57 if (IsKilled()) { in SendMessage()
|
| H A D | generic_virtual_device.cpp | 195 if ((status == SyncTaskContext::RUNNING) || context_->IsKilled()) { in StartResponseTask()
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/multiver/ |
| H A D | multi_ver_sync_state_machine.cpp | 124 if (context_->IsKilled()) { in MessageCallbackCheck()
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/cloud/ |
| H A D | cloud_syncer_extend.cpp | 562 return closed_ || IsKilled(); in IsClosed()
|