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

MXS-1824: Track only the opening of cursors

Browse Source 
Whether a cursor is open or not does not matter as long as the attempt to
open a cursor is detected.
This commit is contained in:
Markus Mäkelä
2018-04-25 09:24:52 +03:00
parent 08230ef24c
commit 0df326d581
3 changed files with 12 additions and 11 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
server/modules/routing/readwritesplit/readwritesplit.cc
View File

@ -596,8 +596,9 @@ bool reply_is_complete(SRWBackend& backend, GWBUF *buffer)
LOG_RS(backend, REPLY_STATE_RSET_ROWS);
backend->set_reply_state(REPLY_STATE_RSET_ROWS);
if (backend->cursor_is_open())
if (backend->is_opening_cursor())
{
backend->set_cursor_opened();
MXS_INFO("Cursor successfully opened");
LOG_RS(backend, REPLY_STATE_DONE);
backend->set_reply_state(REPLY_STATE_DONE);

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

@ -19,7 +19,7 @@ RWBackend::RWBackend(SERVER_REF* ref):
m_reply_state(REPLY_STATE_DONE),
m_large_packet(false),
m_command(0),
m_open_cursor(false),
m_opening_cursor(false),
m_expected_rows(0)
{
}
@ -84,20 +84,15 @@ bool RWBackend::write(GWBUF* buffer, response_type type)
gwbuf_copy_data(buffer, MYSQL_PS_ID_OFFSET + MYSQL_PS_ID_SIZE, 1, &flags);
// Any non-zero flag value means that we have an open cursor
m_open_cursor = flags != 0;
m_opening_cursor = flags != 0;
}
else if (cmd == MXS_COM_STMT_FETCH)
{
ss_dassert(m_open_cursor);
// Number of rows to fetch is a 4 byte integer after the ID
uint8_t buf[4];
gwbuf_copy_data(buffer, MYSQL_PS_ID_OFFSET + MYSQL_PS_ID_SIZE, 4, buf);
m_expected_rows = gw_mysql_get_byte4(buf);
}
else
{
m_open_cursor = false;
}
}
}

11
server/modules/routing/readwritesplit/rwsplitsession.hh
View File

@ -77,9 +77,14 @@ public:
return m_command;
}
inline bool cursor_is_open() const
inline bool is_opening_cursor() const
{
return m_open_cursor;
return m_opening_cursor;
}
inline void set_cursor_opened()
{
m_opening_cursor = false;
}
private:
@ -89,7 +94,7 @@ private:
*calculation for result sets when the result
* contains very large rows */
uint8_t m_command;
bool m_open_cursor; /**< Whether we have an open cursor */
bool m_opening_cursor; /**< Whether we are opening a cursor */
uint32_t m_expected_rows; /**< Number of rows a COM_STMT_FETCH is retrieving */
};