thevar1able/ClickHouse
1
0
Fork 0
mirror of https://github.com/ClickHouse/ClickHouse.git synced 2024-11-22 07:31:57 +00:00
Code Issues Packages Projects Releases Wiki Activity

Fixed tests

Browse Source
This commit is contained in:
Maksim Kita 2021-10-08 20:18:33 +03:00
parent 46ba649821
commit c6eece5a03
2 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
src/Common/ConcurrentBoundedQueue.h
View File

@ -45,7 +45,7 @@ private:
}
else
{
push_condition.wait(queue_lock, [&](){ return is_finished || queue.size() < max_fill; });
push_condition.wait(queue_lock, predicate);
}
if (is_finished)

2
src/Coordination/KeeperStateMachine.cpp
View File

@ -122,7 +122,7 @@ nuraft::ptr<nuraft::buffer> KeeperStateMachine::commit(const uint64_t log_idx, n
LOG_DEBUG(log, "Session ID response {} with timeout {}", session_id, session_id_request.session_timeout_ms);
response->session_id = session_id;
if (!responses_queue.push(response_for_session))
LOG_WARNING(log, "Could not push response {} into responses queue", session_id);
throw Exception(ErrorCodes::SYSTEM_ERROR, "Could not push response with session id {} into responses queue", session_id);
}
}
else