1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48

// Copyright 2023 The Fuchsia Authors. All rights reserved.
// Use of this source code is governed by a BSD-style license that can be
// found in the LICENSE file.

use crate::log_debug;
use fuchsia_inspect::Node;
use fuchsia_inspect_contrib::nodes::BoundedListNode;
use fuchsia_zircon as zx;
use starnix_sync::Mutex;

/// The maximum number of failed tasks to record.
///
/// This number is arbitrary and we may want to make it configurable in the future.
const MAX_NUM_COREDUMPS: usize = 64;

/// The maximum length of an argv string to record.
///
/// This number is arbitrary and we may wand to make it configurable in the future.
pub const MAX_ARGV_LENGTH: usize = 128;

/// A list of recently coredumped tasks in Inspect.
pub struct CoreDumpList {
    list: Mutex<BoundedListNode>,
}

pub struct CoreDumpInfo {
    pub process_koid: zx::Koid,
    pub thread_koid: zx::Koid,
    pub pid: i64,
    pub argv: String,
}

impl CoreDumpList {
    pub fn new(node: Node) -> Self {
        Self { list: Mutex::new(BoundedListNode::new(node, MAX_NUM_COREDUMPS)) }
    }

    pub fn record_core_dump(&self, core_dump_info: CoreDumpInfo) {
        let mut list = self.list.lock();
        list.add_entry(|crash_node| {
            log_debug!(core_dump_info.pid, %core_dump_info.argv, "Recording task with a coredump.");
            crash_node.record_uint("thread_koid", core_dump_info.thread_koid.raw_koid());
            crash_node.record_uint("process_koid", core_dump_info.process_koid.raw_koid());
            crash_node.record_int("pid", core_dump_info.pid);
            crash_node.record_string("argv", core_dump_info.argv);
        });
    }
}