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
92
#![allow(non_snake_case, non_camel_case_types)]
#![doc(html_root_url = "http://docs.rs/qapi-qmp/0.7.0")]
#![allow(deprecated)]
use std::io;
use std::string::String as StdString;
use std::convert::TryFrom;
use serde::{Deserialize, Serialize};
include!(concat!(env!("OUT_DIR"), "/qmp.rs"));
pub type QmpMessageAny = QmpMessage<qapi_spec::Any>;
pub trait QmpCommand: qapi_spec::Command { }
impl<'a, T: QmpCommand> QmpCommand for &'a T { }
impl<'a, T: QmpCommand> QmpCommand for &'a mut T { }
#[derive(Debug, Clone, Serialize, Deserialize)]
#[serde(untagged)]
pub enum QmpMessage<C> {
Event(Event),
Response(qapi_spec::Response<C>),
}
impl<C> TryFrom<QmpMessage<C>> for qapi_spec::Response<C> {
type Error = io::Error;
fn try_from(m: QmpMessage<C>) -> Result<Self, Self::Error> {
match m {
QmpMessage::Response(res) => Ok(res),
QmpMessage::Event(..) =>
Err(io::Error::new(io::ErrorKind::InvalidData, "QMP event where a response was expected")),
}
}
}
#[derive(Debug, Clone, Serialize, Deserialize)]
pub struct QMP {
pub version: VersionInfo,
pub capabilities: Vec<QmpCapability>,
}
#[derive(Debug, Clone, Serialize, Deserialize)]
#[serde(untagged)]
pub enum QmpCapability {
#[serde(rename = "oob")]
OutOfBand,
Unknown(qapi_spec::Any),
}
#[derive(Debug, Clone, Serialize, Deserialize)]
pub struct QapiCapabilities {
pub QMP: QMP,
}
impl QapiCapabilities {
pub fn supports_oob(&self) -> bool {
self.QMP.capabilities.iter().any(|c| match c {
QmpCapability::OutOfBand => true,
_ => false,
})
}
pub fn capabilities<'a>(&'a self) -> impl Iterator<Item=QMPCapability> + 'a {
self.QMP.capabilities.iter().filter_map(|c| match c {
QmpCapability::OutOfBand => Some(QMPCapability::oob),
QmpCapability::Unknown(..) => None,
})
}
}
impl device_add {
pub fn new<D: Into<StdString>, I: Into<Option<StdString>>, B: Into<Option<StdString>>, P: IntoIterator<Item=(StdString, qapi_spec::Any)>>(driver: D, id: I, bus: B, props: P) -> Self {
device_add {
driver: driver.into(),
id: id.into(),
bus: bus.into(),
arguments: props.into_iter().collect(),
}
}
}
impl object_add {
pub fn new<T: Into<StdString>, I: Into<StdString>, P: IntoIterator<Item=(StdString, qapi_spec::Any)>>(qom_type: T, id: I, props: P) -> Self {
object_add {
qom_type: qom_type.into(),
id: id.into(),
props: Default::default(),
arguments: props.into_iter().collect(),
}
}
}