| /test/xts/acts/distributed_schedule_lite/system_ability_manager_hal/src/ |
| H A D | broadcast_subscribe_func_test.c | 134 Subscriber *subscriber = &fapi->subscriber;
variable
135 if (subscriber == NULL) {
140 int result = subscriber->AddTopic((IUnknown *)fapi, &topic0);
157 Subscriber *subscriber = &fapi->subscriber;
variable
158 if (subscriber == NULL) {
163 subscriber->AddTopic((IUnknown *)fapi, &topic0);
165 int result = subscriber->AddTopic((IUnknown *)fapi, NULL);
168 result = subscriber
185 Subscriber *subscriber = &fapi->subscriber; global() variable
212 Subscriber *subscriber = &fapi->subscriber; global() variable
237 Subscriber *subscriber = &fapi->subscriber; global() variable
264 Subscriber *subscriber = &fapi->subscriber; global() variable
292 Subscriber *subscriber = &fapi->subscriber; global() variable
320 Subscriber *subscriber = &fapi->subscriber; global() variable
351 Subscriber *subscriber = &fapi->subscriber; global() variable
380 Subscriber *subscriber = &fapi->subscriber; global() variable
410 Subscriber *subscriber = &fapi->subscriber; global() variable
446 Subscriber *subscriber = &fapi->subscriber; global() variable
477 Subscriber *subscriber = &fapi->subscriber; global() variable
508 Subscriber *subscriber = &fapi->subscriber; global() variable
[all...] |
| H A D | broadcast_publish_func_test.c | 135 Subscriber *subscriber = &fapi->subscriber;
variable
136 if (subscriber == NULL) {
145 subscriber->AddTopic((IUnknown *)fapi, &topic0);
146 subscriber->Subscribe((IUnknown *)fapi, &topic0, &c1);
147 subscriber->Subscribe((IUnknown *)fapi, &topic0, &c2);
166 Subscriber *subscriber = &fapi->subscriber;
variable
167 if (subscriber == NULL) {
176 subscriber
198 Subscriber *subscriber = &fapi->subscriber; global() variable
232 Subscriber *subscriber = &fapi->subscriber; global() variable
263 Subscriber *subscriber = &fapi->subscriber; global() variable
293 Subscriber *subscriber = &fapi->subscriber; global() variable
324 Subscriber *subscriber = &fapi->subscriber; global() variable
[all...] |
| /test/xts/acts/distributed_schedule_lite/system_ability_manager_posix/src/ |
| H A D | BroadcastSubscribeTest.cpp | 134 Subscriber *subscriber = &fapi->subscriber; in HWTEST_F() local
135 if (subscriber == nullptr) { in HWTEST_F()
140 int result = subscriber->AddTopic((IUnknown *)fapi, &topic0); in HWTEST_F()
157 Subscriber *subscriber = &fapi->subscriber; in HWTEST_F() local
158 if (subscriber == nullptr) { in HWTEST_F()
163 subscriber->AddTopic((IUnknown *)fapi, &topic0); in HWTEST_F()
165 int result = subscriber->AddTopic((IUnknown *)fapi, nullptr); in HWTEST_F()
168 result = subscriber in HWTEST_F()
185 Subscriber *subscriber = &fapi->subscriber; HWTEST_F() local
212 Subscriber *subscriber = &fapi->subscriber; HWTEST_F() local
241 Subscriber *subscriber = &fapi->subscriber; HWTEST_F() local
268 Subscriber *subscriber = &fapi->subscriber; HWTEST_F() local
296 Subscriber *subscriber = &fapi->subscriber; HWTEST_F() local
323 Subscriber *subscriber = &fapi->subscriber; HWTEST_F() local
354 Subscriber *subscriber = &fapi->subscriber; HWTEST_F() local
383 Subscriber *subscriber = &fapi->subscriber; HWTEST_F() local
412 Subscriber *subscriber = &fapi->subscriber; HWTEST_F() local
442 Subscriber *subscriber = &fapi->subscriber; HWTEST_F() local
478 Subscriber *subscriber = &fapi->subscriber; HWTEST_F() local
509 Subscriber *subscriber = &fapi->subscriber; HWTEST_F() local
540 Subscriber *subscriber = &fapi->subscriber; HWTEST_F() local
[all...] |
| H A D | BroadcastPublishTest.cpp | 138 Subscriber *subscriber = &fapi->subscriber; in HWTEST_F() local
139 if (subscriber == nullptr) { in HWTEST_F()
148 subscriber->AddTopic((IUnknown *)fapi, &topic0); in HWTEST_F()
149 subscriber->Subscribe((IUnknown *)fapi, &topic0, &c1); in HWTEST_F()
150 subscriber->Subscribe((IUnknown *)fapi, &topic0, &c2); in HWTEST_F()
169 Subscriber *subscriber = &fapi->subscriber; in HWTEST_F() local
170 if (subscriber == nullptr) { in HWTEST_F()
179 subscriber in HWTEST_F()
201 Subscriber *subscriber = &fapi->subscriber; HWTEST_F() local
235 Subscriber *subscriber = &fapi->subscriber; HWTEST_F() local
266 Subscriber *subscriber = &fapi->subscriber; HWTEST_F() local
293 Subscriber *subscriber = &fapi->subscriber; HWTEST_F() local
324 Subscriber *subscriber = &fapi->subscriber; HWTEST_F() local
[all...] |
| /test/xts/hats/hdf/usb/usbdBenchmarkTest/common/ |
| H A D | HdfUsbdBenchmarkRequestTest.cpp | 64 void HdfUsbdBenchmarkRequestTest::InitPara(const sptr<UsbSubscriberTest> &subscriber)
in InitPara() argument
66 auto ret = g_usbInterface->BindUsbdSubscriber(subscriber);
in InitPara()
68 dev_ = {subscriber->busNum_, subscriber->devAddr_};
in InitPara()
73 void HdfUsbdBenchmarkRequestTest::ReleasePara(const sptr<UsbSubscriberTest> &subscriber)
in ReleasePara() argument
76 auto ret = g_usbInterface->UnbindUsbdSubscriber(subscriber);
in ReleasePara()
93 sptr<UsbSubscriberTest> subscriber = new UsbSubscriberTest();
in BENCHMARK_F() local
94 ASSERT_TRUE(subscriber != nullptr);
in BENCHMARK_F()
96 InitPara(subscriber);
in BENCHMARK_F()
103 ReleasePara(subscriber);
in BENCHMARK_F()
122 sptr<UsbSubscriberTest> subscriber = new UsbSubscriberTest(); BENCHMARK_F() local
151 sptr<UsbSubscriberTest> subscriber = new UsbSubscriberTest(); BENCHMARK_F() local
180 sptr<UsbSubscriberTest> subscriber = new UsbSubscriberTest(); BENCHMARK_F() local
211 sptr<UsbSubscriberTest> subscriber = new UsbSubscriberTest(); BENCHMARK_F() local
240 sptr<UsbSubscriberTest> subscriber = new UsbSubscriberTest(); BENCHMARK_F() local
270 sptr<UsbSubscriberTest> subscriber = new UsbSubscriberTest(); BENCHMARK_F() local
300 sptr<UsbSubscriberTest> subscriber = new UsbSubscriberTest(); BENCHMARK_F() local
329 sptr<UsbSubscriberTest> subscriber = new UsbSubscriberTest(); BENCHMARK_F() local
359 sptr<UsbSubscriberTest> subscriber = new UsbSubscriberTest(); BENCHMARK_F() local
397 sptr<UsbSubscriberTest> subscriber = new UsbSubscriberTest(); BENCHMARK_F() local
436 sptr<UsbSubscriberTest> subscriber = new UsbSubscriberTest(); BENCHMARK_F() local
472 sptr<UsbSubscriberTest> subscriber = new UsbSubscriberTest(); BENCHMARK_F() local
502 sptr<UsbSubscriberTest> subscriber = new UsbSubscriberTest(); BENCHMARK_F() local
538 sptr<UsbSubscriberTest> subscriber = new UsbSubscriberTest(); BENCHMARK_F() local
569 sptr<UsbSubscriberTest> subscriber = new UsbSubscriberTest(); BENCHMARK_F() local
599 sptr<UsbSubscriberTest> subscriber = new UsbSubscriberTest(); BENCHMARK_F() local
[all...] |
| H A D | HdfUsbdBenchmarkTransferTest.cpp | 93 void HdfUsbdBenchmarkTransferTest::InitPara(const sptr<UsbSubscriberTest> &subscriber)
in InitPara() argument
95 auto ret = g_usbInterface->BindUsbdSubscriber(subscriber);
in InitPara()
97 dev_ = {subscriber->busNum_, subscriber->devAddr_};
in InitPara()
102 void HdfUsbdBenchmarkTransferTest::ReleasePara(const sptr<UsbSubscriberTest> &subscriber)
in ReleasePara() argument
105 auto ret = g_usbInterface->UnbindUsbdSubscriber(subscriber);
in ReleasePara()
123 sptr<UsbSubscriberTest> subscriber = new UsbSubscriberTest();
in BENCHMARK_F() local
124 ASSERT_TRUE(subscriber != nullptr);
in BENCHMARK_F()
125 InitPara(subscriber);
in BENCHMARK_F()
134 ReleasePara(subscriber);
in BENCHMARK_F()
154 sptr<UsbSubscriberTest> subscriber = new UsbSubscriberTest(); BENCHMARK_F() local
189 sptr<UsbSubscriberTest> subscriber = new UsbSubscriberTest(); BENCHMARK_F() local
223 sptr<UsbSubscriberTest> subscriber = new UsbSubscriberTest(); BENCHMARK_F() local
257 sptr<UsbSubscriberTest> subscriber = new UsbSubscriberTest(); BENCHMARK_F() local
291 sptr<UsbSubscriberTest> subscriber = new UsbSubscriberTest(); BENCHMARK_F() local
325 sptr<UsbSubscriberTest> subscriber = new UsbSubscriberTest(); BENCHMARK_F() local
359 sptr<UsbSubscriberTest> subscriber = new UsbSubscriberTest(); BENCHMARK_F() local
392 sptr<UsbSubscriberTest> subscriber = new UsbSubscriberTest(); BENCHMARK_F() local
428 sptr<UsbSubscriberTest> subscriber = new UsbSubscriberTest(); BENCHMARK_F() local
464 sptr<UsbSubscriberTest> subscriber = new UsbSubscriberTest(); BENCHMARK_F() local
496 sptr<UsbSubscriberTest> subscriber = new UsbSubscriberTest(); BENCHMARK_F() local
529 sptr<UsbSubscriberTest> subscriber = new UsbSubscriberTest(); BENCHMARK_F() local
556 sptr<UsbSubscriberTest> subscriber = new UsbSubscriberTest(); BENCHMARK_F() local
587 sptr<UsbSubscriberTest> subscriber = new UsbSubscriberTest(); BENCHMARK_F() local
624 sptr<UsbSubscriberTest> subscriber = new UsbSubscriberTest(); BENCHMARK_F() local
[all...] |
| H A D | HdfUsbdBenchmarkDeviceTest.cpp | 58 void HdfUsbdBenchmarkDeviceTest::InitPara(const sptr<UsbSubscriberTest> &subscriber)
in InitPara() argument
60 auto ret = g_usbInterface->BindUsbdSubscriber(subscriber);
in InitPara()
62 dev_ = {subscriber->busNum_, subscriber->devAddr_};
in InitPara()
67 void HdfUsbdBenchmarkDeviceTest::ReleasePara(const sptr<UsbSubscriberTest> &subscriber)
in ReleasePara() argument
70 auto ret = g_usbInterface->UnbindUsbdSubscriber(subscriber);
in ReleasePara()
87 sptr<UsbSubscriberTest> subscriber = new UsbSubscriberTest();
in BENCHMARK_F() local
88 ASSERT_NE(subscriber, nullptr);
in BENCHMARK_F()
89 InitPara(subscriber);
in BENCHMARK_F()
96 ReleasePara(subscriber);
in BENCHMARK_F()
115 sptr<UsbSubscriberTest> subscriber = new UsbSubscriberTest(); BENCHMARK_F() local
147 sptr<UsbSubscriberTest> subscriber = new UsbSubscriberTest(); BENCHMARK_F() local
178 sptr<UsbSubscriberTest> subscriber = new UsbSubscriberTest(); BENCHMARK_F() local
[all...] |
| /test/xts/acts/powermgr/battery_manager/entry/src/ohosTest/js/test/ |
| H A D | battery_common_event.test.js | 1442 .then(subscriber => {
1444 var mySubscriber = subscriber;
1445 console.log(subscriber);
1447 if (subscriber == "" || subscriber == undefined || subscriber == null) {
1495 .then(subscriber => {
1497 var mySubscriber = subscriber;
1498 console.log(subscriber);
1500 if (subscriber
[all...] |
| /test/xts/acts/notification/ces_standard/actsCommonEventSubscribeNDKTest/entry/src/main/cpp/ |
| H A D | subscribe.cpp | 92 static CommonEvent_Subscriber *subscriber = {};
variable
228 subscriber = OH_CommonEvent_CreateSubscriber(information, OnReceive);
in CreateSubscriber()
229 if (subscriber == nullptr) {
in CreateSubscriber()
230 OH_LOG_Print(LOG_APP, LOG_WARN, 1, "CES_TEST", "Create subscriber failed.");
in CreateSubscriber()
235 OH_LOG_Print(LOG_APP, LOG_INFO, 1, "CES_TEST", "Create subscriber successful.");
in CreateSubscriber()
242 OH_CommonEvent_DestroySubscriber(subscriber);
in DestroySubscriber()
243 subscriber = nullptr;
in DestroySubscriber()
244 OH_LOG_Print(LOG_APP, LOG_INFO, 1, "CES_TEST", "Destroy subscriber successful.");
in DestroySubscriber()
252 int32_t ret = OH_CommonEvent_Subscribe(subscriber);
in CommonEventSubscribe()
261 int32_t ret = OH_CommonEvent_UnSubscribe(subscriber);
in CommonEventUnSubscribe()
[all...] |
| /test/xts/hats/hdf/external_device_manager/bus_extension_usb/src/ |
| H A D | usb_impl_mock.cpp | 86 int32_t UsbImplMock::BindUsbdSubscriber(const sptr<IUsbdSubscriber> &subscriber) in BindUsbdSubscriber() argument
88 subscriber_ = subscriber; in BindUsbdSubscriber()
92 int32_t UsbImplMock::UnbindUsbdSubscriber(const sptr<IUsbdSubscriber> &subscriber) in UnbindUsbdSubscriber() argument
94 (void)subscriber; in UnbindUsbdSubscriber()
|
| /test/xts/hats/hdf/usb/usbdBenchmarkTest/include/ |
| H A D | HdfUsbdBenchmarkDeviceTest.h | 34 void InitPara(const OHOS::sptr<OHOS::USB::UsbSubscriberTest> &subscriber);
35 void ReleasePara(const OHOS::sptr<OHOS::USB::UsbSubscriberTest> &subscriber);
|
| H A D | HdfUsbdBenchmarkRequestTest.h | 37 void InitPara(const OHOS::sptr<OHOS::USB::UsbSubscriberTest> &subscriber);
38 void ReleasePara(const OHOS::sptr<OHOS::USB::UsbSubscriberTest> &subscriber);
|
| H A D | HdfUsbdBenchmarkTransferTest.h | 45 void InitPara(const OHOS::sptr<OHOS::USB::UsbSubscriberTest> &subscriber);
46 void ReleasePara(const OHOS::sptr<OHOS::USB::UsbSubscriberTest> &subscriber);
|
| /test/testfwk/arkxtest/uitest/connection/ |
| H A D | ipc_transactor.cpp | 242 shared_ptr<CommonEventForwarder> subscriber = make_shared<CommonEventForwarder>(info, onEvent); in WaitForPublishedCaller() local
243 if (!CommonEventManager::SubscribeCommonEvent(subscriber)) { in WaitForPublishedCaller()
249 CommonEventManager::UnSubscribeCommonEvent(subscriber); in WaitForPublishedCaller()
250 subscriber->UpdateHandler(nullptr); // unset handler in WaitForPublishedCaller()
|
| /test/xts/hats/hdf/external_device_manager/bus_extension_usb/include/ |
| H A D | usb_impl_mock.h | 53 int32_t BindUsbdSubscriber(const sptr<IUsbdSubscriber> &subscriber) override;
54 int32_t UnbindUsbdSubscriber(const sptr<IUsbdSubscriber> &subscriber) override;
|
| /test/xts/acts/account/appaccount/sceneProject/actsaccountsceneonoff/entry/src/main/js/MainAbility/pages/index/ |
| H A D | index.js | 458 let subscriber
461 subscriber = data;
463 commonevent.subscribe(subscriber, subscriberCallback);
|