| /foundation/arkui/ace_engine_lite/frameworks/packages/runtime-core/src/observer/ |
| H A D | subject.js | 121 let inserted;
123 inserted = args;
125 inserted = args.slice(2);
128 if (inserted && inserted.length) {
129 inserted.forEach(Subject.of);
|
| /foundation/distributeddatamgr/kv_store/frameworks/innerkitsimpl/kvdb/src/ |
| H A D | observer_bridge.cpp | 85 auto inserted = ConvertDB(data.GetEntriesInserted(), deviceId, convert_); in OnChange() local
88 ChangeNotification notice(std::move(inserted), std::move(updated), std::move(deleted), deviceId, false); in OnChange()
103 auto inserted = ObserverBridge::ConvertDB(data.GetInsertEntries(), deviceId, convert_); in OnChange() local
106 ChangeNotification notice(std::move(inserted), std::move(updated), std::move(deleted), deviceId, false); in OnChange()
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/include/ |
| H A D | multi_ver_def.h | 61 std::list<Entry> inserted; member
67 inserted.clear(); in Reset()
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/multiver/ |
| H A D | multi_ver_natural_store_commit_notify_data.cpp | 46 return diffData_.inserted; in GetInsertedEntries()
83 diffData_.inserted.empty() && in IsChangedDataEmpty()
|
| /foundation/graphic/graphic_2d/rosen/samples/opengl/test_eglCreateWindowSurface/entry/src/main/cpp/manager/ |
| H A D | plugin_manager.cpp | 92 auto [iter, inserted] = nativeXComponentMap_.try_emplace(id, nativeXComponent); in SetNativeXComponent()
93 if (!inserted && iter->second != nativeXComponent) { in SetNativeXComponent()
|
| /foundation/graphic/graphic_2d/rosen/samples/opengl/test_xComponentContext/entry/src/main/cpp/plugin/ |
| H A D | plugin_manager.cpp | 49 auto [iter, inserted] = nativeXComponentMap_.try_emplace(id, nativeXComponent);
in SetNativeXComponent()
50 if (!inserted && iter->second != nativeXComponent) {
in SetNativeXComponent()
|
| /foundation/multimodalinput/input/intention/ipc/socket/src/ |
| H A D | socket_client.cpp | 45 auto [_, inserted] = callbacks_.emplace(id, callback); in RegisterEvent()
46 return inserted; in RegisterEvent()
|
| H A D | socket_session_manager.cpp | 222 auto [_, inserted] = sessions_.emplace(session->GetFd(), session); in AddSession()
223 if (!inserted) { in AddSession()
237 auto [_, inserted] = callbacks_.emplace(pid, callback); in AddSessionDeletedCallback()
238 if (!inserted) { in AddSessionDeletedCallback()
|
| /foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/cloud/ |
| H A D | cloud_types_util.cpp | 81 return ITypesUtil::Marshal(data, input.table, input.inserted, input.updated, input.normal); in Marshalling()
87 return ITypesUtil::Unmarshal(data, output.table, output.inserted, output.updated, output.normal); in Unmarshalling()
|
| /foundation/distributeddatamgr/kv_store/frameworks/innerkitsimpl/distributeddatafwk/src/ |
| H A D | kvdb_notifier_client.cpp | 122 auto inserted = syncCallbackInfo_.Insert(sequenceId, callback); in AddSyncCallback() local
123 if (!inserted) { in AddSyncCallback()
|
| /foundation/distributeddatamgr/relational_store/frameworks/js/napi/relationalstore/include/ |
| H A D | napi_rdb_store_observer.h | 33 std::vector<PrimaryKey> inserted; member
|
| /foundation/graphic/graphic_3d/lume/LumeEngine/src/log/ |
| H A D | logger.cpp | 137 auto const [pos, inserted] = registeredOnce_.insert(string(id)); in VLogOnce()
138 if (inserted) { in VLogOnce()
|
| /foundation/distributeddatamgr/relational_store/interfaces/inner_api/cloud_data/include/ |
| H A D | cloud_types.h | 60 int32_t inserted = 0; member
|
| /foundation/arkui/ace_engine/frameworks/core/image/apng/ |
| H A D | apng_image_decoder.cpp | 505 bool inserted = false; in png_copy_frame_data_at_index() local
513 if (shared_chunk_index >= info->apngSharedInsertIndex && !inserted) { in png_copy_frame_data_at_index()
514 inserted = true; in png_copy_frame_data_at_index()
811 bool inserted = false; in GetFrameData() local
825 if (sharedChunkIndex >= pngInfo_->apngSharedInsertIndex && !inserted) { in GetFrameData()
826 inserted = true; in GetFrameData()
|
| /foundation/communication/netmanager_base/services/netmanagernative/src/manager/ |
| H A D | bandwidth_manager.cpp | 466 auto [_, inserted] = deniedListUids_.insert(uid); in AddDeniedList()
467 if (!inserted) { in AddDeniedList()
503 auto [_, inserted] = allowedListUids_.insert(uid); in AddAllowedList()
504 if (!inserted) { in AddAllowedList()
|
| /foundation/distributeddatamgr/relational_store/frameworks/js/napi/cloud_data/src/ |
| H A D | js_cloud_utils.cpp | 236 napi_value inserted = Convert2JSValue(env, value.inserted); in Convert2JSValue() local
240 napi_set_named_property(env, jsValue, "inserted", inserted); in Convert2JSValue()
|
| /foundation/distributeddatamgr/relational_store/interfaces/ndk/src/ |
| H A D | relational_store.cpp | 1061 infos[index]->inserted.count = static_cast<int>(it->second[RdbStoreObserver::CHG_TYPE_INSERT].size()); in OnChange()
1062 infos[index]->inserted.type = GetKeyDataType(it->second[RdbStoreObserver::CHG_TYPE_INSERT]); in OnChange()
1068 infos[index]->inserted.data = data; in OnChange()
1069 ConvertKeyInfoData(data + infos[index]->inserted.count, it->second[RdbStoreObserver::CHG_TYPE_UPDATE]); in OnChange()
1070 infos[index]->updated.data = data + infos[index]->inserted.count; in OnChange()
1071 ConvertKeyInfoData(data + infos[index]->inserted.count + infos[index]->updated.count, in OnChange()
1073 infos[index]->deleted.data = data + infos[index]->inserted.count + infos[index]->updated.count; in OnChange()
|
| /foundation/distributeddatamgr/relational_store/frameworks/js/napi/relationalstore/src/ |
| H A D | napi_rdb_store_observer.cpp | 111 inserted = std::move(info->second[CHG_TYPE_INSERT]); in JSChangeInfo()
|
| /foundation/graphic/graphic_3d/lume/LumeEngine/src/perf/ |
| H A D | performance_data_manager.cpp | 231 auto inserted = managers_.insert({ category, make_unique<PerformanceDataManager>(category) }); in Get() local
232 return inserted.first->second.get(); in Get()
|
| /foundation/distributeddatamgr/relational_store/test/ndk/unittest/ |
| H A D | rdb_store_test.cpp | 1080 EXPECT_EQ(1, changeInfo[i]->inserted.count); in LocalDataChangeObserverCallback1()
1081 EXPECT_EQ(TYPE_INT64, changeInfo[i]->inserted.type); in LocalDataChangeObserverCallback1()
1083 EXPECT_EQ(2, changeInfo[i]->inserted.data->integer); in LocalDataChangeObserverCallback1()
1129 EXPECT_EQ(0, changeInfo[i]->inserted.count); in LocalDataChangeObserverCallback2()
1180 EXPECT_EQ(0, changeInfo[i]->inserted.count); in LocalDataChangeObserverCallback3()
1291 EXPECT_EQ(1, changeInfo[i]->inserted.count); in LocalDataChangeObserverCallback5()
1292 EXPECT_EQ(TYPE_INT64, changeInfo[i]->inserted.type); in LocalDataChangeObserverCallback5()
1294 EXPECT_EQ(1, changeInfo[i]->inserted.data->integer); in LocalDataChangeObserverCallback5()
1357 EXPECT_EQ(0, changeInfo[i]->inserted.count); in LocalDataChangeObserverCallback6()
|
| /foundation/distributeddatamgr/relational_store/frameworks/cj/include/ |
| H A D | relational_store_utils.h | 132 CArrPRIKeyType inserted; member
|
| /foundation/distributeddatamgr/relational_store/frameworks/native/cloud_data/src/ |
| H A D | cloud_types_util.cpp | 133 return ITypesUtil::Unmarshal(data, output.table, output.inserted, output.updated, output.normal); in Unmarshalling()
|
| /foundation/distributeddatamgr/relational_store/interfaces/ndk/include/ |
| H A D | relational_store.h | 432 * @param valuesBucket Indicates the row of data {@link OH_VBucket} to be inserted into the table.
812 * The {@link Rdb_KeyInfo} of inserted rows.
814 Rdb_KeyInfo inserted; member
|
| /foundation/distributedhardware/distributed_input/services/source/inputinject/src/ |
| H A D | distributed_input_node_manager.cpp | 419 auto [dev_it, inserted] = virtualDeviceMap_.insert_or_assign( in AddDeviceLocked()
421 if (!inserted) { in AddDeviceLocked()
|
| /foundation/filemanagement/dfs_service/services/distributedfiledaemon/src/device/ |
| H A D | device_manager_agent.cpp | 107 auto [ignored, inserted] = mpToNetworks_.insert({ smp->GetID(), agent }); in JoinGroup()
108 if (!inserted) { in JoinGroup()
|