Home
last modified time | relevance | path

Searched refs:event_name (Results 1 – 25 of 28) sorted by relevance

12

/tools/test/connectivity/acts/framework/acts/controllers/sl4a_lib/
Devent_dispatcher.py99 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/
DWifiScannerBssidTest.py108 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 …]
DWifiScannerScanTest.py236 def pop_scan_result_events(self, event_name): argument
247 events = self.dut.ed.pop_all(event_name)
282 event_name = "{}{}onResults".format(EVENT_TAG, idx)
283 self.log.debug("Waiting for event: %s for time %s", event_name,
285 event = self.dut.ed.pop_event(event_name, wait_time)
336 event_name = "%s%sonResults" % (EVENT_TAG, idx)
337 self.log.debug("Waiting for event: %s for time %s", event_name,
339 event = self.dut.ed.pop_event(event_name, wait_time)
346 event_name = "{}{}onFullResult".format(EVENT_TAG, idx)
347 results = self.pop_scan_result_events(event_name)
[all …]
DWifiScannerMultiScanTest.py320 event_name = SCAN_EVENT_TAG
323 event_name, event_wait_time)
324 events = self.dut.ed.pop_events(event_name, event_wait_time)
353 event_name, event_wait_time))
DWifiRttManagerTest.py225 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)
DWifiWakeTest.py139 event_name = "{}{}onResults".format("WifiScannerScan", idx)
141 event_name, wait_time)
142 event = self.dut.ed.pop_event(event_name, wait_time)
/tools/test/connectivity/acts/framework/acts/test_utils/wifi/aware/
Daware_test_utils.py42 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/
Devent_handler.py216 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 …]
Drobolectric_test_runner_unittest.py64 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)]
Drobolectric_test_runner.py183 event_name = match.group('event_name')
184 event_handler.process_event(event_name, event_data)
Datest_tf_test_runner.py266 event_name = match.group('event_name')
267 event_handler.process_event(event_name, event_data)
/tools/asuite/atest/test_runners/
Devent_handler.py218 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 …]
Drobolectric_test_runner_unittest.py67 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)]
Drobolectric_test_runner.py189 event_name = match.group('event_name')
190 event_handler.process_event(event_name, event_data)
Datest_tf_test_runner.py300 event_name = match.group('event_name')
301 event_handler.process_event(event_name, event_data)
/tools/test/connectivity/acts/framework/acts/test_utils/wifi/rtt/
Drtt_test_utils.py30 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/
DServiceIdsTest.py52 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/
DDiscoveryStressTest.py82 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/wifi/aware/functional/
DCapabilitiesTest.py68 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/wifi/rtt/functional/
DRangeAwareTest.py78 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/wifi/aware/performance/
DLatencyTest.py54 event_name = aconsts.SESSION_CB_ON_PUBLISH_STARTED
57 event_name = aconsts.SESSION_CB_ON_SUBSCRIBE_STARTED
59 event = autils.wait_for_event(dut, event_name)
/tools/test/connectivity/acts_tests/tests/google/ble/examples/
DBleExamplesTest.py101 event_name = scan_result.format(scan_callback)
103 event = self.scn_ed.pop_event(event_name, self.default_timeout)
/tools/test/connectivity/acts_tests/tests/google/fuchsia/bt/
DBleFuchsiaAndroidTest.py157 event_name = scan_result.format(scan_callback)
159 event = self.ad.ed.pop_event(event_name, self.default_timeout)
/tools/test/connectivity/acts_tests/tests/google/ble/scan/
DBleOnLostOnFoundTest.py75 def _verify_no_events_found(self, event_name): argument
77 self.scn_ad.ed.pop_event(event_name, self.default_timeout)
DBleOpportunisticScanTest.py74 def _verify_no_events_found(self, event_name): argument
76 event = self.scn_ad.ed.pop_event(event_name, self.default_timeout)

12