wanderer/fastnetmon-rewritten
1
0
Fork 0
mirror of https://github.com/pavel-odintsov/fastnetmon synced 2024-11-24 02:46:36 +01:00
Code Issues Releases Activity

Switch off counter to deadline

Browse Source
This commit is contained in:
Pavel Odintsov 2015-05-19 00:18:31 +02:00
parent 080b9b2541
commit a1060d6e1e
1 changed files with 1 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
src/scripts/exabgp_queue_writer.py
View File

@ -26,12 +26,6 @@ while True:
# print >> sys.stderr, "GOT A LINE"
sys.stdout.flush()
if line == "":
counter += 1
if counter > 100:
break
continue
counter = 0
# { "exabgp": "3.5.0", "time": 1431716393, "host" : "synproxied.fv.ee", "pid" : 2599, "ppid" : 2008, "counter": 1, "type": "update", "neighbor": { "address": { "local": "10.0.3.115", "peer": "10.0.3.114" }, "asn": { "local": "1234", "peer": "65001" }, "direction": "receive", "message": { "update": { "attribute": { "origin": "igp", "as-path": [ 65001 ], "confederation-path": [], "extended-community": [ 9225060886715039744 ] }, "announce": { "ipv4 flow": { "no-nexthop": { "flow-0": { "destination-ipv4": [ "10.0.0.2/32" ], "source-ipv4": [ "10.0.0.1/32" ], "protocol": [ "=tcp" ], "destination-port": [ "=3128" ], "string": "flow destination-ipv4 10.0.0.2/32 source-ipv4 10.0.0.1/32 protocol =tcp destination-port =3128" } } } } } } } }
@ -49,7 +43,7 @@ while True:
# Fix bug: https://github.com/Exa-Networks/exabgp/issues/269
line = line.replace('0x800900000000000A', '"0x800900000000000A"')
io = StringIO(line)
### print >> sys.stderr, line
print >> sys.stderr, line
decoded_update = json.load(io)
pp = pprint.PrettyPrinter(indent=4, stream=sys.stderr)