mirror of
https://github.com/scylladb/scylladb.git
synced 2026-05-12 19:02:12 +00:00
replica: database: flush_all_tables log on completion
In database::flush_all_tables add log on completion. This slightly improves the readability of logs when debugging an issue. Refs #26932
This commit is contained in:
@@ -2793,6 +2793,7 @@ future<> database::flush_all_tables() {
|
||||
});
|
||||
_all_tables_flushed_at = db_clock::now();
|
||||
co_await _commitlog->wait_for_pending_deletes();
|
||||
dblog.info("Forcing new commitlog segment and flushing all tables complete");
|
||||
}
|
||||
|
||||
future<db_clock::time_point> database::get_all_tables_flushed_at(sharded<database>& sharded_db) {
|
||||
|
||||
@@ -131,7 +131,7 @@ async def test_major_compaction_flush_all_tables(manager: ManagerClient, compact
|
||||
await manager.api.keyspace_compaction(server.ip_addr, ks, cf)
|
||||
|
||||
flush_log = await log.grep("Forcing new commitlog segment and flushing all tables", from_mark=mark)
|
||||
assert len(flush_log) == (1 if expect_all_table_flush else 0)
|
||||
assert len(flush_log) == (2 if expect_all_table_flush else 0)
|
||||
|
||||
# all tables should be flushed the first time unless compaction_flush_all_tables_before_major_seconds == 0
|
||||
await check_all_table_flush_in_major_compaction(compaction_flush_all_tables_before_major_seconds != 0)
|
||||
|
||||
Reference in New Issue
Block a user