/foundation/distributeddatamgr/preferences/test/js/unittest/storage/src/ |
H A D | StorageHelperJsunit.test.js | 17 import storage from '@ohos.data.storage' 19 const PATH = "/data/storage/el2/database/test_storage"; 29 mPref = storage.getStorageSync(PATH); 34 storage.deleteStorageSync(PATH); 58 const promise = storage.getStorage(PATH); 74 let perf = storage.getStorageSync('/data/storage/el2/database/test_storage1'); 78 storage.removeStorageFromCacheSync('/data/storage/el [all...] |
H A D | StoragePromiseJsunit.test.js | 16 import storage from '@ohos.data.storage' 18 const PATH = "/data/storage/el2/database/test_storage"; 33 mPref = storage.getStorageSync(PATH); 38 storage.deleteStorageSync(PATH); 221 storage.removeStorageFromCacheSync(PATH); 223 mPref = storage.getStorageSync(PATH); 240 storage.removeStorageFromCacheSync(PATH); 242 mPref = storage.getStorageSync(PATH); 259 storage [all...] |
H A D | StorageCallBackJsunit.test.js | 16 import storage from '@ohos.data.storage' 18 const PATH = "/data/storage/el2/database/test_storage"; 33 mPref = storage.getStorageSync(PATH); 38 storage.deleteStorageSync(PATH); 199 storage.removeStorageFromCacheSync(PATH); 201 mPref = storage.getStorageSync(PATH); 216 storage.removeStorageFromCache(PATH); 218 mPref = storage.getStorageSync(PATH); 233 storage [all...] |
H A D | StorageSyncJsunit.test.js | 16 import storage from '@ohos.data.storage' 18 const PATH = "/data/storage/el2/database/test_storage"; 34 mPref = await storage.getStorageSync(PATH); 39 await storage.deleteStorageSync(PATH); 191 storage.removeStorageFromCacheSync(PATH); 193 mPref = storage.getStorageSync(PATH); 206 storage.removeStorageFromCacheSync(PATH); 208 mPref = storage.getStorageSync(PATH); 221 storage [all...] |
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/singlever/ |
H A D | single_ver_syncer.cpp | 35 ISyncInterface *storage = syncInterface_; in RemoteDeviceOffline() local 36 storage->IncRefCount(); in RemoteDeviceOffline() 37 int errCode = RuntimeContext::GetInstance()->ScheduleTask([engine, device, storage]() { in RemoteDeviceOffline() 38 static_cast<SingleVerSyncEngine *>(engine)->OfflineHandleByDevice(device, storage); in RemoteDeviceOffline() 40 storage->DecRefCount(); in RemoteDeviceOffline() 45 storage->DecRefCount(); in RemoteDeviceOffline() 58 ISyncInterface *storage = nullptr; in EraseDeviceWaterMark() local 65 storage = syncInterface_; in EraseDeviceWaterMark() 66 storage->IncRefCount(); in EraseDeviceWaterMark() 69 storage in EraseDeviceWaterMark() [all...] |
H A D | single_ver_data_sync_utils.cpp | 24 void FillPermissionCheckParam(const SyncGenericInterface* storage, int mode, PermissionCheckParam ¶m, uint8_t &flag) in FillPermissionCheckParam() argument 26 param.appId = storage->GetDbProperties().GetStringProp(DBProperties::APP_ID, ""); in FillPermissionCheckParam() 27 param.userId = storage->GetDbProperties().GetStringProp(DBProperties::USER_ID, ""); in FillPermissionCheckParam() 28 param.storeId = storage->GetDbProperties().GetStringProp(DBProperties::STORE_ID, ""); in FillPermissionCheckParam() 29 param.instanceId = storage->GetDbProperties().GetIntProp(DBProperties::INSTANCE_ID, 0); in FillPermissionCheckParam() 93 int SingleVerDataSyncUtils::RequestQueryCheck(const DataRequestPacket *packet, SyncGenericInterface *storage) in RequestQueryCheck() argument 95 if (storage == nullptr || packet == nullptr) { in RequestQueryCheck() 102 int errCode = storage->CheckAndInitQueryCondition(syncQuery); in RequestQueryCheck() 117 const SecurityOption &remoteSecOption, SyncGenericInterface *storage) in IsPermitRemoteDeviceRecvData() 119 if (storage in IsPermitRemoteDeviceRecvData() 116 IsPermitRemoteDeviceRecvData(const std::string &deviceId, const SecurityOption &remoteSecOption, SyncGenericInterface *storage) IsPermitRemoteDeviceRecvData() argument 200 RunPermissionCheck(SingleVerSyncTaskContext *context, const SyncGenericInterface* storage, const std::string &label, const DataRequestPacket *packet) RunPermissionCheck() argument 207 RunPermissionCheck(SingleVerSyncTaskContext *context, const SyncGenericInterface* storage, const std::string &label, int mode) RunPermissionCheck() argument 213 CheckPermitReceiveData(const SingleVerSyncTaskContext *context, const ICommunicator *communicator, const SyncGenericInterface *storage) CheckPermitReceiveData() argument 489 RunPermissionCheckInner(const SingleVerSyncTaskContext *context, const SyncGenericInterface* storage, const std::string &label, const DataRequestPacket *packet, int mode) RunPermissionCheckInner() argument 522 RecordClientId(const SingleVerSyncTaskContext &context, const SyncGenericInterface &storage, std::shared_ptr<Metadata> &metadata) RecordClientId() argument 539 SetDataRequestCommonInfo(const SingleVerSyncTaskContext &context, const SyncGenericInterface &storage, DataRequestPacket &packet, std::shared_ptr<Metadata> &metadata) SetDataRequestCommonInfo() argument 580 GetUnsyncTotal(const SingleVerSyncTaskContext *context, const SyncGenericInterface *storage, uint32_t &total) GetUnsyncTotal() argument 594 GetUnsyncTotal(const SingleVerSyncTaskContext *context, const SyncGenericInterface *storage, SyncTimeRange &waterMarkInfo, uint32_t &total) GetUnsyncTotal() argument [all...] |
H A D | single_ver_data_sync_utils.h | 29 static int RequestQueryCheck(const DataRequestPacket *packet, SyncGenericInterface *storage); 34 SyncGenericInterface *storage); 46 static int RunPermissionCheck(SingleVerSyncTaskContext *context, const SyncGenericInterface* storage, 49 static int RunPermissionCheck(SingleVerSyncTaskContext *context, const SyncGenericInterface* storage, 53 const SyncGenericInterface *storage); 98 static void RecordClientId(const SingleVerSyncTaskContext &context, const SyncGenericInterface &storage, 102 const SyncGenericInterface &storage, DataRequestPacket &packet, std::shared_ptr<Metadata> &metadata); 107 static int GetUnsyncTotal(const SingleVerSyncTaskContext *context, const SyncGenericInterface *storage, 109 static int GetUnsyncTotal(const SingleVerSyncTaskContext *context, const SyncGenericInterface *storage, 118 static int RunPermissionCheckInner(const SingleVerSyncTaskContext *context, const SyncGenericInterface* storage, [all...] |
H A D | single_ver_kv_syncer.cpp | 94 ISyncInterface *storage = syncInterface_; in LocalDataChanged() local 96 storage->IncRefCount(); in LocalDataChanged() 100 int errCode = RuntimeContext::GetInstance()->ScheduleTask([this, devices, engine, storage] { in LocalDataChanged() 106 storage->DecRefCount(); in LocalDataChanged() 115 storage->DecRefCount(); in LocalDataChanged() 170 ISyncInterface *storage) const in SyncConditionCheck() 176 int errCode = static_cast<SingleVerKvDBSyncInterface *>(storage)->CheckAndInitQueryCondition(query); in SyncConditionCheck() 317 auto storage = static_cast<SyncGenericInterface *>(syncInterface); in TriggerAddSubscribeAsync() local 318 storage->GetDBInfo(dbInfo); in TriggerAddSubscribeAsync() 325 storage in TriggerAddSubscribeAsync() [all...] |
/foundation/multimedia/media_library/frameworks/services/media_mtp/src/ |
H A D | mtp_storage_manager.cpp | 82 void MtpStorageManager::AddStorage(shared_ptr<Storage> &storage) in AddStorage() argument 84 storages.push_back(storage); in AddStorage() 87 void MtpStorageManager::RemoveStorage(std::shared_ptr<Storage> &storage) in RemoveStorage() argument 89 auto iter = std::find(storages.begin(), storages.end(), storage); in RemoveStorage() 97 for (auto storage : storages) { in GetStorage() 98 if (storage->GetStorageID() == id) { in GetStorage() 99 return storage; in GetStorage()
|
/foundation/arkui/ace_engine/interfaces/native/node/ |
H A D | native_node_extented.cpp | 526 ArkUI_StyledString* storage = new ArkUI_StyledString; in OH_ArkUI_StyledString_Create() local 527 storage->builder = OH_Drawing_CreateTypographyHandler(typoStyle, collection); in OH_ArkUI_StyledString_Create() 529 storage->paragraphStyle = typographyStyle; in OH_ArkUI_StyledString_Create() 530 return storage; in OH_ArkUI_StyledString_Create() 533 void OH_ArkUI_StyledString_Destroy(ArkUI_StyledString* storage) in OH_ArkUI_StyledString_Destroy() argument 535 OH_Drawing_DestroyTypographyHandler(reinterpret_cast<OH_Drawing_TypographyCreate*>(storage->builder)); in OH_ArkUI_StyledString_Destroy() 536 for (auto item : storage->items) { in OH_ArkUI_StyledString_Destroy() 543 while (!storage->styles.empty()) { in OH_ArkUI_StyledString_Destroy() 544 auto style = reinterpret_cast<OH_Drawing_TextStyle*>(storage->styles.top()); in OH_ArkUI_StyledString_Destroy() 546 storage in OH_ArkUI_StyledString_Destroy() 556 OH_ArkUI_StyledString_PushTextStyle(ArkUI_StyledString* storage, OH_Drawing_TextStyle* style) OH_ArkUI_StyledString_PushTextStyle() argument 572 OH_ArkUI_StyledString_AddText(ArkUI_StyledString* storage, const char* content) OH_ArkUI_StyledString_AddText() argument 586 OH_ArkUI_StyledString_PopTextStyle(ArkUI_StyledString* storage) OH_ArkUI_StyledString_PopTextStyle() argument 595 OH_ArkUI_StyledString_CreateTypography(ArkUI_StyledString* storage) OH_ArkUI_StyledString_CreateTypography() argument 603 OH_ArkUI_StyledString_AddPlaceholder(ArkUI_StyledString* storage, OH_Drawing_PlaceholderSpan* placeholder) OH_ArkUI_StyledString_AddPlaceholder() argument [all...] |
/foundation/graphic/graphic_3d/lume/LumeEngine/src/io/ |
H A D | memory_filesystem.cpp | 46 auto storage = pos->second.lock(); in OpenFile() local 47 if (storage) { in OpenFile() 48 return IFile::Ptr { new MemoryFile(BASE_NS::move(storage)) }; in OpenFile() 59 auto storage = std::make_shared<MemoryFileStorage>(); in CreateFile() local 60 memoryFiles_[path] = storage; in CreateFile() 62 return IFile::Ptr { new MemoryFile(BASE_NS::move(storage)) }; in CreateFile()
|
/foundation/resourceschedule/ffrt/interfaces/kits/c/ |
H A D | type_def.h | 99 * @brief Defines the storage size of multiple types of structs. 103 /** Task attribute storage size. */ 105 /** Task executor storage size. */ 107 /* Mutex storage size. */ 109 /** Condition variable storage size. */ 111 /** Queue storage size. */ 160 uint32_t storage[(ffrt_task_attr_storage_size + sizeof(uint32_t) - 1) / sizeof(uint32_t)]; member 164 uint32_t storage[(ffrt_queue_attr_storage_size + sizeof(uint32_t) - 1) / sizeof(uint32_t)]; member 179 long storage; member 183 long storage; member 204 uint32_t storage[(ffrt_mutex_storage_size + sizeof(uint32_t) - 1) / sizeof(uint32_t)]; global() member 208 uint32_t storage[(ffrt_cond_storage_size + sizeof(uint32_t) - 1) / sizeof(uint32_t)]; global() member [all...] |
/foundation/graphic/graphic_3d/lume/LumeEngine/src/os/ohos/ |
H A D | ohos_filesystem.cpp | 66 auto storage = pos->second.lock(); in OpenFile() local 67 if (storage) { in OpenFile() 69 file->UpdateStorage(storage); in OpenFile() 73 auto storage = std::make_shared<OhosFileStorage>(nullptr); in OpenFile() local 76 storage = file->Open(path.data()); in OpenFile() 78 if (storage == nullptr) { in OpenFile() 81 ohosFiles_[path] = std::move(storage); in OpenFile()
|
/foundation/multimedia/media_library/frameworks/innerkitsimpl/test/unittest/medialibrary_mtp_test/src/ |
H A D | mtp_set_object_prop_test.cpp | 35 auto storage = make_shared<Storage>(); in HWTEST_F() local 38 mtpStorageManager->AddStorage(storage); in HWTEST_F() 53 mtpStorageManager->RemoveStorage(storage); in HWTEST_F() 65 auto storage = make_shared<Storage>(); in HWTEST_F() local 66 mtpStorageManager->AddStorage(storage); in HWTEST_F() 73 mtpStorageManager->RemoveStorage(storage); in HWTEST_F() 85 auto storage = make_shared<Storage>(); in HWTEST_F() local 86 mtpStorageManager->AddStorage(storage); in HWTEST_F() 90 mtpStorageManager->RemoveStorage(storage); in HWTEST_F() 101 auto storage in HWTEST_F() local 120 auto storage = make_shared<Storage>(); HWTEST_F() local 137 auto storage = make_shared<Storage>(); HWTEST_F() local [all...] |
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/ |
H A D | remote_executor.cpp | 219 SyncGenericInterface *storage = static_cast<SyncGenericInterface *>(GetAndIncSyncInterface()); in CheckPermissions() local 220 if (storage == nullptr) { in CheckPermissions() 221 LOGE("[RemoteExecutor][CheckPermissions] storage is nullptr."); in CheckPermissions() 225 std::string appId = storage->GetDbProperties().GetStringProp(DBProperties::APP_ID, ""); in CheckPermissions() 226 std::string userId = storage->GetDbProperties().GetStringProp(DBProperties::USER_ID, ""); in CheckPermissions() 227 std::string storeId = storage->GetDbProperties().GetStringProp(DBProperties::STORE_ID, ""); in CheckPermissions() 233 storage->DecRefCount(); in CheckPermissions() 239 storage->DecRefCount(); in CheckPermissions() 243 errCode = CheckRemoteRecvData(device, storage, requestPacket->GetSecLabel(), requestPacket->GetVersion()); in CheckPermissions() 244 storage in CheckPermissions() 260 RelationalDBSyncInterface *storage = static_cast<RelationalDBSyncInterface *>(syncInterface); SendRemoteExecutorData() local 289 auto storage = GetAndIncSyncInterface(); ReceiveRemoteExecutorAck() local 570 SyncGenericInterface *storage = static_cast<SyncGenericInterface *>(GetAndIncSyncInterface()); ResponseStart() local 742 ISyncInterface *storage = GetAndIncSyncInterface(); FillRequestPacket() local 938 ResponseRemoteQueryRequest(RelationalDBSyncInterface *storage, const PreparedStmt &stmt, const std::string &device, uint32_t sessionId) ResponseRemoteQueryRequest() argument 978 CheckSecurityOption(ISyncInterface *storage, ICommunicator *communicator, const SecurityOption &remoteOption) CheckSecurityOption() argument 1005 CheckRemoteRecvData(const std::string &device, SyncGenericInterface *storage, int32_t remoteSecLabel, uint32_t remoteVersion) CheckRemoteRecvData() argument [all...] |
/foundation/multimedia/media_foundation/engine/include/plugin/common/ |
H A D | any.h | 349 static void Destroy(Storage& storage) noexcept 351 reinterpret_cast<T*>(storage.trivialStack_.data())->~T(); 366 static const void* GetConstPtr(const Storage& storage) noexcept 368 return reinterpret_cast<const void*>(storage.trivialStack_.data()); 371 static void* GetPtr(Storage& storage) noexcept 373 return reinterpret_cast<void*>(storage.trivialStack_.data()); 391 static void Destroy(Storage& storage) noexcept 393 reinterpret_cast<T*>(GetPtr(storage))->~T(); // NOLINT: cast 409 static const void* GetConstPtr(const Storage& storage) noexcept 411 return reinterpret_cast<const void*>(&storage [all...] |
/foundation/graphic/graphic_3d/lume/metaobject/src/ |
H A D | meta_object_lib.cpp | 35 sizeof(InternalMutexType) <= sizeof(MutexHandle::storage) && alignof(InternalMutexType) <= alignof(MutexHandle); 39 // do we have suitable storage for constructing mutex in-place in CreateMutex() 41 new (handle.storage) InternalMutexType; in CreateMutex() 50 static_cast<InternalMutexType*>(static_cast<void*>(handle.storage))->~InternalMutexType(); in DestroyMutex() 59 static_cast<InternalMutexType*>(static_cast<void*>(handle.storage))->lock(); in LockMutex() 69 static_cast<InternalMutexType*>(static_cast<void*>(handle.storage))->unlock(); in UnlockMutex()
|
/foundation/window/window_manager/window_scene/session/host/src/ |
H A D | root_scene_session.cpp | 25 const std::string& contentUrl, napi_env env, napi_value storage, AbilityRuntime::Context* context) in LoadContent() 28 loadContentFunc_(contentUrl, env, storage, context); in LoadContent() 24 LoadContent( const std::string& contentUrl, napi_env env, napi_value storage, AbilityRuntime::Context* context) LoadContent() argument
|
/foundation/resourceschedule/ffrt/interfaces/inner_api/c/ |
H A D | type_def_ext.h | 52 /* rwlock storage size. */ 57 uint32_t storage[(ffrt_thread_attr_storage_size + sizeof(uint32_t) - 1) / sizeof(uint32_t)]; member 91 long storage; member 136 uint32_t storage[(ffrt_rwlock_storage_size + sizeof(uint32_t) - 1) / sizeof(uint32_t)]; member
|
/foundation/window/window_manager/test/common/mock/ |
H A D | mock_uicontent.h | 29 napi_value storage)); 31 const std::shared_ptr<std::vector<uint8_t>>& content, napi_value storage)); 33 napi_value storage)); 35 void(OHOS::Rosen::Window* window, const std::string& url, napi_value storage, uint32_t focusWindowID)); 43 napi_value storage, ContentInfoType type)); 66 MOCK_METHOD3(PreInitializeForm, void(OHOS::Rosen::Window* window, const std::string& url, napi_value storage));
|
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/ |
H A D | mock_single_ver_kv_syncer.h | 44 void Init(ISyncEngine *engine, ISyncInterface *storage, bool init)
in Init() argument 47 syncInterface_ = storage;
in Init()
|
H A D | distributeddb_single_ver_p2p_query_sync_test.cpp | 780 VirtualSingleVerSyncDBInterface storage; in HWTEST_F() local 784 * @tc.steps: step1. initialize meta with storage in HWTEST_F() 787 int errCode = meta.Initialize(&storage); in HWTEST_F() 861 VirtualSingleVerSyncDBInterface storage; in HWTEST_F() local 865 * @tc.steps: step1. initialize meta with storage in HWTEST_F() 868 int errCode = meta.Initialize(&storage); in HWTEST_F() 907 VirtualSingleVerSyncDBInterface storage; in HWTEST_F() local 910 int errCode = meta.Initialize(&storage); in HWTEST_F() 934 VirtualSingleVerSyncDBInterface storage; in HWTEST_F() local 938 * @tc.steps: step1. initialize meta with storage in HWTEST_F() 979 VirtualSingleVerSyncDBInterface storage; HWTEST_F() local 1035 VirtualSingleVerSyncDBInterface storage; HWTEST_F() local 1086 VirtualSingleVerSyncDBInterface storage; HWTEST_F() local 1122 VirtualSingleVerSyncDBInterface storage; HWTEST_F() local 1188 VirtualSingleVerSyncDBInterface storage; HWTEST_F() local 1269 VirtualSingleVerSyncDBInterface storage; HWTEST_F() local 1315 VirtualSingleVerSyncDBInterface storage; HWTEST_F() local 1372 VirtualSingleVerSyncDBInterface storage; HWTEST_F() local 1489 VirtualSingleVerSyncDBInterface storage; HWTEST_F() local 1532 InitVerifyStorageEnvironment(Metadata &meta, VirtualSingleVerSyncDBInterface &storage, const std::string &deviceId, const int &startCount, const uint32_t &maxStoreItems) InitVerifyStorageEnvironment() argument 1563 VirtualSingleVerSyncDBInterface storage; HWTEST_F() local 1621 VirtualSingleVerSyncDBInterface storage; HWTEST_F() local 1673 VirtualSingleVerSyncDBInterface storage; HWTEST_F() local [all...] |
/foundation/multimedia/media_foundation/interface/inner_api/meta/ |
H A D | any.h | 487 static void Destroy(Storage& storage) noexcept 489 reinterpret_cast<T*>(storage.trivialStack_.data())->~T(); 504 static const void* GetConstPtr(const Storage& storage) noexcept 506 return reinterpret_cast<const void *>(storage.trivialStack_.data()); 509 static void* GetPtr(Storage& storage) noexcept 511 return reinterpret_cast<void *>(storage.trivialStack_.data()); 563 static void Destroy(Storage& storage) noexcept 565 reinterpret_cast<T*>(GetPtr(storage))->~T(); // NOLINT: cast 581 static const void* GetConstPtr(const Storage& storage) noexcept 583 return reinterpret_cast<const void*>(&storage [all...] |
/foundation/multimedia/media_library/frameworks/services/media_mtp/src/payload_data/ |
H A D | get_storage_ids_data.cpp | 44 for (auto storage : storages_) { in Maker() 45 MtpPacketTool::PutUInt32(outBuffer, storage->GetStorageID()); in Maker()
|
/foundation/multimedia/media_library/frameworks/services/media_mtp/include/ |
H A D | mtp_storage_manager.h | 26 #include "storage.h" 38 void AddStorage(std::shared_ptr<Storage> &storage); 39 void RemoveStorage(std::shared_ptr<Storage> &storage);
|