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

Use correct write in Backend::execute_session_command

Browse Source 
Backend::execute_session_command would use the overridden write method
instead of the Backend::write method that it intended to use. This caused
session commands that did not expect a response to be in a state that
expected a result.

Also fixed RWBackend::write pass the response_type value to
Backend::write.
This commit is contained in:
Markus Mäkelä 2018-06-21 14:43:15 +03:00
parent c49b6ada7d
commit e561c3995c
No known key found for this signature in database
GPG Key ID: 72D48FCE664F7B19
2 changed files with 10 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

19
server/core/backend.cc
View File

@ -87,18 +87,18 @@ bool Backend::execute_session_command()
CHK_DCB(m_dcb);
SessionCommandList::iterator iter = m_session_commands.begin();
SessionCommand& sescmd = *(*iter);
GWBUF *buffer = sescmd.deep_copy_buffer();
SSessionCommand& sescmd = m_session_commands.front();
GWBUF *buffer = sescmd->deep_copy_buffer();
bool rval = false;
switch (sescmd.get_command())
switch (sescmd->get_command())
{
case MXS_COM_QUIT:
case MXS_COM_STMT_CLOSE:
/** These commands do not generate responses */
rval = write(buffer, NO_RESPONSE);
rval = Backend::write(buffer, NO_RESPONSE);
complete_session_command();
ss_dassert(!is_waiting_result());
break;
case MXS_COM_CHANGE_USER:
@ -109,12 +109,11 @@ bool Backend::execute_session_command()
case MXS_COM_QUERY:
default:
/**
* Mark session command buffer, it triggers writing
* MySQL command to protocol
*/
// TODO: Remove use of GWBUF_TYPE_SESCMD
//Mark session command buffer, it triggers writing MySQL command to protocol
gwbuf_set_type(buffer, GWBUF_TYPE_SESCMD);
rval = write(buffer);
rval = Backend::write(buffer);
ss_dassert(is_waiting_result());
break;
}

2
server/modules/routing/readwritesplit/rwsplitsession.cc
View File

@ -96,7 +96,7 @@ bool RWBackend::write(GWBUF* buffer, response_type type)
}
}
return mxs::Backend::write(buffer);
return mxs::Backend::write(buffer, type);
}
bool RWBackend::consume_fetched_rows(GWBUF* buffer)