cybercyst/jj
1
0
Fork 0
mirror of https://github.com/martinvonz/jj.git synced 2025-05-05 23:42:50 +00:00
Code Issues Packages Projects Releases Wiki Activity

update_from_content: write sides to backend concurrently

Browse Source
This commit is contained in:
Martin von Zweigbergk 2025-04-19 21:50:27 -07:00
parent 7073811fe0
commit 382cedc114
No known key found for this signature in database
1 changed files with 17 additions and 15 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
lib/src/conflicts.rs
View File

@ -21,6 +21,7 @@ use std::iter::zip;
use bstr::BString; use bstr::BString;
use bstr::ByteSlice as _; use bstr::ByteSlice as _;
use futures::future::try_join_all;
use futures::stream::BoxStream; use futures::stream::BoxStream;
use futures::try_join; use futures::try_join;
use futures::Stream; use futures::Stream;
@ -1017,12 +1018,12 @@ pub async fn update_from_content(
// Now write the new files contents we found by parsing the file with conflict // Now write the new files contents we found by parsing the file with conflict
// markers. // markers.
// TODO: Write these concurrently let new_file_ids: Vec<Option<FileId>> =
let new_file_ids: Vec<Option<FileId>> = zip(contents.iter(), simplified_file_ids.iter()) try_join_all(zip(contents.iter(), simplified_file_ids.iter()).map(
.map(|(content, file_id)| -> BackendResult<Option<FileId>> { async |(content, file_id)| -> BackendResult<Option<FileId>> {
match file_id { match file_id {
Some(_) => { Some(_) => {
let file_id = store.write_file(path, &mut content.as_slice()).block_on()?; let file_id = store.write_file(path, &mut content.as_slice()).await?;
Ok(Some(file_id)) Ok(Some(file_id))
} }
None => { None => {
@ -1031,8 +1032,9 @@ pub async fn update_from_content(
Ok(None) Ok(None)
} }
} }
}) },
.try_collect()?; ))
.block_on()?;
// If the conflict was simplified, expand the conflict to the original // If the conflict was simplified, expand the conflict to the original
// number of sides. // number of sides.