Implement #85440
This commit is contained in:
@@ -91,6 +91,7 @@ mod tests;
|
||||
use event::{CompletedTest, TestEvent};
|
||||
use helpers::concurrency::get_concurrency;
|
||||
use helpers::exit_code::get_exit_code;
|
||||
use helpers::shuffle::{get_shuffle_seed, shuffle_tests};
|
||||
use options::{Concurrent, RunStrategy};
|
||||
use test_result::*;
|
||||
use time::TestExecTime;
|
||||
@@ -247,7 +248,9 @@ where
|
||||
|
||||
let filtered_descs = filtered_tests.iter().map(|t| t.desc.clone()).collect();
|
||||
|
||||
let event = TestEvent::TeFiltered(filtered_descs);
|
||||
let shuffle_seed = get_shuffle_seed(opts);
|
||||
|
||||
let event = TestEvent::TeFiltered(filtered_descs, shuffle_seed);
|
||||
notify_about_test_event(event)?;
|
||||
|
||||
let (filtered_tests, filtered_benchs): (Vec<_>, _) = filtered_tests
|
||||
@@ -259,7 +262,11 @@ where
|
||||
let concurrency = opts.test_threads.unwrap_or_else(get_concurrency);
|
||||
|
||||
let mut remaining = filtered_tests;
|
||||
remaining.reverse();
|
||||
if let Some(shuffle_seed) = shuffle_seed {
|
||||
shuffle_tests(shuffle_seed, &mut remaining);
|
||||
} else {
|
||||
remaining.reverse();
|
||||
}
|
||||
let mut pending = 0;
|
||||
|
||||
let (tx, rx) = channel::<CompletedTest>();
|
||||
|
||||
Reference in New Issue
Block a user