| 71 | } |
| 72 | |
| 73 | ReaderExecutor::ReaderExecutor( |
| 74 | std::shared_ptr<IFileBasedSourceReader> source_, |
| 75 | const StoredObjects & objects, |
| 76 | size_t block_size_) |
| 77 | : source(std::move(source_)) |
| 78 | , block_size(block_size_ ? block_size_ : DEFAULT_BLOCK_SIZE) |
| 79 | , active_metric(CurrentMetrics::ReaderExecutorActive) |
| 80 | { |
| 81 | offset_map.build(objects); |
| 82 | log_file_path = objects.empty() ? "" : objects.front().remote_path; |
| 83 | LOG_DEBUG(log, "Created: source={}, objects={}, total_size={}, block_size={}", |
| 84 | source ? source->name() : "none", objects.size(), offset_map.totalSize(), block_size); |
| 85 | } |
| 86 | |
| 87 | ReaderExecutor::~ReaderExecutor() |
| 88 | { |