| /tools/test/connectivity/acts/framework/acts/controllers/sl4a_lib/ |
| D | event_dispatcher.py | 98 event_name = event_obj['name']
100 if event_name == 'EventDispatcherShutdown':
105 if event_name in self._handlers:
106 self.handle_subscribed_event(event_obj, event_name)
109 if event_name in self._event_dict: # otherwise, cache event
110 self._event_dict[event_name].put(event_obj)
114 self._event_dict[event_name] = q
117 def register_handler(self, handler, event_name, args): argument
138 if event_name in self._handlers:
140 'A handler for {} already exists'.format(event_name))
[all …]
|
| /tools/test/connectivity/acts/tests/google/wifi/ |
| D | WifiScannerBssidTest.py | 108 event_name = "%s%sonResults" % (SCAN_EVENT_TAG, scan_idx)
109 self.log.info("Waiting for the scan result event %s", event_name)
110 event = self.dut.ed.pop_event(event_name, waittime)
190 event_name = "%s%sonFound" % (BSSID_EVENT_TAG, idx)
191 self.log.info("Waiting for the BSSID event %s", event_name)
192 event = self.dut.ed.pop_event(event_name, BSSID_EVENT_WAIT)
203 (event_name, track_setting["bssidInfos"],
238 event_name = "%s%sonFound" % (BSSID_EVENT_TAG, idx)
239 self.log.info("Waiting for the BSSID event %s", event_name)
240 event = self.dut.ed.pop_event(event_name, BSSID_EVENT_WAIT)
[all …]
|
| D | WifiScannerScanTest.py | 243 def pop_scan_result_events(self, event_name): argument
254 events = self.dut.ed.pop_all(event_name)
289 event_name = "{}{}onResults".format(EVENT_TAG, idx)
290 self.log.debug("Waiting for event: %s for time %s", event_name,
292 event = self.dut.ed.pop_event(event_name, wait_time)
343 event_name = "%s%sonResults" % (EVENT_TAG, idx)
344 self.log.debug("Waiting for event: %s for time %s", event_name,
346 event = self.dut.ed.pop_event(event_name, wait_time)
353 event_name = "{}{}onFullResult".format(EVENT_TAG, idx)
354 results = self.pop_scan_result_events(event_name)
[all …]
|
| D | WifiScannerMultiScanTest.py | 312 event_name = SCAN_EVENT_TAG
315 event_name, event_wait_time)
316 events = self.dut.ed.pop_events(event_name, event_wait_time)
345 event_name, event_wait_time))
|
| D | WifiRttManagerTest.py | 225 event_name = "WifiScannerScan%donFullResult" % idx
234 event = self.dut.ed.wait_for_event(event_name, condition, 30)
237 event_name = "WifiScannerScan%donResults" % idx
238 event = self.dut.ed.pop_event(event_name, 300)
|
| /tools/test/connectivity/acts/framework/acts/test_utils/wifi/aware/ |
| D | aware_test_utils.py | 41 def decorate_event(event_name, id): argument
42 return '%s_%d' % (event_name, id)
45 def wait_for_event(ad, event_name, timeout=EVENT_TIMEOUT): argument
59 event = ad.ed.pop_event(event_name, timeout)
60 ad.log.info('%s%s: %s', prefix, event_name, event['data'])
63 ad.log.info('%sTimed out while waiting for %s', prefix, event_name)
64 asserts.fail(event_name)
66 def wait_for_event_with_keys(ad, event_name, timeout=EVENT_TIMEOUT, *keyvalues): argument
88 event = ad.ed.wait_for_event(event_name, filter_callbacks, timeout,
90 ad.log.info('%s%s: %s', prefix, event_name, event['data'])
[all …]
|
| /tools/test/connectivity/acts/framework/acts/test_utils/wifi/rtt/ |
| D | rtt_test_utils.py | 29 def decorate_event(event_name, id): argument
30 return '%s_%d' % (event_name, id)
33 def wait_for_event(ad, event_name, timeout=EVENT_TIMEOUT): argument
47 event = ad.ed.pop_event(event_name, timeout)
48 ad.log.info('%s%s: %s', prefix, event_name, event['data'])
51 ad.log.info('%sTimed out while waiting for %s', prefix, event_name)
52 asserts.fail(event_name)
54 def fail_on_event(ad, event_name, timeout=EVENT_TIMEOUT): argument
66 event = ad.ed.pop_event(event_name, timeout)
67 ad.log.info('%sReceived unwanted %s: %s', prefix, event_name, event['data'])
[all …]
|
| /tools/test/connectivity/acts/tests/google/wifi/aware/ota/ |
| D | ServiceIdsTest.py | 55 event_name = aconsts.SESSION_CB_ON_PUBLISH_STARTED
58 event_name = aconsts.SESSION_CB_ON_SUBSCRIBE_STARTED
60 autils.wait_for_event(dut, event_name)
|
| /tools/test/connectivity/acts/tests/google/wifi/aware/stress/ |
| D | DiscoveryStressTest.py | 82 event_name = aconsts.SESSION_CB_ON_PUBLISH_STARTED
91 event_name = aconsts.SESSION_CB_ON_SUBSCRIBE_STARTED
95 dut.ed.pop_event(event_name, autils.EVENT_TIMEOUT)
|
| /tools/test/connectivity/acts/tests/google/ble/examples/ |
| D | BleExamplesTest.py | 101 event_name = scan_result.format(scan_callback)
103 event = self.scn_ed.pop_event(event_name, self.default_timeout)
|
| /tools/test/connectivity/acts/tests/google/wifi/aware/functional/ |
| D | CapabilitiesTest.py | 71 event_name = aconsts.SESSION_CB_ON_PUBLISH_STARTED
74 event_name = aconsts.SESSION_CB_ON_SUBSCRIBE_STARTED
77 autils.wait_for_event(dut, event_name)
|
| /tools/test/connectivity/acts/tests/google/ble/scan/ |
| D | BleOnLostOnFoundTest.py | 77 def _verify_no_events_found(self, event_name): argument
79 self.scn_ad.ed.pop_event(event_name, self.default_timeout)
|
| D | BleOpportunisticScanTest.py | 76 def _verify_no_events_found(self, event_name): argument
78 event = self.scn_ad.ed.pop_event(event_name, self.default_timeout)
|
| /tools/test/connectivity/acts/tests/google/wifi/aware/performance/ |
| D | LatencyTest.py | 57 event_name = aconsts.SESSION_CB_ON_PUBLISH_STARTED
60 event_name = aconsts.SESSION_CB_ON_SUBSCRIBE_STARTED
62 event = autils.wait_for_event(dut, event_name)
|
| /tools/test/connectivity/acts/framework/acts/test_utils/bt/ |
| D | gattc_lib.py | 59 event_name = scan_result.format(scan_callback)
66 event = self.dut.ed.pop_event(event_name, 10)
|
| D | bt_test_utils.py | 770 event_name="BluetoothActionPairingRequest",
777 event_name="BluetoothActionPairingRequest",
|