| /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:
109 (self._handlers[event_name].__name__, event_obj))
110 self.handle_subscribed_event(event_obj, event_name)
114 if event_name in self._event_dict: # otherwise, cache event
115 self._event_dict[event_name].put(event_obj)
119 self._event_dict[event_name] = q
122 def register_handler(self, handler, event_name, args): argument
143 if event_name in self._handlers:
[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 | 233 def pop_scan_result_events(self, event_name): argument
244 events = self.dut.ed.pop_all(event_name)
279 event_name = "{}{}onResults".format(EVENT_TAG, idx)
280 self.log.debug("Waiting for event: %s for time %s", event_name,
282 event = self.dut.ed.pop_event(event_name, wait_time)
333 event_name = "%s%sonResults" % (EVENT_TAG, idx)
334 self.log.debug("Waiting for event: %s for time %s", event_name,
336 event = self.dut.ed.pop_event(event_name, wait_time)
343 event_name = "{}{}onFullResult".format(EVENT_TAG, idx)
344 results = self.pop_scan_result_events(event_name)
[all …]
|
| 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 | 151 event_name = "{}{}onResults".format("WifiScannerScan", idx)
153 event_name, wait_time)
154 event = self.dut.ed.pop_event(event_name, wait_time)
|
| /tools/tradefederation/core/atest/test_runners/ |
| D | robolectric_test_runner_unittest.py | 64 event_name = 'TEST_STARTED'
68 data = '%s %s\n\n' %(event_name, json_event_data)
73 calls = [mock.call.process_event(event_name, event_data)]
79 event_name = 'TEST_STARTED'
82 data1 = '%s %s'%(event_name, event1)
92 calls = [mock.call.process_event(event_name,
99 event_name = 'TEST_FAILED'
104 data = '%s %s\n\n'%(event_name, json.dumps(event_data))
109 calls = [mock.call.process_event(event_name, event_data)]
|
| D | event_handler.py | 216 def process_event(self, event_name, event_data): argument
223 logging.debug('Processing %s %s', event_name, event_data)
224 if event_name in START_EVENTS:
225 self.event_stack.append(event_name)
226 elif event_name in END_EVENTS:
227 self._check_events_are_balanced(event_name, self.reporter)
228 if self.switch_handler.has_key(event_name):
229 self.switch_handler[event_name](self, event_data)
232 logging.debug('Event[%s] is not processable.', event_name)
234 def _check_events_are_balanced(self, event_name, reporter): argument
[all …]
|
| D | robolectric_test_runner.py | 183 event_name = match.group('event_name')
184 event_handler.process_event(event_name, event_data)
|
| D | atest_tf_test_runner.py | 266 event_name = match.group('event_name')
267 event_handler.process_event(event_name, event_data)
|
| /tools/asuite/atest/test_runners/ |
| D | robolectric_test_runner_unittest.py | 67 event_name = 'TEST_STARTED'
71 data = '%s %s\n\n' %(event_name, json_event_data)
76 calls = [mock.call.process_event(event_name, event_data)]
82 event_name = 'TEST_STARTED'
85 data1 = '%s %s'%(event_name, event1)
95 calls = [mock.call.process_event(event_name,
102 event_name = 'TEST_FAILED'
107 data = '%s %s\n\n'%(event_name, json.dumps(event_data))
112 calls = [mock.call.process_event(event_name, event_data)]
|
| D | event_handler.py | 218 def process_event(self, event_name, event_data): argument
225 logging.debug('Processing %s %s', event_name, event_data)
226 if event_name in START_EVENTS:
227 self.event_stack.append(event_name)
228 elif event_name in END_EVENTS:
229 self._check_events_are_balanced(event_name, self.reporter)
230 if event_name in self.switch_handler:
231 self.switch_handler[event_name](self, event_data)
235 logging.debug('Event[%s] is not processable.', event_name)
237 def _check_events_are_balanced(self, event_name, reporter): argument
[all …]
|
| D | robolectric_test_runner.py | 189 event_name = match.group('event_name')
190 event_handler.process_event(event_name, event_data)
|
| D | atest_tf_test_runner.py | 275 event_name = match.group('event_name')
276 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/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/test/connectivity/acts/tests/google/wifi/aware/ota/ |
| D | ServiceIdsTest.py | 52 event_name = aconsts.SESSION_CB_ON_PUBLISH_STARTED
55 event_name = aconsts.SESSION_CB_ON_SUBSCRIBE_STARTED
57 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
94 event_name = aconsts.SESSION_CB_ON_SUBSCRIBE_STARTED
98 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 | 68 event_name = aconsts.SESSION_CB_ON_PUBLISH_STARTED
71 event_name = aconsts.SESSION_CB_ON_SUBSCRIBE_STARTED
74 autils.wait_for_event(dut, event_name)
|
| /tools/test/connectivity/acts/tests/google/fuchsia/bt/ |
| D | BleFuchsiaAndroidTest.py | 146 event_name = scan_result.format(scan_callback)
148 event = self.ad.ed.pop_event(event_name, self.default_timeout)
|
| /tools/test/connectivity/acts/tests/google/wifi/rtt/functional/ |
| D | RangeAwareTest.py | 78 event_name = rutils.decorate_event(rconsts.EVENT_CB_RANGING_ON_RESULT,
81 event = init_dut.ed.pop_event(event_name, rutils.EVENT_TIMEOUT)
90 self.log.warning("Timed-out waiting for %s", event_name)
|
| /tools/test/connectivity/acts/tests/google/ble/scan/ |
| D | BleOnLostOnFoundTest.py | 75 def _verify_no_events_found(self, event_name): argument
77 self.scn_ad.ed.pop_event(event_name, self.default_timeout)
|
| D | BleOpportunisticScanTest.py | 74 def _verify_no_events_found(self, event_name): argument
76 event = self.scn_ad.ed.pop_event(event_name, self.default_timeout)
|
| /tools/test/connectivity/acts/framework/acts/controllers/buds_lib/test_actions/ |
| D | bt_utils.py | 107 pri_device.ed.pop_event(event_name='BluetoothStateChangedOn',
|
| /tools/test/connectivity/acts/framework/acts/test_utils/bt/ |
| D | bt_test_utils.py | 1675 event_name="BluetoothActionPairingRequest",
1682 event_name="BluetoothActionPairingRequest",
|