pmeunier/postrep - Change UZXIRPR3NPWWFX7R2PB7TI2GPHH6XYQWCY5IOFZ2ALHGSWGYI37AC

Restarting after various failures

Created by pmeunier on April 17, 2022

UZXIRPR3NPWWFX7R2PB7TI2GPHH6XYQWCY5IOFZ2ALHGSWGYI37AC

Dependencies

In channels

main

Change contents

Replacement in src/main.rs at line 102 [4.17]
B:BD[3.1073] → [3.1073:1074]
[3.1073]
[4.1757]
```
    let process_lock = Arc::new(Mutex::new(()));
```
Insertion in src/main.rs at line 111 [4.17]
[4.1935]
[4.1935]
```
        process_lock.clone(),
```
Insertion in src/main.rs at line 118 [4.17]
[5.965]
[5.965]
```
        process_lock.clone(),
```

Insertion in src/main.rs at line 173 [4.17]

[5.1049]

    host: String,
    path: String,
    mut leader: Receiver<String>,
    pool: Arc<Mutex<Option<tokio_postgres::Client>>>,
    process_lock: Arc<Mutex<()>>,
) {
    loop {
        match race_(
            host.clone(),
            path.clone(),
            leader.clone(),
            pool.clone(),
            process_lock.clone(),
        )
        .await
        {
            Ok(()) => {
                error!("race stopped")
            }
            Err(e) => {
                error!("race_ error {:?}", e);
            }
        }
        tokio::time::sleep(std::time::Duration::from_secs(1)).await;
    }
}
async fn race_(

Insertion in src/main.rs at line 204 [4.17]
[5.1173]
[5.1173]
```
    process_lock: Arc<Mutex<()>>,
```

Replacement in src/main.rs at line 236 [4.17]

B:BD[5.1475] → [5.1475:1505]

        promote(&path).await;

[5.1475]

[4.5486]

        // promote(&process_lock, &path).await;

Insertion in src/main.rs at line 261 [4.17]
[3.2476]
[4.6132]
```
    process_lock: Arc<Mutex<()>>,
```

Replacement in src/main.rs at line 280 [4.17]

B:BD[6.2939] → [6.2939:2972]

            promote(&path).await

[6.2939]

[5.1766]

            promote(&process_lock, &path).await

Replacement in src/main.rs at line 292 [4.17]

B:BD[5.2226] → [2.0:72]

                rewind(&path, port, &db_name, leader, &password).await;

[5.2226]

[2.72]

                rewind(&process_lock, &path, port, &db_name, leader, &password).await;

Replacement in src/main.rs at line 294 [4.17]

B:BD[2.93] → [2.93:130]

                reload(&path).await;

[2.93]

[5.2287]

                reload(&process_lock, &path).await;

Replacement in src/main.rs at line 297 [4.17]

B:BD[2.148] → [2.148:181]

            reload(&path).await;

[2.148]

[3.3173]

            reload(&process_lock, &path).await;

Replacement in src/main.rs at line 305 [4.17]
B:BD[6.3137] → [6.3137:3168]
```
async fn promote(path: &str) {
```
[6.3137]
[5.2302]
```
async fn promote(process_lock: &Mutex<()>, path: &str) {
```
Insertion in src/main.rs at line 308 [4.17]
[6.3201]
[5.2328]
```
    let guard = process_lock.lock().await;
```
Insertion in src/main.rs at line 317 [4.17]
[5.2500]
[4.6959]
```
    std::mem::drop(guard);
```
Replacement in src/main.rs at line 320 [4.17]
B:BD[6.3348] → [2.182:212]
```
async fn reload(path: &str) {
```
[6.3348]
[2.212]
```
async fn reload(process_lock: &Mutex<()>, path: &str) {
```
Insertion in src/main.rs at line 323 [4.17]
[6.3451]
[2.235]
```
    let guard = process_lock.lock().await;
```
Insertion in src/main.rs at line 332 [4.17]
[5.2702]
[2.311]
```
    std::mem::drop(guard);
```

Replacement in src/main.rs at line 335 [4.17]

B:BD[2.314] → [2.314:400]

async fn rewind(path: &str, port: u16, db_name: &str, leader: &str, password: &str) {

[2.314]

[2.400]

async fn rewind(
    process_lock: &Mutex<()>,
    path: &str,
    port: u16,
    db_name: &str,
    leader: &str,
    password: &str,
) {

Insertion in src/main.rs at line 344 [4.17]
[2.425]
[2.425]
```
    let guard = process_lock.lock().await;
```
Insertion in src/main.rs at line 403 [4.17]
[2.1664]
[6.4112]
```
    std::mem::drop(guard);
```

Restarting after various failures

Dependencies

In channels

Change contents

Replacement in src/main.rs at line 102 [4.17]

Insertion in src/main.rs at line 111 [4.17]

Insertion in src/main.rs at line 118 [4.17]

Insertion in src/main.rs at line 173 [4.17]

Insertion in src/main.rs at line 204 [4.17]

Replacement in src/main.rs at line 236 [4.17]

Insertion in src/main.rs at line 261 [4.17]

Replacement in src/main.rs at line 280 [4.17]

Replacement in src/main.rs at line 292 [4.17]

Replacement in src/main.rs at line 294 [4.17]

Replacement in src/main.rs at line 297 [4.17]

Replacement in src/main.rs at line 305 [4.17]

Insertion in src/main.rs at line 308 [4.17]

Insertion in src/main.rs at line 317 [4.17]

Replacement in src/main.rs at line 320 [4.17]

Insertion in src/main.rs at line 323 [4.17]

Insertion in src/main.rs at line 332 [4.17]

Replacement in src/main.rs at line 335 [4.17]

Insertion in src/main.rs at line 344 [4.17]

Insertion in src/main.rs at line 403 [4.17]