File tree Expand file tree Collapse file tree 1 file changed +5
-1
lines changed
src/query/service/src/servers/mysql Expand file tree Collapse file tree 1 file changed +5
-1
lines changed Original file line number Diff line number Diff line change @@ -31,6 +31,7 @@ use opensrv_mysql::*;
31
31
use tokio_stream:: wrappers:: TcpListenerStream ;
32
32
use tracing:: error;
33
33
use tracing:: info;
34
+ use tracing:: warn;
34
35
35
36
use crate :: servers:: mysql:: mysql_session:: MySQLConnection ;
36
37
use crate :: servers:: mysql:: reject_connection:: RejectConnection ;
@@ -81,7 +82,10 @@ impl MySQLHandler {
81
82
fn accept_socket ( sessions : Arc < SessionManager > , executor : Arc < Runtime > , socket : TcpStream ) {
82
83
executor. spawn ( async move {
83
84
match sessions. create_session ( SessionType :: MySQL ) . await {
84
- Err ( error) => Self :: reject_session ( socket, error) . await ,
85
+ Err ( error) => {
86
+ warn ! ( "create session failed, {:?}" , error) ;
87
+ Self :: reject_session ( socket, error) . await
88
+ }
85
89
Ok ( session) => {
86
90
info ! ( "MySQL connection coming: {:?}" , socket. peer_addr( ) ) ;
87
91
if let Err ( error) = MySQLConnection :: run_on_stream ( session, socket) {
You can’t perform that action at this time.
0 commit comments