mysql_async/conn/routines/
ping.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 executes `COM_PING`.
12#[derive(Debug, Copy, Clone)]
13pub struct PingRoutine;
14
15impl Routine<()> for PingRoutine {
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::ping", mysql_async.connection.id = conn.id());
19
20        let fut = async move {
21            conn.write_command_data(Command::COM_PING, &[]).await?;
22            conn.read_packet().await?;
23            Ok(())
24        };
25
26        #[cfg(feature = "tracing")]
27        let fut = instrument_result!(fut, span);
28
29        fut.boxed()
30    }
31}