summaryrefslogtreecommitdiff
path: root/sql/log_event.cc
diff options
context:
space:
mode:
authorsachin <sachin.setiya@mariadb.com>2021-03-11 21:59:13 +0000
committersachin <sachin.setiya@mariadb.com>2021-03-11 21:59:13 +0000
commit3ad829d31aeb56cd76331d3478a1d8e04ed7300a (patch)
treee855752cc9ed8b90b67b89b51336ac26ed977f7a /sql/log_event.cc
parent4b4a020d1ce15275689fc307b8d13c107e6a41be (diff)
downloadmariadb-git-queue-v1.tar.gz
commit 5queue-v1
Diffstat (limited to 'sql/log_event.cc')
-rw-r--r--sql/log_event.cc11
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;
}