mysql_async/conn/routines/
reset.rs

1use futures_core::future::BoxFuture;
2use futures_util::FutureExt;
3use mysql_common::constants::Command;
4#[cfg(feature = "tracing")]
5use tracing::debug_span;
6
7use crate::Conn;
8
9use super::Routine;
10
11/// A routine that performs `COM_RESET_CONNECTION`.
12#[derive(Debug, Copy, Clone)]
13pub struct ResetRoutine;
14
15impl Routine<()> for ResetRoutine {
16    fn call<'a>(&'a mut self, conn: &'a mut Conn) -> BoxFuture<'a, crate::Result<()>> {
17        #[cfg(feature = "tracing")]
18        let span = debug_span!("mysql_async::reset", mysql_async.connection.id = conn.id());
19
20        let fut = async move {
21            conn.write_command_data(Command::COM_RESET_CONNECTION, &[])
22                .await?;
23            conn.read_packet().await?;
24            Ok(())
25        };
26
27        #[cfg(feature = "tracing")]
28        let fut = instrument_result!(fut, span);
29
30        fut.boxed()
31    }
32}