Unified · Split
| @@ -1,6 +1,7 @@ | |||
| 1 | use git_features::parallel::InOrderIter; | ||
| 2 | use std::convert::Infallible; | 1 | use std::convert::Infallible; |
| 3 | 2 | ||
| 3 | use git_features::parallel::InOrderIter; | ||
| 4 | |||
| 4 | #[test] | 5 | #[test] |
| 5 | fn in_order_stays_in_order() { | 6 | fn in_order_stays_in_order() { |
| 6 | assert_eq!( | 7 | assert_eq!( |
| @@ -1,7 +1,6 @@ | |||
| 1 | use std::{cmp::Ordering, sync::Arc}; | 1 | use std::{cmp::Ordering, sync::Arc}; |
| 2 | 2 | ||
| 3 | use git_features::parallel::SequenceId; | 3 | use git_features::{parallel, parallel::SequenceId, progress::Progress}; |
| 4 | use git_features::{parallel, progress::Progress}; | ||
| 5 | 4 | ||
| 6 | use crate::data::output; | 5 | use crate::data::output; |
| 7 | 6 | ||
| @@ -277,8 +276,7 @@ mod util { · 269 unmodified lines | |||
| 277 | mod reduce { | 276 | mod reduce { |
| 278 | use std::marker::PhantomData; | 277 | use std::marker::PhantomData; |
| 279 | 278 | ||
| 280 | use git_features::parallel; | 279 | use git_features::{parallel, parallel::SequenceId}; |
| 281 | use git_features::parallel::SequenceId; | ||
| 282 | 280 | ||
| 283 | use super::Outcome; | 281 | use super::Outcome; |
| 284 | use crate::data::output; | 282 | use crate::data::output; |
| @@ -1,7 +1,9 @@ | |||
| 1 | use std::{convert::Infallible, sync::atomic::AtomicBool}; | 1 | use std::{convert::Infallible, sync::atomic::AtomicBool}; |
| 2 | 2 | ||
| 3 | use git_features::parallel::InOrderIter; | 3 | use git_features::{ |
| 4 | use git_features::{parallel::reduce::Finalize, progress}; | 4 | parallel::{reduce::Finalize, InOrderIter}, |
| 5 | progress, | ||
| 6 | }; | ||
| 5 | use git_odb::{compound, pack, pack::FindExt}; | 7 | use git_odb::{compound, pack, pack::FindExt}; |
| 6 | use git_pack::data::{ | 8 | use git_pack::data::{ |
| 7 | output, | 9 | output, |
| @@ -8,6 +8,7 @@ use git_repository::{ · 7 unmodified lines | |||
| 8 | interrupt, | 8 | interrupt, |
| 9 | objs::bstr::ByteVec, | 9 | objs::bstr::ByteVec, |
| 10 | odb::{pack, pack::FindExt}, | 10 | odb::{pack, pack::FindExt}, |
| 11 | parallel::InOrderIter, | ||
| 11 | prelude::Finalize, | 12 | prelude::Finalize, |
| 12 | progress, traverse, Progress, | 13 | progress, traverse, Progress, |
| 13 | }; | 14 | }; |
| @@ -237,7 +238,7 @@ where · 223 unmodified lines | |||
| 237 | let num_objects = counts.len(); | 238 | let num_objects = counts.len(); |
| 238 | let mut in_order_entries = { | 239 | let mut in_order_entries = { |
| 239 | let progress = progress.add_child("creating entries"); | 240 | let progress = progress.add_child("creating entries"); |
| 240 | pack::data::output::InOrderIter::from(pack::data::output::entry::iter_from_counts( | 241 | InOrderIter::from(pack::data::output::entry::iter_from_counts( |
| 241 | counts, | 242 | counts, |
| 242 | handle, | 243 | handle, |
| 243 | progress, | 244 | progress, |