diff options
author | sachin <sachin.setiya@mariadb.com> | 2021-03-11 21:59:13 +0000 |
---|---|---|
committer | sachin <sachin.setiya@mariadb.com> | 2021-03-11 21:59:13 +0000 |
commit | 3ad829d31aeb56cd76331d3478a1d8e04ed7300a (patch) | |
tree | e855752cc9ed8b90b67b89b51336ac26ed977f7a /sql/log_event.cc | |
parent | 4b4a020d1ce15275689fc307b8d13c107e6a41be (diff) | |
download | mariadb-git-queue-v1.tar.gz |
commit 5queue-v1
Diffstat (limited to 'sql/log_event.cc')
-rw-r--r-- | sql/log_event.cc | 11 |
1 files changed, 9 insertions, 2 deletions
diff --git a/sql/log_event.cc b/sql/log_event.cc index 74c0d6a1c4f..94c443e18ba 100644 --- a/sql/log_event.cc +++ b/sql/log_event.cc @@ -1033,9 +1033,10 @@ Log_event * create_log_event_or_get_size(const char *buf, uint event_len, r_queue *rpl_queue, uint32* size) { Log_event *ev; - void *memory __attribute__((unused)) = NULL ; - uint32 ev_size= 0; DBUG_ASSERT(buf == NULL || size == NULL); + void *memory = NULL ; +#ifndef MYSQL_CLIENT + uint32 ev_size= 0; if (rpl_queue && !size) { //get the size of the Log_event object @@ -1044,8 +1045,12 @@ Log_event * create_log_event_or_get_size(const char *buf, uint event_len, { return NULL; } + //debug info + sql_print_information("Setiya , Size of available buffer Enqueue time%ld", + rpl_queue->free_size()); memory= rpl_queue->enqueue_1(ev_size); } +#endif switch(event_type) { case QUERY_EVENT: if (!buf) @@ -1360,8 +1365,10 @@ Log_event * create_log_event_or_get_size(const char *buf, uint event_len, size= NULL; break; } +#ifndef MYSQL_CLIENT if (rpl_queue) rpl_queue->enqueue_2(ev_size); +#endif return ev; } |