Home
last modified time | relevance | path

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

12345678

/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 …]
/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/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/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 …]
DWorkqueueEvent.kt22 override fun import(event: FtraceEvent, state: FtraceImporterState) { in <lambda>()
23 state.threadFor(event).slicesBuilder.beginSlice { in <lambda>()
25 it.startTime = event.timestamp in <lambda>()
31 override fun import(event: FtraceEvent, state: FtraceImporterState) { in import()
32 state.threadFor(event).slicesBuilder.endSlice { in import()
33 it.endTime = event.timestamp in import()
/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 …]
Devent_bus_integration_test.py23 from acts.event import event_bus, subscription_bundle
24 from acts.event.decorators import subscribe, subscribe_static
25 from acts.event.event import Event
40 def subscribed_instance_member(self, event): argument
41 TestClass.instance_event_received.append(event)
45 def subscribed_static_member(event): argument
46 TestClass.static_event_received.append(event)
/tools/tradefederation/core/remote/src/com/android/tradefed/device/
DDeviceAllocationEventHandler.java24 DeviceAllocationState handleDeviceEvent(DeviceEvent event); in handleDeviceEvent() argument
41 public DeviceAllocationState handleDeviceEvent(DeviceEvent event) { in handleDeviceEvent() argument
42 switch (event) { in handleDeviceEvent()
79 public DeviceAllocationState handleDeviceEvent(DeviceEvent event) { in handleDeviceEvent() argument
80 switch (event) { in handleDeviceEvent()
114 public DeviceAllocationState handleDeviceEvent(DeviceEvent event) { in handleDeviceEvent() argument
115 switch (event) { in handleDeviceEvent()
144 public DeviceAllocationState handleDeviceEvent(DeviceEvent event) { in handleDeviceEvent() argument
145 switch (event) { in handleDeviceEvent()
172 public DeviceAllocationState handleDeviceEvent(DeviceEvent event) { in handleDeviceEvent() argument
[all …]
/tools/tradefederation/core/javatests/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/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_tests/acts_contrib/test_utils/bt/
Dgatts_lib.py132 for event in events:
133 self.log.debug("Found event: {}.".format(event))
134 request_id = event['data']['requestId']
135 if event['name'] == execute_write:
136 if ('execute' in event['data']
137 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/acts_contrib/test_utils/tel/
Dtel_message_utils.py352 for event in events:
353 ad_tx.log.info("Got event %s", event["name"])
354 … if event["name"] == EventSmsSentFailure or event["name"] == EventSmsDeliverFailure:
355 if event.get("data") and event["data"].get("Reason"):
357 event["name"],
358 event["data"]["Reason"])
360 … elif event["name"] == EventSmsSentSuccess or event["name"] == EventSmsDeliverSuccess:
563 for event in events:
564 ad.log.info("Got event %s", event["name"])
565 if event["name"] == EventSmsSentFailure or \
[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/tradefederation/core/javatests/com/android/tradefed/util/sl4a/
DSl4aEventDispatcherTest.java88 EventSl4aObject event = in testPopEvent() local
90 Assert.assertEquals(29519495823L, event.getTime()); in testPopEvent()
91 Assert.assertEquals("BluetoothStateChangedOff", event.getName()); in testPopEvent()
92 Assert.assertEquals("{\"State\":\"OFF\"}", event.getData()); in testPopEvent()
100 EventSl4aObject event = in testPopEvent_notExisting() local
102 Assert.assertNull(event); in testPopEvent_notExisting()
171 EventSl4aObject event = mEventDispatcher.waitForEvent("BluetoothStateChangedOff", in testWaitForEvent() local
173 Assert.assertNotNull(event); in testWaitForEvent()
174 Assert.assertEquals(29519495823L, event.getTime()); in testWaitForEvent()
175 Assert.assertEquals("BluetoothStateChangedOff", event.getName()); in testWaitForEvent()
[all …]
/tools/test/connectivity/acts_tests/acts_contrib/test_utils/car/
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 …]
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 …]
/tools/loganalysis/src/com/android/loganalysis/item/
DLogcatItem.java94 public void addEvent(MiscLogcatItem event) { in addEvent() argument
95 ((ItemList) getAttribute(EVENTS)).add(event); in addEvent()
175 for (MiscLogcatItem event : getEvents()) { in merge()
176 final Date eventTime = event.getEventTime(); in merge()
178 !logcat.getEvents().contains(event)) { in merge()
182 mergedEvents.add(event); in merge()
185 for (MiscLogcatItem event : logcat.getEvents()) { in merge()
186 final Date eventTime = event.getEventTime(); in merge()
188 if (!getEvents().contains(event)) { in merge()
193 mergedEvents.add(event); in merge()
[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/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/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/tradefederation/core/src/com/android/tradefed/cluster/
DClusterHostEvent.java189 final ClusterHostEvent event = new ClusterHostEvent(); in build() local
190 event.mType = mType; in build()
191 event.mTimestamp = mTimestamp; in build()
192 event.mClusterId = mClusterId; in build()
193 event.mDeviceInfos = new ArrayList<>(mDeviceInfos); in build()
194 event.mData = new HashMap<>(mData); in build()
195 event.mNextClusterIds = mNextClusterIds; in build()
196 event.mHostState = mHostState; in build()
197 event.mLabName = mLabName; in build()
198 return event; in build()
/tools/trebuchet/core/common/src/main/kotlin/trebuchet/importers/ftrace/
DFtraceImporterState.kt36 fun importEvent(event: FtraceEvent) { in <lambda>()
38 modelFragment.globalStartTime = event.timestamp in <lambda>()
40 modelFragment.globalEndTime = event.timestamp in <lambda>()
41 event.import(this) in <lambda>()
93 fun threadFor(event: FtraceEvent) = threadFor(event.pid, event.tgid, event.task) in <lambda>()

12345678