• Home
  • Raw
  • Download

Lines Matching refs:message_info

218     def parse(self, data, next_header, message_info):  argument
223 options = self._hop_by_hop_options_factory.parse(io.BytesIO(ext_header_data), message_info)
227 message_info.payload_length += len(ext_header)
255 def parse(self, data, message_info): argument
262 return factory.parse(data, next_header, message_info)
305 def parse(self, data, message_info): argument
748 def parse(self, data, message_info): argument
759 src_address = self._decompress_src_addr(iphc, message_info.source_mac_address, sci, data)
761 … dst_address = self._decompress_dst_addr(iphc, message_info.destination_mac_address, dci, data)
800 def decompress(self, data, message_info): argument
801 ipv6_header = self._lowpan_ip_header_factory.parse(data, message_info)
814 … extension_header = self._lowpan_extension_headers_factory.parse(data, message_info)
826 udp_header = self._lowpan_udp_header_factory.parse(data, message_info)
866 def parse(self, data, message_info): argument
964 def _create_key(self, message_info, datagram_tag): argument
965 key = (bytes(message_info.source_mac_address.mac_address) +
966 bytes(message_info.destination_mac_address.mac_address) + bytes(datagram_tag))
978 def get_fragments_buffer(self, message_info, datagram_tag, datagram_size=None): argument
979 key = self._create_key(message_info, datagram_tag)
986 def free_fragments_buffer(self, message_info, datagram_tag): argument
987 key = self._create_key(message_info, datagram_tag)
1023 def _decompress_iphc(self, data, message_info): argument
1024 return self._lowpan_decompressor.decompress(data, message_info)
1026 def _handle_first_fragmentation_header(self, data, message_info): argument
1030 message_info,
1035 ipv6_header, extension_headers, udp_header = self._decompress_iphc(data, message_info)
1056 self._lowpan_fragments_buffers_manager.free_fragments_buffer(message_info,
1059 return self._ipv6_packet_factory.parse(data, message_info)
1063 def _handle_subsequent_fragmentation_header(self, data, message_info): argument
1067 message_info,
1080 self._lowpan_fragments_buffers_manager.free_fragments_buffer(message_info,
1083 return self._ipv6_packet_factory.parse(data, message_info)
1087 def _handle_iphc_header(self, data, message_info): argument
1088 ipv6_header, extension_headers, udp_header = self._decompress_iphc(data, message_info)
1108 return self._ipv6_packet_factory.parse(io.BytesIO(decompressed_data), message_info)
1113 def parse(self, data, message_info): argument
1119 mesh_header = self._lowpan_mesh_header_factory.parse(data, message_info)
1121 message_info.source_mac_address = (mesh_header.originator_address)
1122 message_info.destination_mac_address = (mesh_header.final_destination_address)
1125 return self._handle_first_fragmentation_header(data, message_info)
1128 return self._handle_subsequent_fragmentation_header(data, message_info)
1131 return self._handle_iphc_header(data, message_info)