Modified gw_read_client_event so that it only calls mysql_send_ok after new sessions has been set up and initialized.
This commit is contained in:
@ -556,18 +556,13 @@ int gw_read_client_event(DCB* dcb) {
|
|||||||
if (auth_val == 0)
|
if (auth_val == 0)
|
||||||
{
|
{
|
||||||
SESSION *session = NULL;
|
SESSION *session = NULL;
|
||||||
|
|
||||||
protocol->state = MYSQL_AUTH_RECV;
|
protocol->state = MYSQL_AUTH_RECV;
|
||||||
|
|
||||||
//write to client mysql AUTH_OK packet, packet n. is 2
|
//write to client mysql AUTH_OK packet, packet n. is 2
|
||||||
mysql_send_ok(dcb, 2, 0, NULL);
|
|
||||||
|
|
||||||
// start a new session, and connect to backends
|
// start a new session, and connect to backends
|
||||||
session = session_alloc(dcb->service, dcb);
|
session = session_alloc(dcb->service, dcb);
|
||||||
|
|
||||||
protocol->state = MYSQL_IDLE;
|
protocol->state = MYSQL_IDLE;
|
||||||
|
|
||||||
session->data = (MYSQL_session *)dcb->data;
|
session->data = (MYSQL_session *)dcb->data;
|
||||||
|
mysql_send_ok(dcb, 2, 0, NULL);
|
||||||
}
|
}
|
||||||
else
|
else
|
||||||
{
|
{
|
||||||
@ -862,7 +857,6 @@ int gw_MySQLAccept(DCB *listener) {
|
|||||||
//fprintf(stderr, "Added fd %i to poll, protocol state [%i]\n", c_sock , client->state);
|
//fprintf(stderr, "Added fd %i to poll, protocol state [%i]\n", c_sock , client->state);
|
||||||
client->state = DCB_STATE_POLLING;
|
client->state = DCB_STATE_POLLING;
|
||||||
}
|
}
|
||||||
|
|
||||||
client->state = DCB_STATE_PROCESSING;
|
client->state = DCB_STATE_PROCESSING;
|
||||||
|
|
||||||
//send handshake to the client
|
//send handshake to the client
|
||||||
|
Reference in New Issue
Block a user