Home
last modified time | relevance | path

Searched refs:observer1 (Results 1 - 14 of 14) sorted by relevance

/foundation/ability/ability_runtime/test/unittest/dataobs_mgr_inner_ext_test/
H A Ddataobs_mgr_inner_ext_test.cpp183 sptr<MockDataAbilityObserverStub> observer1(new (std::nothrow) MockDataAbilityObserverStub()); in HWTEST_F()
187 EXPECT_EQ(dataObsMgrInnerExt->HandleRegisterObserver(uri1, observer1), SUCCESS); in HWTEST_F()
194 EXPECT_EQ(dataObsMgrInnerExt->HandleRegisterObserver(uri3, observer1), SUCCESS); in HWTEST_F()
197 EXPECT_TRUE(UrisEqual(observer1->changeInfo_.uris_, { uri1 })); in HWTEST_F()
201 observer1->ReSet(); in HWTEST_F()
205 EXPECT_TRUE(UrisEqual(observer1->changeInfo_.uris_, { uri3 })); in HWTEST_F()
300 sptr<MockDataAbilityObserverStub> observer1(new (std::nothrow) MockDataAbilityObserverStub()); in HWTEST_F()
301 EXPECT_EQ(dataObsMgrInnerExt->HandleRegisterObserver(uri1, observer1, true), SUCCESS); in HWTEST_F()
302 EXPECT_EQ(dataObsMgrInnerExt->HandleRegisterObserver(uri123, observer1, true), SUCCESS); in HWTEST_F()
308 EXPECT_TRUE(UrisEqual(observer1 in HWTEST_F()
739 sptr<MockDataAbilityObserverStub> observer1 = (new (std::nothrow) MockDataAbilityObserverStub()); HWTEST_F() local
779 sptr<MockDataAbilityObserverStub> observer1 = (new (std::nothrow) MockDataAbilityObserverStub()); HWTEST_F() local
[all...]
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/interfaces/
H A Ddistributeddb_interfaces_relational_observer_test.cpp103 * @tc.steps:step1. register observer1 twice in HWTEST_F()
106 RelationalStoreObserverUnitTest *observer1 = new (std::nothrow) RelationalStoreObserverUnitTest(); in HWTEST_F() local
107 EXPECT_NE(observer1, nullptr); in HWTEST_F()
108 EXPECT_EQ(g_delegate->RegisterObserver(observer1), OK); in HWTEST_F()
109 EXPECT_EQ(g_delegate->RegisterObserver(observer1), ALREADY_SET); in HWTEST_F()
112 * @tc.steps:step2. unregister observer1 twice in HWTEST_F()
115 EXPECT_EQ(g_delegate->UnRegisterObserver(observer1), OK); in HWTEST_F()
116 EXPECT_EQ(g_delegate->UnRegisterObserver(observer1), NOT_FOUND); in HWTEST_F()
119 * @tc.steps:step3. register observer1 again in HWTEST_F()
122 EXPECT_EQ(g_delegate->RegisterObserver(observer1), O in HWTEST_F()
[all...]
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/moduletest/src/
H A Ddistributeddb_kv_observer_test.cpp203 KvStoreObserverImpl observer1, observer2; in HWTEST_F() local
205 * @tc.steps: step1. Register observer1 bases on kv db. in HWTEST_F()
208 DBStatus status = DistributedTestTools::RegisterObserver(g_observerDelegate, &observer1); in HWTEST_F()
213 * @tc.expected: step2. put successfully and the observer1 return 1 inserting data info. in HWTEST_F()
220 EXPECT_TRUE(VerifyObserverResult(observer1, CHANGED_ONE_TIME, INSERT_LIST, insertEntries)); in HWTEST_F()
221 observer1.Clear(); in HWTEST_F()
238 EXPECT_TRUE(VerifyObserverResult(observer1, CHANGED_ONE_TIME, INSERT_LIST, insertEntries)); in HWTEST_F()
239 observer1.Clear(); in HWTEST_F()
250 * @tc.expected: step6. put successfully and the observer1,2 return 1 inserting data info individually. in HWTEST_F()
257 EXPECT_TRUE(VerifyObserverResult(observer1, CHANGED_ONE_TIM in HWTEST_F()
430 KvStoreObserverImpl observer1; HWTEST_F() local
477 KvStoreObserverImpl observer1; HWTEST_F() local
852 KvObserverVerifyInsert(KvStoreDelegate *&delegate1, KvStoreDelegate *&delegate2, KvStoreObserverImpl &observer1, KvStoreObserverImpl &observer2) KvObserverVerifyInsert() argument
894 KvObserverVerifyUpdateAndDelete(KvStoreDelegate *&delegate1, KvStoreDelegate *&delegate2, KvStoreObserverImpl &observer1, KvStoreObserverImpl &observer2, vector<Entry> &entriesBatch) KvObserverVerifyUpdateAndDelete() argument
960 KvStoreObserverImpl observer1, observer2; HWTEST_F() local
1018 KvObserverVerifyTransactionCommit(KvStoreObserverImpl &observer1, KvStoreDelegate *&delegate1, KvStoreDelegateManager *&transactionManager1) KvObserverVerifyTransactionCommit() argument
1115 KvStoreObserverImpl observer1; HWTEST_F() local
[all...]
H A Ddistributeddb_kv_observer_snap_test.cpp204 KvStoreObserverImpl observer1, observer2; in HWTEST_F() local
207 * @tc.steps: step1. Register observer1 bases on kv db snap. in HWTEST_F()
210 KvStoreSnapshotDelegate *snapShot1 = DistributedTestTools::RegisterSnapObserver(g_observerSnapDelegate, &observer1); in HWTEST_F()
215 * @tc.expected: step2. put successfully and the observer1 return 1 inserting data info. in HWTEST_F()
221 EXPECT_TRUE(VerifyObserverResult(observer1, CHANGED_ONE_TIME, INSERT_LIST, insertEntries1)); in HWTEST_F()
222 observer1.Clear(); in HWTEST_F()
239 EXPECT_TRUE(VerifyObserverResult(observer1, CHANGED_ONE_TIME, INSERT_LIST, insertEntries1)); in HWTEST_F()
240 observer1.Clear(); in HWTEST_F()
251 * @tc.expected: step6. put successfully and the observer1,2 return 1 inserting data info individually. in HWTEST_F()
257 EXPECT_TRUE(VerifyObserverResult(observer1, CHANGED_ONE_TIM in HWTEST_F()
431 KvStoreObserverImpl observer1; HWTEST_F() local
486 KvStoreObserverImpl observer1; HWTEST_F() local
994 KvStoreObserverImpl observer1, observer2; HWTEST_F() local
1063 ObserverSnapVerifyTransactionCommit(KvStoreDelegate *&delegate1, KvStoreObserverImpl &observer1) ObserverSnapVerifyTransactionCommit() argument
1160 KvStoreObserverImpl observer1; HWTEST_F() local
[all...]
H A Ddistributeddb_nb_local_batch_crud_test.cpp650 KvStoreObserverImpl observer1, observer2, observer3; in HWTEST_F() local
655 EXPECT_EQ(g_nbLocalBatchDelegate->RegisterObserver(KEY_1, OBSERVER_CHANGES_LOCAL_ONLY, &observer1), OK); in HWTEST_F()
661 * @tc.expected: step2. PutLocalBatch and observer1, and observer2 was triggered but observer3 was not triggered. in HWTEST_F()
669 EXPECT_TRUE(VerifyObserverResult(observer1, CHANGED_ONE_TIME, INSERT_LIST, changeList)); in HWTEST_F()
677 * @tc.expected: step3. PutLocalBatch success and observer1 was not triggered, observer2 was triggered update mode, in HWTEST_F()
680 observer1.Clear(); in HWTEST_F()
686 EXPECT_TRUE(VerifyObserverResult(observer1, CHANGED_ZERO_TIME, INSERT_LIST, changeList)); in HWTEST_F()
704 KvStoreObserverImpl observer1, observer2, observer3; in HWTEST_F() local
714 EXPECT_EQ(g_nbLocalBatchDelegate->RegisterObserver(KEY_1, OBSERVER_CHANGES_LOCAL_ONLY, &observer1), OK); in HWTEST_F()
720 * @tc.expected: step2. DeleteLocalBatch success and observer1, an in HWTEST_F()
755 KvStoreObserverImpl observer1, observer2, observer3; HWTEST_F() local
816 KvStoreObserverImpl observer1, observer2, observer3; HWTEST_F() local
[all...]
H A Ddistributeddb_nb_batch_crud_test.cpp742 KvStoreObserverImpl observer1, observer2, observer3; in HWTEST_F() local
751 * @tc.steps: step1. register observer1,observer2,observer3 for k1,k2,k3 with in HWTEST_F()
755 EXPECT_EQ(g_nbBatchCrudDelegate->RegisterObserver(KEY_1, OBSERVER_CHANGES_NATIVE, &observer1), OK); in HWTEST_F()
761 * @tc.expected: step2. putbatch successfully and the callback of observer1 and observer2 in HWTEST_F()
766 EXPECT_TRUE(VerifyObserverResult(observer1, CHANGED_ONE_TIME, ListType::INSERT_LIST, observerCallbackEntries)); in HWTEST_F()
770 observer1.Clear(); in HWTEST_F()
777 * the callback of observer3 is once INSERT_LIST, there is no callback of observer1. in HWTEST_F()
781 EXPECT_TRUE(VerifyObserverResult(observer1, CHANGED_ZERO_TIME, ListType::UPDATE_LIST, observerCallbackEntries)); in HWTEST_F()
798 KvStoreObserverImpl observer1, observer2, observer3; in HWTEST_F() local
817 * @tc.steps: step2. register observer1,observer in HWTEST_F()
852 KvStoreObserverImpl observer1, observer2, observer3; HWTEST_F() local
913 KvStoreObserverImpl observer1, observer2; HWTEST_F() local
2242 KvStoreObserverImpl observer1, observer2; HWTEST_F() local
2321 KvStoreObserverImpl observer1, observer2; HWTEST_F() local
2374 KvStoreObserverImpl observer1, observer2, observer3, observer4; HWTEST_F() local
[all...]
H A Ddistributeddb_kv_batch_crud_test.cpp805 KvStoreObserverSnapImpl observer1; in HWTEST_F() local
822 KvStoreSnapshotDelegate *snap1 = DistributedTestTools::RegisterSnapObserver(g_kvStoreBatchDelegate, &observer1); in HWTEST_F()
842 void RegisterSnapAgainAndCheck1(KvStoreObserverSnapImpl &observer1, KvStoreSnapshotDelegate *&snap1, in RegisterSnapAgainAndCheck1() argument
853 snap1 = DistributedTestTools::RegisterSnapObserver(g_kvStoreBatchDelegate, &observer1); in RegisterSnapAgainAndCheck1()
1054 KvStoreObserverSnapImpl observer1, observer2, observer3, observer4, observer5, observer6, observer7, observer8; in HWTEST_F() local
1055 KvStoreSnapshotDelegate *snap1 = DistributedTestTools::RegisterSnapObserver(g_kvStoreBatchDelegate, &observer1); in HWTEST_F()
1076 RegisterSnapAgainAndCheck1(observer1, snap1, entries1, keyPrefix); in HWTEST_F()
H A Ddistributeddb_nb_observer_test.cpp172 * @tc.steps: step1. register local observer1 use OBSERVER_CHANGES_LOCAL_ONLY mode. in HWTEST_F()
184 * @tc.steps: step3. verify that if observer1 will be triggered when put (KEY_1, VALUE_1) to local db. in HWTEST_F()
185 * @tc.expected: step3. observer1 will be response but observer2 won't. in HWTEST_F()
195 * @tc.steps: step4. verify that if observer1 will be triggered when delete (KEY_1, VALUE_1) from local db. in HWTEST_F()
196 * @tc.expected: step4. observer1 will be response but observer2 won't. in HWTEST_F()
207 * @tc.expected: step5. observer2 will be response but observer1 won't. in HWTEST_F()
218 * @tc.expected: step6. observer1 will be response but observer2 won't. in HWTEST_F()
697 KvStoreObserverImpl observer1, observer2, observer3, observer4, observer; in HWTEST_F() local
700 g_nbObserverDelegate->RegisterObserver(KEY_1, OBSERVER_CHANGES_LOCAL_ONLY, &observer1); in HWTEST_F()
725 g_nbObserverDelegate->UnRegisterObserver(&observer1); in HWTEST_F()
744 KvStoreObserverImpl observer1, observer2, observer3, observer4, observer5, observer6; HWTEST_F() local
[all...]
/foundation/distributeddatamgr/relational_store/test/ndk/unittest/
H A Drdb_store_test.cpp1224 Rdb_DataObserver observer1 = { nullptr, { callback1 } }; in HWTEST_F() local
1229 EXPECT_EQ(OH_Rdb_Subscribe(storeTestRdbStore_, RDB_SUBSCRIBE_TYPE_LOCAL_DETAILS, &observer1), RDB_OK); in HWTEST_F()
1240 EXPECT_EQ(OH_Rdb_Unsubscribe(storeTestRdbStore_, RDB_SUBSCRIBE_TYPE_LOCAL_DETAILS, &observer1), RDB_OK); in HWTEST_F()
1262 Rdb_DataObserver observer1 = { nullptr, { callback1 } }; in HWTEST_F() local
1267 EXPECT_EQ(OH_Rdb_Subscribe(storeTestRdbStore_, RDB_SUBSCRIBE_TYPE_LOCAL_DETAILS, &observer1), RDB_OK); in HWTEST_F()
1269 EXPECT_EQ(OH_Rdb_Unsubscribe(storeTestRdbStore_, RDB_SUBSCRIBE_TYPE_LOCAL_DETAILS, &observer1), RDB_OK); in HWTEST_F()
1426 Rdb_DataObserver observer1 = { nullptr, { callback1 } }; in HWTEST_F() local
1431 EXPECT_EQ(OH_Rdb_Subscribe(storeTestRdbStore_, RDB_SUBSCRIBE_TYPE_LOCAL_DETAILS, &observer1), RDB_OK); in HWTEST_F()
1432 EXPECT_EQ(OH_Rdb_Subscribe(storeTestRdbStore_, RDB_SUBSCRIBE_TYPE_LOCAL_DETAILS, &observer1), RDB_OK); in HWTEST_F()
1475 Rdb_DataObserver observer1 in HWTEST_F() local
[all...]
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/
H A Ddistributeddb_relational_ver_p2p_sync_test.cpp786 static void ReleaseForObserver007(RelationalStoreDelegate *rdb1, RelationalStoreObserverUnitTest *observer1, in ReleaseForObserver007() argument
791 delete observer1; in ReleaseForObserver007()
792 observer1 = nullptr; in ReleaseForObserver007()
1901 * @tc.steps: step5. open store with observer1 in HWTEST_F()
1904 auto observer1 = new (std::nothrow) RelationalStoreObserverUnitTest(); in HWTEST_F() local
1905 ASSERT_NE(observer1, nullptr); in HWTEST_F()
1907 option.observer = observer1; in HWTEST_F()
1919 * @tc.steps: step6. close store and delete observer1 in HWTEST_F()
1922 ReleaseForObserver007(rdb1, observer1, observer); in HWTEST_F()
1925 void RegisterNewObserver(RelationalStoreDelegate *rdb1, RelationalStoreObserverUnitTest *observer1, in RegisterNewObserver() argument
2017 auto observer1 = new (std::nothrow) RelationalStoreObserverUnitTest(); HWTEST_F() local
[all...]
/foundation/distributeddatamgr/kv_store/frameworks/innerkitsimpl/distributeddatafwk/test/unittest/
H A Dlocal_subscribe_store_test.cpp265 auto observer1 = std::make_shared<KvStoreObserverUnitTest>(); in HWTEST_F() local
269 Status status = kvStore->SubscribeKvStore(subscribeType, observer1); in HWTEST_F()
280 EXPECT_EQ(static_cast<int>(observer1->GetCallCount()), 1); in HWTEST_F()
284 status = kvStore->UnSubscribeKvStore(subscribeType, observer1); in HWTEST_F()
804 auto observer1 = std::make_shared<KvStoreObserverUnitTest>(); in HWTEST_F() local
808 Status status = kvStore->SubscribeKvStore(subscribeType, observer1); in HWTEST_F()
819 EXPECT_EQ(static_cast<int>(observer1->GetCallCount()), 1); in HWTEST_F()
820 EXPECT_EQ(static_cast<int>(observer1->insertEntries_.size()), 1); in HWTEST_F()
821 EXPECT_EQ("Id1", observer1->insertEntries_[0].key.ToString()); in HWTEST_F()
822 EXPECT_EQ("subscribe", observer1 in HWTEST_F()
[all...]
H A Dlocal_subscribe_device_store_test.cpp252 auto observer1 = std::make_shared<DeviceObserverTest>(); in HWTEST_F() local
256 Status status = kvStore_->SubscribeKvStore(subscribeType, observer1); in HWTEST_F()
267 EXPECT_EQ(static_cast<int>(observer1->GetCallCount()), 1); in HWTEST_F()
271 status = kvStore_->UnSubscribeKvStore(subscribeType, observer1); in HWTEST_F()
792 auto observer1 = std::make_shared<DeviceObserverTest>(); in HWTEST_F() local
796 Status status = kvStore_->SubscribeKvStore(subscribeType, observer1); in HWTEST_F()
807 EXPECT_EQ(static_cast<int>(observer1->GetCallCount()), 1); in HWTEST_F()
808 EXPECT_EQ(static_cast<int>(observer1->insertEntries_.size()), 1); in HWTEST_F()
809 EXPECT_EQ("Id1", observer1->insertEntries_[0].key.ToString()); in HWTEST_F()
810 EXPECT_EQ("subscribe", observer1 in HWTEST_F()
[all...]
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/storage/cloud/
H A Ddistributeddb_cloud_check_sync_test.cpp983 auto observer1 = new (std::nothrow) RelationalStoreObserverUnitTest(); in HWTEST_F() local
984 ASSERT_NE(observer1, nullptr); in HWTEST_F()
985 option.observer = observer1; in HWTEST_F()
1009 EXPECT_EQ(observer1->GetCloudCallCount(), 1u); in HWTEST_F()
1026 EXPECT_EQ(observer1->GetCloudCallCount(), 2u); // 2 is observer1 triggered times in HWTEST_F()
1029 delete observer1; in HWTEST_F()
1030 observer1 = nullptr; in HWTEST_F()
/foundation/ability/ability_runtime/test/unittest/app_mgr_service_inner_test/
H A Dapp_mgr_service_inner_test.cpp2644 sptr<IConfigurationObserver> observer1; in HWTEST_F() local
2645 appMgrServiceInner->configurationObservers_.push_back({ observer1, 100 }); in HWTEST_F()

Completed in 31 milliseconds