summaryrefslogtreecommitdiff
path: root/lib/output
diff options
context:
space:
mode:
authorDan Goodliffe <dan@randomdan.homeip.net>2021-07-31 17:06:27 +0100
committerDan Goodliffe <dan@randomdan.homeip.net>2021-07-31 17:06:27 +0100
commit05b75be49f2961f72f6cae7fdfcb837cd13a4370 (patch)
tree539a633d8e36d2c1fa3b83b46a28d66807d78386 /lib/output
parentReplicationPosition constructor required for Clang (diff)
downloadmygrate-05b75be49f2961f72f6cae7fdfcb837cd13a4370.tar.bz2
mygrate-05b75be49f2961f72f6cae7fdfcb837cd13a4370.tar.xz
mygrate-05b75be49f2961f72f6cae7fdfcb837cd13a4370.zip
before and afterEvents for log rotate
Diffstat (limited to 'lib/output')
-rw-r--r--lib/output/pq/updateDatabase.cpp2
1 files changed, 2 insertions, 0 deletions
diff --git a/lib/output/pq/updateDatabase.cpp b/lib/output/pq/updateDatabase.cpp
index 59c5013..e5cd8d8 100644
--- a/lib/output/pq/updateDatabase.cpp
+++ b/lib/output/pq/updateDatabase.cpp
@@ -402,8 +402,10 @@ namespace MyGrate::Output::Pq {
UpdateDatabase::rotate(MariaDB_Event_Ptr e)
{
if ((e->flags & LOG_EVENT_ARTIFICIAL_F) == 0) {
+ beforeEvent(e);
output::pq::sql::updateSourceRotate::execute(
this, *e->event.rotate.filename, e->event.rotate.position, source);
+ afterEvent(e);
}
}
}