Home
last modified time | relevance | path

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

12345678

/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/acts/metrics/
Dlogger.py24 from acts.event import event_bus
25 from acts.event import subscription_bundle
26 from acts.event.decorators import subscribe
27 from acts.event.event import TestCaseBeginEvent
28 from acts.event.event import TestCaseEndEvent
29 from acts.event.event import TestClassBeginEvent
30 from acts.event.event import TestClassEndEvent
149 def __init__(self, context=None, publisher=None, event=None): argument
166 if event:
167 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/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
290 for event in self.events:
292 event.ScanForEvent(line, lock=self.lock)
400 self.event_names = set([event.name for event in config.event])
406 events = [x for x in config.event if x.source == file_to_watch.source]
[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/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/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/test/connectivity/acts/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/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/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/connectivity/acts/framework/acts/test_utils/tel/
Dtel_test_utils.py768 for event in events_list:
769 if event in event_to_check['name']:
890 event = {
894 event = ad.ed.pop_event(event, max_wait)
895 ad.log.info("Got event %s", event['name'])
966 event = ad.ed.wait_for_event(
972 ad.log.info("Got event %s", event)
1507 event = ad.ed.wait_for_event(
1513 override_type = event['data']['override']
1538 event = ad.ed.wait_for_event(
[all …]
Danritsu_utils.py1908 event = None
1911 event = ad.ed.pop_event(sms_deliver_event, time_to_wait)
1922 event = None
1925 event = ad.ed.pop_event(sms_sent_event, time_to_wait)
1926 log.info(event)
1937 event = None
1940 event = ad.ed.pop_event(sms_received_event, time_to_wait)
1941 log.info(event)
1945 return status, event
2005 test_status, event = wait_for_incoming_sms(log, ad)
[all …]
/tools/test/connectivity/acts/tests/google/wifi/
DWifiScannerScanTest.py248 for event in events:
249 results.append(event["data"]["Results"])
285 event = self.dut.ed.pop_event(event_name, wait_time)
286 self.log.debug("Event received: %s", event)
287 results = event["data"]["Results"]
290 results, scan_rt, event["data"][KEY_RET], scan_setting)
339 event = self.dut.ed.pop_event(event_name, wait_time)
340 self.log.info("Event received: %s", event)
342 event["data"]["Results"], scan_rt, event["data"][KEY_RET],
403 event = self.dut.ed.pop_event(event_name, wait_time)
[all …]
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 …]
/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.py135 event = Mock()
137 logger = MetricLogger(event=event)
139 get_context.assert_called_once_with(event)
182 event = Mock()
190 proxy._setup_proxy(event)
192 logger_cls.assert_called_once_with(event=event,
195 logger.start.assert_called_once_with(event)
203 event = Mock()
211 proxy._setup_proxy(event)
212 proxy._teardown_proxy(event)
[all …]
/tools/test/connectivity/acts/framework/acts/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/framework/acts/test_utils/wifi/aware/
Daware_test_utils.py60 event = ad.ed.pop_event(event_name, timeout)
61 ad.log.info('%s%s: %s', prefix, event_name, event['data'])
62 return event
81 def filter_callbacks(event, keyvalues): argument
84 if event['data'][key] != value:
92 event = ad.ed.wait_for_event(event_name, filter_callbacks, timeout,
94 ad.log.info('%s%s: %s', prefix, event_name, event['data'])
95 return event
114 event = ad.ed.pop_event(event_name, timeout)
116 event['data'])
[all …]
/tools/test/connectivity/acts/tests/google/wifi/aware/functional/
DDiscoveryTest.py893 event = autils.wait_for_event(dut1,
895 asserts.assert_equal(event["data"][aconsts.SESSION_CB_KEY_SESSION_ID],
901 event = autils.wait_for_event(dut1,
903 asserts.assert_equal(event["data"][aconsts.SESSION_CB_KEY_SESSION_ID],
909 event = autils.wait_for_event(dut2,
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],
934 event = autils.wait_for_event(dut1,
937 event["data"][aconsts.SESSION_CB_KEY_SESSION_ID], dut1_x_sid,
[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/tradefederation/core/tests/src/com/android/tradefed/cluster/
DClusterEventUploaderTest.java80 final Event event = new Event("event"); in testPostCommandEvent_simpleEvent() local
81 mUploader.postEvent(event); in testPostCommandEvent_simpleEvent()
98 final Event event = new Event("event"); in testPostCommandEvent_multipleEvents() local
99 mUploader.postEvent(event); in testPostCommandEvent_multipleEvents()
100 mUploader.postEvent(event); in testPostCommandEvent_multipleEvents()
101 mUploader.postEvent(event); in testPostCommandEvent_multipleEvents()
102 mUploader.postEvent(event); in testPostCommandEvent_multipleEvents()
109 final Event event = new Event("event"); in testPostCommandEvent_multipleBatches() local
111 mUploader.postEvent(event); in testPostCommandEvent_multipleBatches()
112 mUploader.postEvent(event); in testPostCommandEvent_multipleBatches()
[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 …]

12345678