file:rs \.run\(

Search Result Root fuchsia/fuchsia
Branch
Branch
main
Search Result Path
src/sys/test_runners/stress_test/src/test.rs
89:
90:
91:
actor_proxy
.run(&action, seed)
.map(|r| {
249:
250:
251:
// This will block if the actor is currently performing an operation
let previous_result = actor.run(action, seed, self.action_timeout.clone()).await;
Search Result Root fuchsia/fuchsia
Branch
Branch
main
Search Result Path
third_party/antlion/runner/src/main.rs
109:
110:
111:
{
let exit_code = runner.run(config_path).context("Failed to run antlion")?;
match exit_code {
Search Result Root fuchsia/fuchsia
Branch
Branch
main
Search Result Path
src/sys/test_runners/rust/src/test_server.rs
728:
729:
730:
suite_proxy
.run(&invocations, &run_options, run_listener_client)
.context("cannot call run")?;
Search Result Root fuchsia/fuchsia
Branch
Branch
main
Search Result Path
src/sys/test_runners/src/elf/elf_component.rs
553:
554:
555:
let mut abortable_handles = abortable_handles.lock().unwrap();
let abortable_handle = get_test_server().run(weak_component.clone(), &url, stream);
abortable_handles.push(abortable_handle);
Search Result Root fuchsia/fuchsia
Branch
Branch
main
Search Result Path
src/sys/test_runners/inspect/src/test_server.rs
135:
136:
137:
Ok(json) => {
match context.run(&serde_json::to_string_pretty(&json).unwrap_or_default()) {
Ok(_) => {
Search Result Root fuchsia/fuchsia
Branch
Branch
main
Search Result Path
third_party/rust_crates/vendor/tokio-1.38.1/src/runtime/blocking/pool.rs
158:
159:
160:
fn run(self) {
self.task.run();
}
164:
165:
166:
Mandatory::NonMandatory => self.task.shutdown(),
Mandatory::Mandatory => self.task.run(),
}
470:
471:
472:
let _enter = rt.enter();
rt.inner.blocking_spawner().inner.run(id);
drop(shutdown_tx);
Search Result Root fuchsia/fuchsia
Branch
Branch
main
Search Result Path
src/lib/fuchsia-async/src/runtime/task_group.rs
116:
117:
SendExecutorBuilder::new().num_threads(task_count).build().run(async move {
let mut task_group = TaskGroup::new();
133:
134:
135:
fn test_task_group_empty_join_completes() {
SendExecutorBuilder::new().num_threads(1).build().run(async move {
TaskGroup::new().join().await;
144:
145:
SendExecutorBuilder::new().num_threads(task_count).build().run(async move {
let mut task_group = TaskGroup::new();
165:
166:
167:
let task_count = 3;
SendExecutorBuilder::new().num_threads(task_count).build().run(async move {
let mut task_group = TaskGroup::new();
Search Result Root fuchsia/fuchsia
Branch
Branch
main
Search Result Path
third_party/rust_crates/vendor/tokio-1.38.1/src/runtime/scheduler/multi_thread/worker.rs
499:
500:
501:
// using `?` to short circuit.
assert!(cx.run(core).is_err());

584:
585:
586:
coop::budget(|| {
task.run();
let mut lifo_polls = 0;
647:
648:
649:
let task = self.worker.handle.shared.owned.assert_owner(task);
task.run();
}
Search Result Root fuchsia/fuchsia
Branch
Branch
main
Search Result Path
src/lib/fuchsia-async/src/runtime/fuchsia/timer.rs
838:
839:
840:
fn test_shorter_fires_first_multithreaded<T: TestTimeInterface>() {
SendExecutorBuilder::new().num_threads(4).build().run(async {
let shorter = pin!(Timer::new(T::after(zx::Duration::<T::Timeline>::from_millis(100))));
1072:
1073:
1074:
// This is a test for https://fxbug.dev/418235546.
SendExecutorBuilder::new().num_threads(2).build().run(async {
const TIMER_DELAY: zx::MonotonicDuration = zx::Duration::from_micros(100);
Search Result Root fuchsia/fuchsia
Branch
Branch
main
Search Result Path
third_party/rust_crates/vendor/tokio-1.38.1/src/runtime/tests/task.rs
159:
160:
161:
let (task, _) = unowned(async {}, NoopSchedule, Id::next());
task.run();
}
293:
294:
295:
let task = self.0.owned.assert_owner(task);
task.run();
}

Results per page