Home
last modified time | relevance | path

Searched refs:events (Results 1 – 25 of 45) sorted by relevance

12

/tools/tradefederation/core/src/com/android/tradefed/cluster/
DClusterEventUploader.java99 List<T> events = new ArrayList<T>(); in uploadEvents() local
105 while (!mEventQueue.isEmpty() && events.size() < batchSize) { in uploadEvents()
106 events.add(mEventQueue.poll()); in uploadEvents()
108 doUploadEvents(events); in uploadEvents()
109 events.clear(); in uploadEvents()
114 mEventQueue.addAll(events); in uploadEvents()
118 protected abstract void doUploadEvents(List<T> events) throws IOException; in doUploadEvents() argument
DClusterClient.java67 protected void doUploadEvents(List<ClusterCommandEvent> events) throws IOException { in doUploadEvents() argument
69 JSONObject eventData = buildPostData(events, DATA_KEY); in doUploadEvents()
83 protected void doUploadEvents(List<ClusterHostEvent> events) throws IOException { in doUploadEvents() argument
85 JSONObject eventData = buildPostData(events, DATA_KEY); in doUploadEvents()
280 private static JSONObject buildPostData(List<? extends IClusterEvent> events, String key) in buildPostData() argument
284 for (IClusterEvent event : events) { in buildPostData()
/tools/trebuchet/core/model/src/main/kotlin/trebuchet/model/
DCounter.kt23 class Counter(val name: String, val events: List<CounterValue>) { constant in trebuchet.model.Counter
24 constructor(fragment: CounterFragment) : this(fragment.name, fragment.events) {
25 events.sortedBy { it.timestamp } in <lambda>()
/tools/asuite/atest/metrics/
Dclearcut_client.py88 def _serialize_events_to_proto(self, events): argument
94 log_request.log_event.extend(events)
97 def _append_events_to_buffer(self, events, retry=False): argument
99 self._pending_events.extend(events)
137 events = self._pending_events
140 self._append_events_to_buffer(events, retry=True)
142 log_request = self._serialize_events_to_proto(events)
/tools/tradefederation/core/atest/metrics/
Dclearcut_client.py95 def _serialize_events_to_proto(self, events): argument
101 log_request.log_event.extend(events)
104 def _append_events_to_buffer(self, events, retry=False): argument
106 self._pending_events.extend(events)
143 events = self._pending_events
146 self._append_events_to_buffer(events, retry=True)
148 log_request = self._serialize_events_to_proto(events)
/tools/trebuchet/core/common/src/test/kotlin/trebuchet/importers/ftrace/
DEventTestHelpers.kt19 import trebuchet.importers.ftrace.events.FtraceEvent
20 import trebuchet.importers.ftrace.events.FtraceEventDetails
21 import trebuchet.importers.ftrace.events.createEventParser
/tools/test/connectivity/acts/tests/google/wifi/rtt/functional/
DRangeApSupporting11McTest.py59 events = rutils.run_ranging(dut, rtt_supporting_aps, self.NUM_ITER,
61 stats = rutils.analyze_results(events, self.rtt_reference_distance_mm,
135 events = rutils.run_ranging(dut, rtt_supporting_aps, self.NUM_ITER,
137 stats = rutils.analyze_results(events, self.rtt_reference_distance_mm,
163 events = rutils.run_ranging(dut, rtt_supporting_aps, self.NUM_ITER,
165 stats = rutils.analyze_results(events, self.rtt_reference_distance_mm,
197 events = rutils.run_ranging(dut, rtt_supporting_aps, self.NUM_ITER,
199 stats = rutils.analyze_results(events, self.rtt_reference_distance_mm,
240 events = dut.ed.pop_events("WifiRttRanging%d" % idx, 30)
241 dut.log.debug("Event=%s", events)
[all …]
DRangeApNonSupporting11McTest.py58 events = rutils.run_ranging(dut, non_rtt_aps, self.NUM_ITER,
60 stats = rutils.analyze_results(events, self.rtt_reference_distance_mm,
120 events = rutils.run_ranging(dut, non_rtt_aps, self.NUM_ITER,
122 stats = rutils.analyze_results(events, self.rtt_reference_distance_mm,
160 events = rutils.run_ranging(dut, non_rtt_aps, self.NUM_ITER,
162 stats = rutils.analyze_results(events, self.rtt_reference_distance_mm,
DRangeSoftApTest.py86 events = rutils.run_ranging(client, [scanned_softap],
89 events, self.rtt_reference_distance_mm,
101 "SoftAP + RTT validation done", extras=events)
DRangeApMiscTest.py47 events = rutils.run_ranging(dut, mix_list, self.NUM_ITER,
49 stats = rutils.analyze_results(events, self.rtt_reference_distance_mm,
/tools/test/connectivity/acts/framework/acts/test_utils/wifi/rtt/
Drtt_test_utils.py438 events = {} # need to keep track per BSSID!
440 events[ap["BSSID"]] = []
462 bssid in events,
465 len(events[bssid]), iterations_done,
467 events[bssid].append(result)
470 events[ap["BSSID"]].append(None)
475 return events
496 for bssid, events in all_aps_events.items():
497 stats = extract_stats(events, rtt_reference_distance_mm,
/tools/trebuchet/core/common/src/main/kotlin/trebuchet/importers/ftrace/
DFtraceImporter.kt22 import trebuchet.importers.ftrace.events.CpuBufferStarted in <lambda>()
23 import trebuchet.importers.ftrace.events.FtraceEvent in <lambda>()
24 import trebuchet.importers.ftrace.events.createEventParser in <lambda>()
/tools/trebuchet/core/model/src/main/kotlin/trebuchet/model/fragments/
DProcessModelFragment.kt60 _counters.getOrPut(name, { CounterFragment(name) }).events.add(timestamp hasCount value) in <lambda>()
78 _counters[key]!!.events.addAll(existing.events) in <lambda>()
DCounterFragment.kt22 val events: MutableList<CounterValue> = mutableListOf() constant in trebuchet.model.fragments.CounterFragment
/tools/loganalysis/src/com/android/loganalysis/item/
DKernelLogItem.java164 JSONArray events = new JSONArray(); in toJson() local
166 events.put(event.toJson()); in toJson()
170 output.put(EVENTS, events); in toJson()
DLogcatItem.java210 JSONArray events = new JSONArray(); in toJson() local
212 events.put(event.toJson()); in toJson()
216 output.put(EVENTS, events); in toJson()
/tools/test/graphicsbenchmark/apps/sample_app/src/cpp/
Dmain.cpp116 int events; in android_main() local
122 while (ALooper_pollAll(animating ? 0 : -1, NULL, &events, (void**)&source) >= 0) { in android_main()
/tools/test/connectivity/acts/tests/google/wifi/rtt/stress/
DStressRangeApTest.py48 events = rutils.run_ranging(dut, rtt_supporting_aps, num_iter, 0,
51 events,
/tools/trebuchet/
DREADME.md15 …race file, detects any startup events that occurred during the traced time period, and prints info…
19 The Startup Summarizer program takes a set of trace files, detects startup events in each file, and…
/tools/tradefederation/core/atest/test_runners/
Drobolectric_test_runner_unittest.py116 events = [
134 for event in events:
140 calls = [mock.call.process_event(name, data) for name, data in events]
/tools/asuite/atest/test_runners/
Drobolectric_test_runner_unittest.py119 events = [
137 for event in events:
143 calls = [mock.call.process_event(name, data) for name, data in events]
/tools/test/connectivity/acts/framework/tests/controllers/android_lib/
Dservices_test.py21 from acts.controllers.android_lib.events import AndroidStartServicesEvent
22 from acts.controllers.android_lib.events import AndroidStopServicesEvent
/tools/trebuchet/core/common/src/main/kotlin/trebuchet/importers/ftrace/events/
DFtraceEventRegistry.kt17 package trebuchet.importers.ftrace.events
/tools/loganalysis/tests/src/com/android/loganalysis/parser/
DBugreportParserTest.java585 List<MiscKernelLogItem> events = bugreport.getLastKmsg().getMiscEvents( in testNoSections() local
587 assertEquals(events.size(), 1); in testNoSections()
588 assertEquals(events.get(0).getStack(), "Unknown reason"); in testNoSections()
622 events = bugreport.getLastKmsg().getMiscEvents(KernelLogParser.KERNEL_RESET); in testNoSections()
623 assertEquals(events.size(), 1); in testNoSections()
624 assertEquals(events.get(0).getStack(), "Unknown reason"); in testNoSections()
/tools/tradefederation/core/tests/src/com/android/tradefed/cluster/
DClusterEventUploaderTest.java65 protected void doUploadEvents(List<Event> events) throws IOException { in setUp()
66 for (Event e : events) { in setUp()

12