Home
last modified time | relevance | path

Searched refs:query (Results 1 - 25 of 66) sorted by relevance

123

/base/security/asset/test/unittest/inner_kits_rust/src/
H A Dquery_abnormal.rs21 let mut query = AssetMap::new(); in query_invalid_alias() variables
22 query.insert_attr(Tag::Alias, vec![]); in query_invalid_alias()
23 expect_error_eq(ErrCode::InvalidArgument, asset_sdk::Manager::build().unwrap().query(&query).unwrap_err()); in query_invalid_alias()
25 query.insert_attr(Tag::Alias, vec![0; MAX_ALIAS_SIZE + 1]); in query_invalid_alias()
26 expect_error_eq(ErrCode::InvalidArgument, asset_sdk::Manager::build().unwrap().query(&query).unwrap_err()); in query_invalid_alias()
31 let mut query = AssetMap::new(); in query_invalid_accessibility() variables
33 query.insert_attr(Tag::Accessibility, (Accessibility::DeviceUnlocked as u32) + 1); in query_invalid_accessibility()
34 expect_error_eq(ErrCode::InvalidArgument, asset_sdk::Manager::build().unwrap().query( in query_invalid_accessibility()
39 let mut query = AssetMap::new(); query_invalid_auth_type() variables
49 let mut query = AssetMap::new(); query_invalid_sync_type() variables
59 let mut query = AssetMap::new(); query_invalid_label() variables
70 let mut query = AssetMap::new(); query_invalid_return_limit() variables
98 let mut query = AssetMap::new(); query_invalid_return_ordered_by() variables
106 let mut query = AssetMap::new(); query_invalid_return_type() variables
113 let mut query = AssetMap::new(); query_invalid_auth_challenge() variables
123 let mut query = AssetMap::new(); query_invalid_auth_token() variables
135 let mut query = AssetMap::new(); query_with_auth_token_without_auth_challenge() variables
148 let mut query = AssetMap::new(); query_with_auth_challenge_without_auth_token() variables
161 let mut query = AssetMap::new(); query_bool_tag_with_unmatched_type() variables
175 let mut query = AssetMap::new(); query_bytes_tag_with_unmatched_type() variables
196 let mut query = AssetMap::new(); query_number_tag_with_unmatched_type() variables
209 let mut query = AssetMap::new(); query_unsupported_tags() variables
216 let mut query = AssetMap::new(); query_unsupported_tags() variables
[all...]
H A Dpre_query_abnormal.rs21 let mut query = AssetMap::new(); in pre_query_invalid_alias() variables
22 query.insert_attr(Tag::Alias, vec![]); in pre_query_invalid_alias()
23 expect_error_eq(ErrCode::InvalidArgument, asset_sdk::Manager::build().unwrap().pre_query(&query).unwrap_err()); in pre_query_invalid_alias()
25 query.insert_attr(Tag::Alias, vec![0; MAX_ALIAS_SIZE + 1]); in pre_query_invalid_alias()
26 expect_error_eq(ErrCode::InvalidArgument, asset_sdk::Manager::build().unwrap().pre_query(&query).unwrap_err()); in pre_query_invalid_alias()
31 let mut query = AssetMap::new(); in pre_query_invalid_accessibility() variables
32 query.insert_attr(Tag::Accessibility, (Accessibility::DeviceUnlocked as u32) + 1); in pre_query_invalid_accessibility()
33 expect_error_eq(ErrCode::InvalidArgument, asset_sdk::Manager::build().unwrap().pre_query(&query).unwrap_err()); in pre_query_invalid_accessibility()
38 let mut query = AssetMap::new(); in pre_query_invalid_auth_type() variables
39 query in pre_query_invalid_auth_type()
48 let mut query = AssetMap::new(); pre_query_invalid_sync_type() variables
56 let mut query = AssetMap::new(); pre_query_invalid_auth_validity_period() variables
68 let mut query = AssetMap::new(); pre_query_invalid_label() variables
81 let mut query = AssetMap::new(); pre_query_bool_tag_with_unmatched_type() variables
95 let mut query = AssetMap::new(); pre_query_bytes_tag_with_unmatched_type() variables
108 let mut query = AssetMap::new(); pre_query_number_tag_with_unmatched_type() variables
121 let mut query = AssetMap::new(); pre_query_unsupported_tags() variables
129 let mut query = AssetMap::new(); pre_query_unsupported_tags() variables
[all...]
H A Dremove_abnormal.rs21 let mut query = AssetMap::new(); in remove_invalid_alias() variables
22 query.insert_attr(Tag::Alias, vec![]); in remove_invalid_alias()
23 expect_error_eq(ErrCode::InvalidArgument, asset_sdk::Manager::build().unwrap().remove(&query).unwrap_err()); in remove_invalid_alias()
25 query.insert_attr(Tag::Alias, vec![0; MAX_ALIAS_SIZE + 1]); in remove_invalid_alias()
26 expect_error_eq(ErrCode::InvalidArgument, asset_sdk::Manager::build().unwrap().remove(&query).unwrap_err()); in remove_invalid_alias()
31 let mut query = AssetMap::new(); in remove_invalid_accessibility() variables
33 query.insert_attr(Tag::Accessibility, (Accessibility::DeviceUnlocked as u32) + 1); in remove_invalid_accessibility()
34 expect_error_eq(ErrCode::InvalidArgument, asset_sdk::Manager::build().unwrap().remove(&query).unwrap_err()); in remove_invalid_accessibility()
39 let mut query = AssetMap::new(); in remove_invalid_auth_type() variables
40 query in remove_invalid_auth_type()
49 let mut query = AssetMap::new(); remove_invalid_sync_type() variables
59 let mut query = AssetMap::new(); remove_invalid_label() variables
72 let mut query = AssetMap::new(); remove_bool_tag_with_unmatched_type() variables
86 let mut query = AssetMap::new(); remove_bytes_tag_with_unmatched_type() variables
99 let mut query = AssetMap::new(); remove_number_tag_with_unmatched_type() variables
112 let mut query = AssetMap::new(); remove_unsupported_tags() variables
126 let mut query = AssetMap::new(); remove_unsupported_tags() variables
[all...]
H A Dupdate_abnormal.rs25 let query = AssetMap::new(); in update_query_without_alias()
28 asset_sdk::Manager::build().unwrap().update(&query, &update).unwrap_err(), in update_query_without_alias()
38 let mut query = AssetMap::new(); in update_query_invalid_alias() variables
39 query.insert_attr(Tag::Alias, vec![]); in update_query_invalid_alias()
42 asset_sdk::Manager::build().unwrap().update(&query, &update).unwrap_err(), in update_query_invalid_alias()
45 query.insert_attr(Tag::Alias, vec![0; MAX_ALIAS_SIZE + 1]); in update_query_invalid_alias()
48 asset_sdk::Manager::build().unwrap().update(&query, &update).unwrap_err(), in update_query_invalid_alias()
58 let mut query = AssetMap::new(); in update_query_alias_with_unmatched_type() variables
59 query.insert_attr(Tag::Alias, 0); in update_query_alias_with_unmatched_type()
62 asset_sdk::Manager::build().unwrap().update(&query, in update_query_alias_with_unmatched_type()
77 let mut query = AssetMap::new(); update_query_invalid_accessibility() variables
92 let mut query = AssetMap::new(); update_query_invalid_auth_type() variables
112 let mut query = AssetMap::new(); update_query_invalid_sync_type() variables
129 let mut query = AssetMap::new(); update_query_invalid_label() variables
153 let mut query = AssetMap::new(); update_query_bool_tag_with_unmatched_type() variables
177 let mut query = AssetMap::new(); update_query_bytes_tag_with_unmatched_type() variables
200 let mut query = AssetMap::new(); update_query_number_tag_with_unmatched_type() variables
223 let mut query = AssetMap::new(); update_query_unsupported_tags() variables
241 let mut query = AssetMap::new(); update_query_unsupported_tags() variables
254 let mut query = AssetMap::new(); update_empty_attrs() variables
267 let mut query = AssetMap::new(); update_invalid_secret() variables
287 let mut query = AssetMap::new(); update_invalid_label() variables
311 let mut query = AssetMap::new(); update_bytes_tag_with_unmatched_type() variables
336 let mut query = AssetMap::new(); update_unsupported_tags() variables
[all...]
H A Dpre_query.rs22 let mut query = AssetMap::new(); in pre_query_non_exist_with_alias() variables
23 query.insert_attr(Tag::Alias, alias.to_owned()); in pre_query_non_exist_with_alias()
24 expect_error_eq(ErrCode::NotFound, asset_sdk::Manager::build().unwrap().pre_query(&query).unwrap_err()); in pre_query_non_exist_with_alias()
32 let mut query = AssetMap::new(); in pre_query_with_wrong_auth_type() variables
33 query.insert_attr(Tag::Alias, function_name.to_owned()); in pre_query_with_wrong_auth_type()
34 expect_error_eq(ErrCode::NotFound, asset_sdk::Manager::build().unwrap().pre_query(&query).unwrap_err()); in pre_query_with_wrong_auth_type()
43 let mut query = AssetMap::new(); in pre_query_with_wrong_accessibility() variables
44 query.insert_attr(Tag::Accessibility, Accessibility::DeviceUnlocked); in pre_query_with_wrong_accessibility()
45 expect_error_eq(ErrCode::NotFound, asset_sdk::Manager::build().unwrap().pre_query(&query).unwrap_err()); in pre_query_with_wrong_accessibility()
54 let mut query in pre_query_with_unsupported_auth_type() variables
65 let mut query = AssetMap::new(); pre_query_with_wrong_persistent() variables
76 let mut query = AssetMap::new(); pre_query_with_wrong_sync_type() variables
87 let mut query = AssetMap::new(); pre_query_batch_data() variables
102 let mut query = AssetMap::new(); pre_query_single_data() variables
110 let mut query = AssetMap::new(); pre_query_single_data() variables
132 let mut query = AssetMap::new(); pre_query_max_times() variables
[all...]
H A Dpost_query.rs21 let mut query = AssetMap::new(); in post_query_non_exist_with_auth_challenge() variables
22 query.insert_attr(Tag::AuthChallenge, vec![0; CHALLENGE_SIZE]); in post_query_non_exist_with_auth_challenge()
23 assert!(asset_sdk::Manager::build().unwrap().post_query(&query).is_ok()); in post_query_non_exist_with_auth_challenge()
31 let mut query = AssetMap::new(); in post_query_with_wrong_auth_challenge() variables
32 let challenge = asset_sdk::Manager::build().unwrap().pre_query(&query).unwrap(); in post_query_with_wrong_auth_challenge()
34 query.insert_attr(Tag::AuthChallenge, vec![0; CHALLENGE_SIZE]); in post_query_with_wrong_auth_challenge()
35 assert!(asset_sdk::Manager::build().unwrap().post_query(&query).is_ok()); in post_query_with_wrong_auth_challenge()
37 query.insert_attr(Tag::AuthChallenge, challenge); in post_query_with_wrong_auth_challenge()
38 asset_sdk::Manager::build().unwrap().post_query(&query).unwrap(); in post_query_with_wrong_auth_challenge()
47 let mut query in post_query_normal() variables
[all...]
H A Dquery.rs41 let mut query = AssetMap::new(); in query_non_exist_without_alias() variables
42 query.insert_attr(Tag::RequirePasswordSet, true); in query_non_exist_without_alias()
43 expect_error_eq(ErrCode::NotFound, asset_sdk::Manager::build().unwrap().query(&query).unwrap_err()); in query_non_exist_without_alias()
56 let mut query = AssetMap::new(); in query_without_alias_with_wrong_condition() variables
57 query.insert_attr(Tag::RequirePasswordSet, true); in query_without_alias_with_wrong_condition()
58 expect_error_eq(ErrCode::NotFound, asset_sdk::Manager::build().unwrap().query(&query).unwrap_err()); in query_without_alias_with_wrong_condition()
73 let query = AssetMap::new(); in query_without_limit()
75 assert_eq!(asset_num, asset_sdk::Manager::build().unwrap().query( in query_without_limit()
117 let mut query = AssetMap::new(); query_with_limit_with_without_offset() variables
197 let mut query = AssetMap::new(); query_with_order() variables
261 let mut query = AssetMap::new(); query_with_wrong_auth_token() variables
270 let mut query = AssetMap::new(); query_with_wrong_auth_token() variables
299 let mut query = AssetMap::new(); query_with_bytes_tag() variables
313 let mut query = AssetMap::new(); query_with_accessibility() variables
340 let mut query = AssetMap::new(); query_with_return_order_by() variables
363 let mut query = AssetMap::new(); query_with_return_limit() variables
386 let mut query = AssetMap::new(); query_with_return_offset() variables
408 let mut query = AssetMap::new(); query_with_return_type() variables
426 let mut query = AssetMap::new(); query_with_auth_type() variables
440 let mut query = AssetMap::new(); query_with_sync_type() variables
[all...]
H A Dpost_query_abnormal.rs21 let mut query = AssetMap::new(); in post_query_auth_challenge() variables
22 query.insert_attr(Tag::AuthChallenge, vec![0; CHALLENGE_SIZE - 1]); in post_query_auth_challenge()
23 expect_error_eq(ErrCode::InvalidArgument, asset_sdk::Manager::build().unwrap().post_query(&query).unwrap_err()); in post_query_auth_challenge()
25 query.insert_attr(Tag::AuthChallenge, vec![0; CHALLENGE_SIZE + 1]); in post_query_auth_challenge()
26 expect_error_eq(ErrCode::InvalidArgument, asset_sdk::Manager::build().unwrap().post_query(&query).unwrap_err()); in post_query_auth_challenge()
33 let mut query = AssetMap::new(); in post_query_bytes_tag_with_unmatched_type() variables
34 query.insert_attr(tag, 0); in post_query_bytes_tag_with_unmatched_type()
35 expect_error_eq(ErrCode::InvalidArgument, asset_sdk::Manager::build().unwrap().post_query(&query).unwrap_err()); in post_query_bytes_tag_with_unmatched_type()
37 query.insert_attr(tag, true); in post_query_bytes_tag_with_unmatched_type()
38 expect_error_eq(ErrCode::InvalidArgument, asset_sdk::Manager::build().unwrap().post_query(&query) in post_query_bytes_tag_with_unmatched_type()
48 let mut query = AssetMap::new(); post_query_unsupported_tags() variables
65 let mut query = AssetMap::new(); post_query_unsupported_tags() variables
72 let mut query = AssetMap::new(); post_query_unsupported_tags() variables
[all...]
H A Dupdate.rs25 let mut query = AssetMap::new(); in update_same_secret() variables
26 query.insert_attr(Tag::Alias, alias.to_owned()); in update_same_secret()
31 asset_sdk::Manager::build().unwrap().update(&query, &update).unwrap(); in update_same_secret()
42 let mut query = AssetMap::new(); in update_different_secret() variables
43 query.insert_attr(Tag::Alias, alias.to_owned()); in update_different_secret()
50 asset_sdk::Manager::build().unwrap().update(&query, &update).unwrap(); in update_different_secret()
65 let mut query = AssetMap::new(); in update_attr_normal() variables
66 query.insert_attr(Tag::Alias, alias.to_owned()); in update_attr_normal()
72 asset_sdk::Manager::build().unwrap().update(&query, &update).unwrap(); in update_attr_normal()
85 let mut query in update_non_exist() variables
[all...]
/base/security/asset/interfaces/kits/c/src/
H A Dasset_api.c26 int32_t OH_Asset_Remove(const Asset_Attr *query, uint32_t queryCnt) in OH_Asset_Remove() argument
28 return AssetRemove((const AssetAttr *)query, queryCnt); in OH_Asset_Remove()
31 int32_t OH_Asset_Update(const Asset_Attr *query, uint32_t queryCnt, in OH_Asset_Update() argument
34 return AssetUpdate((const AssetAttr *)query, queryCnt, (const AssetAttr *)attributesToUpdate, updateCnt); in OH_Asset_Update()
37 int32_t OH_Asset_PreQuery(const Asset_Attr *query, uint32_t queryCnt, Asset_Blob *challenge) in OH_Asset_PreQuery() argument
39 return AssetPreQuery((const AssetAttr *)query, queryCnt, (AssetBlob *)challenge); in OH_Asset_PreQuery()
42 int32_t OH_Asset_Query(const Asset_Attr *query, uint32_t queryCnt, Asset_ResultSet *resultSet) in OH_Asset_Query() argument
44 return AssetQuery((const AssetAttr *)query, queryCnt, (AssetResultSet *)resultSet); in OH_Asset_Query()
/base/security/asset/frameworks/c/system_api/src/
H A Dasset_system_api.c24 int32_t remove_asset(const AssetAttr *query, uint32_t query_cnt);
25 int32_t update_asset(const AssetAttr *query, uint32_t query_cnt,
27 int32_t pre_query_asset(const AssetAttr *query, uint32_t query_cnt, AssetBlob *challenge);
28 int32_t query_asset(const AssetAttr *query, uint32_t query_cnt, AssetResultSet *result_set);
36 int32_t AssetRemove(const AssetAttr *query, uint32_t queryCnt) in AssetRemove() argument
38 return remove_asset(query, queryCnt); in AssetRemove()
41 int32_t AssetUpdate(const AssetAttr *query, uint32_t queryCnt, in AssetUpdate() argument
44 return update_asset(query, queryCnt, attributesToUpdate, updateCnt); in AssetUpdate()
47 int32_t AssetPreQuery(const AssetAttr *query, uint32_t queryCnt, AssetBlob *challenge) in AssetPreQuery() argument
49 return pre_query_asset(query, queryCn in AssetPreQuery()
52 AssetQuery(const AssetAttr *query, uint32_t queryCnt, AssetResultSet *resultSet) AssetQuery() argument
[all...]
/base/security/asset/interfaces/inner_kits/rs/src/
H A Dlib.rs62 /// Remove one or more Assets that match a search query.
63 pub fn remove(&self, query: &AssetMap) -> Result<()> { in remove()
66 serialize_map(query, &mut parcel)?; in remove()
71 /// Update an Asset that matches a search query.
72 pub fn update(&self, query: &AssetMap, attributes_to_update: &AssetMap) -> Result<()> { in update()
75 serialize_map(query, &mut parcel)?; in update()
82 pub fn pre_query(&self, query: &AssetMap) -> Result<Vec<u8>> { in pre_query()
85 serialize_map(query, &mut parcel)?; in pre_query()
91 /// Query one or more Assets that match a search query.
92 pub fn query( functions
[all...]
/base/security/asset/interfaces/inner_kits/c/inc/
H A Dasset_system_api.h49 * @param query Pointer to the conditions for removing the assets.
54 int32_t AssetRemove(const AssetAttr *query, uint32_t queryCnt);
59 * @param query Pointer to the conditions for updating the asset.
66 int32_t AssetUpdate(const AssetAttr *query, uint32_t queryCnt,
72 * @param query Pointer to the search criteria of the asset.
78 int32_t AssetPreQuery(const AssetAttr *query, uint32_t queryCnt, AssetBlob *challenge);
83 * @param query Pointer to the search criteria.
85 * @param resultSet Pointer to the query result obtained.
89 int32_t AssetQuery(const AssetAttr *query, uint32_t queryCnt, AssetResultSet *resultSet);
92 * @brief Processes data after the query o
[all...]
/base/security/asset/interfaces/kits/c/inc/
H A Dasset_api.h81 * @param query Pointer to the conditions for removing the assets.
99 int32_t OH_Asset_Remove(const Asset_Attr *query, uint32_t queryCnt);
104 * @param query Pointer to the conditions for updating the asset.
127 int32_t OH_Asset_Update(const Asset_Attr *query, uint32_t queryCnt,
133 * @param query Pointer to the search criteria of the asset.
155 int32_t OH_Asset_PreQuery(const Asset_Attr *query, uint32_t queryCnt, Asset_Blob *challenge);
160 * @param query Pointer to the search criteria.
162 * @param resultSet Pointer to the query result obtained.
182 int32_t OH_Asset_Query(const Asset_Attr *query, uint32_t queryCnt, Asset_ResultSet *resultSet);
185 * @brief Processes data after the query o
[all...]
/base/security/asset/services/core_service/src/operations/
H A Doperation_post_query.rs16 //! This module is used to clear resources after query the Asset that required secondary identity authentication.
27 fn check_arguments(query: &AssetMap) -> Result<()> { in check_arguments()
28 common::check_required_tags(query, &REQUIRED_ATTRS)?; in check_arguments()
32 common::check_system_permission(query)?; in check_arguments()
33 common::check_value_validity(query) in check_arguments()
H A Doperation_query.rs16 //! This module is used to query the Asset, including single and batch query.
70 fn exec_crypto(calling_info: &CallingInfo, query: &AssetMap, db_data: &mut DbMap) -> Result<()> { in exec_crypto()
71 common::check_required_tags(query, &AUTH_QUERY_ATTRS)?; in exec_crypto()
72 let challenge = query.get_bytes_attr(&Tag::AuthChallenge)?; in exec_crypto()
73 let auth_token = query.get_bytes_attr(&Tag::AuthToken)?; in exec_crypto()
88 fn query_all(calling_info: &CallingInfo, db_data: &mut DbMap, query: &AssetMap) -> Result<Vec<AssetMap>> { in query_all()
89 let mut db = create_db_instance(query, calling_info)?; in query_all()
96 exec_crypto(calling_info, query, &mut results[0])?; in query_all()
172 pub(crate) fn query(calling_inf
[all...]
H A Doperation_update.rs68 fn check_arguments(query: &AssetMap, attrs_to_update: &AssetMap) -> Result<()> { in check_arguments()
69 // Check attributes used to query. in check_arguments()
70 common::check_required_tags(query, &QUERY_REQUIRED_ATTRS)?; in check_arguments()
75 common::check_tag_validity(query, &valid_tags)?; in check_arguments()
76 common::check_value_validity(query)?; in check_arguments()
77 common::check_system_permission(query)?; in check_arguments()
96 pub(crate) fn update(calling_info: &CallingInfo, query: &AssetMap, update: &AssetMap) -> Result<()> {
97 check_arguments(query, update)?;
99 let mut query_db_data = common::into_db_map(query);
106 let mut db = create_db_instance(query, calling_inf
[all...]
H A Doperation_add.rs49 query: &DbMap, in resolve_conflict()
55 db.replace_datas(query, false, db_data) in resolve_conflict()
58 let mut condition = query.clone(); in resolve_conflict()
73 let mut query = DbMap::new(); in get_query_condition() variables
74 query.insert(column::ALIAS, Value::Bytes(alias.clone())); in get_query_condition()
75 query.insert(column::OWNER, Value::Bytes(calling_info.owner_info().clone())); in get_query_condition()
76 query.insert(column::OWNER_TYPE, Value::Number(calling_info.owner_type())); in get_query_condition()
77 Ok(query) in get_query_condition()
157 let query = get_query_condition(calling_info, attributes)?; in local_add()
161 if db.is_data_exists(&query, fals in local_add()
[all...]
H A Doperation_remove.rs50 pub(crate) fn remove(calling_info: &CallingInfo, query: &AssetMap) -> Result<()> {
51 check_arguments(query)?;
53 let mut db_data = common::into_db_map(query);
60 let mut db = create_db_instance(query, calling_info)?;
76 common::inform_asset_ext(calling_info, query);
H A Doperation_pre_query.rs54 0 => log_throw_error!(ErrCode::NotFound, "[FATAL][SA]No data that meets the query conditions is found."), in query_key_attrs()
67 pub(crate) fn pre_query(calling_info: &CallingInfo, query: &AssetMap) -> Result<Vec<u8>> {
68 check_arguments(query)?;
70 let mut db_data = common::into_db_map(query);
74 let (access_type, require_password_set) = query_key_attrs(calling_info, &db_data, query)?;
75 let valid_time = match query.get(&Tag::AuthValidityPeriod) {
/base/security/asset/services/core_service/src/
H A Dlib.rs176 fn remove(&self, calling_info: &CallingInfo, query: &AssetMap) -> Result<()> { in remove()
177 execute!(operations::remove, calling_info, query) in remove()
180 fn update(&self, calling_info: &CallingInfo, query: &AssetMap, attributes_to_update: &AssetMap) -> Result<()> { in update()
181 execute!(operations::update, calling_info, query, attributes_to_update) in update()
184 fn pre_query(&self, calling_info: &CallingInfo, query: &AssetMap) -> Result<Vec<u8>> { in pre_query()
185 execute!(operations::pre_query, calling_info, query) in pre_query()
188 fn query(&self, calling_info: &CallingInfo, query: &AssetMap) -> Result<Vec<AssetMap>> { in query() functions
189 execute!(operations::query, calling_info, query) in query()
[all...]
/base/hiviewdfx/hiview/plugins/faultlogger/service/
H A Dfaultlog_database.cpp129 auto query = EventStore::SysEventDao::BuildQuery(domain, faultNames); in CreateQueries() local
130 if (query == nullptr) { in CreateQueries()
133 query->And(lowerCaseCond); in CreateQueries()
134 query->Select(QUERY_ITEMS).Order("time_", false); in CreateQueries()
135 queries.push_back(query); in CreateQueries()
145 auto query = EventStore::SysEventDao::BuildQuery(HiSysEvent::Domain::RELIABILITY, name); in CreateQueries() local
146 if (query == nullptr) { in CreateQueries()
149 query->And(upperCaseCond); in CreateQueries()
150 query->Select(QUERY_ITEMS).Order("time_", false); in CreateQueries()
151 queries.push_back(query); in CreateQueries()
[all...]
/base/hiviewdfx/hiview/adapter/plugins/eventservice/service/idl/include/
H A Devent_query_wrapper_builder.h54 BaseEventQueryWrapper(std::shared_ptr<EventStore::SysEventQuery> query);
61 void SetSysEventQuery(std::shared_ptr<EventStore::SysEventQuery> query);
113 TimeStampEventQueryWrapper(std::shared_ptr<EventStore::SysEventQuery> query) in TimeStampEventQueryWrapper() argument
114 : BaseEventQueryWrapper(query) {} in TimeStampEventQueryWrapper()
124 SeqEventQueryWrapper(std::shared_ptr<EventStore::SysEventQuery> query) in SeqEventQueryWrapper() argument
125 : BaseEventQueryWrapper(query) {} in SeqEventQueryWrapper()
147 std::shared_ptr<EventStore::SysEventQuery> query);
/base/notification/distributed_notification_service/services/ans/test/unittest/mock/include/
H A Dmock_single_kv_store.h46 * @brief Get all entries in this store by query.
48 * @param query Indicates the query object.
52 Status GetEntries(const DataQuery &query, std::vector<Entry> &entries) const override;
66 * @param query Indicates the query object.
70 Status GetResultSet(const DataQuery &query, std::shared_ptr<KvStoreResultSet> &resultSet) const override;
81 * @brief Get the number of result by query.
83 * @param query Indicates the query objec
[all...]
/base/notification/distributed_notification_service/services/distributed/test/unittest/distributed_screen_status_manager_branch_test/
H A Dmock_single_kv_store.cpp40 Status MockSingleKvStore::GetEntries(const DataQuery &query, std::vector<Entry> &entries) const in GetEntries() argument
51 const DataQuery &query, std::shared_ptr<KvStoreResultSet> &resultSet) const in GetResultSet()
61 Status MockSingleKvStore::GetCount(const DataQuery &query, int &result) const in GetCount() argument
170 const DataQuery &query, std::shared_ptr<KvStoreSyncCallback> syncCallback) in Sync()
175 Status MockSingleKvStore::SubscribeWithQuery(const std::vector<std::string> &deviceIds, const DataQuery &query) in SubscribeWithQuery() argument
180 Status MockSingleKvStore::UnsubscribeWithQuery(const std::vector<std::string> &deviceIds, const DataQuery &query) in UnsubscribeWithQuery() argument
50 GetResultSet( const DataQuery &query, std::shared_ptr<KvStoreResultSet> &resultSet) const GetResultSet() argument
169 Sync(const std::vector<std::string> &deviceIds, SyncMode mode, const DataQuery &query, std::shared_ptr<KvStoreSyncCallback> syncCallback) Sync() argument

Completed in 8 milliseconds

123