Commit 484e1f68 authored by unknown's avatar unknown

Bug#17678 (RBR format change: moving from VLE to net encoding):

  Switching to use net_*_length() instead of VLE functions.


sql/log_event.cc:
  Switching to use net_*_length() instead of VLE functions.
parent c7617f60
...@@ -28,7 +28,6 @@ ...@@ -28,7 +28,6 @@
#endif /* MYSQL_CLIENT */ #endif /* MYSQL_CLIENT */
#include <base64.h> #include <base64.h>
#include <my_bitmap.h> #include <my_bitmap.h>
#include <my_vle.h>
#define log_cs &my_charset_latin1 #define log_cs &my_charset_latin1
...@@ -5128,7 +5127,8 @@ Rows_log_event::Rows_log_event(const char *buf, uint event_len, ...@@ -5128,7 +5127,8 @@ Rows_log_event::Rows_log_event(const char *buf, uint event_len,
byte const *const var_start= (const byte *)buf + common_header_len + byte const *const var_start= (const byte *)buf + common_header_len +
post_header_len; post_header_len;
byte const *const ptr_width= var_start; byte const *const ptr_width= var_start;
byte const *const ptr_after_width= my_vle_decode(&m_width, ptr_width); uchar *ptr_after_width= (uchar*) ptr_width;
m_width = net_field_length(&ptr_after_width);
const uint byte_count= (m_width + 7) / 8; const uint byte_count= (m_width + 7) / 8;
const byte* const ptr_rows_data= var_start + byte_count + 1; const byte* const ptr_rows_data= var_start + byte_count + 1;
...@@ -5598,13 +5598,13 @@ bool Rows_log_event::write_data_body(IO_CACHE*file) ...@@ -5598,13 +5598,13 @@ bool Rows_log_event::write_data_body(IO_CACHE*file)
Note that this should be the number of *bits*, not the number of Note that this should be the number of *bits*, not the number of
bytes. bytes.
*/ */
byte sbuf[my_vle_sizeof(m_width)]; byte sbuf[sizeof(m_width)];
my_ptrdiff_t const data_size= m_rows_cur - m_rows_buf; my_ptrdiff_t const data_size= m_rows_cur - m_rows_buf;
char *const sbuf_end= (char *const)my_vle_encode(sbuf, sizeof(sbuf), m_width); char *const sbuf_end= net_store_length(sbuf, (uint) m_width);
DBUG_ASSERT(static_cast<my_size_t>(sbuf_end - (char *const)sbuf) <= sizeof(sbuf)); DBUG_ASSERT(static_cast<my_size_t>(sbuf_end - (char*) sbuf) <= sizeof(sbuf));
return (my_b_safe_write(file, sbuf, sbuf_end - (char *const)sbuf) || return (my_b_safe_write(file, sbuf, sbuf_end - (char*) sbuf) ||
my_b_safe_write(file, reinterpret_cast<byte*>(m_cols.bitmap), my_b_safe_write(file, reinterpret_cast<byte*>(m_cols.bitmap),
no_bytes_in_map(&m_cols)) || no_bytes_in_map(&m_cols)) ||
my_b_safe_write(file, m_rows_buf, data_size)); my_b_safe_write(file, m_rows_buf, data_size));
...@@ -5731,7 +5731,8 @@ Table_map_log_event::Table_map_log_event(const char *buf, uint event_len, ...@@ -5731,7 +5731,8 @@ Table_map_log_event::Table_map_log_event(const char *buf, uint event_len,
/* Length of table name + counter + terminating null */ /* Length of table name + counter + terminating null */
byte const* const ptr_colcnt= ptr_tbllen + m_tbllen + 2; byte const* const ptr_colcnt= ptr_tbllen + m_tbllen + 2;
byte const* const ptr_after_colcnt= my_vle_decode(&m_colcnt, ptr_colcnt); uchar *ptr_after_colcnt= (uchar*) ptr_colcnt;
m_colcnt= net_field_length(&ptr_after_colcnt);
DBUG_PRINT("info",("m_dblen=%d off=%d m_tbllen=%d off=%d m_colcnt=%d off=%d", DBUG_PRINT("info",("m_dblen=%d off=%d m_tbllen=%d off=%d m_colcnt=%d off=%d",
m_dblen, ptr_dblen-(const byte*)vpart, m_dblen, ptr_dblen-(const byte*)vpart,
...@@ -6043,9 +6044,9 @@ bool Table_map_log_event::write_data_body(IO_CACHE *file) ...@@ -6043,9 +6044,9 @@ bool Table_map_log_event::write_data_body(IO_CACHE *file)
byte const dbuf[]= { m_dblen }; byte const dbuf[]= { m_dblen };
byte const tbuf[]= { m_tbllen }; byte const tbuf[]= { m_tbllen };
byte cbuf[my_vle_sizeof(m_colcnt)]; byte cbuf[sizeof(m_colcnt)];
byte *const cbuf_end= my_vle_encode(cbuf, sizeof(cbuf), m_colcnt); char *const cbuf_end= net_store_length(cbuf, (uint) m_colcnt);
DBUG_ASSERT(static_cast<my_size_t>(cbuf_end - cbuf) <= sizeof(cbuf)); DBUG_ASSERT(static_cast<my_size_t>(cbuf_end - (char*) cbuf) <= sizeof(cbuf));
return (my_b_safe_write(file, dbuf, sizeof(dbuf)) || return (my_b_safe_write(file, dbuf, sizeof(dbuf)) ||
my_b_safe_write(file, (const byte*)m_dbnam, m_dblen+1) || my_b_safe_write(file, (const byte*)m_dbnam, m_dblen+1) ||
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment