Lines Matching refs:raw
62 pub raw: Vec<u8>, field
116 raw: { in new()
117 let mut raw = Vec::with_capacity(DEFAULT_RAW_CAPACITY); in new() localVariable
118 raw.extend_from_slice(&[0; MESSAGE_HEADER_SIZE]); in new()
119 raw in new()
129 Ok(self.raw.clone()) in marshal_binary()
135 self.raw.clear(); in unmarshal_binary()
136 self.raw.extend_from_slice(data); in unmarshal_binary()
150 self.raw.clear(); in reset()
157 if self.raw.len() >= n { in grow()
159 self.raw.resize(n, 0); in grow()
163 self.raw.extend_from_slice(&vec![0; n - self.raw.len()]); in grow()
187 let buf = &mut self.raw[first..last]; in add()
209 let buf = &mut self.raw[last - bytes_to_add..last]; in add()
222 self.raw[2..4].copy_from_slice(&(self.length as u16).to_be_bytes()); in write_length()
231 self.raw[4..8].copy_from_slice(&MAGIC_COOKIE.to_be_bytes()); // magic cookie in write_header()
232 self.raw[8..MESSAGE_HEADER_SIZE].copy_from_slice(&self.transaction_id.0); in write_header()
238 self.raw[8..MESSAGE_HEADER_SIZE].copy_from_slice(&self.transaction_id.0); in write_transaction_id()
254 self.raw[..2].copy_from_slice(&self.typ.value().to_be_bytes()); // message type in write_type()
265 self.raw.clear(); in encode()
274 let buf = &self.raw; in decode()
350 let n = writer.write(&self.raw)?; in write_to()
362 self.raw = t_buf[..n].to_vec(); in read_from()
371 self.raw.clear(); in write()
372 self.raw.extend_from_slice(t_buf); in write()
379 b.raw.clear(); in clone_to()
380 b.raw.extend_from_slice(&self.raw); in clone_to()