/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/common/src/ |
H A D | auto_launch.cpp | 87 // {identifier, userId} in ~AutoLaunch() 130 LOGE("[AutoLaunch] EnableKvStoreAutoLaunchParmCheck identifier is already enabled in normal tuple mode"); in EnableKvStoreAutoLaunchParmCheck() 135 LOGE("[AutoLaunch] EnableKvStoreAutoLaunchParmCheck identifier is already enabled in dual tuple mode"); in EnableKvStoreAutoLaunchParmCheck() 138 std::string identifier = isDualTupleMode ? dualTupleIdentifier : normalIdentifier; in EnableKvStoreAutoLaunchParmCheck() local 139 if (identifier.empty()) { in EnableKvStoreAutoLaunchParmCheck() 140 LOGE("[AutoLaunch] EnableKvStoreAutoLaunchParmCheck identifier is invalid"); in EnableKvStoreAutoLaunchParmCheck() 143 if (autoLaunchItemMap_.count(identifier) != 0 && autoLaunchItemMap_[identifier].count(userId) != 0) { in EnableKvStoreAutoLaunchParmCheck() 144 LOGE("[AutoLaunch] EnableKvStoreAutoLaunchParmCheck identifier is already enabled!"); in EnableKvStoreAutoLaunchParmCheck() 156 autoLaunchItemMap_[identifier][userI in EnableKvStoreAutoLaunchParmCheck() 168 std::string identifier = properties.GetStringProp(KvDBProperties::IDENTIFIER_DATA, ""); EnableKvStoreAutoLaunch() local 195 GetKVConnectionInEnable(AutoLaunchItem &autoLaunchItem, const std::string &identifier) GetKVConnectionInEnable() argument 290 RegisterObserverAndLifeCycleCallback(AutoLaunchItem &autoLaunchItem, const std::string &identifier, bool isExt) RegisterObserverAndLifeCycleCallback() argument 315 RegisterObserver(AutoLaunchItem &autoLaunchItem, const std::string &identifier, bool isExt) RegisterObserver() argument 332 ObserverFunc(const KvDBCommitNotifyData ¬ifyData, const std::string &identifier, const std::string &userId) ObserverFunc() argument 388 std::string identifier; DisableKvStoreAutoLaunch() local 437 GetAutoLaunchSyncDevices(const std::string &identifier, std::vector<std::string> &devices) const GetAutoLaunchSyncDevices() argument 465 ConnectionLifeCycleCallbackTask(const std::string &identifier, const std::string &userId) ConnectionLifeCycleCallbackTask() argument 503 ConnectionLifeCycleCallback(const std::string &identifier, const std::string &userId) ConnectionLifeCycleCallback() argument 656 ReceiveUnknownIdentifierCallBackTask(const std::string &identifier, const std::string &userId) ReceiveUnknownIdentifierCallBackTask() argument 750 AutoLaunchExt(const std::string &identifier, const std::string &userId) AutoLaunchExt() argument 791 AutoLaunchExtTask(const std::string &identifier, const std::string &userId, AutoLaunchItem &autoLaunchItem) AutoLaunchExtTask() argument 832 ExtObserverFunc(const KvDBCommitNotifyData ¬ifyData, const std::string &identifier, const std::string &userId) ExtObserverFunc() argument 884 ExtConnectionLifeCycleCallback(const std::string &identifier, const std::string &userId) ExtConnectionLifeCycleCallback() argument 894 ExtConnectionLifeCycleCallbackTask(const std::string &identifier, const std::string &userId) ExtConnectionLifeCycleCallbackTask() argument 1057 ExtAutoLaunchRequestCallBack(const std::string &identifier, AutoLaunchParam ¶m, DBTypeInner &openType) ExtAutoLaunchRequestCallBack() argument 1117 RegisterLifeCycleCallback(AutoLaunchItem &autoLaunchItem, const std::string &identifier, bool isExt) RegisterLifeCycleCallback() argument 1208 EraseAutoLaunchItem(const std::string &identifier, const std::string &userId) EraseAutoLaunchItem() argument 1260 RegisterKvObserver(AutoLaunchItem &autoLaunchItem, const std::string &identifier, bool isExt) RegisterKvObserver() argument 1285 RegisterRelationalObserver(AutoLaunchItem &autoLaunchItem, const std::string &identifier, bool isExt) RegisterRelationalObserver() argument 1334 std::string identifier = properties.GetStringProp(DBProperties::IDENTIFIER_DATA, ""); CloseConnection() local 1382 GetAutoLaunchItemUid(const std::string &identifier, const std::string &originalUserId, bool &handleByCallback) GetAutoLaunchItemUid() argument 1414 ChkAutoLaunchAbort(const std::string &identifier, AutoLaunchItem &autoLaunchItem) ChkAutoLaunchAbort() argument [all...] |
/foundation/communication/dsoftbus/tests/adapter/bluetooth/ |
H A D | assert_helper.h | 31 explicit RecordCtx(const char *identifier) : id(-1) in RecordCtx() argument 33 this->identifier = identifier; in RecordCtx() 46 result = testing::AssertionFailure() << identifier << " is call by unexpectedly id," in Expect() 54 const char *identifier; member in RecordCtx 61 explicit StRecordCtx(const char *identifier) : RecordCtx(identifier), st(-1) {} in StRecordCtx() argument 79 result = testing::AssertionFailure() << identifier << " is call by unexpectedly state," in Expect() 94 explicit BtAddrRecordCtx(const char *identifier) : StRecordCtx(identifier) in BtAddrRecordCtx() argument 133 IntRecordCtx(const char *identifier) IntRecordCtx() argument [all...] |
/foundation/communication/dsoftbus/tests/adapter/broadcast/ |
H A D | assert_helper.h | 26 explicit RecordCtx(const char *identifier) : id(-1) in RecordCtx() argument 28 this->identifier = identifier; in RecordCtx() 41 result = testing::AssertionFailure() << identifier << " is call by unexpectedly id," in Expect() 49 const char *identifier; member in RecordCtx 56 explicit StRecordCtx(const char *identifier) : RecordCtx(identifier), st(-1) {} in StRecordCtx() argument 74 result = testing::AssertionFailure() << identifier << " is call by unexpectedly state," in Expect() 89 explicit BtAddrRecordCtx(const char *identifier) : StRecordCtx(identifier) in BtAddrRecordCtx() argument 128 IntRecordCtx(const char *identifier) IntRecordCtx() argument [all...] |
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/common/include/ |
H A D | auto_launch.h | 85 void GetAutoLaunchSyncDevices(const std::string &identifier, std::vector<std::string> &devices) const; 118 int GetKVConnectionInEnable(AutoLaunchItem &autoLaunchItem, const std::string &identifier); 123 int RegisterObserverAndLifeCycleCallback(AutoLaunchItem &autoLaunchItem, const std::string &identifier, 126 int RegisterObserver(AutoLaunchItem &autoLaunchItem, const std::string &identifier, bool isExt); 128 void ObserverFunc(const KvDBCommitNotifyData ¬ifyData, const std::string &identifier, 131 void ConnectionLifeCycleCallbackTask(const std::string &identifier, const std::string &userId); 144 void ReceiveUnknownIdentifierCallBackTask(const std::string &identifier, const std::string &userId); 146 void ConnectionLifeCycleCallback(const std::string &identifier, const std::string &userId); 152 int AutoLaunchExt(const std::string &identifier, const std::string &userId); 154 void AutoLaunchExtTask(const std::string &identifier, cons [all...] |
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/ |
H A D | storage_engine_manager.cpp | 65 std::string identifier = GetIdentifier(property); in GetStorageEngine() local 66 manager->EnterGetEngineProcess(identifier); in GetStorageEngine() 67 auto storageEngine = manager->FindStorageEngine(identifier); in GetStorageEngine() 71 manager->InsertStorageEngine(identifier, storageEngine); in GetStorageEngine() 81 manager->ExitGetEngineProcess(identifier); in GetStorageEngine() 112 int StorageEngineManager::ForceReleaseStorageEngine(const std::string &identifier) in ForceReleaseStorageEngine() argument 121 manager->ReleaseResources(identifier); in ForceReleaseStorageEngine() 228 StorageEngine *StorageEngineManager::FindStorageEngine(const std::string &identifier) in FindStorageEngine() argument 231 auto iter = storageEngines_.find(identifier); in FindStorageEngine() 236 storageEngines_.erase(identifier); in FindStorageEngine() 246 InsertStorageEngine(const std::string &identifier, StorageEngine *&storageEngine) InsertStorageEngine() argument 252 EraseStorageEngine(const std::string &identifier) EraseStorageEngine() argument 258 ReleaseResources(const std::string &identifier) ReleaseResources() argument 279 const std::string identifier = releaseEngine->GetIdentifier(); ReleaseEngine() local 304 EnterGetEngineProcess(const std::string &identifier) EnterGetEngineProcess() argument 313 ExitGetEngineProcess(const std::string &identifier) ExitGetEngineProcess() argument [all...] |
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/include/ |
H A D | storage_engine_manager.h | 34 static int ForceReleaseStorageEngine(const std::string &identifier); 53 StorageEngine *FindStorageEngine(const std::string &identifier); 55 void InsertStorageEngine(const std::string &identifier, StorageEngine *&storageEngine); 57 void EraseStorageEngine(const std::string &identifier); 59 void ReleaseResources(const std::string &identifier); 63 void EnterGetEngineProcess(const std::string &identifier); 65 void ExitGetEngineProcess(const std::string &identifier);
|
H A D | kvdb_manager.h | 61 IKvDB* FindKvDB(const std::string &identifier) const; 104 void EnterDBOpenCloseProcess(const std::string &identifier); 106 void ExitDBOpenCloseProcess(const std::string &identifier); 124 IKvDB *GetKvDBFromCacheByIdentify(const std::string &identifier, const std::map<std::string, IKvDB *> &cache) const;
|
/foundation/distributedhardware/distributed_input/common/include/ |
H A D | input_hub.cpp | 144 device->path.c_str(), device->identifier.name.c_str()); in ScanAndRecordInputDevices() 203 if (!sharedDHIds_[device->identifier.descriptor]) { in GetEvents() 206 GetAnonyString(device->identifier.descriptor).c_str()); in GetEvents() 217 DHLOGI("Removing device %{public}s due to epoll hang-up event.", device->identifier.name.c_str()); in GetEvents() 232 IsTouchPad(device->identifier); in IsTouchPad() 291 if (!IsTouchPad(device->identifier)) { in RecordDeviceChangeStates() 304 event.descriptor = isTouchEvent ? touchDescriptor : device->identifier.descriptor; in RecordDeviceChangeStates() 315 if (!IsTouchPad(device->identifier)) { in CollectEvent() 332 event->descriptor = isTouchEvent ? touchDescriptor : device->identifier.descriptor; in CollectEvent() 374 device->path.c_str(), device->identifier in DeviceIsExists() 765 GetEventTypes(struct libevdev *dev, InputDevice &identifier) GetEventTypes() argument 776 GetEventKeys(struct libevdev *dev, InputDevice &identifier) GetEventKeys() argument 794 GetABSInfo(struct libevdev *dev, InputDevice &identifier) GetABSInfo() argument 825 GetRELTypes(struct libevdev *dev, InputDevice &identifier) GetRELTypes() argument 843 GetProperties(struct libevdev *dev, InputDevice &identifier) GetProperties() argument 1365 RecordDeviceLog(const std::string &devicePath, const InputDevice &identifier) RecordDeviceLog() argument [all...] |
H A D | input_hub.h | 53 InputDevice identifier; member 125 void GetEventTypes(struct libevdev *dev, InputDevice &identifier); 126 int32_t GetEventKeys(struct libevdev *dev, InputDevice &identifier); 127 int32_t GetABSInfo(struct libevdev *dev, InputDevice &identifier); 128 int32_t GetRELTypes(struct libevdev *dev, InputDevice &identifier); 129 void GetProperties(struct libevdev *dev, InputDevice &identifier); 140 void GenerateDescriptor(InputDevice &identifier) const; 177 void RecordDeviceLog(const std::string &devicePath, const InputDevice &identifier);
|
/foundation/graphic/graphic_3d/lume/LumeEngine/src/threading/ |
H A D | task_queue.cpp | 76 TaskQueue::Entry::Entry(uint64_t identifier, IThreadPool::ITask::Ptr task) : task(move(task)), identifier(identifier) {} in Entry() argument 80 return identifier == rhsIdentifier; in operator ==() 85 return identifier == other.identifier; in operator ==()
|
H A D | task_queue.h | 57 * 2. queue.Submit("identifier A", FunctionTask::Create(function)); 58 * 3. queue.Submit("identifier B", FunctionTask::Create(std::bind(&Classname::function, this))); 59 * 4. queue.Submit("identifier C", FunctionTask::Create([]() { <code> })); 115 Entry(uint64_t identifier, IThreadPool::ITask::Ptr task); 116 bool operator==(uint64_t identifier) const; 120 uint64_t identifier {};
|
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/relational/ |
H A D | relational_store_instance.cpp | 56 std::string identifier = connection->GetIdentifier(); in ReleaseDataBaseConnection() local 57 manager->EnterDBOpenCloseProcess(identifier); in ReleaseDataBaseConnection() 59 manager->ExitDBOpenCloseProcess(identifier); in ReleaseDataBaseConnection() 70 std::string identifier = properties.GetStringProp(RelationalDBProperties::IDENTIFIER_DATA, ""); in GetFromCache() local 72 auto iter = dbs_.find(identifier); in GetFromCache() 91 std::string identifier = properties.GetStringProp(RelationalDBProperties::IDENTIFIER_DATA, ""); in RemoveKvDBFromCache() local 93 dbs_.erase(identifier); in RemoveKvDBFromCache() 98 std::string identifier = properties.GetStringProp(RelationalDBProperties::IDENTIFIER_DATA, ""); in SaveRelationalDBToCache() local 100 if (dbs_.count(identifier) == 0) { in SaveRelationalDBToCache() 101 dbs_.insert(std::pair<std::string, IRelationalStore *>(identifier, stor in SaveRelationalDBToCache() 197 std::string identifier = properties.GetStringProp(DBProperties::IDENTIFIER_DATA, ""); GetDatabaseConnection() local 234 EnterDBOpenCloseProcess(const std::string &identifier) EnterDBOpenCloseProcess() argument 243 ExitDBOpenCloseProcess(const std::string &identifier) ExitDBOpenCloseProcess() argument [all...] |
/foundation/distributeddatamgr/kv_store/frameworks/innerkitsimpl/kvdb/src/ |
H A D | process_communication_impl.cpp | 62 auto dataReciveCallback = [callback](const std::string &identifier, const uint8_t *data, uint32_t length) { in RegOnDataReceive() 64 identifier in RegOnDataReceive() 81 std::string dtsIdentifier = dstDevInfo.identifier; in SendData() 98 std::string identifier = devInfo.identifier; in GetMtuSize() local 99 return endpoint_->GetMtuSize(identifier); in GetMtuSize() 104 std::string identifier = endpoint_->GetLocalDeviceInfos(); in GetLocalDeviceInfos() local 106 identifier in GetLocalDeviceInfos()
|
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/kv/ |
H A D | kvdb_manager.cpp | 83 std::string identifier = properties.GetStringProp(KvDBProperties::IDENTIFIER_DATA, ""); in CreateRemoveStateFlagFile() local 84 std::string identifierName = DBCommon::TransferStringToHex(identifier); in CreateRemoveStateFlagFile() 101 std::string identifier = property.GetStringProp(KvDBProperties::IDENTIFIER_DATA, ""); in CheckRemoveStateAndRetry() local 102 std::string identifierName = DBCommon::TransferStringToHex(identifier); in CheckRemoveStateAndRetry() 110 LOGD("Deletekvstore unfinished, can not create new same identifier kvstore!"); in CheckRemoveStateAndRetry() 161 std::string identifier = properties.GetStringProp(KvDBProperties::IDENTIFIER_DATA, ""); in RemoveDBDirectory() local 162 std::string identifierName = DBCommon::TransferStringToHex(identifier); in RemoveDBDirectory() 168 identifier = DBCommon::TransferHashString(storeId); in RemoveDBDirectory() 169 identifierName = DBCommon::TransferStringToHex(identifier); in RemoveDBDirectory() 187 void KvDBManager::EnterDBOpenCloseProcess(const std::string &identifier) in EnterDBOpenCloseProcess() argument 196 ExitDBOpenCloseProcess(const std::string &identifier) ExitDBOpenCloseProcess() argument 325 std::string identifier = properties.GetStringProp(KvDBProperties::IDENTIFIER_DATA, ""); GetDatabaseConnection() local 373 std::string identifier = connection->GetIdentifier(); ReleaseDatabaseConnection() local 488 std::string identifier = GenerateKvDBIdentifier(properties); IsOpenMemoryDb() local 546 GetKvDBFromCacheByIdentify(const std::string &identifier, const std::map<std::string, IKvDB *> &cache) const GetKvDBFromCacheByIdentify() argument 569 std::string identifier = GenerateKvDBIdentifier(properties); CheckDatabaseFileStatus() local 613 auto identifier = DBCommon::TransferStringToHex(property.GetStringProp(KvDBProperties::IDENTIFIER_DATA, "")); OpenNewDatabase() local 639 std::string identifier = GenerateKvDBIdentifier(properties); RemoveDatabase() local 701 std::string identifier = GenerateKvDBIdentifier(properties); SaveKvDBToCache() local 743 std::string identifier = GenerateKvDBIdentifier(properties); RemoveKvDBFromCache() local 790 std::string identifier = GenerateKvDBIdentifier(properties); FindKvDBFromCache() local [all...] |
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/communicator/src/ |
H A D | network_adapter.cpp | 89 onSendableHandle_(devInfo.identifier); in StartAdapter() 170 devInfo.identifier = target; in GetMtuSize() 177 devInfo.identifier = target; in GetMtuSize() 196 devInfos.identifier = target; in GetTimeout() 206 if (devInfo.identifier.empty()) { in GetLocalIdentity() 210 if (devInfo.identifier != localIdentity_) { in GetLocalIdentity() 211 LOGI("[NAdapt][GetLocal] localIdentity=%s{private}.", devInfo.identifier.c_str()); in GetLocalIdentity() 213 localIdentity_ = devInfo.identifier; in GetLocalIdentity() 226 dstDevInfo.identifier = dstTarget; in SendBytes() 274 srcDevInfo.identifier in OnDataReceiveHandler() [all...] |
H A D | db_status_adapter.cpp | 130 bool isLocal = IsLocalDeviceId(devInfos.identifier); in NotifyDBInfos() 131 if (!isLocal && !IsSupport(devInfos.identifier)) { in NotifyDBInfos() 132 LOGW("[DBStatusAdapter][NotifyDBInfos] no support dev %s", STR_MASK(devInfos.identifier)); in NotifyDBInfos() 138 remoteCallback_(devInfos.identifier, dbInfos); in NotifyDBInfos() 249 if (remoteDBInfos_.find(devInfos.identifier) == remoteDBInfos_.end()) { in LoadIntoCache() 250 remoteDBInfos_.insert({devInfos.identifier, {}}); in LoadIntoCache() 252 return MergeDBInfos(dbInfos, remoteDBInfos_[devInfos.identifier]); in LoadIntoCache()
|
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/ |
H A D | mock_auto_launch.h | 31 void CallExtConnectionLifeCycleCallbackTask(const std::string &identifier, const std::string &userId) in CallExtConnectionLifeCycleCallbackTask() argument 33 AutoLaunch::ExtConnectionLifeCycleCallbackTask(identifier, userId); in CallExtConnectionLifeCycleCallbackTask() 46 std::string CallGetAutoLaunchItemUid(const std::string &identifier, const std::string &originalUserId, bool &ext) in CallGetAutoLaunchItemUid() argument 48 return AutoLaunch::GetAutoLaunchItemUid(identifier, originalUserId, ext); in CallGetAutoLaunchItemUid()
|
/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/adapter/communicator/src/ |
H A D | process_communicator_impl.cpp | 141 destination.deviceId = dstDevInfo.identifier; in SendData() 161 return SoftBusAdapter::GetInstance()->GetMtuSize({ devInfo.identifier }); in GetMtuSize() 166 return SoftBusAdapter::GetInstance()->GetTimeout({ devInfo.identifier }); in GetTimeout() 173 localDevInfos.identifier = devInfo.uuid; in GetLocalDeviceInfos() 183 remoteDev.identifier = entry.uuid; in GetRemoteOnlineDeviceInfosList() 192 DeviceId di = {peerDevInfo.identifier}; in IsSameProcessLabelStartedOnPeerDevice() 205 devInfo.identifier = info.uuid; in OnMessage() 220 devInfo.identifier = info.uuid; in OnDeviceChanged() 231 devInfos.identifier = info.uuid; in OnSessionReady()
|
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/moduletest/src/ |
H A D | distributeddb_kv_realdel_test.cpp | 106 std::string identifier = g_kvdbParameter1.userId + "-" + g_kvdbParameter1.appId + "-" + g_kvdbParameter1.storeId; in HWTEST_F() local 107 std::string hashIdentifierRes = TransferStringToHashHexString(identifier); in HWTEST_F() 171 std::string identifier = g_kvdbParameter1.userId + "-" + g_kvdbParameter1.appId + "-" + g_kvdbParameter1.storeId; in HWTEST_F() local 172 std::string hashIdentifierRes = TransferStringToHashHexString(identifier); in HWTEST_F() 212 std::string identifier = g_kvdbParameter1.userId + "-" + g_kvdbParameter1.appId + "-" + g_kvdbParameter1.storeId; in HWTEST_F() local 213 std::string hashIdentifierRes = TransferStringToHashHexString(identifier); in HWTEST_F() 255 std::string identifier = g_kvdbParameter1.userId + "-" + g_kvdbParameter1.appId + "-" + g_kvdbParameter1.storeId; in HWTEST_F() local 256 std::string hashIdentifierRes = TransferStringToHashHexString(identifier); in HWTEST_F() 304 std::string identifier = g_kvdbParameter2.userId + "-" + g_kvdbParameter2.appId + in HWTEST_F() local 306 std::string hashIdentifierRes = TransferStringToHashHexString(identifier); in HWTEST_F() 348 std::string identifier = g_kvdbParameter2.userId + "-" + g_kvdbParameter2.appId + HWTEST_F() local [all...] |
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/storage/ |
H A D | distributeddb_storage_single_ver_upgrade_test.cpp | 203 std::string identifier = DBCommon::TransferStringToHex(g_identifier); in CheckDirectoryV2ToV3() local 204 std::string newDatabaseName = g_testDir + "/" + identifier + "/" + DBConstant::SINGLE_SUB_DIR + "/" + in CheckDirectoryV2ToV3() 206 std::string newMetadatabaseName = g_testDir + "/" + identifier + "/" + DBConstant::SINGLE_SUB_DIR + "/" + in CheckDirectoryV2ToV3() 208 std::string newCacheDirectory = g_testDir + "/" + identifier + "/" + DBConstant::SINGLE_SUB_DIR + "/" + in CheckDirectoryV2ToV3() 279 std::string identifier = DBCommon::TransferStringToHex(g_identifier); in SetUpTestCase() local 280 g_databaseName = "/" + identifier + "/" + DBConstant::SINGLE_SUB_DIR + "/" + in SetUpTestCase() 282 g_newDatabaseName = "/" + identifier + "/" + DBConstant::SINGLE_SUB_DIR + "/" + DBConstant::MAINDB_DIR + "/" + in SetUpTestCase() 284 g_localdatabaseName = "/" + identifier + "/" + DBConstant::LOCAL_SUB_DIR + "/" + in SetUpTestCase() 293 g_maindbPath = g_testDir + "/" + identifier + "/" + DBConstant::SINGLE_SUB_DIR + "/" + DBConstant::MAINDB_DIR + in SetUpTestCase() 295 g_metadbPath = g_testDir + "/" + identifier in SetUpTestCase() 309 std::string identifier = DBCommon::TransferStringToHex(g_identifier); SetUp() local [all...] |
/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/test/ |
H A D | cache_cursor_test.cpp | 62 record["identifier"] = i;
in SetUpTestCase() 82 std::vector<std::string> expectedNames = { "age", "identifier", "name", "phoneNumber" };
in HWTEST_F() 132 std::vector<std::string> expectedNames = { "age", "identifier", "name", "phoneNumber" };
in HWTEST_F() 171 int64_t identifier = *std::get_if<int64_t>(&data["identifier"]);
in HWTEST_F() local 172 EXPECT_EQ(identifier, 0);
in HWTEST_F() 185 identifier = *std::get_if<int64_t>(&data["identifier"]);
in HWTEST_F() 186 EXPECT_EQ(identifier, 99);
in HWTEST_F() 221 int64_t identifier in HWTEST_F() local [all...] |
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/interfaces/ |
H A D | distributeddb_interfaces_auto_launch_test.cpp | 101 void PutCommLackInfo(const std::string &identifier) const in PutCommLackInfo() 104 std::vector<uint8_t> vect(identifier.begin(), identifier.end()); in PutCommLackInfo() 284 std::string identifier = DBCommon::TransferHashString(USER_ID1 + "-" + APP_ID1 + "-" + storeId); in GetKvDB() local 286 prop.SetStringProp(KvDBProperties::IDENTIFIER_DATA, identifier); in GetKvDB() 287 std::string identifierDir = DBCommon::TransferStringToHex(identifier); in GetKvDB() 373 std::string identifier = DBCommon::TransferHashString(USER_ID1 + "-" + APP_ID1 + "-" + storeId); in TriggerAutoLaunch() local 374 g_aggregator->PutCommLackInfo(identifier); in TriggerAutoLaunch() 572 std::string identifier = DBCommon::TransferHashString(USER_ID1 + "-" + APP_ID1 + "-" + storeId); in HWTEST_F() local 573 g_aggregator->PutCommLackInfo(identifier); in HWTEST_F() 608 std::string identifier = DBCommon::TransferHashString(USER_ID1 + "-" + APP_ID1 + "-" + storeId); HWTEST_F() local 655 std::string identifier = DBCommon::TransferHashString(USER_ID1 + "-" + APP_ID1 + "-" + storeId); DelayAutoLaunchCycle() local [all...] |
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/interfaces/src/relational/ |
H A D | relational_store_instance.h | 49 void EnterDBOpenCloseProcess(const std::string &identifier); 50 void ExitDBOpenCloseProcess(const std::string &identifier);
|
/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/app/src/session_manager/ |
H A D | upgrade_manager.cpp | 124 auto identifier =
in SetCompatibleIdentifyByType() local 130 storeDelegate->SetEqualIdentifier(identifier, sameAccountDevs);
in SetCompatibleIdentifyByType() 134 auto identifier =
in SetCompatibleIdentifyByType() local 137 ZLOGI("no account identifier, store:%{public}s, device:%{public}.10s, appId:%{public}s",
in SetCompatibleIdentifyByType() 140 storeDelegate->SetEqualIdentifier(identifier, defaultAccountDevs);
in SetCompatibleIdentifyByType()
|
/foundation/distributeddatamgr/data_object/frameworks/innerkitsimpl/src/communicator/ |
H A D | process_communicator_impl.cpp | 119 destination.deviceId = dstDevInfo.identifier;
in SendData() 143 localDevInfos.identifier = devInfo.deviceId;
in GetLocalDeviceInfos() 153 remoteDev.identifier = entry.deviceId;
in GetRemoteOnlineDeviceInfosList() 162 DeviceId di = { peerDevInfo.identifier };
in IsSameProcessLabelStartedOnPeerDevice() 175 devInfo.identifier = info.deviceId;
in OnMessage()
|