diff options
| author | levlam <levlam@telegram.org> | 2024-02-02 15:09:17 +0300 |
|---|---|---|
| committer | levlam <levlam@telegram.org> | 2024-02-02 15:09:17 +0300 |
| commit | 8377726001a209d0d2c844ee4f4449ea383b4321 (patch) | |
| tree | 4c399c7a92cebf0742d330f3ee2b51a6a048498a /test/secret.cpp | |
| parent | d79bd4b69403868897496da39b773ab25c69f6af (diff) | |
Add source to Binlog::sync.
Diffstat (limited to 'test/secret.cpp')
| -rw-r--r-- | test/secret.cpp | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/test/secret.cpp b/test/secret.cpp index 8d3b2fae2..be3274d0a 100644 --- a/test/secret.cpp +++ b/test/secret.cpp @@ -364,7 +364,7 @@ class FakeBinlog final FakeBinlog() { register_actor("FakeBinlog", this).release(); } - void force_sync(Promise<> promise) final { + void force_sync(Promise<> promise, const char *source) final { if (pending_events_.empty()) { pending_events_.emplace_back(); } @@ -639,7 +639,7 @@ class Master final : public Actor { if (binlog_generation != binlog_generation_) { return promise.set_error(Status::Error("Binlog generation mismatch")); } - binlog_->force_sync(std::move(promise)); + binlog_->force_sync(std::move(promise), "sync_binlog"); } void on_closed() { LOG(INFO) << "CLOSED"; |
