| /tools/test/connectivity/acts/framework/acts/controllers/sl4a_lib/ |
| D | event_dispatcher.py | 99 event_name = event_obj['name']
101 if event_name == 'EventDispatcherShutdown':
106 if event_name in self._handlers:
107 self.handle_subscribed_event(event_obj, event_name)
110 if event_name in self._event_dict: # otherwise, cache event
111 self._event_dict[event_name].put(event_obj)
115 self._event_dict[event_name] = q
118 def register_handler(self, handler, event_name, args): argument
139 if event_name in self._handlers:
141 '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 | 241 def pop_scan_result_events(self, event_name): argument
252 events = self.dut.ed.pop_all(event_name)
287 event_name = "{}{}onResults".format(EVENT_TAG, idx)
288 self.log.debug("Waiting for event: %s for time %s", event_name,
290 event = self.dut.ed.pop_event(event_name, wait_time)
341 event_name = "%s%sonResults" % (EVENT_TAG, idx)
342 self.log.debug("Waiting for event: %s for time %s", event_name,
344 event = self.dut.ed.pop_event(event_name, wait_time)
351 event_name = "{}{}onFullResult".format(EVENT_TAG, idx)
352 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)
|
| D | WifiWakeTest.py | 140 event_name = "{}{}onResults".format("WifiScannerScan", idx)
142 event_name, wait_time)
143 event = self.dut.ed.pop_event(event_name, wait_time)
|
| /tools/test/connectivity/acts/framework/acts/test_utils/wifi/aware/ |
| D | aware_test_utils.py | 42 def decorate_event(event_name, id): argument
43 return '%s_%d' % (event_name, id)
46 def wait_for_event(ad, event_name, timeout=EVENT_TIMEOUT): argument
60 event = ad.ed.pop_event(event_name, timeout)
61 ad.log.info('%s%s: %s', prefix, event_name, event['data'])
64 ad.log.info('%sTimed out while waiting for %s', prefix, event_name)
65 asserts.fail(event_name)
68 def wait_for_event_with_keys(ad, event_name, timeout=EVENT_TIMEOUT, argument
92 event = ad.ed.wait_for_event(event_name, filter_callbacks, timeout,
94 ad.log.info('%s%s: %s', prefix, event_name, event['data'])
[all …]
|
| /tools/tradefederation/core/atest/test_runners/ |
| D | event_handler.py | 210 def process_event(self, event_name, event_data): argument
217 logging.debug('Processing %s %s', event_name, event_data)
218 if event_name in START_EVENTS:
219 self.event_stack.append(event_name)
220 elif event_name in END_EVENTS:
221 self._check_events_are_balanced(event_name, self.reporter)
222 if self.switch_handler.has_key(event_name):
223 self.switch_handler[event_name](self, event_data)
226 logging.debug('Event[%s] is not processable.', event_name)
228 def _check_events_are_balanced(self, event_name, reporter): argument
[all …]
|
| D | robolectric_test_runner_unittest.py | 64 event_name = 'TEST_STARTED'
68 data = '%s %s\n\n' %(event_name, json_event_data)
75 calls = [mock.call.process_event(event_name, event_data)]
81 event_name = 'TEST_STARTED'
84 data1 = '%s %s'%(event_name, event1)
94 calls = [mock.call.process_event(event_name,
101 event_name = 'TEST_FAILED'
106 data = '%s %s\n\n'%(event_name, json.dumps(event_data))
114 calls = [mock.call.process_event(event_name, event_data)]
|
| D | robolectric_test_runner.py | 181 event_name = match.group('event_name')
182 event_handler.process_event(event_name, event_data)
|
| D | atest_tf_test_runner.py | 228 event_name = match.group('event_name')
230 event_handler.process_event(event_name, event_data)
|
| /tools/test/connectivity/acts/framework/acts/test_utils/wifi/rtt/ |
| D | rtt_test_utils.py | 30 def decorate_event(event_name, id): argument
31 return '%s_%d' % (event_name, id)
34 def wait_for_event(ad, event_name, timeout=EVENT_TIMEOUT): argument
48 event = ad.ed.pop_event(event_name, timeout)
49 ad.log.info('%s%s: %s', prefix, event_name, event['data'])
52 ad.log.info('%sTimed out while waiting for %s', prefix, event_name)
53 asserts.fail(event_name)
56 def fail_on_event(ad, event_name, timeout=EVENT_TIMEOUT): argument
68 event = ad.ed.pop_event(event_name, timeout)
69 ad.log.info('%sReceived unwanted %s: %s', prefix, event_name,
[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 | 85 event_name = aconsts.SESSION_CB_ON_PUBLISH_STARTED
97 event_name = aconsts.SESSION_CB_ON_SUBSCRIBE_STARTED
101 dut.ed.pop_event(event_name, autils.EVENT_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/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/rtt/functional/ |
| D | RangeAwareTest.py | 82 event_name = rutils.decorate_event(rconsts.EVENT_CB_RANGING_ON_RESULT,
85 event = init_dut.ed.pop_event(event_name, rutils.EVENT_TIMEOUT)
94 self.log.warning("Timed-out waiting for %s", event_name)
|
| /tools/test/connectivity/acts/tests/google/fuchsia/bt/ |
| D | BleFuchsiaAndroidTest.py | 147 event_name = scan_result.format(scan_callback)
149 event = self.ad.ed.pop_event(event_name, self.default_timeout)
|
| /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/controllers/buds_lib/test_actions/ |
| D | bt_utils.py | 106 pri_device.ed.pop_event(event_name='BluetoothStateChangedOn',
|
| /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 | 1528 event_name="BluetoothActionPairingRequest",
1535 event_name="BluetoothActionPairingRequest",
|