Home
last modified time | relevance | path

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

123

/tools/netsim/rust/daemon/src/
Dsession.rs18 use crate::events::{ChipRemoved, Event, ShutDown};
207 use crate::events;
208 use crate::events::{
230 let mut events = events::test::new(); in setup_session_start_test() localVariable
231 let events_rx = events::test::subscribe(&mut events); in setup_session_start_test()
233 (session, events) in setup_session_start_test()
242 let (mut session, mut events) = setup_session_start_test(); in test_start_and_shutdown()
248 events::test::publish( in test_start_and_shutdown()
249 &mut events, in test_start_and_shutdown()
269 let (session, mut events) = setup_session_start_test(); in test_start_and_stop()
[all …]
Devents.rs169 let events = Events::new(); in test_subscribe_and_publish() localVariable
171 let events_clone = Arc::clone(&events); in test_subscribe_and_publish()
181 events.lock().unwrap().publish(Event::DeviceAdded(DeviceAdded { in test_subscribe_and_publish()
193 let events = Events::new(); in test_publish_to_multiple_subscribers() localVariable
198 let events_clone = Arc::clone(&events); in test_publish_to_multiple_subscribers()
210 events.lock().unwrap().publish(Event::DeviceAdded(DeviceAdded { in test_publish_to_multiple_subscribers()
227 let events = Events::new(); in test_publish_to_dropped_subscriber() localVariable
228 let rx = events.lock().unwrap().subscribe(); in test_publish_to_dropped_subscriber()
229 assert_eq!(events.lock().unwrap().subscribers.len(), 1); in test_publish_to_dropped_subscriber()
231 events.lock().unwrap().publish(Event::DeviceAdded(DeviceAdded { in test_publish_to_dropped_subscriber()
[all …]
Drust_main.rs27 use crate::events;
28 use crate::events::{Event, ShutDown};
271 let capture_events_rx = events::subscribe(); in run_netsimd_primary()
272 let device_events_rx = events::subscribe(); in run_netsimd_primary()
273 let main_events_rx = events::subscribe(); in run_netsimd_primary()
274 let session_events_rx = events::subscribe(); in run_netsimd_primary()
/tools/netsim/rust/daemon/src/devices/
Ddevices_handler.rs30 use crate::events;
31 use crate::events::{
149 events::publish(Event::DeviceAdded(DeviceAdded { id, name: name.to_string(), builtin })); in get_or_create_device()
193 events::publish(Event::ChipAdded(ChipAdded { in add_chip()
318 Some(device) => events::publish(Event::DeviceRemoved(DeviceRemoved { in remove_device()
347 events::publish(Event::ChipRemoved(ChipRemoved { in remove_chip()
464 events::publish(Event::DevicePatched(DevicePatched { id, name })); in patch_device()
485 events::publish(Event::DevicePatched(DevicePatched { id, name })); in patch_device()
509 events::publish(Event::DevicePatched(DevicePatched { id, name })); in patch_device()
588 events::publish(Event::DeviceReset); in reset_all()
[all …]
/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()
287 private static JSONObject buildPostData(List<? extends IClusterEvent> events, String key) in buildPostData() argument
291 for (IClusterEvent event : events) { in buildPostData()
/tools/tradefederation/core/res/perfetto/
Dtrace_config.textproto22 # Ensure worst-case reordering of events in the central tracing buffers.
47 # core: process lifetime events
56 # device suspend/resume events
59 # RSS and ION buffer events
74 # userspace events from system_server
77 # userspace events from activity and window managers
80 # userspace events from java and c runtimes
83 # userspace events from systemui
86 # groups that expand into power events (mix of userspace and ftrace)
98 # available categories. The encoding of userspace events is very verbose
[all …]
/tools/test/connectivity/acts_tests/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,
122 events = rutils.run_ranging(dut, non_rtt_aps, self.NUM_ITER,
124 stats = rutils.analyze_results(events, self.rtt_reference_distance_mm,
162 events = rutils.run_ranging(dut, non_rtt_aps, self.NUM_ITER,
164 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)
/tools/asuite/adevice/src/
Dmetrics.rs43 events: Vec<LogEvent>, field
57 self.events.push(LogEvent { in add_start_event()
88 self.events.push(LogEvent { in add_action_event_with_files_changed()
102 self.events.push(LogEvent { in add_exit_event()
147 events: Vec::new(), in default()
166 for e in &*self.events { in send()
220 assert_eq!(metrics.events.len(), 2); in test_print_events()
222 metrics.events.clear(); in test_print_events()
223 assert_eq!(metrics.events.len(), 0); in test_print_events()
/tools/asuite/atest/metrics/
Dclearcut_client.py98 def _serialize_events_to_proto(self, events): argument
104 log_request.log_event.extend(events)
107 def _append_events_to_buffer(self, events, retry=False): argument
109 self._pending_events.extend(events)
148 events = self._pending_events
151 self._append_events_to_buffer(events, retry=True)
153 log_request = self._serialize_events_to_proto(events)
/tools/test/connectivity/acts_tests/acts_contrib/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/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/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
DFtraceImporterTest.kt143 assertEquals(2, c.events.size) in testCounters()
144 assertEquals(4493.660106, c.events[0].timestamp, .1) in testCounters()
145 assertEquals(1, c.events[0].count) in testCounters()
146 assertEquals(4493.660790, c.events[1].timestamp, .1) in testCounters()
147 assertEquals(0, c.events[1].count) in testCounters()
/tools/test/openhst/
Dstress_test.py199 def __init__(self, name, command, output, events, argument
226 self.events = []
227 for event in events:
228 self.events.append(ProcessLogger.EventScanner(event.name, self.name,
242 for event in self.events:
295 for event in self.events:
415 events = [x for x in config.event if x.source == file_to_watch.source]
435 events, True, file_to_watch.repeats_output_on_open)
442 events = [x for x in config.event if x.source == daemon_process.name]
452 process_logger = ProcessLogger(name, command, output, events,
[all …]
/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>()
/tools/loganalysis/javatests/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/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/connectivity/acts_tests/acts_contrib/test_utils/bt/
Dgatts_lib.py128 events = self.dut.ed.pop_events(regex, 5, small_timeout)
132 for event in events:
295 events = self.dut.ed.pop_events(regex, 10, small_timeout)
296 for event in events:
335 events = self.dut.ed.pop_events(regex, 10, small_timeout)
336 for event in 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/asuite/atest/test_runners/
Drobolectric_test_runner_unittest.py135 events = [
190 for event in events:
198 calls = [mock.call.process_event(name, data) for name, data in events]

123