Index: third_party/twisted_8_1/twisted/pair/rawudp.py |
diff --git a/third_party/twisted_8_1/twisted/pair/rawudp.py b/third_party/twisted_8_1/twisted/pair/rawudp.py |
deleted file mode 100644 |
index 42f1d2fe9129e691ee8b8b4430aff96b7170d89b..0000000000000000000000000000000000000000 |
--- a/third_party/twisted_8_1/twisted/pair/rawudp.py |
+++ /dev/null |
@@ -1,55 +0,0 @@ |
-# -*- test-case-name: twisted.pair.test.test_rawudp -*- |
-# Copyright (c) 2001-2004 Twisted Matrix Laboratories. |
-# See LICENSE for details. |
- |
-# |
- |
-"""Implementation of raw packet interfaces for UDP""" |
- |
-import struct |
- |
-from twisted.internet import protocol |
-from twisted.pair import raw |
-from zope.interface import implements |
- |
-class UDPHeader: |
- def __init__(self, data): |
- |
- (self.source, self.dest, self.len, self.check) \ |
- = struct.unpack("!HHHH", data[:8]) |
- |
-class RawUDPProtocol(protocol.AbstractDatagramProtocol): |
- implements(raw.IRawDatagramProtocol) |
- def __init__(self): |
- self.udpProtos = {} |
- |
- def addProto(self, num, proto): |
- if not isinstance(proto, protocol.DatagramProtocol): |
- raise TypeError, 'Added protocol must be an instance of DatagramProtocol' |
- if num < 0: |
- raise TypeError, 'Added protocol must be positive or zero' |
- if num >= 2**16: |
- raise TypeError, 'Added protocol must fit in 16 bits' |
- if num not in self.udpProtos: |
- self.udpProtos[num] = [] |
- self.udpProtos[num].append(proto) |
- |
- def datagramReceived(self, |
- data, |
- partial, |
- source, |
- dest, |
- protocol, |
- version, |
- ihl, |
- tos, |
- tot_len, |
- fragment_id, |
- fragment_offset, |
- dont_fragment, |
- more_fragments, |
- ttl): |
- header = UDPHeader(data) |
- for proto in self.udpProtos.get(header.dest, ()): |
- proto.datagramReceived(data[8:], |
- (source, header.source)) |