show that all data can be passed for processing in threads

Sebastian Thiel committed 6 years ago

Commit a95ce9c1 parent 1d4879a1 file · +17 −2Browse files

Unified · Split

         out: impl io::Write,
     ) -> Result<Outcome, Error>
     where
-        F: for<'r> Fn(u64, &'r mut Vec<u8>) -> Option<(pack::data::Header, u64)>,
+        F: for<'r> Fn(u64, &'r mut Vec<u8>) -> Option<(pack::data::Header, u64)> + Send + Sync,
     {
         use io::Write;
                 },
                 thread_limit,
                 |_| (),
-                |_base_pack_offsets, _state| Vec::new(),
+                |base_pack_offsets, state| {
+                    apply_deltas(base_pack_offsets, state, &index_entries, &_cache_by_offset, &mode)
+                },
                 Reducer::new(num_objects),
             )?;
             items.sort_by_key(|e| e.1);
         })
     }
 }
+fn apply_deltas<F>(
+    _base_entries: Vec<&Entry>,
+    _state: &mut (),
+    _entries: &[Entry],
+    _caches: &parking_lot::Mutex<BTreeMap<u64, CacheEntry>>,
+    _mode: &Mode<F>,
+) -> Vec<(u64, owned::Id)>
+where
+    F: for<'r> Fn(u64, &'r mut Vec<u8>) -> Option<(pack::data::Header, u64)> + Send + Sync,
+{
+    Vec::new()
+}