alagopus/pijul-test - Change VBMXB443FGZL6DLT6KAP2ICFCCQNXCUMDEUL67HB4CNKFMBBNSSAC

Retrying if the HTTP connection drops while reading the body

Created by pmeunier on December 25, 2020

VBMXB443FGZL6DLT6KAP2ICFCCQNXCUMDEUL67HB4CNKFMBBNSSAC

Dependencies

In channels

main

Change contents

Replacement in pijul/src/remote/http.rs at line 22 [3.10]
B:BD[2.157] → [2.157:190]
```
) -> Result<(), anyhow::Error> {
```
[2.157]
[2.190]
```
) -> Result<libpijul::pristine::Hash, anyhow::Error> {
```

Replacement in pijul/src/remote/http.rs at line 31 [3.10]

B:BD[2.578] → [2.578:697]

    let mut res = loop {
        let res = if let Ok(res) = client.get(&url).query(&[("change", &c32)]).send().await {

[2.578]

[2.697]

    'outer: loop {
        let mut res = if let Ok(res) = client.get(&url).query(&[("change", &c32)]).send().await {
            delay = 1f64;

Replacement in pijul/src/remote/http.rs at line 42 [3.10]

B:BD[2.984] → [2.984:1063]

        if res.status().is_success() {
            break res;
        } else {

[2.984]

[2.1063]

        if !res.status().is_success() {

Replacement in pijul/src/remote/http.rs at line 48 [3.10]

B:BD[2.1193] → [2.1193:1324]

    };
    while let Some(chunk) = res.chunk().await? {
        debug!("writing {:?}", chunk.len());
        f.write_all(&chunk)?;

[2.1193]

[2.1324]

        loop {
            match res.chunk().await {
                Ok(Some(chunk)) => {
                    debug!("writing {:?}", chunk.len());
                    f.write_all(&chunk)?;
                }
                Ok(None) => break 'outer,
                Err(_) => {
                    error!("Error while downloading {:?}, retrying", url);
                    tokio::time::delay_for(std::time::Duration::from_secs_f64(delay)).await;
                    delay *= 2.;
                    break;
                }
            }
        }
        std::fs::rename(&path_, &path_.with_extension("change"))?;

Replacement in pijul/src/remote/http.rs at line 65 [3.10]
B:BD[2.1330] → [2.1330:1404]
```
    std::fs::rename(&path_, &path_.with_extension("change"))?;
    Ok(())
```
[2.1330]
[3.207]
```
    Ok(c)
```

Replacement in pijul/src/remote/http.rs at line 99 [3.10]

B:BD[2.1867] → [2.1867:1944]

                t.await??;
                if send.send(*c).await.is_err() {

[2.1867]

[2.1944]

                let c = t.await??;
                if send.send(c).await.is_err() {