diff --git a/include/maxscale/protocol/rwbackend.hh b/include/maxscale/protocol/rwbackend.hh index 3dcbfdef8..d8b1841d5 100644 --- a/include/maxscale/protocol/rwbackend.hh +++ b/include/maxscale/protocol/rwbackend.hh @@ -54,6 +54,27 @@ public: return m_reply_state; } + const char* reply_state_str() const + { + switch (m_reply_state) + { + case REPLY_STATE_START: + return "START"; + + case REPLY_STATE_DONE: + return "DONE"; + + case REPLY_STATE_RSET_COLDEF: + return "COLDEF"; + + case REPLY_STATE_RSET_ROWS: + return "ROWS"; + + default: + return "UNKNOWN"; + } + } + void add_ps_handle(uint32_t id, uint32_t handle); uint32_t get_ps_handle(uint32_t id) const; diff --git a/server/modules/protocol/MySQL/rwbackend.cc b/server/modules/protocol/MySQL/rwbackend.cc index 5924d60b0..e95b6406b 100644 --- a/server/modules/protocol/MySQL/rwbackend.cc +++ b/server/modules/protocol/MySQL/rwbackend.cc @@ -254,6 +254,9 @@ void RWBackend::process_reply(GWBUF* buffer) } } + MXS_DEBUG("cmd: %02hhx bytes: %u packets: %d state: %s", mxs_mysql_get_command(buffer), + gwbuf_length(buffer), modutil_count_packets(buffer), reply_state_str()); + if (get_reply_state() == REPLY_STATE_DONE) { ack_write();