nvme-mi-dev 0.1.0

A device-side implementation of NVMe-MI
Documentation 
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
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91

// SPDX-License-Identifier: GPL-3.0-only
/*
 * Copyright (c) 2025 Code Construct
 */
use mctp::MsgIC;
mod common;

use common::DeviceType;

use crate::common::NeverRespChannel;
use crate::common::new_device;
use crate::common::setup;

#[test]
fn invalid_ic_bit() {
    common::setup();

    let (mut mep, mut subsys) = new_device(DeviceType::P1p1tC1iN0a0a);
    let resp = NeverRespChannel::new("Response sent for request with bad IC bit");

    smol::block_on(async {
        mep.handle_async(&mut subsys, &[], MsgIC(false), resp, async |_| Ok(()))
            .await
    });
}

#[test]
fn invalid_ic_object() {
    setup();

    let (mut mep, mut subsys) = new_device(DeviceType::P1p1tC1iN0a0a);
    let resp = NeverRespChannel::new("Response sent for request with invalid IC object");

    const REQ: [u8; 3] = [0x00, 0x00, 0x00];
    smol::block_on(async {
        mep.handle_async(&mut subsys, &REQ, MsgIC(true), resp, async |_| Ok(()))
            .await
    });
}

#[test]
fn invalid_ic_value() {
    setup();

    let (mut mep, mut subsys) = new_device(DeviceType::P1p1tC1iN0a0a);
    let resp = NeverRespChannel::new("Response sent for request with invalid IC value");

    const REQ: [u8; 4] = [!0x36, !0xff, !0x11, !0x17];
    smol::block_on(async {
        mep.handle_async(&mut subsys, &REQ, MsgIC(true), resp, async |_| Ok(()))
            .await
    });
}

#[test]
fn invalid_message_header_object() {
    setup();

    let (mut mep, mut subsys) = new_device(DeviceType::P1p1tC1iN0a0a);
    let resp =
        NeverRespChannel::new("Response sent for request with invalid message header object");

    #[rustfmt::skip]
    const REQ: [u8; 6] = [
        0x00, 0x00,
        0x23, 0x70, 0x9d, 0x75
    ];
    smol::block_on(async {
        mep.handle_async(&mut subsys, &REQ, MsgIC(true), resp, async |_| Ok(()))
            .await
    });
}

#[test]
fn invalid_message_header_ror() {
    setup();

    let (mut mep, mut subsys) = new_device(DeviceType::P1p1tC1iN0a0a);
    let resp =
        NeverRespChannel::new("Response sent for request with invalid message header ROR value");

    #[rustfmt::skip]
    const REQ: [u8; 7] = [
        0x80, 0x00, 0x00,
        0x48, 0xc4, 0xc2, 0xea
    ];
    smol::block_on(async {
        mep.handle_async(&mut subsys, &REQ, MsgIC(true), resp, async |_| Ok(()))
            .await
    });
}