Home
last modified time | relevance | path

Searched refs:UNSUBSCRIBE_QUERY (Results 1 – 9 of 9) sorted by relevance

/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/
H A Dsync_types.h49 UNSUBSCRIBE_QUERY, enumerator
H A Dsync_operation.cpp267 if (mode_ != SyncModeType::SUBSCRIBE_QUERY && mode_ != SyncModeType::UNSUBSCRIBE_QUERY) { in SetQuery()
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/
H A Dkv_virtual_device.cpp123 …auto operation = new (std::nothrow) SyncOperation(id, {remoteDeviceId_}, UNSUBSCRIBE_QUERY, callba… in UnSubscribe()
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/singlever/
H A Dsingle_ver_data_sync_utils.cpp327 } else if (mode == SyncModeType::UNSUBSCRIBE_QUERY) { in GetControlCmdType()
338 return SyncModeType::UNSUBSCRIBE_QUERY; in GetModeByControlCmdType()
H A Dsingle_ver_sync_state_machine.cpp530 if (mode == SyncModeType::SUBSCRIBE_QUERY || mode == SyncModeType::UNSUBSCRIBE_QUERY) { in GetEventAfterTimeSync()
1212 if ((mode == SyncModeType::SUBSCRIBE_QUERY) || (mode == SyncModeType::UNSUBSCRIBE_QUERY)) { in JumpStatusAfterAbilitySync()
H A Dsingle_ver_data_sync.cpp1875 (context->GetMode() != SyncModeType::UNSUBSCRIBE_QUERY)) { in ControlCmdStartCheck()
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/
H A Dsync_task_context.cpp595 if (isAutoSync_ || mode_ == SUBSCRIBE_QUERY || mode_ == UNSUBSCRIBE_QUERY) { in CopyTargetData()
683 if (IsAutoSync() || mode_ == SUBSCRIBE_QUERY || mode_ == UNSUBSCRIBE_QUERY) { in GetSyncRetryTimes()
H A Dgeneric_syncer.cpp659 (mode == SyncModeType::SUBSCRIBE_QUERY) || (mode == SyncModeType::UNSUBSCRIBE_QUERY)) { in IsManualSync()
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/interfaces/src/
H A Dkv_store_nb_delegate_impl.cpp1003 PragmaSync pragmaData(devices, SyncModeType::UNSUBSCRIBE_QUERY, querySyncObj, in UnSubscribeRemoteQuery()