mongodb 3.6.0

The official MongoDB driver for Rust
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39

use std::sync::atomic::Ordering;

use futures_util::future::join_all;

use crate::action::action_impl;

#[action_impl]
impl Action for crate::action::Shutdown {
    type Future = ShutdownFuture;

    async fn execute(self) -> () {
        if !self.immediate {
            // Subtle bug: if this is inlined into the `join_all(..)` call, Rust will extend the
            // lifetime of the temporary unnamed `MutexLock` until the end of the *statement*,
            // causing the lock to be held for the duration of the join, which deadlocks.
            let pending = self
                .client
                .inner
                .shutdown
                .pending_drops
                .lock()
                .unwrap()
                .extract();
            join_all(pending).await;
        }
        // If shutdown has already been called on a different copy of the client, don't call
        // end_all_sessions again.
        if !self.client.inner.shutdown.executed.load(Ordering::SeqCst) {
            self.client.end_all_sessions().await;
        }
        self.client.inner.topology.updater().shutdown().await;
        // This has to happen last to allow pending cleanup to execute commands.
        self.client
            .inner
            .shutdown
            .executed
            .store(true, Ordering::SeqCst);
    }
}