/foundation/distributeddatamgr/kv_store/interfaces/innerkits/distributeddata/include/ |
H A D | single_kvstore.h | 145 * @brief Sync store with other devices. 157 virtual Status Sync(const std::vector<std::string> &devices, SyncMode mode, uint32_t delay) = 0; 160 * @brief Sync store with other devices only syncing the data which is satisfied with the condition. 173 virtual Status Sync(const std::vector<std::string> &devices, SyncMode mode, const DataQuery &query, in Sync() function in OHOS::DistributedKv::SingleKvStore 176 return Sync(devices, mode, query, syncCallback, 0); in Sync() 180 * @brief Sync store with other devices only syncing the data which is satisfied with the condition. 194 virtual Status Sync(const std::vector<std::string> &devices, SyncMode mode, const DataQuery &query, in Sync() function in OHOS::DistributedKv::SingleKvStore 201 * @brief Sync store with other device, while delay is 0. 203 API_EXPORT inline Status Sync(const std::vector<std::string> &devices, SyncMode mode) in Sync() function in OHOS::DistributedKv::SingleKvStore 205 return Sync(device in Sync() 214 API_EXPORT inline Status Sync(const std::vector<std::string> &devices, SyncMode mode, const DataQuery &query) Sync() function in OHOS::DistributedKv::SingleKvStore [all...] |
/foundation/bundlemanager/bundle_framework/interfaces/kits/js/zip/napi/properties/ |
H A D | prop_n_exporter.cpp | 38 NapiValue::DeclareNapiFunction("createChecksumSync", CreateChecksum::Sync), in Export() 40 NapiValue::DeclareNapiFunction("createZipSync", CreateZip::Sync), in Export() 42 NapiValue::DeclareNapiFunction("createGZipSync", CreateGZip::Sync), in Export()
|
/foundation/filemanagement/file_api/interfaces/kits/js/src/mod_fileio/properties/ |
H A D | prop_n_exporter.cpp | 597 NVal::DeclareNapiFunction("chmodSync", Chmod::Sync), in ExportSync() 598 NVal::DeclareNapiFunction("chownSync", Chown::Sync), in ExportSync() 599 NVal::DeclareNapiFunction("closeSync", Close::Sync), in ExportSync() 600 NVal::DeclareNapiFunction("copyFileSync", CopyFile::Sync), in ExportSync() 601 NVal::DeclareNapiFunction("createStreamSync", CreateStream::Sync), in ExportSync() 602 NVal::DeclareNapiFunction("fchmodSync", Fchmod::Sync), in ExportSync() 603 NVal::DeclareNapiFunction("fchownSync", Fchown::Sync), in ExportSync() 604 NVal::DeclareNapiFunction("fdatasyncSync", Fdatasync::Sync), in ExportSync() 605 NVal::DeclareNapiFunction("fdopenStreamSync", FdopenStream::Sync), in ExportSync() 606 NVal::DeclareNapiFunction("fstatSync", Fstat::Sync), in ExportSync() [all...] |
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/ |
H A D | generic_virtual_device.h | 45 virtual int Sync(const DeviceSyncOption &option, const DeviceSyncProcessCallback &onProcess); 46 virtual int Sync(SyncMode mode, bool wait); 47 virtual int Sync(SyncMode mode, const Query &query, bool wait); 48 virtual int Sync(SyncMode mode, const Query &query, const SyncOperation::UserCallback &callBack, bool wait);
|
H A D | distributeddb_single_ver_p2p_sync_check_test.cpp | 173 * @tc.name: sec option check Sync 001 221 * @tc.name: sec option check Sync 002 274 * @tc.name: sec option check Sync 003 315 * @tc.name: sec option check Sync 004 361 * @tc.name: sec option check Sync 005 396 * @tc.name: sec option check Sync 006 442 * @tc.name: sec option check Sync 007 626 int status = g_deviceB->Sync(option, onProcess); in HWTEST_F() 683 int status = g_deviceB->Sync(option, onProcess); in HWTEST_F() 984 ASSERT_TRUE(g_kvDelegatePtr->Sync(optio in HWTEST_F() 1137 void Sync(KvStoreNbDelegate *kvDelegatePtr, vector<std::string> &devices, const DBStatus &targetStatus) Sync() function 1147 void Sync(vector<std::string> &devices, const DBStatus &targetStatus) Sync() function [all...] |
H A D | generic_virtual_device.cpp | 237 int GenericVirtualDevice::Sync(const DeviceSyncOption &option, const DeviceSyncProcessCallback &onProcess) in Sync() function in DistributedDB::GenericVirtualDevice 265 int GenericVirtualDevice::Sync(SyncMode mode, bool wait) in Sync() function in DistributedDB::GenericVirtualDevice 281 int GenericVirtualDevice::Sync(SyncMode mode, const Query &query, bool wait) in Sync() function in DistributedDB::GenericVirtualDevice 283 return Sync(mode, query, nullptr, wait); in Sync() 286 int GenericVirtualDevice::Sync(SyncMode mode, const Query &query, in Sync() function in DistributedDB::GenericVirtualDevice
|
/foundation/ability/ability_runtime/test/unittest/task_handler_wrap_test/ |
H A D | task_handler_wrap_test.cpp | 63 taskHandle.Sync(); in HWTEST_F() 79 taskHandle.Sync(); in HWTEST_F() 122 taskHandle.Sync(); in HWTEST_F() 138 taskHandle.Sync(); in HWTEST_F() 154 taskHandle.Sync(); in HWTEST_F()
|
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/storage/cloud/ |
H A D | distributeddb_cloud_task_merge_test.cpp | 276 ASSERT_EQ(delegate_->Sync(option, nullptr), OK); in HWTEST_F() 296 ASSERT_EQ(delegate_->Sync(option, callback1), OK); in HWTEST_F() 303 ASSERT_EQ(delegate_->Sync(option, nullptr), OK); in HWTEST_F() 307 ASSERT_EQ(delegate_->Sync(option, nullptr), OK); in HWTEST_F() 339 ASSERT_EQ(delegate_->Sync(option, nullptr), OK); in HWTEST_F() 343 ASSERT_EQ(delegate_->Sync(option, nullptr), OK); in HWTEST_F() 357 ASSERT_EQ(delegate_->Sync(option, callback3), OK); in HWTEST_F() 372 ASSERT_EQ(delegate_->Sync(option, callback4), OK); in HWTEST_F() 387 ASSERT_EQ(delegate_->Sync(option, callback5), OK); in HWTEST_F() 421 ASSERT_EQ(delegate_->Sync(optio in HWTEST_F() [all...] |
/foundation/graphic/graphic_2d/rosen/modules/render_service/core/pipeline/ |
H A D | rs_draw_frame.cpp | 60 Sync();
in RenderFrame() 154 void RSDrawFrame::Sync()
in Sync() function in OHOS::Rosen::RSDrawFrame 156 RS_TRACE_NAME_FMT("Sync");
in Sync() 157 RSMainThread::Instance()->GetContext().GetGlobalRootRenderNode()->Sync();
in Sync() 163 node->Sync();
in Sync() 171 unirenderInstance_.Sync(std::move(stagingRenderThreadParams_));
in Sync()
|
/foundation/ability/ability_runtime/services/common/include/ |
H A D | task_handler_wrap.h | 44 void Sync() const; 108 Sync(); in ~AutoSyncTaskHandle() 114 void Sync() in Sync() function in OHOS::AAFwk::AutoSyncTaskHandle 119 handle.Sync(); in Sync()
|
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/interfaces/src/relational/ |
H A D | relational_store_delegate_impl.h | 32 DBStatus Sync(const std::vector<std::string> &devices, SyncMode mode, 53 DBStatus Sync(const std::vector<std::string> &devices, SyncMode mode, const Query &query, 68 DBStatus Sync(const CloudSyncOption &option, const SyncProcessCallback &onProcess) override; 85 DBStatus Sync(const CloudSyncOption &option, const SyncProcessCallback &onProcess, uint64_t taskId) override;
|
/foundation/filemanagement/file_api/interfaces/kits/js/src/mod_fs/properties/ |
H A D | prop_n_exporter.cpp | 782 NVal::DeclareNapiFunction("closeSync", Close::Sync),
in ExportSync() 783 NVal::DeclareNapiFunction("fdatasyncSync", Fdatasync::Sync),
in ExportSync() 784 NVal::DeclareNapiFunction("fsyncSync", Fsync::Sync),
in ExportSync() 785 NVal::DeclareNapiFunction("lstatSync", Lstat::Sync),
in ExportSync() 787 NVal::DeclareNapiFunction("mkdtempSync", Mkdtemp::Sync),
in ExportSync() 788 NVal::DeclareNapiFunction("openSync", Open::Sync),
in ExportSync() 790 NVal::DeclareNapiFunction("renameSync", Rename::Sync),
in ExportSync() 791 NVal::DeclareNapiFunction("rmdirSync", Rmdirent::Sync),
in ExportSync() 792 NVal::DeclareNapiFunction("statSync", Stat::Sync),
in ExportSync() 793 NVal::DeclareNapiFunction("truncateSync", Truncate::Sync),
in ExportSync() [all...] |
H A D | utimes.h | 27 static napi_value Sync(napi_env env, napi_callback_info info);
|
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/interfaces/include/relational/ |
H A D | relational_store_delegate.h | 50 DB_API virtual DBStatus Sync(const std::vector<std::string> &devices, SyncMode mode, 69 DB_API virtual DBStatus Sync(const std::vector<std::string> &devices, SyncMode mode, 86 DB_API virtual DBStatus Sync(const CloudSyncOption &option, const SyncProcessCallback &onProcess) = 0; 104 DB_API virtual DBStatus Sync([[gnu::unused]] const CloudSyncOption &option, in Sync() function in DistributedDB::RelationalStoreDelegate
|
/foundation/communication/netstack/interfaces/innerkits/rust/ylong_http_client/src/reqwest_impl/ |
H A D | error.rs | 22 cause: Option<Box<dyn Error + Send + Sync>>, 51 pub fn other<T: Into<Box<dyn Error + Send + Sync>>>(cause: Option<T>) -> Self { in other() 78 T: Into<Box<dyn Error + Send + Sync>>,
|
/foundation/deviceprofile/device_info_manager/services/core/test/unittest/ |
H A D | kv_adapter_test.cpp | 332 * @tc.desc: Sync failed, kvStorePtr is nullptr. 340 EXPECT_EQ(DP_KV_DB_PTR_NULL, kvStore->Sync(deviceList, SyncMode::PUSH)); in HWTEST_F() 345 * @tc.desc: Sync failed, deviceList is invalid. 352 EXPECT_EQ(DP_INVALID_PARAMS, kvStore->Sync(deviceList, SyncMode::PUSH)); in HWTEST_F() 357 EXPECT_EQ(DP_INVALID_PARAMS, kvStore->Sync(deviceList, SyncMode::PUSH)); in HWTEST_F() 371 kvStore->Sync(deviceList, mode); in HWTEST_F() 374 EXPECT_EQ(DP_INVALID_PARAMS, kvStore->Sync(deviceList, mode)); in HWTEST_F() 377 EXPECT_EQ(DP_INVALID_PARAMS, kvStore->Sync(deviceList, mode)); in HWTEST_F()
|
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/interfaces/ |
H A D | distributeddb_interfaces_relational_sync_test.cpp | 227 int errCode = delegate->Sync(devices, SyncMode::SYNC_MODE_PUSH_ONLY, query, in HWTEST_F() 246 int errCode = delegate->Sync(devices, SyncMode::SYNC_MODE_PUSH_ONLY, query, in HWTEST_F() 265 int errCode = delegate->Sync(devices, SyncMode::SYNC_MODE_PUSH_ONLY, query, in HWTEST_F() 284 int errCode = delegate->Sync(devices, SyncMode::SYNC_MODE_PUSH_ONLY, query, in HWTEST_F() 306 int errCode = delegate->Sync(devices, SyncMode::SYNC_MODE_PUSH_ONLY, query, in HWTEST_F() 325 int errCode = delegate->Sync(devices, SyncMode::SYNC_MODE_PUSH_ONLY, query, in HWTEST_F() 350 int errCode = delegate->Sync(devices, SyncMode::SYNC_MODE_PUSH_ONLY, query, in HWTEST_F() 380 int errCode = delegate->Sync(devices, SyncMode::SYNC_MODE_PUSH_ONLY, query, in HWTEST_F() 407 errCode = delegate->Sync(devices, SyncMode::SYNC_MODE_PUSH_ONLY, query, in HWTEST_F() 432 status = delegate->Sync(device in HWTEST_F() [all...] |
/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/test/mock/ |
H A D | kv_store_nb_delegate_mock.h | 61 DBStatus Sync(const std::vector<std::string> &devices, SyncMode mode, 77 DBStatus Sync(const std::vector<std::string> &devices, SyncMode mode, 95 DBStatus Sync(const CloudSyncOption &option, const SyncProcessCallback &onProcess); 107 DBStatus Sync(const DeviceSyncOption &option, const DeviceSyncProcessCallback &onProcess);
|
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/ |
H A D | syncer_proxy.cpp | 57 int SyncerProxy::Sync(const std::vector<std::string> &devices, int mode, in Sync() function in DistributedDB::SyncerProxy 64 return syncer_->Sync(devices, mode, onComplete, onFinalize, wait); in Sync() 67 int SyncerProxy::Sync(const SyncParma &parma, uint64_t connectionId) in Sync() function in DistributedDB::SyncerProxy 72 return syncer_->Sync(parma, connectionId); in Sync()
|
H A D | generic_syncer.h | 43 // Sync function. 45 // param mode: Sync mode, see SyncMode. 47 // param onFinalize: will be callback when this Sync Operation finalized. 48 // return a Sync id. It will return a positive value if failed, 49 int Sync(const std::vector<std::string> &devices, int mode, 53 // Sync function. use SyncParma to reduce parameter. 54 int Sync(const SyncParma ¶m); 56 int Sync(const SyncParma ¶m, uint64_t connectionId) override; 87 // Set Manual Sync retry config 94 int Sync(cons [all...] |
/foundation/distributeddatamgr/kv_store/test/distributedtest/single_kvstore_client/ |
H A D | distributed_test_agent.cpp | 49 int Sync(const std::string &args);
134 commandFunctionMap_["sync"] = &DistributedTestAgent::Sync;
in SetUp() 198 int DistributedTestAgent::Sync(const std::string &args)
in Sync() function in OHOS::Test::DistributedTestAgent 202 auto status = singleKvStore_->Sync(devices, syncMode);
in Sync()
|
/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/framework/test/ |
H A D | meta_data_manager_test.cpp | 84 auto result = MetaDataManager::GetInstance().Sync(devices, complete);
in HWTEST_F() 100 auto result = MetaDataManager::GetInstance().Sync(devices, complete);
in HWTEST_F()
|
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/multiver/ |
H A D | multi_ver_syncer.cpp | 55 int errCode = Sync(devices, SyncModeType::AUTO_PULL, nullptr, nullptr, false); in EnableAutoSync() 91 int errCode = Sync(devices, SyncModeType::AUTO_PULL, nullptr, nullptr, false); in RemoteDataChanged()
|
/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/udmf/store/ |
H A D | store.h | 40 virtual Status Sync(const std::vector<std::string> &devices) = 0;
41 virtual Status Sync(const std::vector<std::string> &devices, ProcessCallback callback) = 0;
|
/foundation/distributeddatamgr/relational_store/test/native/rdb/unittest/ |
H A D | rdb_distributed_test.cpp | 240 * @tc.desc: Normal testCase of Sync 251 errCode = rdbStore->Sync(option, predicate, OHOS::DistributedRdb::AsyncBrief()); in HWTEST_F() 254 errCode = rdbStore->Sync(option, tables, OHOS::DistributedRdb::AsyncDetail()); in HWTEST_F() 257 errCode = rdbStore->Sync(option, predicate, OHOS::DistributedRdb::AsyncDetail()); in HWTEST_F() 267 errCode = store->Sync(option, predicate, OHOS::DistributedRdb::AsyncBrief()); in HWTEST_F() 269 errCode = store->Sync(option, tables, nullptr); in HWTEST_F()
|