Lines Matching refs:data
134 def parse(self, data, message_info): argument
135 address = struct.unpack(">H", data.read(2))[0]
176 def parse(self, data, message_info): argument
177 mode = ord(data.read(1))
205 def parse(self, data, message_info): argument
206 timeout = struct.unpack(">I", data.read(4))[0]
230 def parse(self, data, message_info): argument
231 challenge = data.read()
255 def parse(self, data, message_info): argument
256 response = data.read()
280 def parse(self, data, message_info): argument
281 frame_counter = struct.unpack(">I", data.read(4))[0]
305 def parse(self, data, message_info): argument
306 frame_counter = struct.unpack(">I", data.read(4))[0]
340 def parse(self, data, message_info): argument
341 lqrd = ord(data.read(1))
384 def parse(self, data, message_info): argument
385 id_sequence = ord(data.read(1))
386 router_id_mask = struct.unpack(">Q", data.read(8))[0]
390 while data.tell() < len(data.getvalue()):
391 link_quality_and_route_data.append(self._lqrd_factory.parse(data, message_info))
416 def parse(self, data, message_info): argument
417 address = struct.unpack(">H", data.read(2))[0]
476 def parse(self, data, message_info): argument
477 partition_id = struct.unpack(">I", data.read(4))[0]
478 weighting = ord(data.read(1))
479 data_version = ord(data.read(1))
480 stable_data_version = ord(data.read(1))
481 leader_router_id = ord(data.read(1))
515 def parse(self, data, message_info): argument
516 tlvs = self._tlvs_factory.parse(data, message_info)
541 def parse(self, data, message_info): argument
542 tlvs = [b for b in bytearray(data.read())]
571 def parse(self, data, message_info): argument
572 scan_mask = ord(data.read(1))
675 def parse(self, data, message_info): argument
676 pp_byte = ord(data.read(1))
677 link_quality_3 = ord(data.read(1))
678 link_quality_2 = ord(data.read(1))
679 link_quality_1 = ord(data.read(1))
680 leader_cost = ord(data.read(1))
681 id_sequence = ord(data.read(1))
682 active_routers = ord(data.read(1))
684 sed_data = io.BytesIO(data.read(3))
726 def parse(self, data, message_info): argument
727 link_margin = ord(data.read(1))
751 def parse(self, data, message_info): argument
752 status = ord(data.read(1))
776 def parse(self, data, message_info): argument
777 version = struct.unpack(">H", data.read(2))[0]
801 def parse(self, data, message_info): argument
802 data.read(1) # first byte is ignored
803 ipv6_address = data.read(16)
832 def parse(self, data, message_info): argument
833 cid = ord(data.read(1)) & 0x0F
834 iid = bytearray(data.read(8))
863 def parse(self, data, message_info): argument
866 while data.tell() < len(data.getvalue()):
867 compressed = (ord(data.read(1)) >> 7) & 0x01
868 data.seek(-1, io.SEEK_CUR)
871 addresses.append(self._addr_compressed_factory.parse(data, message_info))
873 addresses.append(self._addr_full_factory.parse(data, message_info))
903 def parse(self, data, message_info): argument
904 channel_page = ord(data.read(1))
905 channel = struct.unpack(">H", data.read(2))[0]
929 def parse(self, data, message_info): argument
930 pan_id = struct.unpack(">H", data.read(2))[0]
966 def parse(self, data, message_info): argument
967 seconds = bytearray([0x00, 0x00]) + bytearray(data.read(6))
968 ticks = struct.unpack(">H", data.read(2))[0]
1008 def parse(self, data, message_info): argument
1009 seconds = bytearray([0x00, 0x00]) + bytearray(data.read(6))
1010 ticks = struct.unpack(">H", data.read(2))[0]
1027 def parse(self, data, message_info): argument
1040 def parse(self, data, message_info): argument
1065 def parse(self, data, message_info): argument
1066 tlvs = self._tlvs_factory.parse(data, message_info)
1080 def parse(self, data, message_info): argument
1093 def parse(self, data, message_info): argument
1106 def parse(self, data, message_info): argument
1119 def parse(self, data, message_info): argument
1132 def parse(self, data, message_info): argument
1145 def parse(self, data, message_info): argument
1158 def parse(self, data, message_info): argument
1171 def parse(self, data, message_info): argument
1184 def parse(self, data, message_info): argument
1214 def _get_length(self, data): argument
1215 length = ord(data.read(1))
1218 length = struct.unpack(">H", data.read(2))[0]
1229 def _parse_tlv(self, data, message_info): argument
1230 _type = TlvType(ord(data.read(1)))
1231 length = self._get_length(data)
1232 value = data.read(length)
1238 def parse(self, data, message_info): argument
1239 cmd_type = CommandType(ord(data.read(1)))
1242 while data.tell() < len(data.getvalue()):
1243 tlv = self._parse_tlv(data, message_info)
1289 def _create_mle_secured_message(self, data, message_info): argument
1290 aux_sec_hdr = self._aux_sec_hdr_factory.parse(data, message_info)
1292 enc_data_length = len(data.getvalue())
1294 … enc_data = bytearray(data.read(enc_data_length - data.tell() - self._crypto_engine.mic_length))
1295 mic = bytearray(data.read())
1303 def _create_mle_message(self, data, message_info): argument
1304 command = self._mle_command_factory.parse(data, message_info)
1308 def parse(self, data, message_info): argument
1309 security_indicator = ord(data.read(1))
1312 return self._create_mle_secured_message(data, message_info)
1315 return self._create_mle_message(data, message_info)