@@ -5,9 +5,10 @@ import (
5
5
"net"
6
6
"sync/atomic"
7
7
8
+ "github.com/siddontang/go/sync2"
9
+
8
10
. "github.com/go-mysql-org/go-mysql/mysql"
9
11
"github.com/go-mysql-org/go-mysql/packet"
10
- "github.com/siddontang/go/sync2"
11
12
)
12
13
13
14
/*
@@ -45,7 +46,6 @@ var baseConnID uint32 = 10000
45
46
func NewConn (conn net.Conn , user string , password string , h Handler ) (* Conn , error ) {
46
47
p := NewInMemoryProvider ()
47
48
p .AddUser (user , password )
48
- salt , _ := RandomBuf (20 )
49
49
50
50
var packetConn * packet.Conn
51
51
if defaultServer .tlsConfig != nil {
@@ -61,7 +61,7 @@ func NewConn(conn net.Conn, user string, password string, h Handler) (*Conn, err
61
61
h : h ,
62
62
connectionID : atomic .AddUint32 (& baseConnID , 1 ),
63
63
stmts : make (map [uint32 ]* Stmt ),
64
- salt : salt ,
64
+ salt : RandomBuf ( 20 ) ,
65
65
}
66
66
c .closed .Set (false )
67
67
@@ -82,15 +82,14 @@ func NewCustomizedConn(conn net.Conn, serverConf *Server, p CredentialProvider,
82
82
packetConn = packet .NewConn (conn )
83
83
}
84
84
85
- salt , _ := RandomBuf (20 )
86
85
c := & Conn {
87
86
Conn : packetConn ,
88
87
serverConf : serverConf ,
89
88
credentialProvider : p ,
90
89
h : h ,
91
90
connectionID : atomic .AddUint32 (& baseConnID , 1 ),
92
91
stmts : make (map [uint32 ]* Stmt ),
93
- salt : salt ,
92
+ salt : RandomBuf ( 20 ) ,
94
93
}
95
94
c .closed .Set (false )
96
95
0 commit comments