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

Merge pull request #34715 from azat/fix-opened-file-cache-race

Browse Source 
Workaround for a bug in NuRaft library
This commit is contained in:
alesapin 2022-03-02 13:58:43 +01:00 committed by GitHub
commit 576ff0b40d
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
2 changed files with 10 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
src/Coordination/KeeperStateManager.cpp
View File

@ -115,6 +115,15 @@ void KeeperStateManager::loadLogStore(uint64_t last_commited_index, uint64_t log
log_store->init(last_commited_index, logs_to_keep); log_store->init(last_commited_index, logs_to_keep);
} }
void KeeperStateManager::system_exit(const int /* exit_code */)
{
/// NuRaft itself calls exit() which will call atexit handlers
/// and this may lead to an issues in multi-threaded program.
///
/// Override this with abort().
abort();
}
ClusterConfigPtr KeeperStateManager::getLatestConfigFromLogStore() const ClusterConfigPtr KeeperStateManager::getLatestConfigFromLogStore() const
{ {
auto entry_with_change = log_store->getLatestConfigChange(); auto entry_with_change = log_store->getLatestConfigChange();

2
src/Coordination/KeeperStateManager.h
View File

@ -73,7 +73,7 @@ public:
nuraft::ptr<nuraft::srv_config> get_srv_config() const { return configuration_wrapper.config; } nuraft::ptr<nuraft::srv_config> get_srv_config() const { return configuration_wrapper.config; }
void system_exit(const int /* exit_code */) override {} void system_exit(const int exit_code) override;
int getPort() const int getPort() const
{ {