laumann/pijul - Change IBPVOKM5MXTGB2P7LCD75MISAYUNDPEKQAUEVCXJJWLWCX2TJZBAC

Fixing a bug in patch download

Created by pmeunier on March 1, 2023

IBPVOKM5MXTGB2P7LCD75MISAYUNDPEKQAUEVCXJJWLWCX2TJZBAC

Dependencies

In channels

main

Change contents

Deletion in pijul/src/remote/mod.rs at line 1162 [3.52474]
B:BD[3.69111] → [4.3025:3095]
```
        let mut to_download = HashSet::with_capacity(to_apply.len());
```

Insertion in pijul/src/remote/mod.rs at line 1163 [3.52474]

[2.94]

[5.231]

        let (send_ready, mut recv_ready) = tokio::sync::mpsc::channel(100);

Insertion in pijul/src/remote/mod.rs at line 1166 [3.52474]
[5.259]
[6.0]
```
            debug!("to_apply {:?}", h);
```

Deletion in pijul/src/remote/mod.rs at line 1174 [3.52474]

B:BD[7.16468] → [6.298:408]

B:BD[6.408] → [2.95:125]

∅:D[2.125] → [6.408:448]

B:BD[6.408] → [6.408:448]

            }
            if std::fs::metadata(&change_path_).is_err() {
                hash_send.send(*h)?;
                waiting += 1;
                to_download.insert(*h);

Insertion in pijul/src/remote/mod.rs at line 1175 [3.52474]

[5.454]

[6.449]

            hash_send.send(*h)?;
            waiting += 1;

Replacement in pijul/src/remote/mod.rs at line 1180 [3.52474]

B:BD[2.127] → [2.127:237]

        let (u, mut to_apply) = self
            .download_changes_rec(repo, hash_send, recv, pro_a, waiting)

[2.127]

[2.237]

        let u = self
            .download_changes_rec(repo, hash_send, recv, send_ready, pro_a, waiting)

Replacement in pijul/src/remote/mod.rs at line 1186 [3.52474]

B:BD[8.1454] → [2.259:311]

        while let Some(h) = to_apply.recv().await {

[8.1454]

[4.3174]

        while let Some(h) = recv_ready.recv().await {

Insertion in pijul/src/remote/mod.rs at line 1248 [3.52474]
[2.800]
[2.800]
```
        send_ready: tokio::sync::mpsc::Sender<CS>,
```

Replacement in pijul/src/remote/mod.rs at line 1251 [3.52474]

B:BD[2.850] → [2.850:1100]

    ) -> Result<
        (
            tokio::task::JoinHandle<Result<(), anyhow::Error>>,
            tokio::sync::mpsc::Receiver<CS>,
        ),
        anyhow::Error,
    > {
        let (send_ready, recv_ready) = tokio::sync::mpsc::channel(100);

[2.850]

[2.1100]

    ) -> Result<tokio::task::JoinHandle<Result<(), anyhow::Error>>, anyhow::Error> {

Replacement in pijul/src/remote/mod.rs at line 1305 [3.52474]
B:BD[2.3274] → [2.3274:3302]
```
        Ok((t, recv_ready))
```
[2.3274]
[2.3302]
```
        Ok(t)
```

Replacement in pijul/src/remote/mod.rs at line 1345 [3.52474]

B:BD[3.72022] → [2.3447:3566]

        let (u, mut recv_ready) = self
            .download_changes_rec(repo, send_hash, recv_signal, pro_n, waiting)

[3.72022]

[2.3566]


        let (send_ready, mut recv_ready) = tokio::sync::mpsc::channel(100);
        let u = self
            .download_changes_rec(repo, send_hash, recv_signal, send_ready, pro_n, waiting)