diff options
| author | Dan Goodliffe <dan@randomdan.homeip.net> | 2021-08-22 13:58:49 +0100 |
|---|---|---|
| committer | Dan Goodliffe <dan@randomdan.homeip.net> | 2021-08-22 13:58:49 +0100 |
| commit | 172567f6ee168846b41d11ed7b8bd9c1ccbb659b (patch) | |
| tree | 31cb78c4dedc32e9629815b855ecc7bedfcaf0b0 /lib/output/pq/updateDatabase.cpp | |
| parent | Add EventCounter class (diff) | |
| download | mygrate-172567f6ee168846b41d11ed7b8bd9c1ccbb659b.tar.bz2 mygrate-172567f6ee168846b41d11ed7b8bd9c1ccbb659b.tar.xz mygrate-172567f6ee168846b41d11ed7b8bd9c1ccbb659b.zip | |
Wait on specific events being processed
Diffstat (limited to 'lib/output/pq/updateDatabase.cpp')
| -rw-r--r-- | lib/output/pq/updateDatabase.cpp | 7 |
1 files changed, 7 insertions, 0 deletions
diff --git a/lib/output/pq/updateDatabase.cpp b/lib/output/pq/updateDatabase.cpp index 485c914..330a0af 100644 --- a/lib/output/pq/updateDatabase.cpp +++ b/lib/output/pq/updateDatabase.cpp @@ -183,6 +183,12 @@ namespace MyGrate::Output::Pq { } } + const EventCounter & + UpdateDatabase::getProcessedCounts() const + { + return processed; + } + void UpdateDatabase::tableMap(MariaDB_Event_Ptr e) { @@ -207,6 +213,7 @@ namespace MyGrate::Output::Pq { void UpdateDatabase::afterEvent(const MariaDB_Event_Ptr & e) { + processed.tick(e->event_type); if (!intx) { output::pq::sql::updateSourcePosition::execute(this, e->next_event_pos, source); commitTx(); |