Skip to content

Commit 7242d1e

Browse files
committed
rename init and auth packets to documented names
1 parent 9be743a commit 7242d1e

File tree

4 files changed

+9
-9
lines changed

4 files changed

+9
-9
lines changed

auth_test.go

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -93,7 +93,7 @@ func TestAuthCachingSHA256PasswordCached(t *testing.T) {
9393
if err != nil {
9494
t.Fatal(err)
9595
}
96-
if err = mc.writeAuthPacket(authResp, plugin); err != nil {
96+
if err = mc.writeHandshakeResponsePacket(authResp, plugin); err != nil {
9797
t.Fatal(err)
9898
}
9999

@@ -137,7 +137,7 @@ func TestAuthCachingSHA256PasswordEmpty(t *testing.T) {
137137
if err != nil {
138138
t.Fatal(err)
139139
}
140-
if err = mc.writeAuthPacket(authResp, plugin); err != nil {
140+
if err = mc.writeHandshakeResponsePacket(authResp, plugin); err != nil {
141141
t.Fatal(err)
142142
}
143143

@@ -178,7 +178,7 @@ func TestAuthCachingSHA256PasswordFullRSA(t *testing.T) {
178178
if err != nil {
179179
t.Fatal(err)
180180
}
181-
if err = mc.writeAuthPacket(authResp, plugin); err != nil {
181+
if err = mc.writeHandshakeResponsePacket(authResp, plugin); err != nil {
182182
t.Fatal(err)
183183
}
184184

@@ -232,7 +232,7 @@ func TestAuthCachingSHA256PasswordFullSecure(t *testing.T) {
232232
if err != nil {
233233
t.Fatal(err)
234234
}
235-
if err = mc.writeAuthPacket(authResp, plugin); err != nil {
235+
if err = mc.writeHandshakeResponsePacket(authResp, plugin); err != nil {
236236
t.Fatal(err)
237237
}
238238

driver.go

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -107,7 +107,7 @@ func (d MySQLDriver) Open(dsn string) (driver.Conn, error) {
107107
mc.writeTimeout = mc.cfg.WriteTimeout
108108

109109
// Reading Handshake Initialization Packet
110-
authData, plugin, err := mc.readInitPacket()
110+
authData, plugin, err := mc.readHandshakePacket()
111111
if err != nil {
112112
mc.cleanup()
113113
return nil, err
@@ -125,7 +125,7 @@ func (d MySQLDriver) Open(dsn string) (driver.Conn, error) {
125125
return nil, err
126126
}
127127
}
128-
if err = mc.writeAuthPacket(authResp, plugin); err != nil {
128+
if err = mc.writeHandshakeResponsePacket(authResp, plugin); err != nil {
129129
mc.cleanup()
130130
return nil, err
131131
}

packets.go

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -154,7 +154,7 @@ func (mc *mysqlConn) writePacket(data []byte) error {
154154

155155
// Handshake Initialization Packet
156156
// http://dev.mysql.com/doc/internals/en/connection-phase-packets.html#packet-Protocol::Handshake
157-
func (mc *mysqlConn) readInitPacket() ([]byte, string, error) {
157+
func (mc *mysqlConn) readHandshakePacket() ([]byte, string, error) {
158158
data, err := mc.readPacket()
159159
if err != nil {
160160
// for init we can rewrite this to ErrBadConn for sql.Driver to retry, since
@@ -246,7 +246,7 @@ func (mc *mysqlConn) readInitPacket() ([]byte, string, error) {
246246

247247
// Client Authentication Packet
248248
// http://dev.mysql.com/doc/internals/en/connection-phase-packets.html#packet-Protocol::HandshakeResponse
249-
func (mc *mysqlConn) writeAuthPacket(authResp []byte, plugin string) error {
249+
func (mc *mysqlConn) writeHandshakeResponsePacket(authResp []byte, plugin string) error {
250250
// Adjust client flags based on server support
251251
clientFlags := clientProtocol41 |
252252
clientSecureConn |

packets_test.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -319,7 +319,7 @@ func TestRegression801(t *testing.T) {
319319
112, 97, 115, 115, 119, 111, 114, 100}
320320
conn.maxReads = 1
321321

322-
authData, pluginName, err := mc.readInitPacket()
322+
authData, pluginName, err := mc.readHandshakePacket()
323323
if err != nil {
324324
t.Fatalf("got error: %v", err)
325325
}

0 commit comments

Comments
 (0)