database/mariadb-connector-c
1
0
Fork 0
mirror of https://github.com/mariadb-corporation/mariadb-connector-c.git synced 2025-08-07 02:42:49 +03:00
Code Activity

Fixed ROTATE_EVENT

Browse Source 
If timestamp is zero and flag LOG_EVEBNT_ARTIFICIAL_F was set the
event is a fake ROTATE_EVENT (https://mariadb.com/kb/en/fake-rotate_event/)
and needs different handling:
- a checksum might follow if @@binlog_checksum was set (CRC32)
- length calculation is different
This commit is contained in:
Georg Richter
2022-06-22 16:25:37 +02:00
parent 3230e75646
commit abddf0b0af
2 changed files with 32 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

1
include/mariadb_rpl.h
View File

@@ -155,6 +155,7 @@ typedef struct st_mariadb_rpl {
uint32_t flags;
uint8_t fd_header_len; /* header len from last format description event */
uint8_t use_checksum;
uint8_t artificial_checksun;
} MARIADB_RPL;
/* Event header */

32
libmariadb/mariadb_rpl.c
View File

@@ -67,6 +67,21 @@ MARIADB_RPL * STDCALL mariadb_rpl_init_ex(MYSQL *mysql, unsigned int version)
}
rpl->version= version;
rpl->mysql= mysql;
if (!mysql_query(mysql, "select @@binlog_checksum"))
{
MYSQL_RES *result;
if ((result= mysql_store_result(mysql)))
{
MYSQL_ROW row= mysql_fetch_row(result);
if (!strcmp(row[0], "CRC32"))
{
rpl->artificial_checksun= 1;
}
mysql_free_result(result);
}
}
return rpl;
}
@@ -378,8 +393,23 @@ MARIADB_RPL_EVENT * STDCALL mariadb_rpl_fetch(MARIADB_RPL *rpl, MARIADB_RPL_EVEN
break;
case ROTATE_EVENT:
rpl_event->event.rotate.position= uint8korr(ev);
len= rpl_event->event_length - (ev - rpl->mysql->net.read_pos) - 8;
ev+= 8;
if (rpl_event->timestamp == 0 &&
rpl_event->flags & LOG_EVENT_ARTIFICIAL_F)
{
const uint8_t header_size= 19;
len= rpl_event->event_length - header_size - 8;
if (rpl->artificial_checksun)
{
len-= 4;
int4store(ev + len, rpl_event->checksum);
rpl->artificial_checksun= 0;
}
}
else
{
len= rpl_event->event_length - (ev - rpl->mysql->net.read_pos) - 1;
}
if (rpl_alloc_string(rpl_event, &rpl_event->event.rotate.filename, ev, len) ||
ma_set_rpl_filename(rpl, ev, len))
goto mem_error;