| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/ |
| H A D | subscribe_manager.cpp | 46 …LOGI("[SubscribeManager] dev=%s,queryId=%s remote reserve err=%d", STR_MASK(device), STR_MASK(quer… in ReserveRemoteSubscribeQuery()
56 …LOGI("[SubscribeManager] dev=%s,queryId=%s remote active err=%d", STR_MASK(device), STR_MASK(query… in ActiveRemoteSubscribeQuery()
64 …LOGI("[SubscribeManager] dev=%s,queryId=%s local reserve err=%d", STR_MASK(device), STR_MASK(query… in ReserveLocalSubscribeQuery()
74 …LOGI("[SubscribeManager] dev=%s,queryId=%s local active err=%d", STR_MASK(device), STR_MASK(queryI… in ActiveLocalSubscribeQuery()
151 …ubscribeManager] dev=%s,queryId=%s delete from UnFinishedMap", STR_MASK(device), STR_MASK(queryId)… in RemoveLocalSubscribeQuery()
277 …("[SubscribeManager] dev=%s,queryId=%s already active in map", STR_MASK(device), STR_MASK(queryId)… in ReserveSubscribeQuery()
309 …LOGE("[SubscribeManager] can not find dev=%s,queryId=%s in map", STR_MASK(device), STR_MASK(queryI… in ActiveSubscribeQuery()
324 …LOGE("[SubscribeManager] can not find dev=%s,queryId=%s in map", STR_MASK(device), STR_MASK(queryI… in DeleteSubscribeQuery()
330 …ubscribeManager] dev=%s,queryId=%s is active, no need to del", STR_MASK(device), STR_MASK(queryId)… in DeleteSubscribeQuery()
344 …eManager] dev=%s,queryId=%s remove from SubscribeMap success", STR_MASK(device), STR_MASK(queryId)… in DeleteSubscribeQuery()
[all …]
|
| H A D | sync_engine.cpp | 614 … LOGI("[SyncEngine] dev=%s, context is null, no need to clear sync operation", STR_MASK(deviceId)); in GetSyncTaskContextAndInc()
641 LOGE("[SyncEngine] context init failed err %d, dev %s", errCode, STR_MASK(deviceId)); in GetSyncTaskContext()
651 LOGD("[SyncEngine] SyncTaskContext for id %s finalized", STR_MASK(deviceId)); in GetSyncTaskContext()
847 … LOGI("[SyncEngine] target dev=%s is online, no need to clear task.", STR_MASK(deviceId)); in OfflineHandleByDevice()
1228 STR_MASK(device), STR_MASK(query.GetIdentify())); in AddQuerySubscribe()
|
| H A D | meta_data.cpp | 85 LOGD("Metadata::SaveTimeOffset = %" PRId64 " dev %s", inValue, STR_MASK(deviceId)); in SaveTimeOffset()
494 LOGI("Metadata::GetDbCreateTime, not found dev = %s dbCreateTime", STR_MASK(deviceId)); in GetDbCreateTime()
508 STR_MASK(deviceId), inValue); in SetDbCreateTime()
511 …LOGI("Metadata::SetDbCreateTime,update dev=%s,dbCreateTime=%" PRIu64, STR_MASK(deviceId), inValue); in SetDbCreateTime()
|
| H A D | ability_sync.cpp | 497 STR_MASK(deviceId_), remoteSoftwareVersion, errCode); in AckNotifyRecv()
1148 LOGI("[AbilitySync][RequestRecv] remote dev=%s,ver=%u,schemaCompatible=%d", STR_MASK(deviceId_), in HandleRequestRecv()
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/singlever/ |
| H A D | single_ver_data_sync.cpp | 708 … STR_MASK(GetDeviceId()), STR_MASK(context->GetQuery().GetIdentify()), packet->IsCompressData()); in FillDataRequestPacket()
998 STR_MASK(packet->GetQueryId()), label_.c_str(), STR_MASK(GetDeviceId())); in DataRequestRecv()
1201 STR_MASK(GetDeviceId())); in AckRecv()
1214 STR_MASK(GetDeviceId())); in AckRecv()
1385 STR_MASK(GetDeviceId())); in SendResetWatchDogPacket()
1388 STR_MASK(GetDeviceId())); in SendResetWatchDogPacket()
2028 STR_MASK(GetDeviceId())); in SubscribeRequestRecv()
2035 STR_MASK(GetDeviceId())); in SubscribeRequestRecv()
2045 STR_MASK(GetDeviceId())); in SubscribeRequestRecv()
2074 STR_MASK(GetDeviceId())); in UnsubscribeRequestRecv()
[all …]
|
| H A D | single_ver_kv_syncer.cpp | 122 LOGI("[SingleVerKVSyncer] device online dev %s", STR_MASK(device)); in RemoteDataChanged()
270 … LOGE("[Syncer] get queryId=%s,dev=%s watermark failed", STR_MASK(queryId), STR_MASK(device)); in TriggerSubQuerySync()
277 queryWaterMark, STR_MASK(queryId), STR_MASK(device)); in TriggerSubQuerySync()
|
| H A D | single_ver_data_message_schedule.cpp | 97 expectedSequenceId_, finishedPacketId_, label_.c_str(), STR_MASK(deviceId_)); in ScheduleInfoHandle()
309 STR_MASK(deviceId_)); in UpdateMsgMapIfNeed()
327 packetId, cachePacketId, label_.c_str(), STR_MASK(deviceId_)); in UpdateMsgMapIfNeed()
336 packetId, label_.c_str(), STR_MASK(deviceId_)); in UpdateMsgMapIfNeed()
|
| H A D | single_ver_sync_state_machine.cpp | 232 dataSync_->GetLabel().c_str(), STR_MASK(context_->GetDeviceId())); in SyncStepInner()
259 STR_MASK(context_->GetDeviceId())); in AbortInner()
292 currentState_, STR_MASK(context_->GetDeviceId())); in PrepareNextSyncTask()
374 dataSync_->GetLabel().c_str(), STR_MASK(context_->GetDeviceId())); in DoInitiactiveDataSyncWithSlidingWindow()
435 dataSync_->GetLabel().c_str(), STR_MASK(context_->GetDeviceId())); in DoInitiactiveControlSync()
518 STR_MASK(context_->GetDeviceId())); in DoAbilitySync()
605 dataSync_->GetLabel().c_str(), STR_MASK(context_->GetDeviceId())); in AbilitySyncResponseRecv()
887 dataSync_->GetLabel().c_str(), STR_MASK(context_->GetDeviceId())); in TimeMarkSyncRecv()
936 dataSync_->GetLabel().c_str(), STR_MASK(context_->GetDeviceId())); in IsPacketValid()
943 dataSync_->GetLabel().c_str(), STR_MASK(context_->GetDeviceId())); in IsPacketValid()
[all …]
|
| H A D | single_ver_syncer.cpp | 23 LOGI("[SingleVerSyncer] device online dev %s", STR_MASK(device)); in RemoteDataChanged()
28 LOGI("[SingleVerSyncer] device offline dev %s", STR_MASK(device)); in RemoteDeviceOffline()
|
| H A D | single_ver_sync_task_context.cpp | 280 …ngleVerSyncTaskContext] killing syncId=%d,dev=%s", tmpOperation->GetSyncId(), STR_MASK(deviceId_)); in ClearAllSyncTask()
449 STR_MASK(GetDeviceId()), GetRemoteCompressAlgoStr().c_str(), in SetDbAbility()
583 STR_MASK(deviceId_), localWaterMark, maxTimestampInDb); in IsCurrentSyncTaskCanBeSkippedInner()
|
| H A D | single_ver_relational_syncer.cpp | 79 subSyncId, syncId, STR_MASK(DBCommon::TransferStringToHex(hashTableName))); in GenerateEachSyncTask()
|
| H A D | single_ver_data_sync_utils.cpp | 262 " secflag=%d", isPermitSync, STR_MASK(localDeviceId), remoteSecOption.securityLabel, in CheckPermitReceiveData()
502 STR_MASK(context->GetDeviceId())); in RunPermissionCheckInner()
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/multiver/ |
| H A D | multi_ver_sync_state_machine.cpp | 118 LOGD("[MultiVerSyncStateMachine][%s] step to idle", STR_MASK(context_->GetDeviceId())); in StepToIdle()
222 …LOGD("[MultiVerSyncStateMachine] SyncStep dst=%s, state = %d", STR_MASK(context_->GetDeviceId()), … in SyncStepInnerLocked()
432 LOGD("MultiVerSyncStateMachine::Finish merge src=%s", STR_MASK(context_->GetDeviceId())); in Finish()
439 STR_MASK(context_->GetDeviceId()), errCode); in Finish()
457 …LOGD("MultiVerSyncStateMachine::OneCommitSyncFinish src=%s, commitIndex = %d,", STR_MASK(context_… in OneCommitSyncFinish()
465 STR_MASK(context_->GetDeviceId()), entries.size()); in OneCommitSyncFinish()
478 STR_MASK(context_->GetDeviceId()), timefixOffset); in OneCommitSyncFinish()
487 STR_MASK(context_->GetDeviceId()), errCode); in OneCommitSyncFinish()
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/kv/ |
| H A D | kvdb_manager.cpp | 239 …LOGI("[%s]locked!", STR_MASK(DBCommon::TransferStringToHex(KvDBManager::GenerateKvDBIdentifier(kvD… in TryLockDB()
326 …LOGD("Begin to get [%s] database connection.", STR_MASK(DBCommon::TransferStringToHex(identifier))… in GetDatabaseConnection()
361 STR_MASK(DBCommon::TransferStringToHex(identifier)), errCode); in GetDatabaseConnection()
385 LOGI("[Connection] db[%s] conn Close", STR_MASK(DBCommon::TransferStringToHex(identifier))); in ReleaseDatabaseConnection()
811 STR_MASK(DBCommon::TransferStringToHex(identifier)), newType, oldType); in FindKvDBFromCache()
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/common/include/ |
| H A D | db_common.h | 163 #define STR_MASK(x) DBCommon::StringMasking(x).c_str() macro
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/relational/ |
| H A D | relational_store_instance.cpp | 197 …LOGD("Begin to get [%s] database connection.", STR_MASK(DBCommon::TransferStringToHex(identifier))… in GetDatabaseConnection()
|
| H A D | relational_sync_able_storage.cpp | 1222 LOGI("Get schema by tableName %s failed.", DBCommon::STR_MASK(tableName)); in ChkSchema()
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/communicator/src/ |
| H A D | db_status_adapter.cpp | 132 … LOGW("[DBStatusAdapter][NotifyDBInfos] no support dev %s", STR_MASK(devInfos.identifier)); in NotifyDBInfos()
|
| H A D | network_adapter.cpp | 51 …LOGI("[NAdapt][Start] Enter, ProcessLabel=%s.", STR_MASK(DBCommon::TransferStringToHex(processLabe… in StartAdapter()
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/interfaces/src/relational/ |
| H A D | relational_store_delegate_impl.cpp | 290 LOGD("begin to observer on changed, changedDevice=%s", STR_MASK(changedDevice)); in RegisterObserver()
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/common/src/ |
| H A D | auto_launch.cpp | 1464 LOGD("begin to observer onchange, changedDevice=%s", STR_MASK(changedDevice)); in AutoLaunchOnChange()
|