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
pub mod message_reply;
use crate::*;
use crate::{identity::IdentityObject, socket::SocketAddr};
use bytes::Buf;
use core::{slice, str};
use rseip_core::codec::{Decode, Decoder};
use std::borrow::Cow;
impl<'de> Decode<'de> for IdentityObject<'de> {
fn decode<D>(mut decoder: D) -> Result<Self, D::Error>
where
D: rseip_core::codec::Decoder<'de>,
{
decoder.ensure_size(33)?;
let identity = IdentityObject {
protocol_version: decoder.decode_u16(),
socket_addr: {
let addr = decoder.buf_mut().copy_to_bytes(16);
SocketAddr::from_bytes::<D::Error>(addr)?
},
vendor_id: decoder.decode_u16(),
device_type: decoder.decode_u16(),
product_code: decoder.decode_u16(),
revision: Revision {
major: decoder.decode_u8(),
minor: decoder.decode_u8(),
},
status: decoder.decode_u16(),
serial_number: decoder.decode_u32(),
product_name: {
let name_len = decoder.decode_u8();
decoder.ensure_size(name_len as usize + 1)?;
let data = decoder.buf_mut().copy_to_bytes(name_len as usize);
unsafe {
let buf = data.as_ptr();
let buf = slice::from_raw_parts(buf, name_len as usize);
let name = str::from_utf8_unchecked(buf);
Cow::from(name)
}
},
state: decoder.decode_u8(),
};
Ok(identity)
}
}
impl<'de> Decode<'de> for ListServiceItem<'de> {
fn decode<D>(mut decoder: D) -> Result<Self, D::Error>
where
D: Decoder<'de>,
{
debug_assert!(decoder.remaining() > 4);
let item = ListServiceItem {
protocol_version: decoder.decode_u16(),
capability: decoder.decode_u16(),
name: {
const STR_LEN: usize = 16;
decoder.ensure_size(STR_LEN)?;
let data = decoder.buf_mut().copy_to_bytes(STR_LEN);
unsafe {
let buf = data.as_ptr();
let buf = slice::from_raw_parts(buf, STR_LEN);
let name = str::from_utf8_unchecked(buf);
Cow::from(name)
}
},
};
Ok(item)
}
}
