X-Git-Url: http://www.chiark.greenend.org.uk/ucgi/~ian/git?p=hippotat.git;a=blobdiff_plain;f=hippotat%2F__init__.py;h=d5da7dd81f1c57ab98304e8e436cd281febb4f17;hp=35c87f2e1ce2b494c24da44ca8d7911bfb2a5bac;hb=8718b02cbe478247f57af8516f2502edd80bcf33;hpb=b68c0739e0dbabf20117e637b10ac3cf61ebb783 diff --git a/hippotat/__init__.py b/hippotat/__init__.py index 35c87f2..d5da7dd 100644 --- a/hippotat/__init__.py +++ b/hippotat/__init__.py @@ -37,6 +37,7 @@ class DBG(twisted.python.constants.Names): INIT = NamedConstant() QUEUE = NamedConstant() QUEUE_CTRL = NamedConstant() + HTTP_FULL = NamedConstant() _hex_codec = codecs.getencoder('hex_codec') @@ -111,9 +112,9 @@ class ConfigResults: c = ConfigResults() -def log_discard(packet, saddr, daddr, why): +def log_discard(packet, iface, saddr, daddr, why): log_debug(DBG.DROP, - 'discarded packet %s -> %s (%s)' % (saddr, daddr, why), + 'discarded packet [%s] %s -> %s: %s' % (iface, saddr, daddr, why), d=packet) #---------- packet parsing ---------- @@ -184,7 +185,7 @@ class _IpifProcessProtocol(twisted.internet.protocol.ProcessProtocol): def slip_on_packet(self, packet): (saddr, daddr) = packet_addrs(packet) if saddr.is_link_local or daddr.is_link_local: - log_discard(packet, saddr, daddr, 'link-local') + log_discard(packet, 'ipif', saddr, daddr, 'link-local') return self._router(packet, saddr, daddr) def processEnded(self, status): @@ -208,6 +209,7 @@ def queue_inbound(packet): class PacketQueue(): def __init__(self, desc, max_queue_time): self._desc = desc + assert(desc + '') self._max_queue_time = max_queue_time self._pq = collections.deque() # packets