Searched refs:header_bytes (Results 1 – 4 of 4) sorted by relevance
41 header_bytes = await self.reader.read(2)42 packet_length = int.from_bytes(header_bytes, byteorder='little')51 header_bytes = int.to_bytes(len(packet_bytes), length=2, byteorder='little')52 self.writer.write(header_bytes + packet_bytes)
144 let mut header_bytes = [packet[0], packet[1], 0]; in write() localVariable156 header_bytes[0] &= !PBF_MASK; in write()157 header_bytes[0] |= (pbf as u8) << 4; in write()158 header_bytes[2] = chunk_length as u8; in write()161 self.socket.write_all(&header_bytes).await?; in write()
63 let mut header_bytes = [0; HEADER_SIZE]; in read() localVariable66 self.socket.read_exact(&mut header_bytes[0..HEADER_SIZE]).await?; in read()67 let packet_length = u16::from_le_bytes(header_bytes) as usize; in read()87 let header_bytes = packet_length.to_le_bytes(); in write() localVariable90 self.socket.write_all(&header_bytes).await?; in write()
64 let mut header_bytes = [0; HEADER_SIZE]; in read() localVariable67 self.socket.read_exact(&mut header_bytes[0..HEADER_SIZE]).await?; in read()68 let packet_length = u16::from_le_bytes(header_bytes) as usize; in read()88 let header_bytes = packet_length.to_le_bytes(); in write() localVariable91 self.socket.write_all(&header_bytes).await?; in write()