risingwave_rt/
deadlock.rs

1// Copyright 2025 RisingWave Labs
2//
3// Licensed under the Apache License, Version 2.0 (the "License");
4// you may not use this file except in compliance with the License.
5// You may obtain a copy of the License at
6//
7//     http://www.apache.org/licenses/LICENSE-2.0
8//
9// Unless required by applicable law or agreed to in writing, software
10// distributed under the License is distributed on an "AS IS" BASIS,
11// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
12// See the License for the specific language governing permissions and
13// limitations under the License.
14
15use std::time::Duration;
16
17/// Enable parking lot's deadlock detection.
18pub fn enable_parking_lot_deadlock_detection() {
19    tracing::info!("parking lot deadlock detection enabled");
20    // TODO: deadlock detection as a feature instead of always enabling
21    std::thread::spawn(move || {
22        loop {
23            std::thread::sleep(Duration::from_secs(3));
24            let deadlocks = parking_lot::deadlock::check_deadlock();
25            if deadlocks.is_empty() {
26                continue;
27            }
28
29            println!("{} deadlocks detected", deadlocks.len());
30            for (i, threads) in deadlocks.iter().enumerate() {
31                println!("Deadlock #{}", i);
32                for t in threads {
33                    println!("Thread Id {:#?}", t.thread_id());
34                    println!("{:#?}", t.backtrace());
35                }
36            }
37        }
38    });
39}
risingwave_rt/deadlock.rs

risingwave_rt/
deadlock.rs
