Coverage Report

Created: 2026-06-13 01:53

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
721k
    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
721k
    using namespace std::chrono_literals;                                               \
36
721k
    auto VARNAME_LINENUM(scoped_simple_trace) = doris::MonotonicMicros();               \
37
721k
    Defer trace_defer = [&] {                                                           \
38
721k
        auto VARNAME_LINENUM(timeout_us) =                                              \
39
721k
                std::chrono::duration_cast<std::chrono::microseconds>(timeout).count(); \
40
721k
        auto VARNAME_LINENUM(cost_us) =                                                 \
41
721k
                doris::MonotonicMicros() - VARNAME_LINENUM(scoped_simple_trace);        \
42
721k
        if (VARNAME_LINENUM(cost_us) >= VARNAME_LINENUM(timeout_us)) {                  \
43
0
            stream << "Simple trace cost(us): " << VARNAME_LINENUM(cost_us);            \
44
0
        }                                                                               \
45
721k
    };
compaction.cpp:_ZZN5doris15CompactionMixin14modify_rowsetsEvENK3$_1clEv
Line
Count
Source
37
58
    Defer trace_defer = [&] {                                                           \
38
58
        auto VARNAME_LINENUM(timeout_us) =                                              \
39
58
                std::chrono::duration_cast<std::chrono::microseconds>(timeout).count(); \
40
58
        auto VARNAME_LINENUM(cost_us) =                                                 \
41
58
                doris::MonotonicMicros() - VARNAME_LINENUM(scoped_simple_trace);        \
42
58
        if (VARNAME_LINENUM(cost_us) >= VARNAME_LINENUM(timeout_us)) {                  \
43
0
            stream << "Simple trace cost(us): " << VARNAME_LINENUM(cost_us);            \
44
0
        }                                                                               \
45
58
    };
compaction.cpp:_ZZN5doris15CompactionMixin14modify_rowsetsEvENK3$_2clEv
Line
Count
Source
37
9
    Defer trace_defer = [&] {                                                           \
38
9
        auto VARNAME_LINENUM(timeout_us) =                                              \
39
9
                std::chrono::duration_cast<std::chrono::microseconds>(timeout).count(); \
40
9
        auto VARNAME_LINENUM(cost_us) =                                                 \
41
9
                doris::MonotonicMicros() - VARNAME_LINENUM(scoped_simple_trace);        \
42
9
        if (VARNAME_LINENUM(cost_us) >= VARNAME_LINENUM(timeout_us)) {                  \
43
0
            stream << "Simple trace cost(us): " << VARNAME_LINENUM(cost_us);            \
44
0
        }                                                                               \
45
9
    };
Unexecuted instantiation: cold_data_compaction.cpp:_ZZN5doris18ColdDataCompaction14modify_rowsetsEvENK3$_0clEv
rowset.cpp:_ZZN5doris6Rowset11clear_cacheEvENK3$_0clEv
Line
Count
Source
37
32.5k
    Defer trace_defer = [&] {                                                           \
38
32.5k
        auto VARNAME_LINENUM(timeout_us) =                                              \
39
32.5k
                std::chrono::duration_cast<std::chrono::microseconds>(timeout).count(); \
40
32.5k
        auto VARNAME_LINENUM(cost_us) =                                                 \
41
32.5k
                doris::MonotonicMicros() - VARNAME_LINENUM(scoped_simple_trace);        \
42
32.5k
        if (VARNAME_LINENUM(cost_us) >= VARNAME_LINENUM(timeout_us)) {                  \
43
0
            stream << "Simple trace cost(us): " << VARNAME_LINENUM(cost_us);            \
44
0
        }                                                                               \
45
32.5k
    };
rowset.cpp:_ZZN5doris6Rowset11clear_cacheEvENK3$_1clEv
Line
Count
Source
37
32.5k
    Defer trace_defer = [&] {                                                           \
38
32.5k
        auto VARNAME_LINENUM(timeout_us) =                                              \
39
32.5k
                std::chrono::duration_cast<std::chrono::microseconds>(timeout).count(); \
40
32.5k
        auto VARNAME_LINENUM(cost_us) =                                                 \
41
32.5k
                doris::MonotonicMicros() - VARNAME_LINENUM(scoped_simple_trace);        \
42
32.5k
        if (VARNAME_LINENUM(cost_us) >= VARNAME_LINENUM(timeout_us)) {                  \
43
0
            stream << "Simple trace cost(us): " << VARNAME_LINENUM(cost_us);            \
44
0
        }                                                                               \
45
32.5k
    };
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_6RowsetEES3_ENK3$_0clEv
Line
Count
Source
37
6.27k
    Defer trace_defer = [&] {                                                           \
38
6.27k
        auto VARNAME_LINENUM(timeout_us) =                                              \
39
6.27k
                std::chrono::duration_cast<std::chrono::microseconds>(timeout).count(); \
40
6.27k
        auto VARNAME_LINENUM(cost_us) =                                                 \
41
6.27k
                doris::MonotonicMicros() - VARNAME_LINENUM(scoped_simple_trace);        \
42
6.27k
        if (VARNAME_LINENUM(cost_us) >= VARNAME_LINENUM(timeout_us)) {                  \
43
0
            stream << "Simple trace cost(us): " << VARNAME_LINENUM(cost_us);            \
44
0
        }                                                                               \
45
6.27k
    };
tablet.cpp:_ZZN5doris6Tablet14add_inc_rowsetERKSt10shared_ptrINS_6RowsetEES5_ENK3$_0clEv
Line
Count
Source
37
5.88k
    Defer trace_defer = [&] {                                                           \
38
5.88k
        auto VARNAME_LINENUM(timeout_us) =                                              \
39
5.88k
                std::chrono::duration_cast<std::chrono::microseconds>(timeout).count(); \
40
5.88k
        auto VARNAME_LINENUM(cost_us) =                                                 \
41
5.88k
                doris::MonotonicMicros() - VARNAME_LINENUM(scoped_simple_trace);        \
42
5.88k
        if (VARNAME_LINENUM(cost_us) >= VARNAME_LINENUM(timeout_us)) {                  \
43
0
            stream << "Simple trace cost(us): " << VARNAME_LINENUM(cost_us);            \
44
0
        }                                                                               \
45
5.88k
    };
tablet.cpp:_ZZN5doris6Tablet27delete_expired_stale_rowsetEvENK3$_0clEv
Line
Count
Source
37
567k
    Defer trace_defer = [&] {                                                           \
38
567k
        auto VARNAME_LINENUM(timeout_us) =                                              \
39
567k
                std::chrono::duration_cast<std::chrono::microseconds>(timeout).count(); \
40
567k
        auto VARNAME_LINENUM(cost_us) =                                                 \
41
567k
                doris::MonotonicMicros() - VARNAME_LINENUM(scoped_simple_trace);        \
42
567k
        if (VARNAME_LINENUM(cost_us) >= VARNAME_LINENUM(timeout_us)) {                  \
43
0
            stream << "Simple trace cost(us): " << VARNAME_LINENUM(cost_us);            \
44
0
        }                                                                               \
45
567k
    };
tablet.cpp:_ZZN5doris6Tablet26calculate_cumulative_pointEvENK3$_0clEv
Line
Count
Source
37
72.2k
    Defer trace_defer = [&] {                                                           \
38
72.2k
        auto VARNAME_LINENUM(timeout_us) =                                              \
39
72.2k
                std::chrono::duration_cast<std::chrono::microseconds>(timeout).count(); \
40
72.2k
        auto VARNAME_LINENUM(cost_us) =                                                 \
41
72.2k
                doris::MonotonicMicros() - VARNAME_LINENUM(scoped_simple_trace);        \
42
72.2k
        if (VARNAME_LINENUM(cost_us) >= VARNAME_LINENUM(timeout_us)) {                  \
43
0
            stream << "Simple trace cost(us): " << VARNAME_LINENUM(cost_us);            \
44
0
        }                                                                               \
45
72.2k
    };
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
3.14k
    Defer trace_defer = [&] {                                                           \
38
3.14k
        auto VARNAME_LINENUM(timeout_us) =                                              \
39
3.14k
                std::chrono::duration_cast<std::chrono::microseconds>(timeout).count(); \
40
3.14k
        auto VARNAME_LINENUM(cost_us) =                                                 \
41
3.14k
                doris::MonotonicMicros() - VARNAME_LINENUM(scoped_simple_trace);        \
42
3.14k
        if (VARNAME_LINENUM(cost_us) >= VARNAME_LINENUM(timeout_us)) {                  \
43
0
            stream << "Simple trace cost(us): " << VARNAME_LINENUM(cost_us);            \
44
0
        }                                                                               \
45
3.14k
    };
Unexecuted instantiation: full_compaction.cpp:_ZZN5doris14FullCompaction14modify_rowsetsEvENK3$_0clEv
Unexecuted instantiation: binlog_compaction.cpp:_ZZN5doris16BinlogCompaction14modify_rowsetsEvENK3$_0clEv
tablet_manager.cpp:_ZZN5doris13TabletManager12_drop_tabletEllbbbENK3$_1clEv
Line
Count
Source
37
1.44k
    Defer trace_defer = [&] {                                                           \
38
1.44k
        auto VARNAME_LINENUM(timeout_us) =                                              \
39
1.44k
                std::chrono::duration_cast<std::chrono::microseconds>(timeout).count(); \
40
1.44k
        auto VARNAME_LINENUM(cost_us) =                                                 \
41
1.44k
                doris::MonotonicMicros() - VARNAME_LINENUM(scoped_simple_trace);        \
42
1.44k
        if (VARNAME_LINENUM(cost_us) >= VARNAME_LINENUM(timeout_us)) {                  \
43
0
            stream << "Simple trace cost(us): " << VARNAME_LINENUM(cost_us);            \
44
0
        }                                                                               \
45
1.44k
    };
Unexecuted instantiation: engine_clone_task.cpp:_ZZN5doris15EngineCloneTask13_finish_cloneEPNS_6TabletERKNSt7__cxx1112basic_stringIcSt11char_traitsIcESaIcEEElbbENK3$_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
    };