thevar1able/ClickHouse
1
0
Fork 0
mirror of https://github.com/ClickHouse/ClickHouse.git synced 2024-12-15 10:52:30 +00:00
Code Issues Packages Projects Releases Wiki Activity

fix code style

Browse Source
This commit is contained in:
taiyang-li 2021-11-29 12:01:52 +08:00
parent 85cb7fc23e
commit e8addd3243
2 changed files with 9 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
src/IO/RemoteReadBufferCache.cpp
View File

@ -24,12 +24,12 @@ namespace ErrorCodes
std::shared_ptr<RemoteCacheController> RemoteCacheController::recover( std::shared_ptr<RemoteCacheController> RemoteCacheController::recover(
const std::filesystem::path & local_path_, std::function<void(RemoteCacheController *)> const & finish_callback) const std::filesystem::path & local_path_, std::function<void(RemoteCacheController *)> const & finish_callback)
{ {
const auto & dir_handle = local_path_;
std::filesystem::path data_file = local_path_ / "data.bin"; std::filesystem::path data_file = local_path_ / "data.bin";
std::filesystem::path meta_file = local_path_ / "meta.txt"; std::filesystem::path meta_file = local_path_ / "meta.txt";
if (!std::filesystem::exists(dir_handle) || !std::filesystem::exists(data_file) || !std::filesystem::exists(meta_file)) auto * log = &Poco::Logger::get("RemoteCacheController");
if (!std::filesystem::exists(data_file) || !std::filesystem::exists(meta_file))
{ {
LOG_ERROR(&Poco::Logger::get("RemoteCacheController"), "not exists directory:" + local_path_.string()); LOG_ERROR(log, "Directory {} or file {}, {} does not exist", local_path_.string(), data_file.string(), meta_file.string());
return nullptr; return nullptr;
} }
@ -423,7 +423,11 @@ void RemoteReadBufferCache::recoverCachedFilesMeta(
void RemoteReadBufferCache::initOnce( void RemoteReadBufferCache::initOnce(
const std::filesystem::path & dir, size_t limit_size_, size_t bytes_read_before_flush_, size_t max_threads) const std::filesystem::path & dir, size_t limit_size_, size_t bytes_read_before_flush_, size_t max_threads)
{ {
LOG_TRACE(log, "init local cache. path: {}, limit {}", dir.string(), limit_size_); LOG_INFO(
log,
"Initializing local cache for remote data sources. Local cache root path: {}, cache size limit: {}",
dir.string(),
limit_size_);
local_path_prefix = dir; local_path_prefix = dir;
limit_size = limit_size_; limit_size = limit_size_;
local_cache_bytes_read_before_flush = bytes_read_before_flush_; local_cache_bytes_read_before_flush = bytes_read_before_flush_;

2
src/IO/RemoteReadBufferCache.h
View File

@ -83,7 +83,7 @@ public:
/** /**
* called in LocalCachedFileReader read(), the reading process would be blocked until * called in LocalCachedFileReader read(), the reading process would be blocked until
* enough data be downloaded. * enough data be downloaded.
* If the file has finished download, the process would be block * If the file has finished download, the process would be unblock
*/ */
RemoteReadBufferCacheError waitMoreData(size_t start_offset_, size_t end_offset_); RemoteReadBufferCacheError waitMoreData(size_t start_offset_, size_t end_offset_);