Coverage Report

Created: 2025-09-12 18:53

next uncovered line (L), next uncovered region (R), next uncovered branch (B)
/root/doris/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
54.4k
    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
54.4k
    using namespace std::chrono_literals;                                               \
36
54.4k
    auto VARNAME_LINENUM(scoped_simple_trace) = doris::MonotonicMicros();               \
37
54.4k
    Defer trace_defer = [&] {                                                           \
38
54.4k
        auto VARNAME_LINENUM(timeout_us) =                                              \
39
54.4k
                std::chrono::duration_cast<std::chrono::microseconds>(timeout).count(); \
40
54.4k
        auto VARNAME_LINENUM(cost_us) =                                                 \
41
54.4k
                doris::MonotonicMicros() - VARNAME_LINENUM(scoped_simple_trace);        \
42
54.4k
        if (VARNAME_LINENUM(cost_us) >= VARNAME_LINENUM(timeout_us)) {                  \
43
0
            stream << "Simple trace cost(us): " << VARNAME_LINENUM(cost_us);            \
44
0
        }                                                                               \
45
54.4k
    };
Unexecuted instantiation: compaction.cpp:_ZZN5doris15CompactionMixin14modify_rowsetsEvENK3$_1clEv
Unexecuted instantiation: compaction.cpp:_ZZN5doris15CompactionMixin14modify_rowsetsEvENK3$_2clEv
Unexecuted instantiation: cold_data_compaction.cpp:_ZZN5doris18ColdDataCompaction14modify_rowsetsEvENK3$_0clEv
rowset.cpp:_ZZN5doris6Rowset11clear_cacheEvENK3$_0clEv
Line
Count
Source
37
21.3k
    Defer trace_defer = [&] {                                                           \
38
21.3k
        auto VARNAME_LINENUM(timeout_us) =                                              \
39
21.3k
                std::chrono::duration_cast<std::chrono::microseconds>(timeout).count(); \
40
21.3k
        auto VARNAME_LINENUM(cost_us) =                                                 \
41
21.3k
                doris::MonotonicMicros() - VARNAME_LINENUM(scoped_simple_trace);        \
42
21.3k
        if (VARNAME_LINENUM(cost_us) >= VARNAME_LINENUM(timeout_us)) {                  \
43
0
            stream << "Simple trace cost(us): " << VARNAME_LINENUM(cost_us);            \
44
0
        }                                                                               \
45
21.3k
    };
rowset.cpp:_ZZN5doris6Rowset11clear_cacheEvENK3$_1clEv
Line
Count
Source
37
21.3k
    Defer trace_defer = [&] {                                                           \
38
21.3k
        auto VARNAME_LINENUM(timeout_us) =                                              \
39
21.3k
                std::chrono::duration_cast<std::chrono::microseconds>(timeout).count(); \
40
21.3k
        auto VARNAME_LINENUM(cost_us) =                                                 \
41
21.3k
                doris::MonotonicMicros() - VARNAME_LINENUM(scoped_simple_trace);        \
42
21.3k
        if (VARNAME_LINENUM(cost_us) >= VARNAME_LINENUM(timeout_us)) {                  \
43
0
            stream << "Simple trace cost(us): " << VARNAME_LINENUM(cost_us);            \
44
0
        }                                                                               \
45
21.3k
    };
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
417
    Defer trace_defer = [&] {                                                           \
38
417
        auto VARNAME_LINENUM(timeout_us) =                                              \
39
417
                std::chrono::duration_cast<std::chrono::microseconds>(timeout).count(); \
40
417
        auto VARNAME_LINENUM(cost_us) =                                                 \
41
417
                doris::MonotonicMicros() - VARNAME_LINENUM(scoped_simple_trace);        \
42
417
        if (VARNAME_LINENUM(cost_us) >= VARNAME_LINENUM(timeout_us)) {                  \
43
0
            stream << "Simple trace cost(us): " << VARNAME_LINENUM(cost_us);            \
44
0
        }                                                                               \
45
417
    };
tablet.cpp:_ZZN5doris6Tablet14add_inc_rowsetERKSt10shared_ptrINS_6RowsetEEENK3$_0clEv
Line
Count
Source
37
10.5k
    Defer trace_defer = [&] {                                                           \
38
10.5k
        auto VARNAME_LINENUM(timeout_us) =                                              \
39
10.5k
                std::chrono::duration_cast<std::chrono::microseconds>(timeout).count(); \
40
10.5k
        auto VARNAME_LINENUM(cost_us) =                                                 \
41
10.5k
                doris::MonotonicMicros() - VARNAME_LINENUM(scoped_simple_trace);        \
42
10.5k
        if (VARNAME_LINENUM(cost_us) >= VARNAME_LINENUM(timeout_us)) {                  \
43
0
            stream << "Simple trace cost(us): " << VARNAME_LINENUM(cost_us);            \
44
0
        }                                                                               \
45
10.5k
    };
tablet.cpp:_ZZN5doris6Tablet27delete_expired_stale_rowsetEvENK3$_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
    };
tablet.cpp:_ZZN5doris6Tablet26calculate_cumulative_pointEvENK3$_0clEv
Line
Count
Source
37
49
    Defer trace_defer = [&] {                                                           \
38
49
        auto VARNAME_LINENUM(timeout_us) =                                              \
39
49
                std::chrono::duration_cast<std::chrono::microseconds>(timeout).count(); \
40
49
        auto VARNAME_LINENUM(cost_us) =                                                 \
41
49
                doris::MonotonicMicros() - VARNAME_LINENUM(scoped_simple_trace);        \
42
49
        if (VARNAME_LINENUM(cost_us) >= VARNAME_LINENUM(timeout_us)) {                  \
43
0
            stream << "Simple trace cost(us): " << VARNAME_LINENUM(cost_us);            \
44
0
        }                                                                               \
45
49
    };
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
480
    Defer trace_defer = [&] {                                                           \
38
480
        auto VARNAME_LINENUM(timeout_us) =                                              \
39
480
                std::chrono::duration_cast<std::chrono::microseconds>(timeout).count(); \
40
480
        auto VARNAME_LINENUM(cost_us) =                                                 \
41
480
                doris::MonotonicMicros() - VARNAME_LINENUM(scoped_simple_trace);        \
42
480
        if (VARNAME_LINENUM(cost_us) >= VARNAME_LINENUM(timeout_us)) {                  \
43
0
            stream << "Simple trace cost(us): " << VARNAME_LINENUM(cost_us);            \
44
0
        }                                                                               \
45
480
    };
Unexecuted instantiation: full_compaction.cpp:_ZZN5doris14FullCompaction14modify_rowsetsEvENK3$_0clEv
tablet_manager.cpp:_ZZN5doris13TabletManager12_drop_tabletEllbbbENK3$_1clEv
Line
Count
Source
37
255
    Defer trace_defer = [&] {                                                           \
38
255
        auto VARNAME_LINENUM(timeout_us) =                                              \
39
255
                std::chrono::duration_cast<std::chrono::microseconds>(timeout).count(); \
40
255
        auto VARNAME_LINENUM(cost_us) =                                                 \
41
255
                doris::MonotonicMicros() - VARNAME_LINENUM(scoped_simple_trace);        \
42
255
        if (VARNAME_LINENUM(cost_us) >= VARNAME_LINENUM(timeout_us)) {                  \
43
0
            stream << "Simple trace cost(us): " << VARNAME_LINENUM(cost_us);            \
44
0
        }                                                                               \
45
255
    };
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
    };