aboutsummaryrefslogtreecommitdiff
diff options
context:
space:
mode:
-rw-r--r--rpkid/rpki/left_right.py8
1 files changed, 8 insertions, 0 deletions
diff --git a/rpkid/rpki/left_right.py b/rpkid/rpki/left_right.py
index 5f1a68ef..6604d136 100644
--- a/rpkid/rpki/left_right.py
+++ b/rpkid/rpki/left_right.py
@@ -486,6 +486,14 @@ class self_elt(data_elt):
self.gctx.checkpoint()
+ if self.gctx.sql.dirty:
+ rpki.log.warn("Unexpected dirty SQL cache, flushing")
+ self.gctx.sql.sweep()
+
+ ## @todo
+ # This doesn't look right, <asn, prefixlist> may not be unique
+ # during some transient states. Need rewriting.
+ #
roas = dict(((r.asn, str(r.ipv4), str(r.ipv6)), r) for r in self.roas())
publisher = rpki.rpki_engine.publication_queue()