fix hangs on authenticate

query/Cargo.toml

@@ -53,7 +53,7 @@ common-tracing = { path = "../common/tracing" }
 
 # Github dependencies
 cargo-license = { git = "https://github.com/datafuse-extras/cargo-license", rev = "f1ce4a2" }
-msql-srv = { git = "https://github.com/datafuse-extras/msql-srv", rev = "70aa0b2" }
+msql-srv = { git = "https://github.com/datafuse-extras/msql-srv", rev = "af29f7b" }
 sqlparser = { git = "https://github.com/datafuse-extras/sqlparser-rs", rev = "472f5b6" }
 
 # Crates.io dependencies

query/src/servers/mysql/mysql_interactive_worker.rs

@@ -55,7 +55,7 @@ pub struct InteractiveWorker<W: std::io::Write> {
 }
 
 #[async_trait::async_trait]
-impl<W: std::io::Write + Send> AsyncMysqlShim<W> for InteractiveWorker<W> {
+impl<W: std::io::Write + Send + Sync> AsyncMysqlShim<W> for InteractiveWorker<W> {
     type Error = ErrorCode;
 
     fn version(&self) -> &str {
@@ -78,34 +78,33 @@ impl<W: std::io::Write + Send> AsyncMysqlShim<W> for InteractiveWorker<W> {
         self.salt
     }
 
-    fn authenticate(
+    async fn authenticate(
         &self,
         _auth_plugin: &str,
         username: &[u8],
         salt: &[u8],
         auth_data: &[u8],
     ) -> bool {
         let username = String::from_utf8_lossy(username);
-        let info = CertifiedInfo::create(&username, auth_data, &self.client_addr);
+        let client_addr = self.client_addr.clone();
+        let info = CertifiedInfo::create(&username, auth_data, &client_addr);
 
         let authenticate = self.base.authenticate(salt, info);
-        futures::executor::block_on(async move {
-            match authenticate.await {
-                Ok(res) => res,
-                Err(failure) => {
-                    tracing::error!(
-                        "MySQL handler authenticate failed, \
+        match authenticate.await {
+            Ok(res) => res,
+            Err(failure) => {
+                tracing::error!(
+                    "MySQL handler authenticate failed, \
                         user_name: {}, \
                         client_address: {}, \
                         failure_cause: {}",
-                        username,
-                        self.client_addr,
-                        failure
-                    );
-                    false
-                }
+                    username,
+                    client_addr,
+                    failure
+                );
+                false
             }
-        })
+        }
     }
 
     async fn on_prepare<'a>(