Coverage Report

Created: 2026-08-20 20:03

next uncovered line (L), next uncovered region (R), next uncovered branch (B)
be/src/io/io_common.h
Line
Count
Source
1
// Licensed to the Apache Software Foundation (ASF) under one
2
// or more contributor license agreements.  See the NOTICE file
3
// distributed with this work for additional information
4
// regarding copyright ownership.  The ASF licenses this file
5
// to you under the Apache License, Version 2.0 (the
6
// "License"); you may not use this file except in compliance
7
// with the License.  You may obtain a copy of the License at
8
//
9
//   http://www.apache.org/licenses/LICENSE-2.0
10
//
11
// Unless required by applicable law or agreed to in writing,
12
// software distributed under the License is distributed on an
13
// "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
14
// KIND, either express or implied.  See the License for the
15
// specific language governing permissions and limitations
16
// under the License.
17
18
#pragma once
19
20
#include <gen_cpp/Types_types.h>
21
22
#include <array>
23
#include <cstddef>
24
#include <cstdint>
25
#include <optional>
26
#include <set>
27
#include <string>
28
29
namespace doris {
30
31
enum class ReaderType : uint8_t {
32
    READER_QUERY = 0,
33
    READER_ALTER_TABLE = 1,
34
    READER_BASE_COMPACTION = 2,
35
    READER_CUMULATIVE_COMPACTION = 3,
36
    READER_CHECKSUM = 4,
37
    READER_COLD_DATA_COMPACTION = 5,
38
    READER_SEGMENT_COMPACTION = 6,
39
    READER_FULL_COMPACTION = 7,
40
    UNKNOWN = 8
41
};
42
43
namespace io {
44
45
class RemoteScanCacheWriteLimiter;
46
enum class CacheWriteMode : uint8_t;
47
48
enum class FileCacheMissPolicy : uint8_t {
49
    READ_THROUGH_AND_WRITE_BACK = 0,
50
    REMOTE_ONLY_ON_MISS = 1,
51
};
52
53
struct FileReaderStats {
54
    size_t read_calls = 0;
55
    size_t read_bytes = 0;
56
    int64_t read_time_ns = 0;
57
    size_t read_rows = 0;
58
};
59
60
struct FileCacheStatistics {
61
    int64_t num_local_io_total = 0;
62
    int64_t num_remote_io_total = 0;
63
    int64_t num_peer_io_total = 0;
64
    int64_t local_io_timer = 0;
65
    int64_t bytes_read_from_local = 0;
66
    int64_t bytes_read_from_remote = 0;
67
    int64_t bytes_read_from_peer = 0;
68
    int64_t remote_io_timer = 0;
69
    int64_t peer_io_timer = 0;
70
    int64_t remote_wait_timer = 0;
71
    int64_t write_cache_io_timer = 0;
72
    int64_t bytes_write_into_cache = 0;
73
    int64_t num_skip_cache_io_total = 0;
74
    int64_t read_cache_file_directly_timer = 0;
75
    int64_t cache_get_or_set_timer = 0;
76
    int64_t lock_wait_timer = 0;
77
    int64_t get_timer = 0;
78
    int64_t set_timer = 0;
79
    int64_t async_cache_write_submitted = 0;
80
    int64_t async_cache_write_rejected = 0;
81
    int64_t async_cache_write_buffer_alloc_fail = 0;
82
    int64_t async_cache_write_drop_stale_epoch = 0;
83
    int64_t inflight_write_buffer_index_hit = 0;
84
    int64_t inflight_write_buffer_index_miss = 0;
85
    int64_t probe_downloaded_hit = 0;
86
    int64_t probe_downloading_hit = 0;
87
    int64_t probe_miss = 0;
88
    int64_t block_wait_success = 0;
89
    int64_t block_wait_timeout = 0;
90
91
    int64_t inverted_index_num_local_io_total = 0;
92
    int64_t inverted_index_num_remote_io_total = 0;
93
    int64_t inverted_index_num_peer_io_total = 0;
94
    int64_t inverted_index_bytes_read_from_local = 0;
95
    int64_t inverted_index_bytes_read_from_remote = 0;
96
    int64_t inverted_index_bytes_read_from_peer = 0;
97
    int64_t inverted_index_remote_physical_read_bytes = 0;
98
    int64_t inverted_index_bytes_write_into_cache = 0;
99
    int64_t inverted_index_local_io_timer = 0;
100
    int64_t inverted_index_remote_io_timer = 0;
101
    int64_t inverted_index_peer_io_timer = 0;
102
    int64_t inverted_index_io_timer = 0;
103
    int64_t inverted_index_write_cache_io_timer = 0;
104
    int64_t inverted_index_request_bytes = 0;
105
    int64_t inverted_index_read_bytes = 0;
106
    int64_t inverted_index_range_read_count = 0;
107
    int64_t inverted_index_serial_read_rounds = 0;
108
109
    int64_t segment_footer_index_num_local_io_total = 0;
110
    int64_t segment_footer_index_num_remote_io_total = 0;
111
    int64_t segment_footer_index_num_peer_io_total = 0;
112
    int64_t segment_footer_index_bytes_read_from_local = 0;
113
    int64_t segment_footer_index_bytes_read_from_remote = 0;
114
    int64_t segment_footer_index_bytes_read_from_peer = 0;
115
    int64_t segment_footer_index_local_io_timer = 0;
116
    int64_t segment_footer_index_remote_io_timer = 0;
117
    int64_t segment_footer_index_peer_io_timer = 0;
118
    int64_t segment_footer_index_write_cache_io_timer = 0;
119
    int64_t segment_footer_index_bytes_write_into_cache = 0;
120
    int64_t remote_only_on_miss_triggered = 0;
121
    int64_t remote_only_on_miss_threshold_bytes = 0;
122
123
    // Cross-CG / Same-CG peer read statistics
124
    int64_t num_cross_cg_peer_io_total = 0;
125
    int64_t bytes_read_from_cross_cg_peer = 0;
126
    int64_t cross_cg_peer_io_timer = 0; // nanoseconds
127
    int64_t num_same_cg_peer_io_total = 0;
128
    int64_t bytes_read_from_same_cg_peer = 0;
129
    int64_t same_cg_peer_io_timer = 0; // nanoseconds
130
    int64_t num_peer_race_peer_win = 0;
131
    int64_t num_peer_race_s3_win = 0;
132
    int64_t num_peer_lazy_fetch = 0;
133
    int64_t peer_lazy_fetch_timer = 0; // nanoseconds
134
135
    std::set<std::string> peer_hosts;
136
137
2.65M
    void merge_from(const FileCacheStatistics& other) {
138
2.65M
        num_local_io_total += other.num_local_io_total;
139
2.65M
        num_remote_io_total += other.num_remote_io_total;
140
2.65M
        num_peer_io_total += other.num_peer_io_total;
141
2.65M
        local_io_timer += other.local_io_timer;
142
2.65M
        bytes_read_from_local += other.bytes_read_from_local;
143
2.65M
        bytes_read_from_remote += other.bytes_read_from_remote;
144
2.65M
        bytes_read_from_peer += other.bytes_read_from_peer;
145
2.65M
        remote_io_timer += other.remote_io_timer;
146
2.65M
        peer_io_timer += other.peer_io_timer;
147
2.65M
        remote_wait_timer += other.remote_wait_timer;
148
2.65M
        write_cache_io_timer += other.write_cache_io_timer;
149
2.65M
        bytes_write_into_cache += other.bytes_write_into_cache;
150
2.65M
        num_skip_cache_io_total += other.num_skip_cache_io_total;
151
2.65M
        read_cache_file_directly_timer += other.read_cache_file_directly_timer;
152
2.65M
        cache_get_or_set_timer += other.cache_get_or_set_timer;
153
2.65M
        lock_wait_timer += other.lock_wait_timer;
154
2.65M
        get_timer += other.get_timer;
155
2.65M
        set_timer += other.set_timer;
156
2.65M
        async_cache_write_submitted += other.async_cache_write_submitted;
157
2.65M
        async_cache_write_rejected += other.async_cache_write_rejected;
158
2.65M
        async_cache_write_buffer_alloc_fail += other.async_cache_write_buffer_alloc_fail;
159
2.65M
        async_cache_write_drop_stale_epoch += other.async_cache_write_drop_stale_epoch;
160
2.65M
        inflight_write_buffer_index_hit += other.inflight_write_buffer_index_hit;
161
2.65M
        inflight_write_buffer_index_miss += other.inflight_write_buffer_index_miss;
162
2.65M
        probe_downloaded_hit += other.probe_downloaded_hit;
163
2.65M
        probe_downloading_hit += other.probe_downloading_hit;
164
2.65M
        probe_miss += other.probe_miss;
165
2.65M
        block_wait_success += other.block_wait_success;
166
2.65M
        block_wait_timeout += other.block_wait_timeout;
167
168
2.65M
        inverted_index_num_local_io_total += other.inverted_index_num_local_io_total;
169
2.65M
        inverted_index_num_remote_io_total += other.inverted_index_num_remote_io_total;
170
2.65M
        inverted_index_num_peer_io_total += other.inverted_index_num_peer_io_total;
171
2.65M
        inverted_index_bytes_read_from_local += other.inverted_index_bytes_read_from_local;
172
2.65M
        inverted_index_bytes_read_from_remote += other.inverted_index_bytes_read_from_remote;
173
2.65M
        inverted_index_bytes_read_from_peer += other.inverted_index_bytes_read_from_peer;
174
2.65M
        inverted_index_remote_physical_read_bytes +=
175
2.65M
                other.inverted_index_remote_physical_read_bytes;
176
2.65M
        inverted_index_local_io_timer += other.inverted_index_local_io_timer;
177
2.65M
        inverted_index_remote_io_timer += other.inverted_index_remote_io_timer;
178
2.65M
        inverted_index_peer_io_timer += other.inverted_index_peer_io_timer;
179
2.65M
        inverted_index_io_timer += other.inverted_index_io_timer;
180
2.65M
        inverted_index_write_cache_io_timer += other.inverted_index_write_cache_io_timer;
181
2.65M
        inverted_index_bytes_write_into_cache += other.inverted_index_bytes_write_into_cache;
182
2.65M
        inverted_index_request_bytes += other.inverted_index_request_bytes;
183
2.65M
        inverted_index_read_bytes += other.inverted_index_read_bytes;
184
2.65M
        inverted_index_range_read_count += other.inverted_index_range_read_count;
185
2.65M
        inverted_index_serial_read_rounds += other.inverted_index_serial_read_rounds;
186
187
2.65M
        segment_footer_index_num_local_io_total += other.segment_footer_index_num_local_io_total;
188
2.65M
        segment_footer_index_num_remote_io_total += other.segment_footer_index_num_remote_io_total;
189
2.65M
        segment_footer_index_num_peer_io_total += other.segment_footer_index_num_peer_io_total;
190
2.65M
        segment_footer_index_bytes_read_from_local +=
191
2.65M
                other.segment_footer_index_bytes_read_from_local;
192
2.65M
        segment_footer_index_bytes_read_from_remote +=
193
2.65M
                other.segment_footer_index_bytes_read_from_remote;
194
2.65M
        segment_footer_index_bytes_read_from_peer +=
195
2.65M
                other.segment_footer_index_bytes_read_from_peer;
196
2.65M
        segment_footer_index_local_io_timer += other.segment_footer_index_local_io_timer;
197
2.65M
        segment_footer_index_remote_io_timer += other.segment_footer_index_remote_io_timer;
198
2.65M
        segment_footer_index_peer_io_timer += other.segment_footer_index_peer_io_timer;
199
2.65M
        segment_footer_index_write_cache_io_timer +=
200
2.65M
                other.segment_footer_index_write_cache_io_timer;
201
2.65M
        segment_footer_index_bytes_write_into_cache +=
202
2.65M
                other.segment_footer_index_bytes_write_into_cache;
203
2.65M
        remote_only_on_miss_triggered =
204
2.66M
                remote_only_on_miss_triggered || other.remote_only_on_miss_triggered;
205
2.65M
        if (other.remote_only_on_miss_threshold_bytes > remote_only_on_miss_threshold_bytes) {
206
1
            remote_only_on_miss_threshold_bytes = other.remote_only_on_miss_threshold_bytes;
207
1
        }
208
209
2.65M
        num_cross_cg_peer_io_total += other.num_cross_cg_peer_io_total;
210
2.65M
        bytes_read_from_cross_cg_peer += other.bytes_read_from_cross_cg_peer;
211
2.65M
        cross_cg_peer_io_timer += other.cross_cg_peer_io_timer;
212
2.65M
        num_same_cg_peer_io_total += other.num_same_cg_peer_io_total;
213
2.65M
        bytes_read_from_same_cg_peer += other.bytes_read_from_same_cg_peer;
214
2.65M
        same_cg_peer_io_timer += other.same_cg_peer_io_timer;
215
2.65M
        num_peer_race_peer_win += other.num_peer_race_peer_win;
216
2.65M
        num_peer_race_s3_win += other.num_peer_race_s3_win;
217
2.65M
        num_peer_lazy_fetch += other.num_peer_lazy_fetch;
218
2.65M
        peer_lazy_fetch_timer += other.peer_lazy_fetch_timer;
219
220
2.65M
        peer_hosts.insert(other.peer_hosts.begin(), other.peer_hosts.end());
221
2.65M
    }
222
};
223
224
struct IOContext {
225
    ReaderType reader_type = ReaderType::UNKNOWN;
226
    // FIXME(plat1ko): Seems `is_disposable` can be inferred from the `reader_type`?
227
    bool is_disposable = false;
228
    bool is_index_data = false;
229
    bool read_file_cache = true;
230
    // TODO(lightman): use following member variables to control file cache
231
    bool is_persistent = false;
232
    // stop reader when reading, used in some interrupted operations
233
    bool should_stop = false;
234
    int64_t expiration_time = 0;
235
    const TUniqueId* query_id = nullptr;             // Ref
236
    FileCacheStatistics* file_cache_stats = nullptr; // Ref
237
    FileReaderStats* file_reader_stats = nullptr;    // Ref
238
    bool is_inverted_index = false;
239
    // if is_dryrun, read IO will download data to cache but return no data to reader
240
    // useful to skip cache data read from local disk to accelarate warm up
241
    bool is_dryrun = false;
242
    // if `is_warmup` == true, this I/O request is from a warm up task
243
    bool is_warmup {false};
244
    int64_t condition_cache_filtered_rows = 0;
245
    // Rows removed by file-local predicate conjuncts inside FileReader/TableReader. Scanner-level
246
    // output filtering already records its own unselected rows; this counter carries the rows that
247
    // were filtered before the block returned to Scanner.
248
    int64_t predicate_filtered_rows = 0;
249
    // if true, bypass peer read / peer-vs-S3 race and read directly from remote storage
250
    bool bypass_peer_read {false};
251
    // Per-call override for cache write completion semantics. An unset value follows the reader
252
    // option and the global async file-cache write switch.
253
    std::optional<CacheWriteMode> cache_write_mode_override = std::nullopt;
254
    FileCacheMissPolicy file_cache_miss_policy = FileCacheMissPolicy::READ_THROUGH_AND_WRITE_BACK;
255
    // From session variable inverted_index_snii_read_no_write_file_cache: SNII index
256
    // reads of this query take REMOTE_ONLY_ON_MISS (hit served, miss reads remote
257
    // and skips the cache write-back). Carried down to the SNII adapter, which is
258
    // the sole place that turns it into a file_cache_miss_policy -- keeping CLucene
259
    // index reads and data reads on the normal write-back path.
260
    bool inverted_index_snii_read_no_write_file_cache = false;
261
    RemoteScanCacheWriteLimiter* remote_scan_cache_write_limiter = nullptr; // Ref
262
};
263
264
} // namespace io
265
} // namespace doris