| /foundation/distributeddatamgr/udmf/framework/innerkitsimpl/client/ |
| H A D | async_obtain_data.cpp | 54 processInfo_.syncStatus = ASYNC_RUNNING; in InitTask()
78 if ((taskStatus_ == ASYNC_RUNNING) && (processInfo_.syncStatus == ASYNC_RUNNING)) { in ObtainDataTask()
123 ((processInfo.syncStatus == ASYNC_RUNNING) || (processInfo.permStatus == ASYNC_RUNNING))) { in ProgressTask()
150 processInfo_.syncStatus = info.syncStatus; in UpdateProcessInfo()
152 processInfo_.srcDevName = (info.syncStatus == ASYNC_IDLE ? "Local" : info.srcDevName); in UpdateProcessInfo()
159 if (processInfo_.syncStatus == ASYNC_FAILURE || processInfo_.permStatus == ASYNC_FAILURE) { in UpdateProcessInfo()
189 if ((taskStatus_ == ASYNC_FAILURE) || (processInfo_.syncStatus == ASYNC_FAILURE) || in CalProgress()
202 if (processInfo_.syncStatus == ASYNC_SUCCESS || processInfo_.syncStatus in CalSyncProgress()
[all...] |
| /foundation/resourceschedule/resource_schedule_service/ressched/sched_controller/observer/src/ |
| H A D | mmi_observer.cpp | 29 void MmiObserver::SyncBundleName(int32_t pid, int32_t uid, std::string bundleName, int32_t syncStatus)
in SyncBundleName() argument
37 pid, uid, bundleName.c_str(), syncStatus);
in SyncBundleName()
42 payload["syncStatus"] = std::to_string(syncStatus);
in SyncBundleName()
|
| /foundation/distributeddatamgr/udmf/framework/common/ |
| H A D | udmf_types_util.cpp | 203 uint32_t syncStatus = input.syncStatus; in Marshalling() local
205 return ITypesUtil::Marshal(parcel, syncStatus, permStatus, input.srcDevName, input.syncFinished, input.syncTotal, in Marshalling()
212 uint32_t syncStatus; in Unmarshalling() local
214 if (!ITypesUtil::Unmarshal(parcel, syncStatus, permStatus, output.srcDevName, output.syncFinished, output.syncTotal, in Unmarshalling()
220 if (syncStatus > ASYNC_FAILURE || permStatus > ASYNC_FAILURE) { in Unmarshalling()
224 output.syncStatus = static_cast<AsyncTaskStatus>(syncStatus); in Unmarshalling()
|
| /foundation/multimedia/media_library/frameworks/services/media_distributed/include/database_manage/ |
| H A D | medialibrary_device_operations.h | 51 const std::string &tableName, int32_t syncStatus);
53 const std::string &tableName, int32_t &syncStatus);
|
| /foundation/deviceprofile/device_info_manager/services/core/src/deviceprofilemanager/listener/ |
| H A D | kv_sync_completed_listener.cpp | 67 SyncStatus syncStatus = (status == DistributedKv::Status::SUCCESS) ? SyncStatus::SUCCEEDED : SyncStatus::FAILED; in SyncCompleted() local
68 syncResults.emplace(deviceId, syncStatus); in SyncCompleted()
|
| /foundation/multimedia/media_library/frameworks/services/media_distributed/src/database_manage/ |
| H A D | medialibrary_device_operations.cpp | 130 const std::string &tableName, const std::string &udid, int32_t syncStatus) in UpdateSyncStatus()
146 valuesBucket.PutInt(TABLE_SYNC_STATUS_MAP.at(tableName), syncStatus); in UpdateSyncStatus()
156 const std::string &udid, const std::string &table, int32_t &syncStatus) in GetSyncStatusById()
171 queryResultSet->GetInt(columnIndexId, syncStatus); in GetSyncStatusById()
176 queryResultSet->GetInt(columnIndexId, syncStatus); in GetSyncStatusById()
177 if (syncStatus == DEVICE_SYNCSTATUSING) { in GetSyncStatusById()
183 MEDIA_INFO_LOG("MediaLibraryDeviceOperations::GetSyncStatusById syncStatus = %{public}d", syncStatus); in GetSyncStatusById()
129 UpdateSyncStatus(const std::shared_ptr<NativeRdb::RdbStore> &rdbStore, const std::string &tableName, const std::string &udid, int32_t syncStatus) UpdateSyncStatus() argument
155 GetSyncStatusById(const std::shared_ptr<NativeRdb::RdbStore> &rdbStore, const std::string &udid, const std::string &table, int32_t &syncStatus) GetSyncStatusById() argument
|
| H A D | medialibrary_sync_operation.cpp | 129 static int32_t UpdateDeviceSyncStatus(const shared_ptr<RdbStore> &rdbStore, const string &networkId, int32_t syncStatus) in UpdateDeviceSyncStatus() argument
152 valuesBucket.PutInt(DEVICE_DB_SYNC_STATUS, syncStatus); in UpdateDeviceSyncStatus()
|
| /foundation/multimodalinput/input/interfaces/native/innerkits/event/include/ |
| H A D | mmi_event_observer.h | 31 virtual void SyncBundleName(int32_t pid, int32_t uid, std::string bundleName, int32_t syncStatus) = 0;
|
| /foundation/resourceschedule/resource_schedule_service/ressched/sched_controller/observer/include/ |
| H A D | mmi_observer.h | 33 * @param syncStatus the sync status.
35 void SyncBundleName(int32_t pid, int32_t uid, std::string bundleName, int32_t syncStatus) override;
|
| /foundation/distributeddatamgr/kv_store/frameworks/innerkitsimpl/distributeddatafwk/test/unittest/ |
| H A D | device_kvstore_test.cpp | 450 auto syncStatus = kvStore_->RegisterSyncCallback(syncCallback); in HWTEST_F() local
451 EXPECT_EQ(syncStatus, Status::SUCCESS) << "Register sync callback failed."; in HWTEST_F()
503 auto syncStatus = kvStore_->Sync(deviceIds, SyncMode::PUSH); in HWTEST_F() local
504 EXPECT_NE(syncStatus, Status::SUCCESS) << "Sync device should not return success"; in HWTEST_F()
554 auto syncStatus = kvStore_->Sync(deviceIds, SyncMode::PUSH, allowedDelayMs); in HWTEST_F() local
555 EXPECT_EQ(syncStatus, Status::SUCCESS) << "sync device should return success"; in HWTEST_F()
1241 auto syncStatus = kvStore_->Sync(deviceIds, SyncMode::PUSH, dataQuery, nullptr); in HWTEST_F() local
1242 EXPECT_NE(syncStatus, Status::SUCCESS) << "sync device should not return success"; in HWTEST_F()
1259 auto syncStatus = kvStore_->Sync(deviceIds, SyncMode::PUSH, dataQuery, nullptr, delay); in HWTEST_F() local
1260 EXPECT_NE(syncStatus, Statu in HWTEST_F()
1276 auto syncStatus = kvStore_->SubscribeWithQuery(deviceIds, dataQuery); HWTEST_F() local
[all...] |
| H A D | single_kvstore_client_test.cpp | 338 auto syncStatus = singleKvStore->RegisterSyncCallback(syncCallback); in HWTEST_F() local
339 EXPECT_EQ(syncStatus, Status::SUCCESS) << "register sync callback failed."; in HWTEST_F()
391 auto syncStatus = singleKvStore->Sync(deviceIds, SyncMode::PUSH); in HWTEST_F() local
392 EXPECT_NE(syncStatus, Status::SUCCESS) << "sync device should not return success"; in HWTEST_F()
443 auto syncStatus = singleKvStore->Sync(deviceIds, SyncMode::PUSH, allowedDelayMs); in HWTEST_F() local
444 EXPECT_EQ(syncStatus, Status::SUCCESS) << "sync device should return success"; in HWTEST_F()
1160 auto syncStatus = singleKvStore->Sync(deviceIds, SyncMode::PUSH, dataQuery, nullptr); in HWTEST_F() local
1161 EXPECT_NE(syncStatus, Status::SUCCESS) << "sync device should not return success"; in HWTEST_F()
1177 auto syncStatus = singleKvStore->SubscribeWithQuery(deviceIds, dataQuery); in HWTEST_F() local
1178 EXPECT_NE(syncStatus, Statu in HWTEST_F()
[all...] |
| /foundation/multimedia/media_library/frameworks/services/media_distributed/include/device_manage/ |
| H A D | medialibrary_device.h | 63 bool UpdateDeviceSyncStatus(const std::string &networkId, const std::string &tableName, int32_t syncStatus);
64 bool GetDeviceSyncStatus(const std::string &networkId, const std::string &tableName, int32_t &syncStatus);
|
| /foundation/distributeddatamgr/udmf/interfaces/innerkits/common/ |
| H A D | unified_types.h | 92 AsyncTaskStatus syncStatus; member
|
| /foundation/multimedia/media_library/frameworks/innerkitsimpl/test/unittest/medialibrary_device_test/src/ |
| H A D | medialibrary_device_test.cpp | 97 int32_t syncStatus = 1; in HWTEST_F() local
99 bool ret = deviceTest->UpdateDeviceSyncStatus(networkIdTest, MEDIALIBRARY_TABLE, syncStatus); in HWTEST_F()
104 ret = deviceTest->UpdateDeviceSyncStatus(networkIdTest, MEDIALIBRARY_TABLE, syncStatus); in HWTEST_F()
|
| /foundation/multimedia/media_library/frameworks/services/media_distributed/src/device_manage/ |
| H A D | medialibrary_device.cpp | 337 const string &tableName, int32_t syncStatus) in UpdateDeviceSyncStatus()
349 return MediaLibraryDeviceOperations::UpdateSyncStatus(rdbStore_, udid, tableName, syncStatus); in UpdateDeviceSyncStatus()
353 int32_t &syncStatus) in GetDeviceSyncStatus()
365 return MediaLibraryDeviceOperations::GetSyncStatusById(rdbStore_, udid, tableName, syncStatus); in GetDeviceSyncStatus()
336 UpdateDeviceSyncStatus(const std::string &networkId, const string &tableName, int32_t syncStatus) UpdateDeviceSyncStatus() argument
352 GetDeviceSyncStatus(const std::string &networkId, const std::string &tableName, int32_t &syncStatus) GetDeviceSyncStatus() argument
|
| /foundation/multimodalinput/input/frameworks/proxy/event_handler/src/ |
| H A D | client_msg_handler.cpp | 162 int32_t syncStatus = 0; in NotifyBundleName() local
164 pkt >> pid >> uid >> bundleName >> syncStatus; in NotifyBundleName() local
165 InputMgrImpl.NotifyBundleName(pid, uid, bundleName, syncStatus); in NotifyBundleName()
166 MMI_HILOGD("NotifyBundleName pid:%{public}d, uid:%{public}d, bundleName:%{public}s, syncStatus:%{public}d", in NotifyBundleName()
167 pid, uid, bundleName.c_str(), syncStatus); in NotifyBundleName()
|
| /foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/udmf/ |
| H A D | udmf_service_impl.cpp | 545 asyncProcessInfo_.syncStatus = syncInfo.syncStatus; in Sync()
549 if (asyncProcessInfo_.syncStatus != ASYNC_RUNNING) { in Sync()
553 syncInfo.srcDevName.c_str(), syncInfo.syncId, syncInfo.syncStatus, in Sync()
738 if (syncingData_ && processInfo.syncStatus != ASYNC_RUNNING) { in ObtainAsynProcess()
739 processInfo.syncStatus = ASYNC_RUNNING; in ObtainAsynProcess()
|
| /foundation/multimedia/media_lite/services/player_lite/impl/player_control/sink/ |
| H A D | player_sink_manager.cpp | 398 streamInfo.avStatus.syncStatus.lastAudPts = AV_INVALID_PTS; in GetStatus()
399 streamInfo.avStatus.syncStatus.lastVidPts = AV_INVALID_PTS; in GetStatus()
401 sync_->GetStatus(streamInfo.avStatus.syncStatus); in GetStatus()
|
| /foundation/multimedia/media_lite/services/player_lite/impl/player_control/include/ |
| H A D | player_define.h | 151 PlaySyncStatus syncStatus; member
|
| /foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/udmf/store/ |
| H A D | runtime_store.cpp | 344 processInfo.syncStatus = ASYNC_RUNNING;
in NotifySyncProcss()
348 processInfo.syncStatus = ASYNC_SUCCESS;
in NotifySyncProcss()
352 processInfo.syncStatus = ASYNC_FAILURE;
in NotifySyncProcss()
|
| /foundation/resourceschedule/resource_schedule_service/ressched/sched_controller/test/fuzztest/resschedobserver_fuzzer/ |
| H A D | resschedobserver_fuzzer.cpp | 402 int32_t syncStatus = GetData<int32_t>(); in MmiObserverSyncBundleNameFuzzTest() local
406 mmiObserver->SyncBundleName(pid, uid, bundleName, syncStatus); in MmiObserverSyncBundleNameFuzzTest()
|
| /foundation/multimedia/media_lite/services/player_lite/impl/player_control/player/ |
| H A D | liteplayer.cpp | 1520 streamInfo.avStatus.syncStatus.lastAudPts = AV_INVALID_PTS; in GetStreamInfo()
1521 streamInfo.avStatus.syncStatus.lastVidPts = AV_INVALID_PTS; in GetStreamInfo()
1559 lastVidRendPts = streamInfo.avStatus.syncStatus.lastVidPts; in IsRepeatTplayReq()
1664 lastRendPts = streamInfo.avStatus.syncStatus.lastAudPts; in UpdateProgressNotify()
1675 lastRendPts = streamInfo.avStatus.syncStatus.lastVidPts; in UpdateProgressNotify()
|
| /foundation/multimodalinput/input/frameworks/proxy/event_handler/include/ |
| H A D | input_manager_impl.h | 82 void NotifyBundleName(int32_t pid, int32_t uid, const std::string &bundleName, int32_t syncStatus);
|
| /foundation/multimedia/media_library/frameworks/innerkitsimpl/medialibrary_data_extension/src/ |
| H A D | medialibrary_data_manager.cpp | 1789 int32_t syncStatus = DEVICE_SYNCSTATUSING; in QuerySync() local
1790 auto result = MediaLibraryDevice::GetInstance()->GetDeviceSyncStatus(networkId, tableName, syncStatus); in QuerySync()
1791 if (result && syncStatus == DEVICE_SYNCSTATUS_COMPLETE) { in QuerySync()
|
| /foundation/multimedia/media_library/frameworks/services/media_thumbnail/src/ |
| H A D | thumbnail_utils.cpp | 1848 auto syncStatus = MediaLibrarySyncOperation::SyncPullKvstore(kvStore, keys, networkId); in IsImageExist() local
1849 if (syncStatus == DistributedKv::Status::SUCCESS) { in IsImageExist()
1853 MEDIA_ERR_LOG("SyncPullKvstore failed! ret %{public}d", syncStatus); in IsImageExist()
|