aboutsummaryrefslogtreecommitdiff
path: root/rtr-origin
diff options
context:
space:
mode:
authorRob Austein <sra@hactrn.net>2009-05-11 05:21:14 +0000
committerRob Austein <sra@hactrn.net>2009-05-11 05:21:14 +0000
commit42edf90e3796d347cdf907f59b7b0977520632fd (patch)
tree437d98b5e65806a83f91a6e8faee1b80d488099e /rtr-origin
parent5d2624071ce7117b859ce829a2837a26ef138f39 (diff)
Sort filenames on printout, to make changes more obvious. Avoid
producing null diff of current version against itself. svn path=/rtr-origin/rtr-origin.py; revision=2422
Diffstat (limited to 'rtr-origin')
-rw-r--r--rtr-origin/rtr-origin.py33
1 files changed, 25 insertions, 8 deletions
diff --git a/rtr-origin/rtr-origin.py b/rtr-origin/rtr-origin.py
index c2adebd1..ce880d63 100644
--- a/rtr-origin/rtr-origin.py
+++ b/rtr-origin/rtr-origin.py
@@ -477,9 +477,13 @@ class axfr_set(prefix_set):
self.serial = int(fn1)
return self
+ def filename(self):
+ """Generate filename for this axfr_set."""
+ return "%d.ax" % self.serial
+
def save_axfr(self):
"""Write axfr__set to file with magic filename."""
- f = open("%d.ax" % self.serial, "wb")
+ f = open(self.filename(), "wb")
for p in self:
f.write(p.to_pdu())
f.close()
@@ -542,6 +546,10 @@ class ixfr_set(prefix_set):
self.to_serial = int(fn1)
return self
+ def filename(self):
+ """Generate filename for this ixfr_set."""
+ return "%d.ix.%d" % (self.to_serial, self.from_serial)
+
def show(self):
"""Print this ixfr_set."""
print "# IXFR %d (%s) -> %d (%s)" % (self.from_serial, rpki.sundial.datetime.utcfromtimestamp(self.from_serial),
@@ -786,8 +794,9 @@ def cronjob_main(argv):
pdus = axfr_set.parse_rcynic(argv[0])
pdus.save_axfr()
- for axfr in glob.glob("*.ax"):
- pdus.save_ixfr(axfr_set.load(axfr))
+ for axfr in glob.iglob("*.ax"):
+ if axfr != pdus.filename():
+ pdus.save_ixfr(axfr_set.load(axfr))
pdus.mark_current()
print "# New serial is %s" % pdus.serial
@@ -802,17 +811,25 @@ def cronjob_main(argv):
print "# Failed to kick %s" % name
sock.close()
- for f in old_ixfrs:
- print "# Deleting old file %s" % f
- os.unlink(f)
+ old_ixfrs.sort()
+ for ixfr in old_ixfrs:
+ print "# Deleting old file %s" % ixfr
+ os.unlink(ixfr)
def show_main(argv):
"""Main program for show mode. Just displays current AXFR and IXFR dumps"""
+
if argv:
raise RuntimeError, "Unexpected arguments: %s" % argv
- for f in glob.glob("*.ax"):
+
+ g = glob.glob("*.ax")
+ g.sort()
+ for f in g:
axfr_set.load(f).show()
- for f in glob.glob("*.ix.*"):
+
+ g = glob.glob("*.ix.*")
+ g.sort()
+ for f in g:
ixfr_set.load(f).show()
def server_main(argv):