Usage with asynchronous code problem - how to shut down `.connect()` call that hangs indefinitely

[Niedzwiedzw]

My problem now is that some of the connections just hang indefinitely. my code:

#[instrument(skip_all)]
async fn acquire_connection(
    OracleConnectionCredentials {
        username,
        password,
        connect_string,
    }: OracleConnectionCredentials,
) -> Result<Arc<Connection>> {
    tokio::task::spawn_blocking(move || {
        debug!("getting connection out of a pool");
        let conn = oracle::Connector::new(username, password, connect_string)
            .purity(oracle::conn::Purity::New)
            .connect()
            .map(Arc::new);
        conn
    })
    .await
    .wrap_err("thread crashed")
    .and_then(|v| v.wrap_err("acquiring"))
}

can I either give it some timeout or break this process externally?

[Niedzwiedzw]

more context: .connect() hangs with 1 (!) database out ot 113 databases I'm connecting to. internet connection is surprisingly OK for this one (5MB/s upload and download). restarting my backend fixes it temporarily (1 connection works) , but next connection fails.

this could also be random, but I can't help but suspect that there is some internal state in my app that's left over after the procedure that "stuffs" next conections

[kubo]

How about setting SQLNET.OUTBOUND_CONNECT_TIMEOUT in sqlnet.ora?

[Niedzwiedzw]

sadly I have no control over that database's configuration...

[Niedzwiedzw]

would it be hard to add a timeout to .connect() in oracle-rust ?

[cjbj]

sadly I have no control over that database's configuration...

You would set SQLNET.OUTBOUND_CONNECT_TIMEOUT in sqlnet.ora on the machine where you run Rust, not on the database tier. The potential locations for the file can be gleaned from this doc.

[Niedzwiedzw]

OH!!!! yes it worked ,thank you so much @cjbj you just saved my project, you are the best