pmeunier/postrep - Change 3YOGOAKUFTRSFYT2BY5ZA5TRTIO3YIWT7DASZLT4QH62QZEG4IOAC

Test replication

Created by pmeunier on May 6, 2022

3YOGOAKUFTRSFYT2BY5ZA5TRTIO3YIWT7DASZLT4QH62QZEG4IOAC

Dependencies

In channels

main

Change contents

Replacement in src/main.rs at line 113 [3.17]

B:BD[3.1943] → [4.836:965]

B:BD[4.965] → [2.81:111]

∅:D[2.111] → [4.965:973]

B:BD[4.965] → [4.965:973]

    let mut race = tokio::spawn(race(
        host.clone(),
        path.clone(),
        is_leader.clone(),
        db.clone(),
        process_lock.clone(),
    ));

[3.1943]

[5.1366]

    let mut race = tokio::spawn(race(host.clone(), is_leader.clone(), db.clone()));

Insertion in src/main.rs at line 120 [3.17]

[3.2258]

    ));
    let mut check = tokio::spawn(check_postgres(
        host.clone(),
        port,
        password.clone(),
        db_name.clone(),
        path.clone(),
        lead.clone(),
        db.clone(),
        process_lock.clone(),

Replacement in src/main.rs at line 152 [3.17]
B:BD[3.3589] → [3.3589:3603]
```
            }
```
[3.3589]
[5.1590]
```
            },
```

Insertion in src/main.rs at line 157 [3.17]

[3.3736]

            e = &mut check => {
                error!("check postgres stopped: {:?}", e);
                break
            }

Replacement in src/main.rs at line 182 [3.17]

B:BD[2.130] → [2.130:182]

    path: String,
    mut leader: Receiver<String>,

[2.130]

[2.182]

    leader: Receiver<String>,

Deletion in src/main.rs at line 184 [3.17]
B:BD[2.236] → [2.236:270]
```
    process_lock: Arc<Mutex<()>>,
```

Replacement in src/main.rs at line 186 [3.17]

B:BD[2.285] → [2.285:481]

        match race_(
            host.clone(),
            path.clone(),
            leader.clone(),
            pool.clone(),
            process_lock.clone(),
        )
        .await
        {

[2.285]

[2.481]

        match race_(host.clone(), leader.clone(), pool.clone()).await {

Deletion in src/main.rs at line 199 [3.17]
B:BD[4.1067] → [4.1067:1085]
```
    path: String,
```
Deletion in src/main.rs at line 201 [3.17]
B:BD[4.1173] → [2.747:781]
```
    process_lock: Arc<Mutex<()>>,
```

Insertion in src/main.rs at line 301 [3.17]

[6.3137]

[2.1105]

async fn check_postgres(
    host: String,
    port: u16,
    password: String,
    db_name: String,
    path: String,
    leader: Arc<Sender<String>>,
    pool: Arc<Mutex<Option<tokio_postgres::Client>>>,
    process_lock: Arc<Mutex<()>>,
) -> Result<(), anyhow::Error> {
    loop {
        let leader = leader.borrow().to_string();
        if leader != host {
            let mut needs_rewind = false;
            let pool_ = { pool.lock().await.take() };
            if let Some(pool_) = pool_ {
                needs_rewind = pool_
                    .query_opt("SELECT 1 FROM pg_stat_wal_receiver", &[])
                    .await?
                    .is_none();
                *pool.lock().await = Some(pool_);
            }
            if needs_rewind {
                debug!("leader: {:?}", leader);
                rewind(&process_lock, &path, port, &db_name, &leader, &password).await
            }
        }
        tokio::time::sleep(std::time::Duration::from_secs(10)).await
    }
}