Lines Matching refs:data

108     def from_bytes(cls, data):  argument
109 content_type = ContentType(struct.unpack(">B", data.read(1))[0])
110 version = ProtocolVersion.from_bytes(data)
111 epoch = struct.unpack(">H", data.read(2))[0]
112 sequence_number = struct.unpack(">Q", b'\x00\x00' + data.read(6))[0]
113 length = struct.unpack(">H", data.read(2))[0]
114 fragment = bytes(data.read(length))
136 def from_bytes(cls, data): argument
165 def from_bytes(cls, data): argument
166 handshake_type = HandshakeType(struct.unpack(">B", data.read(1))[0])
167 length = struct.unpack(">I", b'\x00' + data.read(3))[0]
168 message_seq = struct.unpack(">H", data.read(2))[0]
169 fragment_offset = struct.unpack(">I", b'\x00' + bytes(data.read(3)))[0]
170 fragment_length = struct.unpack(">I", b'\x00' + bytes(data.read(3)))[0]
171 end_position = data.tell() + fragment_length
176 body = message_class.from_bytes(data)
179 body = bytes(data.read(fragment_length))
180 assert data.tell() == end_position
208 def from_bytes(cls, data): argument
209 major, minor = struct.unpack(">BB", data.read(2))
233 def from_bytes(cls, data): argument
234 gmt_unix_time = struct.unpack(">I", data.read(4))[0]
235 random_bytes = bytes(data.read(cls.random_bytes_length))
255 data = reduce(lambda ele, acc: acc + ele.to_bytes(), self.elements)
256 return VariableVector._encode_length(len(data), self.subrange) + data
259 def from_bytes(cls, ele_cls, subrange, data): argument
260 length = cls._decode_length(subrange, data)
261 end_position = data.tell() + length
263 while data.tell() < end_position:
264 elements.append(ele_cls.from_bytes(data))
268 def _decode_length(cls, subrange, data): argument
272 bytearray(data.read(length_in_byte)),
302 def from_bytes(cls, data): argument
303 return cls(struct.unpack(">B", data.read(1))[0])
318 def from_bytes(cls, data): argument
319 return cls(struct.unpack(">BB", data.read(2)))
339 def from_bytes(cls, data): argument
340 method = struct.unpack(">B", data.read(1))[0]
359 def from_bytes(cls, data): argument
360 extension_type = struct.unpack(">H", data.read(2))[0]
361 extension_data = VariableVector.from_bytes(Opaque, (0, 2**16 - 1), data)
391 def from_bytes(cls, data): argument
392 client_version = ProtocolVersion.from_bytes(data)
393 random = Random.from_bytes(data)
394 session_id = VariableVector.from_bytes(Opaque, (0, 32), data)
395 cookie = VariableVector.from_bytes(Opaque, (0, 2**8 - 1), data)
396 cipher_suites = VariableVector.from_bytes(CipherSuite, (2, 2**16 - 1), data)
397 compression_methods = VariableVector.from_bytes(CompressionMethod, (1, 2**8 - 1), data)
399 if data.tell() < len(data.getvalue()):
400 extensions = VariableVector.from_bytes(Extension, (0, 2**16 - 1), data)
422 def from_bytes(cls, data): argument
423 server_version = ProtocolVersion.from_bytes(data)
424 cookie = VariableVector.from_bytes(Opaque, (0, 2**8 - 1), data)
451 def from_bytes(cls, data): argument
452 server_version = ProtocolVersion.from_bytes(data)
453 random = Random.from_bytes(data)
454 session_id = VariableVector.from_bytes(Opaque, (0, 32), data)
455 cipher_suite = CipherSuite.from_bytes(data)
456 compression_method = CompressionMethod.from_bytes(data)
458 if data.tell() < len(data.getvalue()):
459 extensions = VariableVector.from_bytes(Extension, (0, 2**16 - 1), data)
479 def from_bytes(cls, data): argument
536 def from_bytes(cls, data): argument
537 level, description = struct.unpack(">BB", data.read(2))
541 data.read()
558 def from_bytes(cls, data): argument
559 assert struct.unpack(">B", data.read(1))[0] == 1
577 def from_bytes(cls, data): argument
580 length = len(data.getvalue()) - data.tell()
581 return cls(bytes(data.read(length)))
619 def parse(self, data, message_info): argument
623 while data.tell() < len(data.getvalue()):
624 record = Record.from_bytes(data)