Coverage Report

Created: 2025-06-08 06:03

/root/doris/be/src/common/logging.h
Line
Count
Source (jump to first uncovered line)
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 <memory>
21
22
// GLOG defines this based on the system but doesn't check if it's already
23
// been defined.  undef it first to avoid warnings.
24
// glog MUST be included before gflags.  Instead of including them,
25
// our files should include this file instead.
26
#undef _XOPEN_SOURCE
27
// This is including a glog internal file.  We want this to expose the
28
// function to get the stack trace.
29
#include <glog/logging.h> // IWYU pragma: export
30
#undef MutexLock
31
32
// Define VLOG levels.  We want display per-row info less than per-file which
33
// is less than per-query.  For now per-connection is the same as per-query.
34
#define VLOG_CONNECTION VLOG(1)
35
18.4E
#define VLOG_RPC VLOG(8)
36
7
#define VLOG_QUERY VLOG(1)
37
18.4E
#define VLOG_FILE VLOG(2)
38
18.4E
#define VLOG_ROW VLOG(10)
39
18.4E
#define VLOG_PROGRESS VLOG(2)
40
5.37M
#define VLOG_TRACE VLOG(10)
41
18.4E
#define VLOG_DEBUG VLOG(7)
42
83.1k
#define VLOG_NOTICE VLOG(3)
43
18.4E
#define VLOG_CRITICAL VLOG(1)
44
45
#define VLOG_CONNECTION_IS_ON VLOG_IS_ON(1)
46
#define VLOG_RPC_IS_ON VLOG_IS_ON(8)
47
#define VLOG_QUERY_IS_ON VLOG_IS_ON(1)
48
4.53k
#define VLOG_FILE_IS_ON VLOG_IS_ON(2)
49
#define VLOG_ROW_IS_ON VLOG_IS_ON(10)
50
4.23M
#define VLOG_TRACE_IS_ON VLOG_IS_ON(10)
51
590k
#define VLOG_DEBUG_IS_ON VLOG_IS_ON(7)
52
2.43k
#define VLOG_NOTICE_IS_ON VLOG_IS_ON(3)
53
0
#define VLOG_CRITICAL_IS_ON VLOG_IS_ON(1)
54
55
/// Define a wrapper around DCHECK for strongly typed enums that print a useful error
56
/// message on failure.
57
#define DCHECK_ENUM_EQ(a, b)                                                 \
58
    DCHECK(a == b) << "[ " #a " = " << static_cast<int>(a) << " , " #b " = " \
59
                   << static_cast<int>(b) << " ]"
60
61
#include <fmt/format.h>
62
63
#include "util/uid_util.h"
64
65
namespace doris {
66
67
// glog doesn't allow multiple invocations of InitGoogleLogging. This method conditionally
68
// calls InitGoogleLogging only if it hasn't been called before.
69
bool init_glog(const char* basename);
70
71
// Shuts down the google logging library. Call before exit to ensure that log files are
72
// flushed. May only be called once.
73
void shutdown_logging();
74
75
void update_logging(const std::string& name, const std::string& value);
76
77
class TaggableLogger {
78
public:
79
    TaggableLogger(const char* file, int line, google::LogSeverity severity)
80
989k
            : _msg(file, line, severity) {}
81
82
    template <typename... Args>
83
990k
    TaggableLogger& operator()(const std::string_view& fmt, Args&&... args) {
84
990k
        if constexpr (sizeof...(args) == 0) {
85
15.5k
            _msg.stream() << fmt;
86
15.5k
        } else {
87
15.5k
            _msg.stream() << fmt::format(fmt, std::forward<Args&&>(args)...);
88
15.5k
        }
89
990k
        return *this;
90
990k
    }
_ZN5doris14TaggableLoggerclIJEEERS0_RKSt17basic_string_viewIcSt11char_traitsIcEEDpOT_
Line
Count
Source
83
974k
    TaggableLogger& operator()(const std::string_view& fmt, Args&&... args) {
84
974k
        if constexpr (sizeof...(args) == 0) {
85
974k
            _msg.stream() << fmt;
86
974k
        } else {
87
974k
            _msg.stream() << fmt::format(fmt, std::forward<Args&&>(args)...);
88
974k
        }
89
974k
        return *this;
90
974k
    }
Unexecuted instantiation: _ZN5doris14TaggableLoggerclIJNSt7__cxx1112basic_stringIcSt11char_traitsIcESaIcEEES7_S7_S7_EEERS0_RKSt17basic_string_viewIcS5_EDpOT_
Unexecuted instantiation: _ZN5doris14TaggableLoggerclIJRlS2_S2_EEERS0_RKSt17basic_string_viewIcSt11char_traitsIcEEDpOT_
Unexecuted instantiation: _ZN5doris14TaggableLoggerclIJRKNSt7__cxx1112basic_stringIcSt11char_traitsIcESaIcEEEmEEERS0_RKSt17basic_string_viewIcS5_EDpOT_
_ZN5doris14TaggableLoggerclIJRSt17basic_string_viewIcSt11char_traitsIcEEEEERS0_RKS5_DpOT_
Line
Count
Source
83
8.81k
    TaggableLogger& operator()(const std::string_view& fmt, Args&&... args) {
84
8.81k
        if constexpr (sizeof...(args) == 0) {
85
8.81k
            _msg.stream() << fmt;
86
8.81k
        } else {
87
8.81k
            _msg.stream() << fmt::format(fmt, std::forward<Args&&>(args)...);
88
8.81k
        }
89
8.81k
        return *this;
90
8.81k
    }
_ZN5doris14TaggableLoggerclIJNSt7__cxx1112basic_stringIcSt11char_traitsIcESaIcEEEEEERS0_RKSt17basic_string_viewIcS5_EDpOT_
Line
Count
Source
83
54
    TaggableLogger& operator()(const std::string_view& fmt, Args&&... args) {
84
54
        if constexpr (sizeof...(args) == 0) {
85
54
            _msg.stream() << fmt;
86
54
        } else {
87
54
            _msg.stream() << fmt::format(fmt, std::forward<Args&&>(args)...);
88
54
        }
89
54
        return *this;
90
54
    }
Unexecuted instantiation: _ZN5doris14TaggableLoggerclIJRlEEERS0_RKSt17basic_string_viewIcSt11char_traitsIcEEDpOT_
Unexecuted instantiation: _ZN5doris14TaggableLoggerclIJRlS2_S2_NSt7__cxx1112basic_stringIcSt11char_traitsIcESaIcEEEEEERS0_RKSt17basic_string_viewIcS6_EDpOT_
Unexecuted instantiation: _ZN5doris14TaggableLoggerclIJRlNSt7__cxx1112basic_stringIcSt11char_traitsIcESaIcEEES2_S8_EEERS0_RKSt17basic_string_viewIcS6_EDpOT_
Unexecuted instantiation: _ZN5doris14TaggableLoggerclIJRlNSt7__cxx1112basic_stringIcSt11char_traitsIcESaIcEEEEEERS0_RKSt17basic_string_viewIcS6_EDpOT_
Unexecuted instantiation: _ZN5doris14TaggableLoggerclIJPKcEEERS0_RKSt17basic_string_viewIcSt11char_traitsIcEEDpOT_
Unexecuted instantiation: _ZN5doris14TaggableLoggerclIJNSt7__cxx1112basic_stringIcSt11char_traitsIcESaIcEEEPKcEEERS0_RKSt17basic_string_viewIcS5_EDpOT_
_ZN5doris14TaggableLoggerclIJNSt7__cxx1112basic_stringIcSt11char_traitsIcESaIcEEES7_EEERS0_RKSt17basic_string_viewIcS5_EDpOT_
Line
Count
Source
83
1.62k
    TaggableLogger& operator()(const std::string_view& fmt, Args&&... args) {
84
1.62k
        if constexpr (sizeof...(args) == 0) {
85
1.62k
            _msg.stream() << fmt;
86
1.62k
        } else {
87
1.62k
            _msg.stream() << fmt::format(fmt, std::forward<Args&&>(args)...);
88
1.62k
        }
89
1.62k
        return *this;
90
1.62k
    }
Unexecuted instantiation: _ZN5doris14TaggableLoggerclIJNSt7__cxx1112basic_stringIcSt11char_traitsIcESaIcEEEKS7_EEERS0_RKSt17basic_string_viewIcS5_EDpOT_
Unexecuted instantiation: _ZN5doris14TaggableLoggerclIJRNSt7__cxx1112basic_stringIcSt11char_traitsIcESaIcEEERiS7_EEERS0_RKSt17basic_string_viewIcS5_EDpOT_
_ZN5doris14TaggableLoggerclIJNSt7__cxx1112basic_stringIcSt11char_traitsIcESaIcEEES7_S7_EEERS0_RKSt17basic_string_viewIcS5_EDpOT_
Line
Count
Source
83
2.96k
    TaggableLogger& operator()(const std::string_view& fmt, Args&&... args) {
84
2.96k
        if constexpr (sizeof...(args) == 0) {
85
2.96k
            _msg.stream() << fmt;
86
2.96k
        } else {
87
2.96k
            _msg.stream() << fmt::format(fmt, std::forward<Args&&>(args)...);
88
2.96k
        }
89
2.96k
        return *this;
90
2.96k
    }
_ZN5doris14TaggableLoggerclIJNSt7__cxx1112basic_stringIcSt11char_traitsIcESaIcEEERKNS_25PPlanFragmentCancelReasonERKS7_EEERS0_RKSt17basic_string_viewIcS5_EDpOT_
Line
Count
Source
83
7
    TaggableLogger& operator()(const std::string_view& fmt, Args&&... args) {
84
7
        if constexpr (sizeof...(args) == 0) {
85
7
            _msg.stream() << fmt;
86
7
        } else {
87
7
            _msg.stream() << fmt::format(fmt, std::forward<Args&&>(args)...);
88
7
        }
89
7
        return *this;
90
7
    }
Unexecuted instantiation: _ZN5doris14TaggableLoggerclIJRNSt7__cxx1112basic_stringIcSt11char_traitsIcESaIcEEEPKcEEERS0_RKSt17basic_string_viewIcS5_EDpOT_
_ZN5doris14TaggableLoggerclIJmNSt7__cxx1112basic_stringIcSt11char_traitsIcESaIcEEERdEEERS0_RKSt17basic_string_viewIcS5_EDpOT_
Line
Count
Source
83
107
    TaggableLogger& operator()(const std::string_view& fmt, Args&&... args) {
84
107
        if constexpr (sizeof...(args) == 0) {
85
107
            _msg.stream() << fmt;
86
107
        } else {
87
107
            _msg.stream() << fmt::format(fmt, std::forward<Args&&>(args)...);
88
107
        }
89
107
        return *this;
90
107
    }
Unexecuted instantiation: _ZN5doris14TaggableLoggerclIJRKNSt7__cxx1112basic_stringIcSt11char_traitsIcESaIcEEERmS7_EEERS0_RKSt17basic_string_viewIcS5_EDpOT_
_ZN5doris14TaggableLoggerclIJRlS2_S2_RmEEERS0_RKSt17basic_string_viewIcSt11char_traitsIcEEDpOT_
Line
Count
Source
83
178
    TaggableLogger& operator()(const std::string_view& fmt, Args&&... args) {
84
178
        if constexpr (sizeof...(args) == 0) {
85
178
            _msg.stream() << fmt;
86
178
        } else {
87
178
            _msg.stream() << fmt::format(fmt, std::forward<Args&&>(args)...);
88
178
        }
89
178
        return *this;
90
178
    }
Unexecuted instantiation: _ZN5doris14TaggableLoggerclIJRNSt7__cxx1112basic_stringIcSt11char_traitsIcESaIcEEERiS8_S9_RjRlSB_SB_EEERS0_RKSt17basic_string_viewIcS5_EDpOT_
Unexecuted instantiation: _ZN5doris14TaggableLoggerclIJNSt7__cxx1112basic_stringIcSt11char_traitsIcESaIcEEERjRlS9_S9_EEERS0_RKSt17basic_string_viewIcS5_EDpOT_
_ZN5doris14TaggableLoggerclIJRNSt7__cxx1112basic_stringIcSt11char_traitsIcESaIcEEERiRlSA_lRjSA_SA_SA_EEERS0_RKSt17basic_string_viewIcS5_EDpOT_
Line
Count
Source
83
178
    TaggableLogger& operator()(const std::string_view& fmt, Args&&... args) {
84
178
        if constexpr (sizeof...(args) == 0) {
85
178
            _msg.stream() << fmt;
86
178
        } else {
87
178
            _msg.stream() << fmt::format(fmt, std::forward<Args&&>(args)...);
88
178
        }
89
178
        return *this;
90
178
    }
Unexecuted instantiation: _ZN5doris14TaggableLoggerclIJRlS2_S2_RNS_6StatusEEEERS0_RKSt17basic_string_viewIcSt11char_traitsIcEEDpOT_
_ZN5doris14TaggableLoggerclIJRlS2_S2_S2_RKmEEERS0_RKSt17basic_string_viewIcSt11char_traitsIcEEDpOT_
Line
Count
Source
83
178
    TaggableLogger& operator()(const std::string_view& fmt, Args&&... args) {
84
178
        if constexpr (sizeof...(args) == 0) {
85
178
            _msg.stream() << fmt;
86
178
        } else {
87
178
            _msg.stream() << fmt::format(fmt, std::forward<Args&&>(args)...);
88
178
        }
89
178
        return *this;
90
178
    }
Unexecuted instantiation: _ZN5doris14TaggableLoggerclIJNSt7__cxx1112basic_stringIcSt11char_traitsIcESaIcEEERiS7_S7_EEERS0_RKSt17basic_string_viewIcS5_EDpOT_
_ZN5doris14TaggableLoggerclIJNSt7__cxx1112basic_stringIcSt11char_traitsIcESaIcEEERiS7_EEERS0_RKSt17basic_string_viewIcS5_EDpOT_
Line
Count
Source
83
1.47k
    TaggableLogger& operator()(const std::string_view& fmt, Args&&... args) {
84
1.47k
        if constexpr (sizeof...(args) == 0) {
85
1.47k
            _msg.stream() << fmt;
86
1.47k
        } else {
87
1.47k
            _msg.stream() << fmt::format(fmt, std::forward<Args&&>(args)...);
88
1.47k
        }
89
1.47k
        return *this;
90
1.47k
    }
91
92
    template <typename V>
93
2.36M
    TaggableLogger& tag(std::string_view key, V&& value) {
94
2.36M
        _msg.stream() << '|' << key << '=';
95
2.36M
        if constexpr (std::is_same_v<V, TUniqueId> || std::is_same_v<V, PUniqueId>) {
96
2.36M
            _msg.stream() << print_id(value);
97
2.36M
        } else {
98
2.36M
            _msg.stream() << value;
99
2.36M
        }
100
2.36M
        return *this;
101
2.36M
    }
_ZN5doris14TaggableLogger3tagIRKNSt7__cxx1112basic_stringIcSt11char_traitsIcESaIcEEEEERS0_St17basic_string_viewIcS5_EOT_
Line
Count
Source
93
4.44k
    TaggableLogger& tag(std::string_view key, V&& value) {
94
4.44k
        _msg.stream() << '|' << key << '=';
95
4.44k
        if constexpr (std::is_same_v<V, TUniqueId> || std::is_same_v<V, PUniqueId>) {
96
4.44k
            _msg.stream() << print_id(value);
97
4.44k
        } else {
98
4.44k
            _msg.stream() << value;
99
4.44k
        }
100
4.44k
        return *this;
101
4.44k
    }
_ZN5doris14TaggableLogger3tagIRKiEERS0_St17basic_string_viewIcSt11char_traitsIcEEOT_
Line
Count
Source
93
2.96k
    TaggableLogger& tag(std::string_view key, V&& value) {
94
2.96k
        _msg.stream() << '|' << key << '=';
95
2.96k
        if constexpr (std::is_same_v<V, TUniqueId> || std::is_same_v<V, PUniqueId>) {
96
2.96k
            _msg.stream() << print_id(value);
97
2.96k
        } else {
98
2.96k
            _msg.stream() << value;
99
2.96k
        }
100
2.96k
        return *this;
101
2.96k
    }
_ZN5doris14TaggableLogger3tagIRNSt7__cxx1112basic_stringIcSt11char_traitsIcESaIcEEEEERS0_St17basic_string_viewIcS5_EOT_
Line
Count
Source
93
386k
    TaggableLogger& tag(std::string_view key, V&& value) {
94
386k
        _msg.stream() << '|' << key << '=';
95
386k
        if constexpr (std::is_same_v<V, TUniqueId> || std::is_same_v<V, PUniqueId>) {
96
386k
            _msg.stream() << print_id(value);
97
386k
        } else {
98
386k
            _msg.stream() << value;
99
386k
        }
100
386k
        return *this;
101
386k
    }
_ZN5doris14TaggableLogger3tagIRlEERS0_St17basic_string_viewIcSt11char_traitsIcEEOT_
Line
Count
Source
93
402k
    TaggableLogger& tag(std::string_view key, V&& value) {
94
402k
        _msg.stream() << '|' << key << '=';
95
402k
        if constexpr (std::is_same_v<V, TUniqueId> || std::is_same_v<V, PUniqueId>) {
96
402k
            _msg.stream() << print_id(value);
97
402k
        } else {
98
402k
            _msg.stream() << value;
99
402k
        }
100
402k
        return *this;
101
402k
    }
Unexecuted instantiation: _ZN5doris14TaggableLogger3tagIRKNS_9TTaskType4typeEEERS0_St17basic_string_viewIcSt11char_traitsIcEEOT_
_ZN5doris14TaggableLogger3tagIRKlEERS0_St17basic_string_viewIcSt11char_traitsIcEEOT_
Line
Count
Source
93
840k
    TaggableLogger& tag(std::string_view key, V&& value) {
94
840k
        _msg.stream() << '|' << key << '=';
95
840k
        if constexpr (std::is_same_v<V, TUniqueId> || std::is_same_v<V, PUniqueId>) {
96
840k
            _msg.stream() << print_id(value);
97
840k
        } else {
98
840k
            _msg.stream() << value;
99
840k
        }
100
840k
        return *this;
101
840k
    }
_ZN5doris14TaggableLogger3tagIRjEERS0_St17basic_string_viewIcSt11char_traitsIcEEOT_
Line
Count
Source
93
22.5k
    TaggableLogger& tag(std::string_view key, V&& value) {
94
22.5k
        _msg.stream() << '|' << key << '=';
95
22.5k
        if constexpr (std::is_same_v<V, TUniqueId> || std::is_same_v<V, PUniqueId>) {
96
22.5k
            _msg.stream() << print_id(value);
97
22.5k
        } else {
98
22.5k
            _msg.stream() << value;
99
22.5k
        }
100
22.5k
        return *this;
101
22.5k
    }
_ZN5doris14TaggableLogger3tagINSt7__cxx1112basic_stringIcSt11char_traitsIcESaIcEEEEERS0_St17basic_string_viewIcS5_EOT_
Line
Count
Source
93
230k
    TaggableLogger& tag(std::string_view key, V&& value) {
94
230k
        _msg.stream() << '|' << key << '=';
95
230k
        if constexpr (std::is_same_v<V, TUniqueId> || std::is_same_v<V, PUniqueId>) {
96
230k
            _msg.stream() << print_id(value);
97
230k
        } else {
98
230k
            _msg.stream() << value;
99
230k
        }
100
230k
        return *this;
101
230k
    }
_ZN5doris14TaggableLogger3tagIRKNS_9TPushType4typeEEERS0_St17basic_string_viewIcSt11char_traitsIcEEOT_
Line
Count
Source
93
1.54k
    TaggableLogger& tag(std::string_view key, V&& value) {
94
1.54k
        _msg.stream() << '|' << key << '=';
95
1.54k
        if constexpr (std::is_same_v<V, TUniqueId> || std::is_same_v<V, PUniqueId>) {
96
1.54k
            _msg.stream() << print_id(value);
97
1.54k
        } else {
98
1.54k
            _msg.stream() << value;
99
1.54k
        }
100
1.54k
        return *this;
101
1.54k
    }
_ZN5doris14TaggableLogger3tagImEERS0_St17basic_string_viewIcSt11char_traitsIcEEOT_
Line
Count
Source
93
249k
    TaggableLogger& tag(std::string_view key, V&& value) {
94
249k
        _msg.stream() << '|' << key << '=';
95
249k
        if constexpr (std::is_same_v<V, TUniqueId> || std::is_same_v<V, PUniqueId>) {
96
249k
            _msg.stream() << print_id(value);
97
249k
        } else {
98
249k
            _msg.stream() << value;
99
249k
        }
100
249k
        return *this;
101
249k
    }
_ZN5doris14TaggableLogger3tagIlEERS0_St17basic_string_viewIcSt11char_traitsIcEEOT_
Line
Count
Source
93
254
    TaggableLogger& tag(std::string_view key, V&& value) {
94
254
        _msg.stream() << '|' << key << '=';
95
254
        if constexpr (std::is_same_v<V, TUniqueId> || std::is_same_v<V, PUniqueId>) {
96
254
            _msg.stream() << print_id(value);
97
254
        } else {
98
254
            _msg.stream() << value;
99
254
        }
100
254
        return *this;
101
254
    }
Unexecuted instantiation: _ZN5doris14TaggableLogger3tagIRbEERS0_St17basic_string_viewIcSt11char_traitsIcEEOT_
Unexecuted instantiation: _ZN5doris14TaggableLogger3tagIRKSt6vectorINS_7VersionESaIS3_EEEERS0_St17basic_string_viewIcSt11char_traitsIcEEOT_
_ZN5doris14TaggableLogger3tagIRiEERS0_St17basic_string_viewIcSt11char_traitsIcEEOT_
Line
Count
Source
93
224k
    TaggableLogger& tag(std::string_view key, V&& value) {
94
224k
        _msg.stream() << '|' << key << '=';
95
224k
        if constexpr (std::is_same_v<V, TUniqueId> || std::is_same_v<V, PUniqueId>) {
96
224k
            _msg.stream() << print_id(value);
97
224k
        } else {
98
224k
            _msg.stream() << value;
99
224k
        }
100
224k
        return *this;
101
224k
    }
Unexecuted instantiation: _ZN5doris14TaggableLogger3tagIRKNS_17TAgentTaskRequestEEERS0_St17basic_string_viewIcSt11char_traitsIcEEOT_
102
103
    template <typename E>
104
2.92k
    TaggableLogger& error(E&& error) {
105
2.92k
        _msg.stream() << "|error=" << error;
106
2.92k
        return *this;
107
2.92k
    }
_ZN5doris14TaggableLogger5errorIRNS_6StatusEEERS0_OT_
Line
Count
Source
104
2.92k
    TaggableLogger& error(E&& error) {
105
2.92k
        _msg.stream() << "|error=" << error;
106
2.92k
        return *this;
107
2.92k
    }
Unexecuted instantiation: _ZN5doris14TaggableLogger5errorIRNS_7TStatusEEERS0_OT_
108
109
private:
110
    google::LogMessage _msg;
111
};
112
113
// Very very important!!!!
114
// Never define LOG_DEBUG or LOG_TRACE. because the tagged logging method will
115
// always generated string and then check the log level, its performane is bad.
116
// glog's original method will first check log level if it is not satisfied,
117
// the log message is not generated.
118
1.97M
#define LOG_INFO TaggableLogger(__FILE__, __LINE__, google::GLOG_INFO)
119
6.99k
#define LOG_WARNING TaggableLogger(__FILE__, __LINE__, google::GLOG_WARNING)
120
#define LOG_ERROR TaggableLogger(__FILE__, __LINE__, google::GLOG_ERROR)
121
0
#define LOG_FATAL TaggableLogger(__FILE__, __LINE__, google::GLOG_FATAL)
122
123
} // namespace doris