diff --git a/src/IO/RemoteReadBufferCache.cpp b/src/IO/RemoteReadBufferCache.cpp index 08f834b411b..869a174bed4 100644 --- a/src/IO/RemoteReadBufferCache.cpp +++ b/src/IO/RemoteReadBufferCache.cpp @@ -126,7 +126,7 @@ RemoteReadBufferCacheError RemoteCacheController::waitMoreData(size_t start_offs return RemoteReadBufferCacheError::OK; } else - more_data_signal.wait(lock, [this, end_offset_] { return this->download_finished || this->current_offset >= end_offset_ ;}); + more_data_signal.wait(lock, [this, end_offset_] { return this->download_finished || this->current_offset >= end_offset_; }); } lock.unlock(); return RemoteReadBufferCacheError::OK; @@ -436,7 +436,6 @@ void RemoteReadBufferCache::recover_cached_files_meta( auto &cell = caches[path]; cell.cache_controller = cache_cntrl; cell.key_iterator = keys.insert(keys.end(), path); - } return; } diff --git a/src/IO/RemoteReadBufferCache.h b/src/IO/RemoteReadBufferCache.h index 3d4a3880289..6188662577f 100644 --- a/src/IO/RemoteReadBufferCache.h +++ b/src/IO/RemoteReadBufferCache.h @@ -221,7 +221,7 @@ private: std::filesystem::path calculateLocalPath(const RemoteFileMeta &meta); void recover_cached_files_meta( - const std::filesystem::path & current_path_, + const std::filesystem::path & current_path_, size_t current_depth, size_t max_depth, std::function const & finish_callback);