Lines Matching refs:buf

62     fn marshal_to(&self, mut buf: &mut [u8]) -> Result<usize> {  in marshal_to()
64 if buf.remaining_mut() < required_len { in marshal_to()
67 actual: buf.remaining_mut(), in marshal_to()
81 buf.put_u8(byte); in marshal_to()
88 fn unmarshal<B>(buf: &mut B) -> Result<Self> in unmarshal()
94 if buf.remaining() < required_len { in unmarshal()
97 actual: buf.remaining(), in unmarshal()
102 let b0 = buf.get_u8(); in unmarshal()
164 fn marshal_to(&self, mut buf: &mut [u8]) -> Result<usize> { in marshal_to()
166 if buf.remaining_mut() < required_len { in marshal_to()
169 actual: buf.remaining_mut(), in marshal_to()
174 let n = self.channel_type.marshal_to(buf)?; in marshal_to()
175 buf = &mut buf[n..]; in marshal_to()
176 buf.put_u16(self.priority); in marshal_to()
177 buf.put_u32(self.reliability_parameter); in marshal_to()
178 buf.put_u16(self.label.len() as u16); in marshal_to()
179 buf.put_u16(self.protocol.len() as u16); in marshal_to()
180 buf.put_slice(self.label.as_slice()); in marshal_to()
181 buf.put_slice(self.protocol.as_slice()); in marshal_to()
187 fn unmarshal<B>(buf: &mut B) -> Result<Self> in unmarshal()
192 if buf.remaining() < required_len { in unmarshal()
195 actual: buf.remaining(), in unmarshal()
200 let channel_type = ChannelType::unmarshal(buf)?; in unmarshal()
201 let priority = buf.get_u16(); in unmarshal()
202 let reliability_parameter = buf.get_u32(); in unmarshal()
203 let label_len = buf.get_u16() as usize; in unmarshal()
204 let protocol_len = buf.get_u16() as usize; in unmarshal()
207 if buf.remaining() < required_len { in unmarshal()
210 actual: buf.remaining(), in unmarshal()
218 buf.copy_to_slice(&mut label[..]); in unmarshal()
219 buf.copy_to_slice(&mut protocol[..]); in unmarshal()
296 let mut buf = BytesMut::with_capacity(1); in test_channel_type_marshal() localVariable
297 buf.resize(1, 0u8); in test_channel_type_marshal()
299 let bytes_written = channel_type.marshal_to(&mut buf)?; in test_channel_type_marshal()
302 let bytes = buf.freeze(); in test_channel_type_marshal()
431 let mut buf = BytesMut::with_capacity(11 + 5 + 8); in test_channel_open_marshal() localVariable
432 buf.resize(11 + 5 + 8, 0u8); in test_channel_open_marshal()
433 let bytes_written = channel_open.marshal_to(&mut buf).unwrap(); in test_channel_open_marshal()
434 let bytes = buf.freeze(); in test_channel_open_marshal()