Home
last modified time | relevance | path

Searched refs:event (Results 1 – 25 of 147) sorted by relevance

123456

/tools/trebuchet/core/common/src/test/kotlin/trebuchet/importers/ftrace/
DFtraceEventTest.kt29 … val event = parseEvent("atrace-7100 ( 7100) [001] ...1 4492.047398: tracing_mark_write: " + in testParseLineComplete() constant
31 assertEquals("atrace", event.task) in testParseLineComplete()
32 assertEquals(7100, event.pid) in testParseLineComplete()
33 assertEquals(7100, event.tgid) in testParseLineComplete()
34 assertEquals(1, event.cpu) in testParseLineComplete()
35 assertEquals(4492.047398, event.timestamp) in testParseLineComplete()
36 assertEquals("tracing_mark_write", event.function) in testParseLineComplete()
37 assertTrue { event.details is ParentTSEvent } in testParseLineComplete()
38 assertEquals(4492.069824, (event.details as ParentTSEvent).parentTimestamp) in testParseLineComplete()
43 …val event = parseEvent("<...>-2692 (-----) [000] d..4 4492.062904: sched_blocked_reason: pid=269… in testParseLineUnknownTgid() constant
[all …]
/tools/test/connectivity/acts/framework/acts/metrics/
Dlogger.py21 from acts.event import event_bus
22 from acts.event import subscription_bundle
23 from acts.event.decorators import subscribe
24 from acts.event.event import TestCaseBeginEvent
25 from acts.event.event import TestCaseEndEvent
26 from acts.event.event import TestClassBeginEvent
27 from acts.event.event import TestClassEndEvent
123 def __init__(self, context=None, publisher=None, event=None): argument
140 if event:
141 self._init_for_event(event)
[all …]
/tools/test/connectivity/acts/framework/acts/
Dcontext.py21 from acts.event import event_bus
22 from acts.event.event import Event
23 from acts.event.event import TestCaseBeginEvent
24 from acts.event.event import TestCaseEndEvent
25 from acts.event.event import TestCaseEvent
26 from acts.event.event import TestClassBeginEvent
27 from acts.event.event import TestClassEndEvent
28 from acts.event.event import TestClassEvent
54 def get_context_for_event(event): argument
66 if isinstance(event, TestCaseEvent):
[all …]
Dbase_test.py33 from acts.event import event_bus
34 from acts.event import subscription_bundle
35 from acts.event.decorators import subscribe_static
36 from acts.event.event import TestCaseBeginEvent
37 from acts.event.event import TestCaseEndEvent
38 from acts.event.event import TestClassBeginEvent
39 from acts.event.event import TestClassEndEvent
40 from acts.event.subscription_bundle import SubscriptionBundle
51 def _logcat_log_test_begin(event): argument
54 test_instance = event.test_class
[all …]
/tools/test/connectivity/acts_tests/tests/google/ble/gatt/
DGattWriteTest.py71 event = self._server_wait(gatt_event['char_write_req'])
73 request_id = event['data']['requestId']
74 self.assertEqual(True, event['data']['responseNeeded'],
76 self.assertEqual(char_value, event['data']['value'])
77 self.assertEqual(0, event['data']['offset'])
87 event = self._client_wait(gatt_event['char_write'])
88 self.assertEqual(status, event["data"]["Status"],
126 event = self._server_wait(gatt_event['desc_write_req'])
128 request_id = event['data']['requestId']
129 self.assertEqual(True, event['data']['responseNeeded'],
[all …]
DGattReadTest.py60 event = self._server_wait(gatt_event['char_read_req'])
62 request_id = event['data']['requestId']
63 self.assertEqual(0, event['data']['offset'], "offset should be 0")
73 event = self._client_wait(gatt_event['char_read'])
74 self.assertEqual(status, event["data"]["Status"],
76 self.assertEqual(char_value, event["data"]["CharacteristicValue"],
129 event = self._server_wait(gatt_event['char_read_req'])
131 request_id = event['data']['requestId']
132 self.assertEqual(startOffset, event['data']['offset'],
142 event = self._client_wait(gatt_event['char_read'])
[all …]
/tools/test/connectivity/acts/framework/tests/
Dacts_context_test.py30 from acts.event.event import TestCaseBeginEvent
31 from acts.event.event import TestCaseEndEvent
32 from acts.event.event import TestCaseEvent
33 from acts.event.event import TestClassBeginEvent
34 from acts.event.event import TestClassEndEvent
35 from acts.event.event import TestClassEvent
58 event = Mock(spec=TestCaseEvent)
59 event.test_class = Mock()
60 event.test_case = Mock()
61 context = get_context_for_event(event)
[all …]
/tools/test/connectivity/acts_tests/acts_contrib/test_utils/bt/
Dgatts_lib.py133 for event in events:
134 self.log.debug("Found event: {}.".format(event))
135 request_id = event['data']['requestId']
136 if event['name'] == execute_write:
137 if ('execute' in event['data']
138 and event['data']['execute'] == True):
151 offset = event['data']['offset']
152 instance_id = event['data']['instanceId']
153 if (event['name'] == desc_write or event['name'] == char_write
154 or event['name'] == char_write_req):
[all …]
/tools/trebuchet/core/common/src/main/kotlin/trebuchet/importers/ftrace/events/
DTraceMarkerEvent.kt23 override fun import(event: FtraceEvent, state: FtraceImporterState) { in <lambda>()
24 state.threadFor(event.pid, tgid, event.task).slicesBuilder.beginSlice { in <lambda>()
25 it.startTime = event.timestamp in <lambda>()
32 override fun import(event: FtraceEvent, state: FtraceImporterState) { in import()
33 state.threadFor(event.pid, event.tgid, event.task).slicesBuilder.endSlice { in import()
34 it.endTime = event.timestamp in import()
40 override fun import(event: FtraceEvent, state: FtraceImporterState) { in import()
41 state.threadFor(event.pid, tgid, event.task).process in import()
42 .addCounterSample(name, event.timestamp, value) in import()
48 override fun import(event: FtraceEvent, state: FtraceImporterState) { in import()
[all …]
/tools/test/openhst/
Dstress_test.py227 for event in events:
228 self.events.append(ProcessLogger.EventScanner(event.name, self.name,
229 event.regex))
242 for event in self.events:
243 event_map[event.name] = event.count
244 event.count = 0
295 for event in self.events:
297 event.ScanForEvent(line, lock=self.lock)
409 self.event_names = set([event.name for event in config.event])
415 events = [x for x in config.event if x.source == file_to_watch.source]
[all …]
/tools/test/connectivity/acts_tests/tests/google/ble/bt5/
DPhyTest.py74 event = self._client_wait(gatt_event['phy_update'])
75 txPhy = event['data']['TxPhy']
76 rxPhy = event['data']['RxPhy']
78 self.assertEqual(0, event['data']['Status'], "Status should be 0")
79 self.assertEqual(clientTxPhy, event['data']['TxPhy'])
80 self.assertEqual(clientRxPhy, event['data']['RxPhy'])
83 event = self._server_wait(gatt_event['serv_phy_update'])
84 txPhy = event['data']['TxPhy']
85 rxPhy = event['data']['RxPhy']
87 self.assertEqual(0, event['data']['Status'], "Status should be 0")
[all …]
/tools/test/connectivity/acts/framework/tests/metrics/
Dlogger_test.py97 event = Mock()
99 logger = MetricLogger(event=event)
101 get_context.assert_called_once_with(event)
141 event = Mock()
149 proxy._setup_proxy(event)
151 logger_cls.assert_called_once_with(event=event,
154 logger.start.assert_called_once_with(event)
162 event = Mock()
170 proxy._setup_proxy(event)
171 proxy._teardown_proxy(event)
[all …]
/tools/test/connectivity/acts/framework/tests/event/
Ddecorators_test.py19 from acts.event import event_bus
20 from acts.event.decorators import register_instance_subscriptions
21 from acts.event.decorators import register_static_subscriptions
22 from acts.event.decorators import subscribe
23 from acts.event.decorators import subscribe_static
24 from acts.event.event import Event
25 from acts.event.subscription_handle import SubscriptionHandle
94 event = DummyEvent()
95 event_bus.post(event)
97 self.assertEqual(event, RegisterStaticSubscriptionsClass.captured_event,
[all …]
/tools/test/connectivity/acts_tests/tests/google/wifi/rtt/functional/
DAwareDiscoveryWithRangingTest.py99 event = autils.wait_for_event(
103 aconsts.SESSION_CB_KEY_DISTANCE_MM in event["data"],
107 aconsts.SESSION_CB_KEY_DISTANCE_MM in event["data"],
159 event = autils.wait_for_event(
163 aconsts.SESSION_CB_KEY_DISTANCE_MM in event["data"],
167 aconsts.SESSION_CB_KEY_DISTANCE_MM in event["data"],
1223 event = autils.wait_for_event(
1228 aconsts.SESSION_CB_KEY_DISTANCE_MM in event["data"],
1230 event = autils.wait_for_event(
1235 aconsts.SESSION_CB_KEY_DISTANCE_MM in event["data"],
[all …]
/tools/test/connectivity/acts_tests/acts_contrib/test_utils/car/
Dcar_telecom_utils.py61 event = None
63 event = ad.ed.pop_event(
74 call_id = event['data']['CallId']
117 event = ad.ed.pop_event(
120 call_state = event['data']['Event']
162 event = None
164 event = ad.ed.pop_event(
173 log.info("Removed call {}".format(event))
174 if event['data']['CallId'] != call_id:
259 event = ad.ed.pop_event(
[all …]
Dtel_telecom_utils.py48 event = None
50 event = ad.ed.pop_event(
61 call_id = event['data']['CallId']
97 event = ad.ed.pop_event(
100 call_state = event['data']['Event']
135 event = None
137 event = ad.ed.pop_event(
146 log.info("Removed call {}".format(event))
147 if event['data']['CallId'] != call_id:
174 event = ad.ed.pop_event(
[all …]
/tools/test/connectivity/acts_tests/tests/google/tel/live/
DTelLiveCBRSTest.py675 for event in events:
676 ad.log.info("Got event %s", event["name"])
677 if event["name"] == EventActiveDataSubIdChanged:
678 if event.get("data") and \
679 event["data"] == self.default_subid:
681 event["name"], event["data"])
682 initiate_time_after = event["time"]
687 for event in events:
688 ad.log.info("Got event %s", event["name"])
689 if event["name"] == EventNetworkCallback:
[all …]
/tools/test/connectivity/acts/framework/acts/controllers/sl4a_lib/
Devent_dispatcher.py257 event = None
259 event = self.pop_event(event_name, 1)
261 self.log.debug('Consuming event: %r' % event)
263 self.log.debug('Peeking at event: %r' % event)
264 ignored_events.append(event)
268 if event and predicate(event, *args, **kwargs):
272 (event, predicate.__name__))
273 return event
323 return sorted(results, key=lambda event: event['time'])
378 event = self.pop_event(event_name, event_timeout)
[all …]
/tools/test/connectivity/acts_tests/tests/google/wifi/
DWifiScannerBssidTest.py110 event = self.dut.ed.pop_event(event_name, waittime)
111 results = event["data"]["Results"]
192 event = self.dut.ed.pop_event(event_name, BSSID_EVENT_WAIT)
193 self.log.debug(event)
195 event["data"]["Results"])
240 event = self.dut.ed.pop_event(event_name, BSSID_EVENT_WAIT)
241 self.log.debug(event)
243 event["data"]["Results"])
252 event = self.dut.ed.pop_event(event_name, BSSID_EVENT_WAIT)
253 self.log.debug(event)
[all …]
DWifiScannerScanTest.py245 for event in events:
246 results.append(event["data"]["Results"])
282 event = self.dut.ed.pop_event(event_name, wait_time)
283 self.log.debug("Event received: %s", event)
284 results = event["data"]["Results"]
287 results, scan_rt, event["data"][KEY_RET], scan_setting)
336 event = self.dut.ed.pop_event(event_name, wait_time)
337 self.log.info("Event received: %s", event)
339 event["data"]["Results"], scan_rt, event["data"][KEY_RET],
400 event = self.dut.ed.pop_event(event_name, wait_time)
[all …]
/tools/test/connectivity/acts_tests/tests/google/ble/scan/
DBleOnLostOnFoundTest.py131 event = self.scn_ad.ed.pop_event(
133 found_callback_type = event['data']['CallbackType']
134 if event['data']['CallbackType'] != ble_scan_settings_callback_types[
142 event = self.scn_ad.ed.pop_event(
144 found_callback_type = event['data']['CallbackType']
201 event = self.scn_ad.ed.pop_event(
203 found_callback_type = event['data']['CallbackType']
204 if event['data']['CallbackType'] != ble_scan_settings_callback_types[
212 event = self.scn_ad.ed.pop_event(
214 found_callback_type = event['data']['CallbackType']
[all …]
/tools/test/connectivity/acts_tests/tests/google/wifi/aware/functional/
DDiscoveryTest.py901 event = autils.wait_for_event(dut1,
903 asserts.assert_equal(event["data"][aconsts.SESSION_CB_KEY_SESSION_ID],
909 event = autils.wait_for_event(dut1,
911 asserts.assert_equal(event["data"][aconsts.SESSION_CB_KEY_SESSION_ID],
917 event = autils.wait_for_event(dut2,
919 asserts.assert_equal(event["data"][aconsts.SESSION_CB_KEY_SESSION_ID],
925 event = autils.wait_for_event(dut2,
927 asserts.assert_equal(event["data"][aconsts.SESSION_CB_KEY_SESSION_ID],
942 event = autils.wait_for_event(dut1,
945 event["data"][aconsts.SESSION_CB_KEY_SESSION_ID], dut1_x_sid,
[all …]
/tools/test/connectivity/acts_tests/tests/google/bt/gatt/
DGattOverBrEdrTest.py91 event = self.per_ad.ed.pop_event(
94 if event['data']['serviceUuid'].lower() != uuid.lower():
96 event['data']['serviceUuid'], uuid))
234 event = self.cen_ad.ed.pop_event(
237 discovered_services_index = event['data']['ServicesIndex']
290 event = self.cen_ad.ed.pop_event(
293 discovered_services_index = event['data']['ServicesIndex']
349 event = self.cen_ad.ed.pop_event(
352 discovered_services_index = event['data']['ServicesIndex']
456 event = self.cen_ad.ed.pop_event(
[all …]
/tools/test/connectivity/acts/framework/tests/metrics/loggers/
Dbounded_metrics_test.py38 self.event = Mock()
44 logger = BoundedMetricsLogger(event=self.event)
55 logger = BoundedMetricsLogger(event=self.event)
79 logger = BoundedMetricsLogger(event=self.event)
108 logger = BoundedMetricsLogger(event=self.event)
128 logger = BoundedMetricsLogger(event=self.event)
148 logger = BoundedMetricsLogger(self.event)
153 logger.end(self.event)
/tools/test/connectivity/acts_tests/tests/google/ble/filtering/
DUniqueFilteringTest.py46 def blescan_verify_onfailure_event_handler(self, event): argument
48 self.log.debug(pprint.pformat(event))
49 return event
52 event,
57 self.log.debug(pprint.pformat(event))
58 callbacktype = event['data']['CallbackType']
66 def blescan_get_mac_address_event_handler(self, event): argument
67 return event['data']['Result']['deviceInfo']['address']
70 self, event, system_time_nanos=None, report_delay_nanos=None):
73 self.log.debug(pprint.pformat(event))
[all …]

123456