frag6_udpatomic.py revision 1.2 
1#!/usr/local/bin/python2.7
2# send atomic udp fragment
3
4# |--------|
5#          |----|
6
7import os
8from addr import *
9from scapy.all import *
10
11pid=os.getpid()
12payload="ABCDEFGHIJKLMNOP"
13packet=IPv6(src=SRC_OUT6, dst=DST_IN6)/UDP(sport=pid, dport=7)/payload
14frag=[]
15frag.append(IPv6ExtHdrFragment(nh=17, id=pid)/str(packet)[40:64])
16eth=[]
17for f in frag:
18	pkt=IPv6(src=SRC_OUT6, dst=DST_IN6)/f
19	eth.append(Ether(src=SRC_MAC, dst=DST_MAC)/pkt)
20
21if os.fork() == 0:
22	time.sleep(1)
23	sendp(eth, iface=SRC_IF)
24	os._exit(0)
25
26ans=sniff(iface=SRC_IF, timeout=3, filter=
27    "ip6 and src "+DST_IN6+" and dst "+SRC_OUT6+" and udp")
28for a in ans:
29	if a and a.type == scapy.layers.dot11.ETHER_TYPES.IPv6 and \
30	    ipv6nh[a.payload.nh] == 'UDP' and \
31	    a.payload.payload.sport == 7:
32		port=a.payload.payload.dport
33		print "port=%d" % (port)
34		if port != pid:
35			print "WRONG UDP ECHO REPLY PORT"
36			exit(2)
37		data=a.payload.payload.load
38		print "payload=%s" % (data)
39		if data == payload:
40			exit(0)
41		print "PAYLOAD!=%s" % (payload)
42		exit(1)
43print "NO UDP ECHO REPLY"
44exit(2)
45