Coverage Report

Created: 2026-03-13 10:59

next uncovered line (L), next uncovered region (R), next uncovered branch (B)
be/src/util/trace.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
#pragma once
18
19
#include <butil/macros.h>
20
21
// If this scope times out, make a simple trace.
22
// It will log the cost time only.
23
// Timeout is chrono duration struct, eg: 5ms, 100 * 1s.
24
#define SCOPED_SIMPLE_TRACE_IF_TIMEOUT(timeout) \
25
1.27M
    SCOPED_SIMPLE_TRACE_TO_STREAM_IF_TIMEOUT(timeout, LOG(WARNING))
26
27
// If this scope times out, then put simple trace to the stream.
28
// Timeout is chrono duration struct, eg: 5ms, 100 * 1s.
29
// For example:
30
//
31
//    std::string tag = "[foo]";
32
//    SCOPED_SIMPLE_TRACE_TO_STREAM_IF_TIMEOUT(5s, LOG(INFO) << tag);
33
//
34
#define SCOPED_SIMPLE_TRACE_TO_STREAM_IF_TIMEOUT(timeout, stream)                       \
35
1.27M
    using namespace std::chrono_literals;                                               \
36
1.27M
    auto VARNAME_LINENUM(scoped_simple_trace) = doris::MonotonicMicros();               \
37
1.27M
    Defer trace_defer = [&] {                                                           \
38
1.27M
        auto VARNAME_LINENUM(timeout_us) =                                              \
39
1.27M
                std::chrono::duration_cast<std::chrono::microseconds>(timeout).count(); \
40
1.27M
        auto VARNAME_LINENUM(cost_us) =                                                 \
41
1.27M
                doris::MonotonicMicros() - VARNAME_LINENUM(scoped_simple_trace);        \
42
1.27M
        if (VARNAME_LINENUM(cost_us) >= VARNAME_LINENUM(timeout_us)) {                  \
43
0
            stream << "Simple trace cost(us): " << VARNAME_LINENUM(cost_us);            \
44
0
        }                                                                               \
45
1.27M
    };
compaction.cpp:_ZZN5doris15CompactionMixin14modify_rowsetsEvENK3$_1clEv
Line
Count
Source
37
648
    Defer trace_defer = [&] {                                                           \
38
648
        auto VARNAME_LINENUM(timeout_us) =                                              \
39
648
                std::chrono::duration_cast<std::chrono::microseconds>(timeout).count(); \
40
648
        auto VARNAME_LINENUM(cost_us) =                                                 \
41
648
                doris::MonotonicMicros() - VARNAME_LINENUM(scoped_simple_trace);        \
42
648
        if (VARNAME_LINENUM(cost_us) >= VARNAME_LINENUM(timeout_us)) {                  \
43
0
            stream << "Simple trace cost(us): " << VARNAME_LINENUM(cost_us);            \
44
0
        }                                                                               \
45
648
    };
compaction.cpp:_ZZN5doris15CompactionMixin14modify_rowsetsEvENK3$_2clEv
Line
Count
Source
37
664
    Defer trace_defer = [&] {                                                           \
38
664
        auto VARNAME_LINENUM(timeout_us) =                                              \
39
664
                std::chrono::duration_cast<std::chrono::microseconds>(timeout).count(); \
40
664
        auto VARNAME_LINENUM(cost_us) =                                                 \
41
664
                doris::MonotonicMicros() - VARNAME_LINENUM(scoped_simple_trace);        \
42
664
        if (VARNAME_LINENUM(cost_us) >= VARNAME_LINENUM(timeout_us)) {                  \
43
0
            stream << "Simple trace cost(us): " << VARNAME_LINENUM(cost_us);            \
44
0
        }                                                                               \
45
664
    };
Unexecuted instantiation: cold_data_compaction.cpp:_ZZN5doris18ColdDataCompaction14modify_rowsetsEvENK3$_0clEv
rowset.cpp:_ZZN5doris6Rowset11clear_cacheEvENK3$_0clEv
Line
Count
Source
37
204k
    Defer trace_defer = [&] {                                                           \
38
204k
        auto VARNAME_LINENUM(timeout_us) =                                              \
39
204k
                std::chrono::duration_cast<std::chrono::microseconds>(timeout).count(); \
40
204k
        auto VARNAME_LINENUM(cost_us) =                                                 \
41
204k
                doris::MonotonicMicros() - VARNAME_LINENUM(scoped_simple_trace);        \
42
204k
        if (VARNAME_LINENUM(cost_us) >= VARNAME_LINENUM(timeout_us)) {                  \
43
0
            stream << "Simple trace cost(us): " << VARNAME_LINENUM(cost_us);            \
44
0
        }                                                                               \
45
204k
    };
rowset.cpp:_ZZN5doris6Rowset11clear_cacheEvENK3$_1clEv
Line
Count
Source
37
204k
    Defer trace_defer = [&] {                                                           \
38
204k
        auto VARNAME_LINENUM(timeout_us) =                                              \
39
204k
                std::chrono::duration_cast<std::chrono::microseconds>(timeout).count(); \
40
204k
        auto VARNAME_LINENUM(cost_us) =                                                 \
41
204k
                doris::MonotonicMicros() - VARNAME_LINENUM(scoped_simple_trace);        \
42
204k
        if (VARNAME_LINENUM(cost_us) >= VARNAME_LINENUM(timeout_us)) {                  \
43
0
            stream << "Simple trace cost(us): " << VARNAME_LINENUM(cost_us);            \
44
0
        }                                                                               \
45
204k
    };
Unexecuted instantiation: schema_change.cpp:_ZZN5doris15SchemaChangeJob24_do_process_alter_tabletERKNS_17TAlterTabletReqV2EENK3$_2clEv
Unexecuted instantiation: schema_change.cpp:_ZZN5doris15SchemaChangeJob24_do_process_alter_tabletERKNS_17TAlterTabletReqV2EENK3$_3clEv
Unexecuted instantiation: schema_change.cpp:_ZZZN5doris15SchemaChangeJob27_convert_historical_rowsetsERKNS_18SchemaChangeParamsEPlENK3$_0clEvENKUlvE_clEv
Unexecuted instantiation: schema_change.cpp:_ZZN5doris15SchemaChangeJob33_calc_delete_bitmap_for_mow_tableElENK3$_0clEv
tablet.cpp:_ZZN5doris6Tablet10add_rowsetESt10shared_ptrINS_6RowsetEEENK3$_0clEv
Line
Count
Source
37
8.86k
    Defer trace_defer = [&] {                                                           \
38
8.86k
        auto VARNAME_LINENUM(timeout_us) =                                              \
39
8.86k
                std::chrono::duration_cast<std::chrono::microseconds>(timeout).count(); \
40
8.86k
        auto VARNAME_LINENUM(cost_us) =                                                 \
41
8.86k
                doris::MonotonicMicros() - VARNAME_LINENUM(scoped_simple_trace);        \
42
8.86k
        if (VARNAME_LINENUM(cost_us) >= VARNAME_LINENUM(timeout_us)) {                  \
43
0
            stream << "Simple trace cost(us): " << VARNAME_LINENUM(cost_us);            \
44
0
        }                                                                               \
45
8.86k
    };
tablet.cpp:_ZZN5doris6Tablet14add_inc_rowsetERKSt10shared_ptrINS_6RowsetEEENK3$_0clEv
Line
Count
Source
37
24.4k
    Defer trace_defer = [&] {                                                           \
38
24.4k
        auto VARNAME_LINENUM(timeout_us) =                                              \
39
24.4k
                std::chrono::duration_cast<std::chrono::microseconds>(timeout).count(); \
40
24.4k
        auto VARNAME_LINENUM(cost_us) =                                                 \
41
24.4k
                doris::MonotonicMicros() - VARNAME_LINENUM(scoped_simple_trace);        \
42
24.4k
        if (VARNAME_LINENUM(cost_us) >= VARNAME_LINENUM(timeout_us)) {                  \
43
0
            stream << "Simple trace cost(us): " << VARNAME_LINENUM(cost_us);            \
44
0
        }                                                                               \
45
24.4k
    };
tablet.cpp:_ZZN5doris6Tablet27delete_expired_stale_rowsetEvENK3$_0clEv
Line
Count
Source
37
683k
    Defer trace_defer = [&] {                                                           \
38
683k
        auto VARNAME_LINENUM(timeout_us) =                                              \
39
683k
                std::chrono::duration_cast<std::chrono::microseconds>(timeout).count(); \
40
683k
        auto VARNAME_LINENUM(cost_us) =                                                 \
41
683k
                doris::MonotonicMicros() - VARNAME_LINENUM(scoped_simple_trace);        \
42
683k
        if (VARNAME_LINENUM(cost_us) >= VARNAME_LINENUM(timeout_us)) {                  \
43
0
            stream << "Simple trace cost(us): " << VARNAME_LINENUM(cost_us);            \
44
0
        }                                                                               \
45
683k
    };
tablet.cpp:_ZZN5doris6Tablet26calculate_cumulative_pointEvENK3$_0clEv
Line
Count
Source
37
136k
    Defer trace_defer = [&] {                                                           \
38
136k
        auto VARNAME_LINENUM(timeout_us) =                                              \
39
136k
                std::chrono::duration_cast<std::chrono::microseconds>(timeout).count(); \
40
136k
        auto VARNAME_LINENUM(cost_us) =                                                 \
41
136k
                doris::MonotonicMicros() - VARNAME_LINENUM(scoped_simple_trace);        \
42
136k
        if (VARNAME_LINENUM(cost_us) >= VARNAME_LINENUM(timeout_us)) {                  \
43
0
            stream << "Simple trace cost(us): " << VARNAME_LINENUM(cost_us);            \
44
0
        }                                                                               \
45
136k
    };
tablet.cpp:_ZZN5doris6Tablet14_cooldown_dataESt10shared_ptrINS_6RowsetEEENK3$_1clEv
Line
Count
Source
37
5
    Defer trace_defer = [&] {                                                           \
38
5
        auto VARNAME_LINENUM(timeout_us) =                                              \
39
5
                std::chrono::duration_cast<std::chrono::microseconds>(timeout).count(); \
40
5
        auto VARNAME_LINENUM(cost_us) =                                                 \
41
5
                doris::MonotonicMicros() - VARNAME_LINENUM(scoped_simple_trace);        \
42
5
        if (VARNAME_LINENUM(cost_us) >= VARNAME_LINENUM(timeout_us)) {                  \
43
0
            stream << "Simple trace cost(us): " << VARNAME_LINENUM(cost_us);            \
44
0
        }                                                                               \
45
5
    };
tablet.cpp:_ZZN5doris6Tablet14_cooldown_dataESt10shared_ptrINS_6RowsetEEENK3$_2clEv
Line
Count
Source
37
5
    Defer trace_defer = [&] {                                                           \
38
5
        auto VARNAME_LINENUM(timeout_us) =                                              \
39
5
                std::chrono::duration_cast<std::chrono::microseconds>(timeout).count(); \
40
5
        auto VARNAME_LINENUM(cost_us) =                                                 \
41
5
                doris::MonotonicMicros() - VARNAME_LINENUM(scoped_simple_trace);        \
42
5
        if (VARNAME_LINENUM(cost_us) >= VARNAME_LINENUM(timeout_us)) {                  \
43
0
            stream << "Simple trace cost(us): " << VARNAME_LINENUM(cost_us);            \
44
0
        }                                                                               \
45
5
    };
Unexecuted instantiation: tablet.cpp:_ZZN5doris6Tablet23_follow_cooldowned_dataEvENK3$_0clEv
Unexecuted instantiation: tablet.cpp:_ZZN5doris6Tablet23_follow_cooldowned_dataEvENK3$_1clEv
Unexecuted instantiation: tablet.cpp:_ZZN5doris6Tablet25update_max_version_schemaERKSt10shared_ptrINS_12TabletSchemaEEENK3$_0clEv
tablet.cpp:_ZZN5doris6Tablet11clear_cacheEvENK3$_0clEv
Line
Count
Source
37
12.6k
    Defer trace_defer = [&] {                                                           \
38
12.6k
        auto VARNAME_LINENUM(timeout_us) =                                              \
39
12.6k
                std::chrono::duration_cast<std::chrono::microseconds>(timeout).count(); \
40
12.6k
        auto VARNAME_LINENUM(cost_us) =                                                 \
41
12.6k
                doris::MonotonicMicros() - VARNAME_LINENUM(scoped_simple_trace);        \
42
12.6k
        if (VARNAME_LINENUM(cost_us) >= VARNAME_LINENUM(timeout_us)) {                  \
43
0
            stream << "Simple trace cost(us): " << VARNAME_LINENUM(cost_us);            \
44
0
        }                                                                               \
45
12.6k
    };
Unexecuted instantiation: full_compaction.cpp:_ZZN5doris14FullCompaction14modify_rowsetsEvENK3$_0clEv
tablet_manager.cpp:_ZZN5doris13TabletManager12_drop_tabletEllbbbENK3$_1clEv
Line
Count
Source
37
4.23k
    Defer trace_defer = [&] {                                                           \
38
4.23k
        auto VARNAME_LINENUM(timeout_us) =                                              \
39
4.23k
                std::chrono::duration_cast<std::chrono::microseconds>(timeout).count(); \
40
4.23k
        auto VARNAME_LINENUM(cost_us) =                                                 \
41
4.23k
                doris::MonotonicMicros() - VARNAME_LINENUM(scoped_simple_trace);        \
42
4.23k
        if (VARNAME_LINENUM(cost_us) >= VARNAME_LINENUM(timeout_us)) {                  \
43
0
            stream << "Simple trace cost(us): " << VARNAME_LINENUM(cost_us);            \
44
0
        }                                                                               \
45
4.23k
    };
Unexecuted instantiation: engine_clone_task.cpp:_ZZN5doris15EngineCloneTask13_finish_cloneEPNS_6TabletERKNSt7__cxx1112basic_stringIcSt11char_traitsIcESaIcEEElbENK3$_2clEv
index_builder.cpp:_ZZN5doris12IndexBuilder14modify_rowsetsEPKNS_6Merger10StatisticsEENK3$_1clEv
Line
Count
Source
37
1
    Defer trace_defer = [&] {                                                           \
38
1
        auto VARNAME_LINENUM(timeout_us) =                                              \
39
1
                std::chrono::duration_cast<std::chrono::microseconds>(timeout).count(); \
40
1
        auto VARNAME_LINENUM(cost_us) =                                                 \
41
1
                doris::MonotonicMicros() - VARNAME_LINENUM(scoped_simple_trace);        \
42
1
        if (VARNAME_LINENUM(cost_us) >= VARNAME_LINENUM(timeout_us)) {                  \
43
0
            stream << "Simple trace cost(us): " << VARNAME_LINENUM(cost_us);            \
44
0
        }                                                                               \
45
1
    };
pad_rowset_action.cpp:_ZZN5doris15PadRowsetAction11_pad_rowsetEPNS_6TabletERKNS_7VersionEENK3$_0clEv
Line
Count
Source
37
1
    Defer trace_defer = [&] {                                                           \
38
1
        auto VARNAME_LINENUM(timeout_us) =                                              \
39
1
                std::chrono::duration_cast<std::chrono::microseconds>(timeout).count(); \
40
1
        auto VARNAME_LINENUM(cost_us) =                                                 \
41
1
                doris::MonotonicMicros() - VARNAME_LINENUM(scoped_simple_trace);        \
42
1
        if (VARNAME_LINENUM(cost_us) >= VARNAME_LINENUM(timeout_us)) {                  \
43
0
            stream << "Simple trace cost(us): " << VARNAME_LINENUM(cost_us);            \
44
0
        }                                                                               \
45
1
    };