Home
last modified time | relevance | path

Searched refs:event (Results 1 – 25 of 148) 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/
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/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/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/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/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()
77 public DeviceAllocationState handleDeviceEvent(DeviceEvent event) { in handleDeviceEvent() argument
78 switch (event) { in handleDeviceEvent()
112 public DeviceAllocationState handleDeviceEvent(DeviceEvent event) { in handleDeviceEvent() argument
113 switch (event) { in handleDeviceEvent()
142 public DeviceAllocationState handleDeviceEvent(DeviceEvent event) { in handleDeviceEvent() argument
143 switch (event) { in handleDeviceEvent()
170 public DeviceAllocationState handleDeviceEvent(DeviceEvent event) { in handleDeviceEvent() argument
[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 …]
Devent_bus_integration_test.py24 from acts.event import event_bus, subscription_bundle
25 from acts.event.decorators import subscribe, subscribe_static
26 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/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/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/tradefederation/core/tests/src/com/android/tradefed/util/sl4a/
DSl4aEventDispatcherTest.java87 EventSl4aObject event = in testPopEvent() local
89 Assert.assertEquals(29519495823L, event.getTime()); in testPopEvent()
90 Assert.assertEquals("BluetoothStateChangedOff", event.getName()); in testPopEvent()
91 Assert.assertEquals("{\"State\":\"OFF\"}", event.getData()); in testPopEvent()
99 EventSl4aObject event = in testPopEvent_notExisting() local
101 Assert.assertNull(event); in testPopEvent_notExisting()
170 EventSl4aObject event = mEventDispatcher.waitForEvent("BluetoothStateChangedOff", in testWaitForEvent() local
172 Assert.assertNotNull(event); in testWaitForEvent()
173 Assert.assertEquals(29519495823L, event.getTime()); in testWaitForEvent()
174 Assert.assertEquals("BluetoothStateChangedOff", event.getName()); in testWaitForEvent()
[all …]
/tools/trebuchet/core/common/src/main/kotlin/trebuchet/importers/ftrace/events/
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()
DSchedEvent.kt56 override fun import(event: FtraceEvent, state: FtraceImporterState) { in import()
59 val cpu = state.cpuFor(event.cpu) in import()
61 prevThread.schedulingStateBuilder.switchState(prevState, event.timestamp) in import()
62 nextThread.schedulingStateBuilder.switchState(SchedulingState.RUNNING, event.timestamp) in import()
63 cpu.schedulingProcessBuilder.switchProcess(nextThread.process, nextThread, event.timestamp) in import()
69 override fun import(event: FtraceEvent, state: FtraceImporterState) { in import()
71 thread.schedulingStateBuilder.switchState(SchedulingState.WAKING, event.timestamp) in import()
/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/
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/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.mHostName = mHostName; in build()
193 event.mTfVersion = mTfVersion; in build()
194 event.mClusterId = mClusterId; in build()
195 event.mDeviceInfos = new ArrayList<>(mDeviceInfos); in build()
196 event.mData = new HashMap<>(mData); in build()
197 event.mNextClusterIds = mNextClusterIds; in build()
198 event.mHostState = mHostState; in build()
[all …]
/tools/test/connectivity/acts/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/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>()
/tools/asuite/asuite_plugin/src/java/com/android/atest/commandAdapter/
DAtestProcessListener.java43 public void startNotified(@NotNull ProcessEvent event) { in startNotified() argument
53 public void processTerminated(@NotNull ProcessEvent event) { in processTerminated() argument
64 public void processWillTerminate(@NotNull ProcessEvent event, boolean willBeDestroyed) {} in processWillTerminate() argument
73 public void onTextAvailable(@NotNull ProcessEvent event, @NotNull Key outputType) { in onTextAvailable() argument
75 LOG.warn(event.getText()); in onTextAvailable()
/tools/test/connectivity/acts/framework/acts/metrics/loggers/
Dblackbox.py47 def __init__(self, metric_key=None, event=None, compiler_out=None): argument
56 super().__init__(event=event)
144 def __init__(self, metric_name, metric_key=None, event=None, argument
155 super().__init__(metric_key=metric_key, event=event,
/tools/test/connectivity/acts/framework/acts/test_utils/tel/loggers/
Dtelephony_metric_logger.py38 def __init__(self, event): argument
39 super().__init__(event=event)
45 def end(self, event): argument
/tools/test/connectivity/acts/tests/google/ble/system_tests/
DGattLongevityTest.py85 event = self._client_wait(gatt_event['char_write'])
86 if event["data"]["Status"] != 0:
90 event = self._server_wait(gatt_event['char_write_req'])
93 'char_write_req'].format(self.gatt_server_callback), event[
95 request_id = event['data']['requestId']
96 found_value = event['data']['value']

123456