| /ohos5.0/foundation/ability/ability_runtime/test/unittest/dataobs_mgr_inner_ext_test/ |
| H A D | dataobs_mgr_inner_ext_test.cpp | 155 dataObsMgrInnerExt->HandleNotifyChange({ ChangeInfo::ChangeType::INSERT, { uri1 } });
159 dataObsMgrInnerExt->HandleNotifyChange({ ChangeInfo::ChangeType::INSERT, { uri2 } });
163 dataObsMgrInnerExt->HandleNotifyChange({ ChangeInfo::ChangeType::INSERT, { uri3 } });
196 dataObsMgrInnerExt->HandleNotifyChange({ ChangeInfo::ChangeType::INSERT, { uri1 } });
235 dataObsMgrInnerExt->HandleNotifyChange({ ChangeInfo::ChangeType::INSERT, { uri1 } });
270 dataObsMgrInnerExt->HandleNotifyChange({ ChangeInfo::ChangeType::INSERT, { uri1 } });
307 dataObsMgrInnerExt->HandleNotifyChange({ ChangeInfo::ChangeType::INSERT, { uri1 } });
347 dataObsMgrInnerExt->HandleNotifyChange({ ChangeInfo::ChangeType::INSERT, { uri1 } });
378 dataObsMgrInnerExt->HandleNotifyChange({ ChangeInfo::ChangeType::INSERT, { uri1 } });
383 dataObsMgrInnerExt->HandleNotifyChange({ ChangeInfo::ChangeType::INSERT, { uri1 } });
[all …]
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/cloud/ |
| H A D | distributeddb_cloud_asset_compare_test.cpp | 276 TagAsset(AssetOpType::INSERT, GetDownloadWithNullStatus(), a1);
277 TagAsset(AssetOpType::INSERT, GetDownloadWithNullStatus(), a2);
278 TagAsset(AssetOpType::INSERT, GetDownloadWithNullStatus(), a3);
703 TagAsset(AssetOpType::INSERT,
705 TagAsset(AssetOpType::INSERT,
707 TagAsset(AssetOpType::INSERT,
709 TagAsset(AssetOpType::INSERT,
756 AssetStatus::INSERT);
812 static_cast<uint32_t>(AssetOpType::INSERT));
1029 param.downloadData.opType.push_back(OpType::INSERT);
[all …]
|
| H A D | distributeddb_cloud_strategy_test.cpp | 107 EXPECT_EQ(strategy->TagSyncDataStatus(false, false, localInfo, cloudInfo), OpType::INSERT);
139 EXPECT_EQ(strategy->TagSyncDataStatus(true, false, localInfo, cloudInfo), OpType::INSERT);
253 EXPECT_EQ(strategy->TagSyncDataStatus(false, false, localInfo, cloudInfo), OpType::INSERT);
312 EXPECT_EQ(strategy->TagSyncDataStatus(true, false, localInfo, cloudInfo), OpType::INSERT);
328 OpType result = OpType::INSERT;
|
| H A D | distributeddb_cloud_syncer_lock_test.cpp | 354 …ption option = PrepareOption(Query::Select().FromTable({ ASSETS_TABLE_NAME }), LockAction::INSERT); in TestConflictSync001()
435 case OpType::INSERT: in CheckUploadAbnormal()
502 …ption option = PrepareOption(Query::Select().FromTable({ ASSETS_TABLE_NAME }), LockAction::INSERT);
562 …ption option = PrepareOption(Query::Select().FromTable({ ASSETS_TABLE_NAME }), LockAction::INSERT);
697 …ption option = PrepareOption(Query::Select().FromTable({ ASSETS_TABLE_NAME }), LockAction::INSERT);
744 …ption option = PrepareOption(Query::Select().FromTable({ ASSETS_TABLE_NAME }), LockAction::INSERT);
799 …ption option = PrepareOption(Query::Select().FromTable({ ASSETS_TABLE_NAME }), LockAction::INSERT);
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/cloud/ |
| H A D | cloud_sync_tag_assets.cpp | 37 if (flag == AssetOpType::INSERT) { in TagSingleAssetForDownload()
61 case AssetOpType::INSERT: { in TagSingleAssetForUpload()
63 asset.status = static_cast<uint32_t>(AssetStatus::INSERT); in TagSingleAssetForUpload()
134 AssetOpType::INSERT : AssetOpType::NO_CHANGE, coveredAsset, res, errCode); in TagAssetWithSameHash()
146 TagAssetsWithNormalStatus(setNormalStatus, AssetOpType::INSERT, in TagForNotContainsAsset()
202 TagAssetWithNormalStatus(setNormalStatus, AssetOpType::INSERT, in TagAssets()
238 TagAssetWithNormalStatus(setNormalStatus, AssetOpType::INSERT, in TagAsset()
287 asset.flag = static_cast<uint32_t>(AssetOpType::INSERT); in MarkAssetForUpload()
288 lowBitStatus = static_cast<uint32_t>(AssetStatus::INSERT); in MarkAssetForUpload()
292 asset.flag = static_cast<uint32_t>(AssetOpType::INSERT); in MarkAssetForUpload()
[all …]
|
| H A D | cloud_merge_strategy.cpp | 44 return OpType::INSERT; in TagSyncDataStatus()
73 : ((isLocalDelete && !JudgeKvScene()) ? OpType::INSERT : OpType::ONLY_UPDATE_GID); in TagLocallyNewer()
91 return OpType::INSERT; in TagCloudUpdateLocal()
102 return OpType::INSERT; in TagLocalNotExist()
|
| H A D | cloud_sync_utils.cpp | 52 case OpType::INSERT: in OpTypeToChangeType()
91 case AssetStatus::INSERT: in StatusToFlag()
92 return AssetOpType::INSERT; in StatusToFlag()
353 case OpType::INSERT : in UpdateLocalCache()
361 } else if (opType == OpType::INSERT) { in UpdateLocalCache()
388 if (opType == OpType::INSERT) { in SaveChangedData()
399 if (!param.isSinglePrimaryKey && opType == OpType::INSERT) { in SaveChangedData()
406 case OpType::INSERT: in SaveChangedData()
583 if (opType != OpType::INSERT && opType != OpType::UPDATE) { in CalOpType()
599 if (opType == OpType::INSERT) { in CalOpType()
[all …]
|
| H A D | cloud_force_pull_strategy.cpp | 36 return OpType::INSERT; in TagSyncDataStatus()
45 return OpType::INSERT; in TagSyncDataStatus()
|
| /ohos5.0/foundation/resourceschedule/ffrt/tools/ffrt_trace_process/ |
| H A D | ffrt_trace_process_gui.pyw | 89 self.text_output.insert(tkinter.INSERT, "正在解析文件：" + filename.split('/')[-1] + "\n")
102 self.text_output.insert(tkinter.INSERT, "解析完成：共检测到%d个进程，其中%d个FFRT相关进程：\n\n\n" %
107 self.text_output.insert(tkinter.INSERT, "解析完成：共检测到%d个进程，未发现FFRT相关进程：\n\n\n" %
129 … self.text_output.insert(tkinter.INSERT, "检测到进程%d内共%d个线程\n" % (pid, len(self.tname_list)))
135 self.text_output.insert(tkinter.INSERT, "检测进程%d内共%d种task类型\n" % (pid, len(task_names)))
142 self.statistics_output.insert(tkinter.INSERT, line)
162 self.statistics_output.insert(tkinter.INSERT, line)
165 self.statistics_output.insert(tkinter.INSERT, line)
181 self.statistics_output.insert(tkinter.INSERT, line)
210 self.text_output.insert(tkinter.INSERT, "解析结果保存至: %s\n" % out_dir)
[all …]
|
| /ohos5.0/foundation/multimedia/ringtone_library/test/unittest/ringtone_data_extension_test/src/ |
| H A D | ringtone_bundle_manager_test.cpp | 56 RingtoneDataCommand cmd(uri, RINGTONE_TABLE, RingtoneOperationType::INSERT);
66 RingtoneDataCommand cmd(uri, RINGTONE_TABLE, RingtoneOperationType::INSERT);
72 EXPECT_EQ(type, RingtoneOperationType::INSERT);
|
| H A D | ringtone_rdbstore_test.cpp | 64 RingtoneDataCommand cmd(uri, RINGTONE_TABLE, RingtoneOperationType::INSERT);
85 RingtoneDataCommand cmd(uri, RINGTONE_TABLE, RingtoneOperationType::INSERT);
103 RingtoneDataCommand cmd(uri, RINGTONE_TABLE, RingtoneOperationType::INSERT);
115 RingtoneDataCommand cmd(uri, RINGTONE_TABLE, RingtoneOperationType::INSERT);
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/interfaces/include/cloud/ |
| H A D | cloud_store_types.h | 44 INSERT, enumerator
53 INSERT, // INSERT/DELETE/UPDATE are for client use enumerator
124 INSERT = 0x1, enumerator
158 LockAction lockAction = LockAction::INSERT;
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/ |
| H A D | single_ver_natural_store_commit_notify_data.cpp | 76 if (dataType == DataType::INSERT || dataType == DataType::UPDATE) { in InsertCommittedData()
82 if (dataType == DataType::INSERT || dataType == DataType::UPDATE) { in InsertCommittedData()
83 type = DataType::INSERT; in InsertCommittedData()
100 if (dataType == DataType::INSERT) { in InsertEntry()
165 if (type == DataType::INSERT) { in DeleteEntryByKey()
|
| /ohos5.0/foundation/multimedia/ringtone_library/test/unittest/ringtone_scanner_test/src/ |
| H A D | ringtone_default_settings_test.cpp | 62 RingtoneDataCommand cmd(uri, RINGTONE_TABLE, RingtoneOperationType::INSERT);
95 RingtoneDataCommand cmd(uri, RINGTONE_TABLE, RingtoneOperationType::INSERT);
128 RingtoneDataCommand cmd(uri, RINGTONE_TABLE, RingtoneOperationType::INSERT);
157 RingtoneDataCommand cmd(uri, RINGTONE_TABLE, RingtoneOperationType::INSERT);
189 RingtoneDataCommand cmd(uri, RINGTONE_TABLE, RingtoneOperationType::INSERT);
|
| /ohos5.0/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/test/mock/ |
| H A D | db_change_data_mock.cpp | 23 entries_[INSERT].push_back(entry); in DBChangeDataMock()
35 return entries_[INSERT]; in GetEntriesInserted()
|
| /ohos5.0/base/useriam/user_auth_framework/test/unittest/services/mocks/ |
| H A D | mock_context_pool_listener.h | 32 INSERT, enumerator
45 return callback(INSERT, context); in Create()
|
| H A D | mock_resource_node_pool_listener.h | 33 INSERT, enumerator
48 return callback(INSERT, resource); in Create()
|
| /ohos5.0/foundation/multimedia/media_library/frameworks/services/media_cloud_sync_notify_handle/src/ |
| H A D | uri_convert_handler.cpp | 28 {ChangeType::INSERT, NotifyType::NOTIFY_ADD},
39 if (changeType == ChangeType::INSERT) { in AddNewNotify()
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/storage/ |
| H A D | distributeddb_relational_cloud_syncable_storage_test.cpp | 240 asset.flag = static_cast<uint32_t>(i == 1 ? AssetOpType::DELETE : AssetOpType::INSERT); in ConstructMultiDownloadData()
249 asset.flag = static_cast<uint32_t>(AssetOpType::INSERT); in ConstructMultiDownloadData()
804 …EXPECT_EQ(g_cloudStore->FillCloudLogAndAsset(OpType::INSERT, syncData, false, false), -E_NOT_FOUND…
832 EXPECT_EQ(g_cloudStore->FillCloudLogAndAsset(OpType::INSERT, syncData, false, false), E_OK);
839 …EXPECT_EQ(g_cloudStore->FillCloudLogAndAsset(OpType::INSERT, syncData, false, false), -E_NOT_FOUND…
1047 std::vector<OpType> opTypes = { OpType::DELETE, OpType::INSERT, OpType::UPDATE,
1224 ASSERT_EQ(g_storageProxy->FillCloudLogAndAsset(OpType::INSERT, syncData), E_OK);
1426 std::vector<OpType> opTypes = { OpType::INSERT, OpType::INSERT, OpType::DELETE, OpType::UPDATE,
1468 std::vector<OpType> opTypes = { OpType::INSERT, OpType::INSERT, OpType::INSERT };
1560 asset.status = static_cast<uint32_t>(AssetStatus::INSERT);
[all …]
|
| /ohos5.0/foundation/ability/ability_runtime/test/mock/frameworks_kits_test/DemoAbility/ |
| H A D | mock_ability_test.h | 27 #define INSERT 20 macro
39 return INSERT; in Insert()
|
| /ohos5.0/base/useriam/user_auth_framework/test/unittest/services/src/ |
| H A D | resource_node_pool_test.cpp | 152 EXPECT_CALL(callback1, Call(MockResourceNodePoolListener::INSERT, _)).Times(1);
153 EXPECT_CALL(callback2, Call(MockResourceNodePoolListener::INSERT, _)).Times(2);
154 EXPECT_CALL(callback3, Call(MockResourceNodePoolListener::INSERT, _)).Times(3);
188 EXPECT_CALL(callback, Call(MockResourceNodePoolListener::INSERT, _)).Times(1);
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/storage/cloud/ |
| H A D | distributeddb_cloud_meta_data_test.cpp | 220 …EXPECT_EQ(proxyObj.GetLocalWaterMarkByMode(TABLE_NAME_1, CloudWaterType::INSERT, retLocalMark), -E…
222 …EXPECT_EQ(proxyObj.PutWaterMarkByMode(TABLE_NAME_1, CloudWaterType::INSERT, retLocalMark), -E_INVA…
223 proxyObj.ReleaseUploadRecord(TABLE_NAME_1, CloudWaterType::INSERT, retLocalMark);
284 proxyObj.FillCloudGidIfSuccess(OpType::INSERT, data);
373 … EXPECT_EQ(obj.FillCloudLogAndAsset(OpType::INSERT, cloudDataResult, true, true), -E_INVALID_DB);
|
| /ohos5.0/base/security/security_guard/services/data_collect/store/src/ |
| H A D | database_manager.cpp | 55 DbChanged(IDbListener::INSERT, event); in InsertEvent()
65 DbChanged(IDbListener::INSERT, event); in InsertEvent()
70 DbChanged(IDbListener::INSERT, event); in InsertEvent()
|
| /ohos5.0/base/security/security_guard/services/risk_classify/model_manager/include/ |
| H A D | i_db_listener.h | 25 INSERT, enumerator
|
| /ohos5.0/base/security/security_guard/test/unittest/data_collect/database_manager/ |
| H A D | i_db_listener.h | 25 INSERT, enumerator
|