/root/doris/be/src/util/scoped_cleanup.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 <utility> |
21 | | |
22 | | #include "gutil/macros.h" |
23 | | |
24 | | // Run the given function body (which is typically a block of code surrounded by |
25 | | // curly-braces) when the current scope exits. |
26 | | // |
27 | | // Example: |
28 | | // int fd = open(...); |
29 | | // SCOPED_CLEANUP({ close(fd); }); |
30 | | // |
31 | | // NOTE: in the case that you want to cancel the cleanup, use the more verbose |
32 | | // (non-macro) form below. |
33 | | #define SCOPED_CLEANUP(func_body) \ |
34 | 276k | auto VARNAME_LINENUM(scoped_cleanup) = MakeScopedCleanup([&] { func_body });scoped_cleanup_test.cpp:_ZZN5doris35ScopedCleanup_TestCleanupMacro_Test8TestBodyEvENK3$_0clEv Line | Count | Source | 34 | 1 | auto VARNAME_LINENUM(scoped_cleanup) = MakeScopedCleanup([&] { func_body }); |
threadpool_test.cpp:_ZZN5doris47ThreadPoolTest_TestThreadPoolWithNoMinimum_Test8TestBodyEvENK3$_0clEv Line | Count | Source | 34 | 1 | auto VARNAME_LINENUM(scoped_cleanup) = MakeScopedCleanup([&] { func_body }); |
threadpool_test.cpp:_ZZN5doris67ThreadPoolTestTokenTypes_TestTokenSubmitsProcessedConcurrently_Test8TestBodyEvENK3$_0clEv Line | Count | Source | 34 | 2 | auto VARNAME_LINENUM(scoped_cleanup) = MakeScopedCleanup([&] { func_body }); |
threadpool_test.cpp:_ZZN5doris49ThreadPoolTest_TestTokenSubmitsNonSequential_Test8TestBodyEvENK3$_0clEv Line | Count | Source | 34 | 1 | auto VARNAME_LINENUM(scoped_cleanup) = MakeScopedCleanup([&] { func_body }); |
threadpool_test.cpp:_ZZN5doris47ThreadPoolTestTokenTypes_TestTokenShutdown_Test8TestBodyEvENK3$_0clEv Line | Count | Source | 34 | 2 | auto VARNAME_LINENUM(scoped_cleanup) = MakeScopedCleanup([&] { func_body }); |
threadpool_test.cpp:_ZZN5doris70ThreadPoolTestTokenTypes_TestTokenSubmissionsAdhereToMaxQueueSize_Test8TestBodyEvENK3$_0clEv Line | Count | Source | 34 | 2 | auto VARNAME_LINENUM(scoped_cleanup) = MakeScopedCleanup([&] { func_body }); |
Unexecuted instantiation: task_worker_pool.cpp:_ZZN5doris22create_tablet_callbackERNS_13StorageEngineERKNS_17TAgentTaskRequestEENK3$_0clEv Unexecuted instantiation: compaction.cpp:_ZZN5doris10Compaction14modify_rowsetsEPKNS_6Merger10StatisticsEENK3$_1clEv Unexecuted instantiation: compaction.cpp:_ZZN5doris10Compaction14modify_rowsetsEPKNS_6Merger10StatisticsEENK3$_2clEv Unexecuted instantiation: cold_data_compaction.cpp:_ZZN5doris18ColdDataCompaction14modify_rowsetsEPKNS_6Merger10StatisticsEENK3$_0clEv tablet.cpp:_ZZN5doris6Tablet10add_rowsetESt10shared_ptrINS_6RowsetEEENK3$_0clEv Line | Count | Source | 34 | 327 | auto VARNAME_LINENUM(scoped_cleanup) = MakeScopedCleanup([&] { func_body }); |
tablet.cpp:_ZZN5doris6Tablet14add_inc_rowsetERKSt10shared_ptrINS_6RowsetEEENK3$_0clEv Line | Count | Source | 34 | 10.3k | auto VARNAME_LINENUM(scoped_cleanup) = MakeScopedCleanup([&] { func_body }); |
tablet.cpp:_ZZN5doris6Tablet27delete_expired_stale_rowsetEvENK3$_0clEv Line | Count | Source | 34 | 1 | auto VARNAME_LINENUM(scoped_cleanup) = MakeScopedCleanup([&] { func_body }); |
tablet.cpp:_ZZN5doris6Tablet26calculate_cumulative_pointEvENK3$_0clEv Line | Count | Source | 34 | 38 | auto VARNAME_LINENUM(scoped_cleanup) = MakeScopedCleanup([&] { func_body }); |
tablet.cpp:_ZZN5doris6Tablet14_cooldown_dataESt10shared_ptrINS_6RowsetEEENK3$_1clEv Line | Count | Source | 34 | 5 | auto VARNAME_LINENUM(scoped_cleanup) = MakeScopedCleanup([&] { func_body }); |
tablet.cpp:_ZZN5doris6Tablet14_cooldown_dataESt10shared_ptrINS_6RowsetEEENK3$_2clEv Line | Count | Source | 34 | 5 | auto VARNAME_LINENUM(scoped_cleanup) = MakeScopedCleanup([&] { func_body }); |
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$_1clEv Line | Count | Source | 34 | 475 | auto VARNAME_LINENUM(scoped_cleanup) = MakeScopedCleanup([&] { func_body }); |
Unexecuted instantiation: full_compaction.cpp:_ZZN5doris14FullCompaction37_full_compaction_update_delete_bitmapERKSt10shared_ptrINS_6RowsetEEPNS_12RowsetWriterEENK3$_0clEv tablet_manager.cpp:_ZZN5doris13TabletManager21_drop_tablet_unlockedEllbbENK3$_1clEv Line | Count | Source | 34 | 251 | auto VARNAME_LINENUM(scoped_cleanup) = MakeScopedCleanup([&] { func_body }); |
Unexecuted instantiation: schema_change.cpp:_ZZZN5doris19SchemaChangeHandler27_convert_historical_rowsetsERKNS0_18SchemaChangeParamsEPlENK3$_0clEvENKUlvE_clEv Unexecuted instantiation: schema_change.cpp:_ZZN5doris19SchemaChangeHandler27_do_process_alter_tablet_v2ERKNS_17TAlterTabletReqV2EENK3$_2clEv Unexecuted instantiation: schema_change.cpp:_ZZN5doris19SchemaChangeHandler27_do_process_alter_tablet_v2ERKNS_17TAlterTabletReqV2EENK3$_3clEv Unexecuted instantiation: schema_change.cpp:_ZZN5doris19SchemaChangeHandler33_calc_delete_bitmap_for_mow_tableESt10shared_ptrINS_6TabletEElENK3$_0clEv Unexecuted instantiation: engine_clone_task.cpp:_ZZN5doris15EngineCloneTask13_finish_cloneEPNS_6TabletERKNSt7__cxx1112basic_stringIcSt11char_traitsIcESaIcEEElbENK3$_2clEv index_builder.cpp:_ZZN5doris12IndexBuilder14modify_rowsetsEPKNS_6Merger10StatisticsEENK3$_1clEv Line | Count | Source | 34 | 1 | auto VARNAME_LINENUM(scoped_cleanup) = MakeScopedCleanup([&] { func_body }); |
threadpool.cpp:_ZZN5doris10ThreadPool15dispatch_threadEvENK3$_0clEv Line | Count | Source | 34 | 265k | auto VARNAME_LINENUM(scoped_cleanup) = MakeScopedCleanup([&] { func_body }); |
pad_rowset_action.cpp:_ZZN5doris15PadRowsetAction11_pad_rowsetESt10shared_ptrINS_6TabletEERKNS_7VersionEENK3$_0clEv Line | Count | Source | 34 | 1 | auto VARNAME_LINENUM(scoped_cleanup) = MakeScopedCleanup([&] { func_body }); |
|
35 | | |
36 | | namespace doris { |
37 | | |
38 | | // A scoped object which runs a cleanup function when going out of scope. Can |
39 | | // be used for scoped resource cleanup. |
40 | | // |
41 | | // Use 'MakeScopedCleanup()' below to instantiate. |
42 | | template <typename F> |
43 | | class ScopedCleanup { |
44 | | public: |
45 | 150k | explicit ScopedCleanup(F f) : cancelled_(false), f_(std::move(f)) {}scoped_cleanup_test.cpp:_ZN5doris13ScopedCleanupIZNS_30ScopedCleanup_TestCleanup_Test8TestBodyEvE3$_0EC2ES2_ Line | Count | Source | 45 | 1 | explicit ScopedCleanup(F f) : cancelled_(false), f_(std::move(f)) {} |
scoped_cleanup_test.cpp:_ZN5doris13ScopedCleanupIZNS_35ScopedCleanup_TestCleanupMacro_Test8TestBodyEvE3$_0EC2ES2_ Line | Count | Source | 45 | 1 | explicit ScopedCleanup(F f) : cancelled_(false), f_(std::move(f)) {} |
scoped_cleanup_test.cpp:_ZN5doris13ScopedCleanupIZNS_36ScopedCleanup_TestCancelCleanup_Test8TestBodyEvE3$_0EC2ES2_ Line | Count | Source | 45 | 1 | explicit ScopedCleanup(F f) : cancelled_(false), f_(std::move(f)) {} |
threadpool_test.cpp:_ZN5doris13ScopedCleanupIZNS_47ThreadPoolTest_TestThreadPoolWithNoMinimum_Test8TestBodyEvE3$_0EC2ES2_ Line | Count | Source | 45 | 1 | explicit ScopedCleanup(F f) : cancelled_(false), f_(std::move(f)) {} |
threadpool_test.cpp:_ZN5doris13ScopedCleanupIZNS_50ThreadPoolTest_TestThreadPoolWithNoMaxThreads_Test8TestBodyEvE3$_0EC2ES2_ Line | Count | Source | 45 | 1 | explicit ScopedCleanup(F f) : cancelled_(false), f_(std::move(f)) {} |
threadpool_test.cpp:_ZN5doris13ScopedCleanupIZNS_28ThreadPoolTest_TestRace_Test8TestBodyEvE3$_0EC2ES2_ Line | Count | Source | 45 | 1 | explicit ScopedCleanup(F f) : cancelled_(false), f_(std::move(f)) {} |
threadpool_test.cpp:_ZN5doris13ScopedCleanupIZNS_67ThreadPoolTestTokenTypes_TestTokenSubmitsProcessedConcurrently_Test8TestBodyEvE3$_0EC2ES2_ Line | Count | Source | 45 | 2 | explicit ScopedCleanup(F f) : cancelled_(false), f_(std::move(f)) {} |
threadpool_test.cpp:_ZN5doris13ScopedCleanupIZNS_49ThreadPoolTest_TestTokenSubmitsNonSequential_Test8TestBodyEvE3$_0EC2ES2_ Line | Count | Source | 45 | 1 | explicit ScopedCleanup(F f) : cancelled_(false), f_(std::move(f)) {} |
threadpool_test.cpp:_ZN5doris13ScopedCleanupIZNS_47ThreadPoolTestTokenTypes_TestTokenShutdown_Test8TestBodyEvE3$_0EC2ES2_ Line | Count | Source | 45 | 2 | explicit ScopedCleanup(F f) : cancelled_(false), f_(std::move(f)) {} |
threadpool_test.cpp:_ZN5doris13ScopedCleanupIZNS_70ThreadPoolTestTokenTypes_TestTokenSubmissionsAdhereToMaxQueueSize_Test8TestBodyEvE3$_0EC2ES2_ Line | Count | Source | 45 | 2 | explicit ScopedCleanup(F f) : cancelled_(false), f_(std::move(f)) {} |
Unexecuted instantiation: task_worker_pool.cpp:_ZN5doris13ScopedCleanupIZNS_22create_tablet_callbackERNS_13StorageEngineERKNS_17TAgentTaskRequestEE3$_0EC2ES6_ Unexecuted instantiation: compaction.cpp:_ZN5doris13ScopedCleanupIZNS_10Compaction14modify_rowsetsEPKNS_6Merger10StatisticsEE3$_1EC2ES6_ Unexecuted instantiation: compaction.cpp:_ZN5doris13ScopedCleanupIZNS_10Compaction14modify_rowsetsEPKNS_6Merger10StatisticsEE3$_2EC2ES6_ Unexecuted instantiation: cold_data_compaction.cpp:_ZN5doris13ScopedCleanupIZNS_18ColdDataCompaction14modify_rowsetsEPKNS_6Merger10StatisticsEE3$_0EC2ES6_ tablet.cpp:_ZN5doris13ScopedCleanupIZNS_6Tablet10add_rowsetESt10shared_ptrINS_6RowsetEEE3$_0EC2ES5_ Line | Count | Source | 45 | 327 | explicit ScopedCleanup(F f) : cancelled_(false), f_(std::move(f)) {} |
tablet.cpp:_ZN5doris13ScopedCleanupIZNS_6Tablet14add_inc_rowsetERKSt10shared_ptrINS_6RowsetEEE3$_0EC2ES7_ Line | Count | Source | 45 | 10.3k | explicit ScopedCleanup(F f) : cancelled_(false), f_(std::move(f)) {} |
tablet.cpp:_ZN5doris13ScopedCleanupIZNS_6Tablet27delete_expired_stale_rowsetEvE3$_0EC2ES2_ Line | Count | Source | 45 | 1 | explicit ScopedCleanup(F f) : cancelled_(false), f_(std::move(f)) {} |
tablet.cpp:_ZN5doris13ScopedCleanupIZNS_6Tablet26calculate_cumulative_pointEvE3$_0EC2ES2_ Line | Count | Source | 45 | 38 | explicit ScopedCleanup(F f) : cancelled_(false), f_(std::move(f)) {} |
tablet.cpp:_ZN5doris13ScopedCleanupIZNS_6Tablet14_cooldown_dataESt10shared_ptrINS_6RowsetEEE3$_1EC2ES5_ Line | Count | Source | 45 | 5 | explicit ScopedCleanup(F f) : cancelled_(false), f_(std::move(f)) {} |
tablet.cpp:_ZN5doris13ScopedCleanupIZNS_6Tablet14_cooldown_dataESt10shared_ptrINS_6RowsetEEE3$_2EC2ES5_ Line | Count | Source | 45 | 5 | explicit ScopedCleanup(F f) : cancelled_(false), f_(std::move(f)) {} |
Unexecuted instantiation: tablet.cpp:_ZN5doris13ScopedCleanupIZNS_6Tablet23_follow_cooldowned_dataEvE3$_0EC2ES2_ Unexecuted instantiation: tablet.cpp:_ZN5doris13ScopedCleanupIZNS_6Tablet23_follow_cooldowned_dataEvE3$_1EC2ES2_ Unexecuted instantiation: tablet.cpp:_ZN5doris13ScopedCleanupIZNS_6Tablet25update_max_version_schemaERKSt10shared_ptrINS_12TabletSchemaEEE3$_0EC2ES7_ tablet.cpp:_ZN5doris13ScopedCleanupIZNS_6Tablet11clear_cacheEvE3$_1EC2ES2_ Line | Count | Source | 45 | 475 | explicit ScopedCleanup(F f) : cancelled_(false), f_(std::move(f)) {} |
Unexecuted instantiation: full_compaction.cpp:_ZN5doris13ScopedCleanupIZNS_14FullCompaction37_full_compaction_update_delete_bitmapERKSt10shared_ptrINS_6RowsetEEPNS_12RowsetWriterEE3$_0EC2ES9_ tablet_manager.cpp:_ZN5doris13ScopedCleanupIZNS_13TabletManager21_drop_tablet_unlockedEllbbE3$_1EC2ES2_ Line | Count | Source | 45 | 251 | explicit ScopedCleanup(F f) : cancelled_(false), f_(std::move(f)) {} |
Unexecuted instantiation: schema_change.cpp:_ZN5doris13ScopedCleanupIZZNS_19SchemaChangeHandler27_convert_historical_rowsetsERKNS1_18SchemaChangeParamsEPlENK3$_0clEvEUlvE_EC2ES7_ Unexecuted instantiation: schema_change.cpp:_ZN5doris13ScopedCleanupIZNS_19SchemaChangeHandler27_do_process_alter_tablet_v2ERKNS_17TAlterTabletReqV2EE3$_2EC2ES5_ Unexecuted instantiation: schema_change.cpp:_ZN5doris13ScopedCleanupIZNS_19SchemaChangeHandler27_do_process_alter_tablet_v2ERKNS_17TAlterTabletReqV2EE3$_3EC2ES5_ Unexecuted instantiation: schema_change.cpp:_ZN5doris13ScopedCleanupIZNS_19SchemaChangeHandler33_calc_delete_bitmap_for_mow_tableESt10shared_ptrINS_6TabletEElE3$_0EC2ES5_ Unexecuted instantiation: engine_clone_task.cpp:_ZN5doris13ScopedCleanupIZNS_15EngineCloneTask13_finish_cloneEPNS_6TabletERKNSt7__cxx1112basic_stringIcSt11char_traitsIcESaIcEEElbE3$_2EC2ESC_ index_builder.cpp:_ZN5doris13ScopedCleanupIZNS_12IndexBuilder14modify_rowsetsEPKNS_6Merger10StatisticsEE3$_1EC2ES6_ Line | Count | Source | 45 | 1 | explicit ScopedCleanup(F f) : cancelled_(false), f_(std::move(f)) {} |
thread.cpp:_ZN5doris13ScopedCleanupIZNS_6Thread12start_threadERKNSt7__cxx1112basic_stringIcSt11char_traitsIcESaIcEEES9_RKSt8functionIFvvEEmP13scoped_refptrIS1_EE3$_0EC2ESI_ Line | Count | Source | 45 | 3.91k | explicit ScopedCleanup(F f) : cancelled_(false), f_(std::move(f)) {} |
threadpool.cpp:_ZN5doris13ScopedCleanupIZNS_10ThreadPool15dispatch_threadEvE3$_0EC2ES2_ Line | Count | Source | 45 | 134k | explicit ScopedCleanup(F f) : cancelled_(false), f_(std::move(f)) {} |
pad_rowset_action.cpp:_ZN5doris13ScopedCleanupIZNS_15PadRowsetAction11_pad_rowsetESt10shared_ptrINS_6TabletEERKNS_7VersionEE3$_0EC2ES8_ Line | Count | Source | 45 | 1 | explicit ScopedCleanup(F f) : cancelled_(false), f_(std::move(f)) {} |
|
46 | 149k | ~ScopedCleanup() { |
47 | 149k | if (!cancelled_) { |
48 | 146k | f_(); |
49 | 146k | } |
50 | 149k | } scoped_cleanup_test.cpp:_ZN5doris13ScopedCleanupIZNS_30ScopedCleanup_TestCleanup_Test8TestBodyEvE3$_0ED2Ev Line | Count | Source | 46 | 1 | ~ScopedCleanup() { | 47 | 1 | if (!cancelled_) { | 48 | 1 | f_(); | 49 | 1 | } | 50 | 1 | } |
scoped_cleanup_test.cpp:_ZN5doris13ScopedCleanupIZNS_35ScopedCleanup_TestCleanupMacro_Test8TestBodyEvE3$_0ED2Ev Line | Count | Source | 46 | 1 | ~ScopedCleanup() { | 47 | 1 | if (!cancelled_) { | 48 | 1 | f_(); | 49 | 1 | } | 50 | 1 | } |
scoped_cleanup_test.cpp:_ZN5doris13ScopedCleanupIZNS_36ScopedCleanup_TestCancelCleanup_Test8TestBodyEvE3$_0ED2Ev Line | Count | Source | 46 | 1 | ~ScopedCleanup() { | 47 | 1 | if (!cancelled_) { | 48 | 0 | f_(); | 49 | 0 | } | 50 | 1 | } |
threadpool_test.cpp:_ZN5doris13ScopedCleanupIZNS_47ThreadPoolTest_TestThreadPoolWithNoMinimum_Test8TestBodyEvE3$_0ED2Ev Line | Count | Source | 46 | 1 | ~ScopedCleanup() { | 47 | 1 | if (!cancelled_) { | 48 | 1 | f_(); | 49 | 1 | } | 50 | 1 | } |
threadpool_test.cpp:_ZN5doris13ScopedCleanupIZNS_50ThreadPoolTest_TestThreadPoolWithNoMaxThreads_Test8TestBodyEvE3$_0ED2Ev Line | Count | Source | 46 | 1 | ~ScopedCleanup() { | 47 | 1 | if (!cancelled_) { | 48 | 1 | f_(); | 49 | 1 | } | 50 | 1 | } |
threadpool_test.cpp:_ZN5doris13ScopedCleanupIZNS_28ThreadPoolTest_TestRace_Test8TestBodyEvE3$_0ED2Ev Line | Count | Source | 46 | 1 | ~ScopedCleanup() { | 47 | 1 | if (!cancelled_) { | 48 | 1 | f_(); | 49 | 1 | } | 50 | 1 | } |
threadpool_test.cpp:_ZN5doris13ScopedCleanupIZNS_67ThreadPoolTestTokenTypes_TestTokenSubmitsProcessedConcurrently_Test8TestBodyEvE3$_0ED2Ev Line | Count | Source | 46 | 2 | ~ScopedCleanup() { | 47 | 2 | if (!cancelled_) { | 48 | 2 | f_(); | 49 | 2 | } | 50 | 2 | } |
threadpool_test.cpp:_ZN5doris13ScopedCleanupIZNS_49ThreadPoolTest_TestTokenSubmitsNonSequential_Test8TestBodyEvE3$_0ED2Ev Line | Count | Source | 46 | 1 | ~ScopedCleanup() { | 47 | 1 | if (!cancelled_) { | 48 | 1 | f_(); | 49 | 1 | } | 50 | 1 | } |
threadpool_test.cpp:_ZN5doris13ScopedCleanupIZNS_47ThreadPoolTestTokenTypes_TestTokenShutdown_Test8TestBodyEvE3$_0ED2Ev Line | Count | Source | 46 | 2 | ~ScopedCleanup() { | 47 | 2 | if (!cancelled_) { | 48 | 2 | f_(); | 49 | 2 | } | 50 | 2 | } |
threadpool_test.cpp:_ZN5doris13ScopedCleanupIZNS_70ThreadPoolTestTokenTypes_TestTokenSubmissionsAdhereToMaxQueueSize_Test8TestBodyEvE3$_0ED2Ev Line | Count | Source | 46 | 2 | ~ScopedCleanup() { | 47 | 2 | if (!cancelled_) { | 48 | 2 | f_(); | 49 | 2 | } | 50 | 2 | } |
Unexecuted instantiation: task_worker_pool.cpp:_ZN5doris13ScopedCleanupIZNS_22create_tablet_callbackERNS_13StorageEngineERKNS_17TAgentTaskRequestEE3$_0ED2Ev Unexecuted instantiation: compaction.cpp:_ZN5doris13ScopedCleanupIZNS_10Compaction14modify_rowsetsEPKNS_6Merger10StatisticsEE3$_1ED2Ev Unexecuted instantiation: compaction.cpp:_ZN5doris13ScopedCleanupIZNS_10Compaction14modify_rowsetsEPKNS_6Merger10StatisticsEE3$_2ED2Ev Unexecuted instantiation: cold_data_compaction.cpp:_ZN5doris13ScopedCleanupIZNS_18ColdDataCompaction14modify_rowsetsEPKNS_6Merger10StatisticsEE3$_0ED2Ev tablet.cpp:_ZN5doris13ScopedCleanupIZNS_6Tablet10add_rowsetESt10shared_ptrINS_6RowsetEEE3$_0ED2Ev Line | Count | Source | 46 | 327 | ~ScopedCleanup() { | 47 | 327 | if (!cancelled_) { | 48 | 327 | f_(); | 49 | 327 | } | 50 | 327 | } |
tablet.cpp:_ZN5doris13ScopedCleanupIZNS_6Tablet14add_inc_rowsetERKSt10shared_ptrINS_6RowsetEEE3$_0ED2Ev Line | Count | Source | 46 | 10.3k | ~ScopedCleanup() { | 47 | 10.3k | if (!cancelled_) { | 48 | 10.3k | f_(); | 49 | 10.3k | } | 50 | 10.3k | } |
tablet.cpp:_ZN5doris13ScopedCleanupIZNS_6Tablet27delete_expired_stale_rowsetEvE3$_0ED2Ev Line | Count | Source | 46 | 1 | ~ScopedCleanup() { | 47 | 1 | if (!cancelled_) { | 48 | 1 | f_(); | 49 | 1 | } | 50 | 1 | } |
tablet.cpp:_ZN5doris13ScopedCleanupIZNS_6Tablet26calculate_cumulative_pointEvE3$_0ED2Ev Line | Count | Source | 46 | 38 | ~ScopedCleanup() { | 47 | 38 | if (!cancelled_) { | 48 | 38 | f_(); | 49 | 38 | } | 50 | 38 | } |
tablet.cpp:_ZN5doris13ScopedCleanupIZNS_6Tablet14_cooldown_dataESt10shared_ptrINS_6RowsetEEE3$_1ED2Ev Line | Count | Source | 46 | 5 | ~ScopedCleanup() { | 47 | 5 | if (!cancelled_) { | 48 | 5 | f_(); | 49 | 5 | } | 50 | 5 | } |
tablet.cpp:_ZN5doris13ScopedCleanupIZNS_6Tablet14_cooldown_dataESt10shared_ptrINS_6RowsetEEE3$_2ED2Ev Line | Count | Source | 46 | 5 | ~ScopedCleanup() { | 47 | 5 | if (!cancelled_) { | 48 | 5 | f_(); | 49 | 5 | } | 50 | 5 | } |
Unexecuted instantiation: tablet.cpp:_ZN5doris13ScopedCleanupIZNS_6Tablet23_follow_cooldowned_dataEvE3$_0ED2Ev Unexecuted instantiation: tablet.cpp:_ZN5doris13ScopedCleanupIZNS_6Tablet23_follow_cooldowned_dataEvE3$_1ED2Ev Unexecuted instantiation: tablet.cpp:_ZN5doris13ScopedCleanupIZNS_6Tablet25update_max_version_schemaERKSt10shared_ptrINS_12TabletSchemaEEE3$_0ED2Ev tablet.cpp:_ZN5doris13ScopedCleanupIZNS_6Tablet11clear_cacheEvE3$_1ED2Ev Line | Count | Source | 46 | 475 | ~ScopedCleanup() { | 47 | 475 | if (!cancelled_) { | 48 | 475 | f_(); | 49 | 475 | } | 50 | 475 | } |
Unexecuted instantiation: full_compaction.cpp:_ZN5doris13ScopedCleanupIZNS_14FullCompaction37_full_compaction_update_delete_bitmapERKSt10shared_ptrINS_6RowsetEEPNS_12RowsetWriterEE3$_0ED2Ev tablet_manager.cpp:_ZN5doris13ScopedCleanupIZNS_13TabletManager21_drop_tablet_unlockedEllbbE3$_1ED2Ev Line | Count | Source | 46 | 251 | ~ScopedCleanup() { | 47 | 251 | if (!cancelled_) { | 48 | 251 | f_(); | 49 | 251 | } | 50 | 251 | } |
Unexecuted instantiation: schema_change.cpp:_ZN5doris13ScopedCleanupIZZNS_19SchemaChangeHandler27_convert_historical_rowsetsERKNS1_18SchemaChangeParamsEPlENK3$_0clEvEUlvE_ED2Ev Unexecuted instantiation: schema_change.cpp:_ZN5doris13ScopedCleanupIZNS_19SchemaChangeHandler27_do_process_alter_tablet_v2ERKNS_17TAlterTabletReqV2EE3$_2ED2Ev Unexecuted instantiation: schema_change.cpp:_ZN5doris13ScopedCleanupIZNS_19SchemaChangeHandler27_do_process_alter_tablet_v2ERKNS_17TAlterTabletReqV2EE3$_3ED2Ev Unexecuted instantiation: schema_change.cpp:_ZN5doris13ScopedCleanupIZNS_19SchemaChangeHandler33_calc_delete_bitmap_for_mow_tableESt10shared_ptrINS_6TabletEElE3$_0ED2Ev Unexecuted instantiation: engine_clone_task.cpp:_ZN5doris13ScopedCleanupIZNS_15EngineCloneTask13_finish_cloneEPNS_6TabletERKNSt7__cxx1112basic_stringIcSt11char_traitsIcESaIcEEElbE3$_2ED2Ev index_builder.cpp:_ZN5doris13ScopedCleanupIZNS_12IndexBuilder14modify_rowsetsEPKNS_6Merger10StatisticsEE3$_1ED2Ev Line | Count | Source | 46 | 1 | ~ScopedCleanup() { | 47 | 1 | if (!cancelled_) { | 48 | 1 | f_(); | 49 | 1 | } | 50 | 1 | } |
thread.cpp:_ZN5doris13ScopedCleanupIZNS_6Thread12start_threadERKNSt7__cxx1112basic_stringIcSt11char_traitsIcESaIcEEES9_RKSt8functionIFvvEEmP13scoped_refptrIS1_EE3$_0ED2Ev Line | Count | Source | 46 | 3.91k | ~ScopedCleanup() { | 47 | 3.91k | if (!cancelled_) { | 48 | 0 | f_(); | 49 | 0 | } | 50 | 3.91k | } |
threadpool.cpp:_ZN5doris13ScopedCleanupIZNS_10ThreadPool15dispatch_threadEvE3$_0ED2Ev Line | Count | Source | 46 | 134k | ~ScopedCleanup() { | 47 | 134k | if (!cancelled_) { | 48 | 134k | f_(); | 49 | 134k | } | 50 | 134k | } |
pad_rowset_action.cpp:_ZN5doris13ScopedCleanupIZNS_15PadRowsetAction11_pad_rowsetESt10shared_ptrINS_6TabletEERKNS_7VersionEE3$_0ED2Ev Line | Count | Source | 46 | 1 | ~ScopedCleanup() { | 47 | 1 | if (!cancelled_) { | 48 | 1 | f_(); | 49 | 1 | } | 50 | 1 | } |
|
51 | 3.91k | void cancel() { cancelled_ = true; }scoped_cleanup_test.cpp:_ZN5doris13ScopedCleanupIZNS_36ScopedCleanup_TestCancelCleanup_Test8TestBodyEvE3$_0E6cancelEv Line | Count | Source | 51 | 1 | void cancel() { cancelled_ = true; } |
thread.cpp:_ZN5doris13ScopedCleanupIZNS_6Thread12start_threadERKNSt7__cxx1112basic_stringIcSt11char_traitsIcESaIcEEES9_RKSt8functionIFvvEEmP13scoped_refptrIS1_EE3$_0E6cancelEv Line | Count | Source | 51 | 3.91k | void cancel() { cancelled_ = true; } |
|
52 | | |
53 | | private: |
54 | | bool cancelled_; |
55 | | F f_; |
56 | | }; |
57 | | |
58 | | // Creates a new scoped cleanup instance with the provided function. |
59 | | template <typename F> |
60 | 150k | ScopedCleanup<F> MakeScopedCleanup(F f) { |
61 | 150k | return ScopedCleanup<F>(f); |
62 | 150k | } scoped_cleanup_test.cpp:_ZN5doris17MakeScopedCleanupIZNS_30ScopedCleanup_TestCleanup_Test8TestBodyEvE3$_0EENS_13ScopedCleanupIT_EES4_ Line | Count | Source | 60 | 1 | ScopedCleanup<F> MakeScopedCleanup(F f) { | 61 | 1 | return ScopedCleanup<F>(f); | 62 | 1 | } |
scoped_cleanup_test.cpp:_ZN5doris17MakeScopedCleanupIZNS_35ScopedCleanup_TestCleanupMacro_Test8TestBodyEvE3$_0EENS_13ScopedCleanupIT_EES4_ Line | Count | Source | 60 | 1 | ScopedCleanup<F> MakeScopedCleanup(F f) { | 61 | 1 | return ScopedCleanup<F>(f); | 62 | 1 | } |
scoped_cleanup_test.cpp:_ZN5doris17MakeScopedCleanupIZNS_36ScopedCleanup_TestCancelCleanup_Test8TestBodyEvE3$_0EENS_13ScopedCleanupIT_EES4_ Line | Count | Source | 60 | 1 | ScopedCleanup<F> MakeScopedCleanup(F f) { | 61 | 1 | return ScopedCleanup<F>(f); | 62 | 1 | } |
threadpool_test.cpp:_ZN5doris17MakeScopedCleanupIZNS_47ThreadPoolTest_TestThreadPoolWithNoMinimum_Test8TestBodyEvE3$_0EENS_13ScopedCleanupIT_EES4_ Line | Count | Source | 60 | 1 | ScopedCleanup<F> MakeScopedCleanup(F f) { | 61 | 1 | return ScopedCleanup<F>(f); | 62 | 1 | } |
threadpool_test.cpp:_ZN5doris17MakeScopedCleanupIZNS_50ThreadPoolTest_TestThreadPoolWithNoMaxThreads_Test8TestBodyEvE3$_0EENS_13ScopedCleanupIT_EES4_ Line | Count | Source | 60 | 1 | ScopedCleanup<F> MakeScopedCleanup(F f) { | 61 | 1 | return ScopedCleanup<F>(f); | 62 | 1 | } |
threadpool_test.cpp:_ZN5doris17MakeScopedCleanupIZNS_28ThreadPoolTest_TestRace_Test8TestBodyEvE3$_0EENS_13ScopedCleanupIT_EES4_ Line | Count | Source | 60 | 1 | ScopedCleanup<F> MakeScopedCleanup(F f) { | 61 | 1 | return ScopedCleanup<F>(f); | 62 | 1 | } |
threadpool_test.cpp:_ZN5doris17MakeScopedCleanupIZNS_67ThreadPoolTestTokenTypes_TestTokenSubmitsProcessedConcurrently_Test8TestBodyEvE3$_0EENS_13ScopedCleanupIT_EES4_ Line | Count | Source | 60 | 2 | ScopedCleanup<F> MakeScopedCleanup(F f) { | 61 | 2 | return ScopedCleanup<F>(f); | 62 | 2 | } |
threadpool_test.cpp:_ZN5doris17MakeScopedCleanupIZNS_49ThreadPoolTest_TestTokenSubmitsNonSequential_Test8TestBodyEvE3$_0EENS_13ScopedCleanupIT_EES4_ Line | Count | Source | 60 | 1 | ScopedCleanup<F> MakeScopedCleanup(F f) { | 61 | 1 | return ScopedCleanup<F>(f); | 62 | 1 | } |
threadpool_test.cpp:_ZN5doris17MakeScopedCleanupIZNS_47ThreadPoolTestTokenTypes_TestTokenShutdown_Test8TestBodyEvE3$_0EENS_13ScopedCleanupIT_EES4_ Line | Count | Source | 60 | 2 | ScopedCleanup<F> MakeScopedCleanup(F f) { | 61 | 2 | return ScopedCleanup<F>(f); | 62 | 2 | } |
threadpool_test.cpp:_ZN5doris17MakeScopedCleanupIZNS_70ThreadPoolTestTokenTypes_TestTokenSubmissionsAdhereToMaxQueueSize_Test8TestBodyEvE3$_0EENS_13ScopedCleanupIT_EES4_ Line | Count | Source | 60 | 2 | ScopedCleanup<F> MakeScopedCleanup(F f) { | 61 | 2 | return ScopedCleanup<F>(f); | 62 | 2 | } |
Unexecuted instantiation: task_worker_pool.cpp:_ZN5doris17MakeScopedCleanupIZNS_22create_tablet_callbackERNS_13StorageEngineERKNS_17TAgentTaskRequestEE3$_0EENS_13ScopedCleanupIT_EES8_ Unexecuted instantiation: compaction.cpp:_ZN5doris17MakeScopedCleanupIZNS_10Compaction14modify_rowsetsEPKNS_6Merger10StatisticsEE3$_1EENS_13ScopedCleanupIT_EES8_ Unexecuted instantiation: compaction.cpp:_ZN5doris17MakeScopedCleanupIZNS_10Compaction14modify_rowsetsEPKNS_6Merger10StatisticsEE3$_2EENS_13ScopedCleanupIT_EES8_ Unexecuted instantiation: cold_data_compaction.cpp:_ZN5doris17MakeScopedCleanupIZNS_18ColdDataCompaction14modify_rowsetsEPKNS_6Merger10StatisticsEE3$_0EENS_13ScopedCleanupIT_EES8_ tablet.cpp:_ZN5doris17MakeScopedCleanupIZNS_6Tablet10add_rowsetESt10shared_ptrINS_6RowsetEEE3$_0EENS_13ScopedCleanupIT_EES7_ Line | Count | Source | 60 | 327 | ScopedCleanup<F> MakeScopedCleanup(F f) { | 61 | 327 | return ScopedCleanup<F>(f); | 62 | 327 | } |
tablet.cpp:_ZN5doris17MakeScopedCleanupIZNS_6Tablet14add_inc_rowsetERKSt10shared_ptrINS_6RowsetEEE3$_0EENS_13ScopedCleanupIT_EES9_ Line | Count | Source | 60 | 10.3k | ScopedCleanup<F> MakeScopedCleanup(F f) { | 61 | 10.3k | return ScopedCleanup<F>(f); | 62 | 10.3k | } |
tablet.cpp:_ZN5doris17MakeScopedCleanupIZNS_6Tablet27delete_expired_stale_rowsetEvE3$_0EENS_13ScopedCleanupIT_EES4_ Line | Count | Source | 60 | 1 | ScopedCleanup<F> MakeScopedCleanup(F f) { | 61 | 1 | return ScopedCleanup<F>(f); | 62 | 1 | } |
tablet.cpp:_ZN5doris17MakeScopedCleanupIZNS_6Tablet26calculate_cumulative_pointEvE3$_0EENS_13ScopedCleanupIT_EES4_ Line | Count | Source | 60 | 38 | ScopedCleanup<F> MakeScopedCleanup(F f) { | 61 | 38 | return ScopedCleanup<F>(f); | 62 | 38 | } |
tablet.cpp:_ZN5doris17MakeScopedCleanupIZNS_6Tablet14_cooldown_dataESt10shared_ptrINS_6RowsetEEE3$_1EENS_13ScopedCleanupIT_EES7_ Line | Count | Source | 60 | 5 | ScopedCleanup<F> MakeScopedCleanup(F f) { | 61 | 5 | return ScopedCleanup<F>(f); | 62 | 5 | } |
tablet.cpp:_ZN5doris17MakeScopedCleanupIZNS_6Tablet14_cooldown_dataESt10shared_ptrINS_6RowsetEEE3$_2EENS_13ScopedCleanupIT_EES7_ Line | Count | Source | 60 | 5 | ScopedCleanup<F> MakeScopedCleanup(F f) { | 61 | 5 | return ScopedCleanup<F>(f); | 62 | 5 | } |
Unexecuted instantiation: tablet.cpp:_ZN5doris17MakeScopedCleanupIZNS_6Tablet23_follow_cooldowned_dataEvE3$_0EENS_13ScopedCleanupIT_EES4_ Unexecuted instantiation: tablet.cpp:_ZN5doris17MakeScopedCleanupIZNS_6Tablet23_follow_cooldowned_dataEvE3$_1EENS_13ScopedCleanupIT_EES4_ Unexecuted instantiation: tablet.cpp:_ZN5doris17MakeScopedCleanupIZNS_6Tablet25update_max_version_schemaERKSt10shared_ptrINS_12TabletSchemaEEE3$_0EENS_13ScopedCleanupIT_EES9_ tablet.cpp:_ZN5doris17MakeScopedCleanupIZNS_6Tablet11clear_cacheEvE3$_1EENS_13ScopedCleanupIT_EES4_ Line | Count | Source | 60 | 475 | ScopedCleanup<F> MakeScopedCleanup(F f) { | 61 | 475 | return ScopedCleanup<F>(f); | 62 | 475 | } |
Unexecuted instantiation: full_compaction.cpp:_ZN5doris17MakeScopedCleanupIZNS_14FullCompaction37_full_compaction_update_delete_bitmapERKSt10shared_ptrINS_6RowsetEEPNS_12RowsetWriterEE3$_0EENS_13ScopedCleanupIT_EESB_ tablet_manager.cpp:_ZN5doris17MakeScopedCleanupIZNS_13TabletManager21_drop_tablet_unlockedEllbbE3$_1EENS_13ScopedCleanupIT_EES4_ Line | Count | Source | 60 | 251 | ScopedCleanup<F> MakeScopedCleanup(F f) { | 61 | 251 | return ScopedCleanup<F>(f); | 62 | 251 | } |
Unexecuted instantiation: schema_change.cpp:_ZN5doris17MakeScopedCleanupIZZNS_19SchemaChangeHandler27_convert_historical_rowsetsERKNS1_18SchemaChangeParamsEPlENK3$_0clEvEUlvE_EENS_13ScopedCleanupIT_EES9_ Unexecuted instantiation: schema_change.cpp:_ZN5doris17MakeScopedCleanupIZNS_19SchemaChangeHandler27_do_process_alter_tablet_v2ERKNS_17TAlterTabletReqV2EE3$_2EENS_13ScopedCleanupIT_EES7_ Unexecuted instantiation: schema_change.cpp:_ZN5doris17MakeScopedCleanupIZNS_19SchemaChangeHandler27_do_process_alter_tablet_v2ERKNS_17TAlterTabletReqV2EE3$_3EENS_13ScopedCleanupIT_EES7_ Unexecuted instantiation: schema_change.cpp:_ZN5doris17MakeScopedCleanupIZNS_19SchemaChangeHandler33_calc_delete_bitmap_for_mow_tableESt10shared_ptrINS_6TabletEElE3$_0EENS_13ScopedCleanupIT_EES7_ Unexecuted instantiation: engine_clone_task.cpp:_ZN5doris17MakeScopedCleanupIZNS_15EngineCloneTask13_finish_cloneEPNS_6TabletERKNSt7__cxx1112basic_stringIcSt11char_traitsIcESaIcEEElbE3$_2EENS_13ScopedCleanupIT_EESE_ index_builder.cpp:_ZN5doris17MakeScopedCleanupIZNS_12IndexBuilder14modify_rowsetsEPKNS_6Merger10StatisticsEE3$_1EENS_13ScopedCleanupIT_EES8_ Line | Count | Source | 60 | 1 | ScopedCleanup<F> MakeScopedCleanup(F f) { | 61 | 1 | return ScopedCleanup<F>(f); | 62 | 1 | } |
thread.cpp:_ZN5doris17MakeScopedCleanupIZNS_6Thread12start_threadERKNSt7__cxx1112basic_stringIcSt11char_traitsIcESaIcEEES9_RKSt8functionIFvvEEmP13scoped_refptrIS1_EE3$_0EENS_13ScopedCleanupIT_EESK_ Line | Count | Source | 60 | 3.91k | ScopedCleanup<F> MakeScopedCleanup(F f) { | 61 | 3.91k | return ScopedCleanup<F>(f); | 62 | 3.91k | } |
threadpool.cpp:_ZN5doris17MakeScopedCleanupIZNS_10ThreadPool15dispatch_threadEvE3$_0EENS_13ScopedCleanupIT_EES4_ Line | Count | Source | 60 | 134k | ScopedCleanup<F> MakeScopedCleanup(F f) { | 61 | 134k | return ScopedCleanup<F>(f); | 62 | 134k | } |
pad_rowset_action.cpp:_ZN5doris17MakeScopedCleanupIZNS_15PadRowsetAction11_pad_rowsetESt10shared_ptrINS_6TabletEERKNS_7VersionEE3$_0EENS_13ScopedCleanupIT_EESA_ Line | Count | Source | 60 | 1 | ScopedCleanup<F> MakeScopedCleanup(F f) { | 61 | 1 | return ScopedCleanup<F>(f); | 62 | 1 | } |
|
63 | | |
64 | | } // namespace doris |