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
93
94
95
96
97
98
99
100
101
102
103
use thiserror::Error;
/// Error types returned by this crate.
#[non_exhaustive]
#[derive(Debug, Error, PartialEq)]
pub enum Error {
/// The message header indicates the RPC message is longer than the amount
/// of data in the buffer, or the buffer contains more than one message.
///
/// This error may also be returned if the RPC message parsed from the
/// buffer is unexpectedly shorter than the header length indicates - in
/// this case, `buffer_len` will be more than `expected` and may indicate a
/// parsing error.
#[error("incomplete rpc message (got {buffer_len} bytes, expected {expected})")]
IncompleteMessage {
/// The length of the buffer provided.
buffer_len: usize,
/// The length expected for this message type.
expected: usize,
},
/// The buffer is too small to contain the RPC header.
#[error("incomplete fragment header")]
IncompleteHeader,
/// The RPC message is fragmented and needs to be reassembled.
///
/// This library doesn't currently support fragmented messages and this
/// error will be returned when parsing any message with the "last fragment"
/// bit unset in the header.
#[error("RPC message is fragmented")]
Fragmented,
/// The message type in the RPC request is neither [`MessageType::Call`]
/// or [`MessageType::Reply`].
///
/// This is a violation of the spec.
///
/// [`MessageType::Call`]: crate::MessageType::Call
/// [`MessageType::Reply`]: crate::MessageType::Reply
#[error("invalid rpc message type {0}")]
InvalidMessageType(u32),
/// The message type in the RPC request is neither [`ReplyBody::Accepted`]
/// or [`ReplyBody::Denied`].
///
/// This is a violation of the spec.
///
/// [`ReplyBody::Accepted`]: crate::ReplyBody::Accepted
/// [`ReplyBody::Denied`]: crate::ReplyBody::Denied
#[error("invalid rpc reply type {0}")]
InvalidReplyType(u32),
/// The reply status code is not one of the specified [status
/// codes](crate::AcceptedStatus).
///
/// This is a violation of the spec.
#[error("invalid rpc reply status {0}")]
InvalidReplyStatus(u32),
/// The auth or verifier is invalid or malformed.
#[error("invalid rpc auth data")]
InvalidAuthData,
/// The auth error code is not one of the specified [error
/// codes](crate::AuthError).
///
/// This is a violation of the spec.
#[error("invalid rpc auth error status {0}")]
InvalidAuthError(u32),
/// The rejected reply status code is not one of the specified [status
/// codes](crate::RejectedReply).
///
/// This is a violation of the spec.
#[error("invalid rpc rejected reply type {0}")]
InvalidRejectedReplyType(u32),
/// A variable length type has a malformed length value which would exceed
/// the length of the buffer.
#[error("invalid length in rpc message")]
InvalidLength,
/// The message contains a rpc protocol identifier that is not 2.
#[error("invalid rpc version {0}")]
InvalidRpcVersion(u32),
/// The [machine name](crate::auth::AuthUnixParams::machine_name) contains
/// non-UTF8 characters.
#[error("invalid machine name: {0}")]
InvalidMachineName(#[from] std::str::Utf8Error),
/// An I/O error occurred when trying to parse the buffer.
#[error("i/o error ({0:?}): {1}")]
IOError(std::io::ErrorKind, String),
}
impl From<std::io::Error> for Error {
fn from(v: std::io::Error) -> Self {
Self::IOError(v.kind(), v.to_string())
}
}