thevar1able/ClickHouse
1
0
Fork 0
mirror of https://github.com/ClickHouse/ClickHouse.git synced 2024-11-26 09:32:01 +00:00
Code Issues Packages Projects Releases Wiki Activity

Fix 4LW test

Browse Source
This commit is contained in:
Antonio Andelic 2022-11-26 19:24:10 +00:00
parent 76eca8bdfb
commit cade21b76e
3 changed files with 7 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
src/Common/ConcurrentBoundedQueue.h
View File

@ -143,6 +143,7 @@ public:
return popImpl(x, milliseconds);
}
/// Returns false if queue is empty.
[[nodiscard]] bool tryPop(T & x)
{
{

4
src/Coordination/CoordinationSettings.cpp
View File

@ -140,6 +140,10 @@ void KeeperConfigurationAndSettings::dump(WriteBufferFromOwnString & buf) const
writeText("max_requests_batch_size=", buf);
write_int(coordination_settings->max_requests_batch_size);
writeText("max_request_queue_size=", buf);
write_int(coordination_settings->max_request_queue_size);
writeText("max_requests_quick_batch_size=", buf);
write_int(coordination_settings->max_requests_quick_batch_size);
writeText("quorum_reads=", buf);
write_bool(coordination_settings->quorum_reads);
writeText("force_sync=", buf);

2
tests/integration/test_keeper_four_word_command/test.py
View File

@ -285,6 +285,8 @@ def test_cmd_conf(started_cluster):
assert result["fresh_log_gap"] == "200"
assert result["max_requests_batch_size"] == "100"
assert result["max_request_queue_size"] == "100000"
assert result["max_requests_quick_batch_size"] == "10"
assert result["quorum_reads"] == "false"
assert result["force_sync"] == "true"