| 218 | } |
| 219 | |
| 220 | ProgressValues Progress::getValues() const |
| 221 | { |
| 222 | ProgressValues res; |
| 223 | |
| 224 | res.read_rows = read_rows.load(std::memory_order_relaxed); |
| 225 | res.read_bytes = read_bytes.load(std::memory_order_relaxed); |
| 226 | res.read_raw_bytes = read_raw_bytes.load(std::memory_order_relaxed); |
| 227 | |
| 228 | res.total_rows_to_read = total_rows_to_read.load(std::memory_order_relaxed); |
| 229 | res.total_raw_bytes_to_read = total_raw_bytes_to_read.load(std::memory_order_relaxed); |
| 230 | |
| 231 | res.disk_cache_read_bytes = disk_cache_read_bytes.load(std::memory_order_relaxed); |
| 232 | |
| 233 | res.written_rows = written_rows.load(std::memory_order_relaxed); |
| 234 | res.written_bytes = written_bytes.load(std::memory_order_relaxed); |
| 235 | |
| 236 | return res; |
| 237 | } |
| 238 | |
| 239 | ProgressValues Progress::fetchAndResetPiecewiseAtomically() |
| 240 | { |
no test coverage detected