itsscb/sqlx
1
0
Fork 0
mirror of https://github.com/launchbadge/sqlx.git synced 2025-12-29 21:00:54 +00:00
Code Issues Packages Projects Releases Wiki Activity

refactor(mysql): prefer handle_ over recv_ for methods that do not recv from the buffer but only handle what was received

Browse Source
This commit is contained in:
Ryan Leckey 2021-03-20 00:14:44 -07:00
parent 6d869bef7e
commit 366741fe0f
No known key found for this signature in database
GPG Key ID: F8AA68C235AB08C9
1 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
sqlx-mysql/src/connection/connect.rs
View File

@ -19,7 +19,7 @@ use crate::protocol::{AuthResponse, Capabilities, Handshake, HandshakeResponse};
use crate::{MySqlConnectOptions, MySqlConnection};
impl<Rt: Runtime> MySqlConnection<Rt> {
fn recv_handshake(
fn handle_handshake(
&mut self,
options: &MySqlConnectOptions,
handshake: &Handshake,
@ -56,7 +56,7 @@ impl<Rt: Runtime> MySqlConnection<Rt> {
Ok(())
}
fn recv_auth_response(
fn handle_auth_response(
&mut self,
options: &MySqlConnectOptions,
handshake: &mut Handshake,
@ -122,11 +122,11 @@ macro_rules! impl_connect {
// immediately the server should emit a <Handshake> packet
// we need to handle that and reply with a <HandshakeResponse>
let mut handshake = read_packet!($(@$blocking)? self_.stream).deserialize()?;
self_.recv_handshake($options, &handshake)?;
self_.handle_handshake($options, &handshake)?;
loop {
let response = read_packet!($(@$blocking)? self_.stream).deserialize_with(self_.capabilities)?;
if self_.recv_auth_response($options, &mut handshake, response)? {
if self_.handle_auth_response($options, &mut handshake, response)? {
// complete, successful authentication
break;
}