hcq/MaxScale
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Fix to MXS-244: https://mariadb.atlassian.net/browse/MXS-244

Browse Source 
Fixed buffers being only partially consumed if they contained more than one packet
when a replu to a prepared statement is received.
This commit is contained in:
Markus Makela
2015-07-04 09:04:53 +03:00
parent 4f421cb69a
commit 03b5a634f4
1 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
server/modules/routing/readwritesplit/readwritesplit.c
View File

@ -3787,7 +3787,7 @@ static GWBUF* sescmd_cursor_process_replies(
dcb_close(bref->bref_dcb); dcb_close(bref->bref_dcb);
*reconnect = true; *reconnect = true;
if(replybuf) if(replybuf)
gwbuf_consume(replybuf,gwbuf_length(replybuf)); while((replybuf = gwbuf_consume(replybuf,gwbuf_length(replybuf))));
} }
} }
/** This is a response from the master and it is the "right" one. /** This is a response from the master and it is the "right" one.
@ -3830,7 +3830,7 @@ static GWBUF* sescmd_cursor_process_replies(
skygw_log_write(LOGFILE_DEBUG,"Slave '%s' responded faster to a session command.", skygw_log_write(LOGFILE_DEBUG,"Slave '%s' responded faster to a session command.",
bref->bref_backend->backend_server->unique_name); bref->bref_backend->backend_server->unique_name);
if(replybuf) if(replybuf)
gwbuf_free(replybuf); while((replybuf = gwbuf_consume(replybuf,gwbuf_length(replybuf))));
return NULL; return NULL;
} }