Lines Matching refs:data
114 def parse(self, data, context): argument
115 return ICMPv6BytesBody(data.read())
126 def __init__(self, header, data, _type): argument
128 self._data = data
328 def any_upper_layer_payload(data, _type): argument
329 return DummyUpperLayerProtocol(DummyHeader(), data, _type)
356 data = ipv6_header.to_bytes()
359 self.assertEqual(6, data[0] >> 4)
360 self.assertEqual(traffic_class, ((data[0] << 8 | data[1]) >> 4) & 0xff)
361 self.assertEqual(flow_label, ((data[1] & 0x0F) << 16) | (data[2] << 8) | data[3])
362 self.assertEqual(payload_length, struct.unpack("!H", data[4:6])[0])
363 self.assertEqual(next_header, data[6])
364 self.assertEqual(hop_limit, data[7])
365 self.assertEqual(source_address, data[8:24])
366 self.assertEqual(destination_address, data[24:40])
378 …data = bytearray([(6 << 4) | (traffic_class >> 4), (traffic_class & 0xF) << 4 | (flow_label >> 16)…
381 … data += ip_address(bytes(source_address)).packed + ip_address(bytes(destination_address)).packed
384 ipv6_header = IPv6Header.from_bytes(io.BytesIO(data))
420 data = udp_header.to_bytes()
423 self.assertEqual(src_port, struct.unpack("!H", data[0:2])[0])
424 self.assertEqual(dst_port, struct.unpack("!H", data[2:4])[0])
425 self.assertEqual(payload_length, struct.unpack("!H", data[4:6])[0])
426 self.assertEqual(checksum, struct.unpack("!H", data[6:])[0])
435 data = struct.pack("!H", src_port) + struct.pack("!H", dst_port) + \
439 udp_header = UDPHeader.from_bytes(io.BytesIO(data))
476 data = icmpv6_header.to_bytes()
479 self.assertEqual(_type, data[0])
480 self.assertEqual(code, data[1])
481 self.assertEqual(checksum, struct.unpack("!H", data[2:])[0])
489 data = bytearray([_type, code]) + struct.pack("!H", checksum)
492 icmpv6_header = ICMPv6Header.from_bytes(io.BytesIO(data))
617 …ertEqual(b'\x80\x00\xc7\xbf\x00\x00\x00\x01AAAAAAAAAA', ipv6_packet.upper_layer_protocol.body.data)
649 …ertEqual(b'\x80\x00\xc7\xbf\x00\x00\x00\x01AAAAAAAAAA', ipv6_packet.upper_layer_protocol.body.data)
726 data = bytearray([type, 0x00, offset >> 5, ((offset << 3) & 0xff) | more_flag])\
730 ipv6_fragment_header = FragmentHeader.from_bytes(io.BytesIO(data))
801 data = hop_by_hop.to_bytes()
808 self.assertEqual(expected_data, data)
824 data = mpl_option.to_bytes()
828 self.assertEqual(expected_data, data)
838 data = bytearray([(S << 6) | (M << 5) | (V << 4), sequence]) + seed_id
841 mpl_option = MPLOption.from_bytes(io.BytesIO(data))
885 data = hop_by_hop_option.to_bytes()
889 self.assertEqual(expected_data, data)
918 data = hop_by_hop_option_header.to_bytes()
922 self.assertEqual(expected_data, data)
929 data = bytearray([_type, length])
932 option_header = HopByHopOptionHeader.from_bytes(io.BytesIO(data))
988 data = bytearray([next_header, hdr_ext_len]) + hop_by_hop_option.to_bytes()
989 data += self.padding(len(data))
992 hop_by_hop = hop_by_hop_factory.parse(io.BytesIO(data), any_message_info())
1010 data = bytes([next_header, hdr_ext_len]) + hop_by_hop_option.to_bytes()
1011 data += self.padding(len(data))
1014 … self.assertRaises(RuntimeError, hop_by_hop_factory.parse, io.BytesIO(data), any_message_info())
1028 data = bytearray([SMV, sequence]) + seed_id
1033 mpl_opt = factory.parse(io.BytesIO(data), any_message_info())
1047 data = any_data()
1057 actual_data = factory.parse(io.BytesIO(data), message_info)
1060 self.assertEqual(data, actual_data.data)
1064 data = any_data()
1074 actual_data = factory.parse(io.BytesIO(data), message_info)
1077 self.assertEqual(data, actual_data.data)
1081 data = any_data()
1090 self.assertRaises(RuntimeError, factory.parse, io.BytesIO(data), message_info)
1104 data = bytearray([(src_port >> 8), (src_port & 0xff), (dst_port >> 8),
1111 udp_dgram = factory.parse(io.BytesIO(data), any_message_info())
1118 self.assertEqual(udp_dgram.payload.data, payload)
1131 data = (bytearray([
1145 factory.parse(io.BytesIO(data), message_info)
1161 data = bytearray([_type, code, (checksum >> 8), (checksum & 0xff)]) + body
1166 icmpv6_msg = factory.parse(io.BytesIO(data), any_message_info())
1181 data = bytes([_type, code, (checksum >> 8), (checksum & 0xff)]) + body
1186 self.assertRaises(RuntimeError, factory.parse, io.BytesIO(data), any_message_info())
1193 data = any_data()
1196 actual = BytesPayload.from_bytes(data)
1199 self.assertEqual(data, actual.data)
1203 data = any_data()
1204 payload = BytesPayload(data)
1210 self.assertEqual(data, actual)
1214 data = any_data()
1215 payload = BytesPayload(data)
1221 self.assertEqual(len(data), actual)
1230 data = any_data()
1232 body = ICMPv6EchoBody(identifier, sequence_number, data)
1238 …ytearray([identifier >> 8, identifier & 0xff, sequence_number >> 8, sequence_number & 0xff]) + data
1247 …data = bytearray([(identifier >> 8), (identifier & 0xff), (sequence_number >> 8), (sequence_number…
1248 data += body_data
1251 actual = ICMPv6EchoBody.from_bytes(io.BytesIO(data))
1256 self.assertEqual(body_data, actual.data)
1287 data = bytearray([(identifier >> 8) & 0xff, identifier & 0xff,
1293 actual = factory.parse(io.BytesIO(data), any_message_info())
1300 self.assertEqual(body_data, actual.data)
1307 data = any_data()
1309 icmpv6_dest_unreachable = ICMPv6DestinationUnreachable(data)
1315 self.assertEqual(bytearray([0x00, 0x00, 0x00, 0x00]) + data, actual_data)
1319 data = any_data()
1323 io.BytesIO(bytearray([0x00, 0x00, 0x00, 0x00]) + data))
1326 self.assertEqual(data, icmpv6_dest_unreachable.data)
1330 data = any_data()
1336 io.BytesIO(bytearray(struct.pack(">I", unused)) + data))
1347 data = bytearray([0x00, 0x00, 0x00, 0x00]) + icmp_data
1350 icmpv6_dest_unreachable = factory.parse(io.BytesIO(data), any_message_info())
1353 self.assertEqual(icmp_data, icmpv6_dest_unreachable.data)
1367 data = struct.pack("!H", src_port) + struct.pack("!H", dst_port) + \
1371 udp_header = factory.parse(io.BytesIO(data), any_message_info())
1387 def parse(self, data, message_info): argument
1388 return data.read()
1392 data = bytearray([0x02, 0x03, 0x11, 0x22, 0x33, 0x01, 0x00])
1395 actual_options = factory.parse(io.BytesIO(data), any_message_info())