summaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorChris St. Pierre <chris.a.st.pierre@gmail.com>2012-11-26 13:20:45 -0500
committerChris St. Pierre <chris.a.st.pierre@gmail.com>2012-11-26 13:21:18 -0500
commit62bc304fe0ea0457dd1707420acd01b3e2fb3b37 (patch)
tree978d560cd71d546a67a6de3cc32a7ede45f4a4fa
parent68e9746830026c9ad6f6e9c972097c2436055629 (diff)
downloadbcfg2-62bc304fe0ea0457dd1707420acd01b3e2fb3b37.tar.gz
bcfg2-62bc304fe0ea0457dd1707420acd01b3e2fb3b37.tar.bz2
bcfg2-62bc304fe0ea0457dd1707420acd01b3e2fb3b37.zip
validate storage backend with DirectStore reporting Transport
-rw-r--r--src/lib/Bcfg2/Reporting/Transport/DirectStore.py3
1 files changed, 3 insertions, 0 deletions
diff --git a/src/lib/Bcfg2/Reporting/Transport/DirectStore.py b/src/lib/Bcfg2/Reporting/Transport/DirectStore.py
index 8677efb5f..d1ad7c2f2 100644
--- a/src/lib/Bcfg2/Reporting/Transport/DirectStore.py
+++ b/src/lib/Bcfg2/Reporting/Transport/DirectStore.py
@@ -15,7 +15,10 @@ class DirectStore(TransportBase, threading.Thread):
TransportBase.__init__(self, setup)
threading.Thread.__init__(self)
self.save_file = os.path.join(self.data, ".saved")
+
self.storage = load_storage_from_config(setup)
+ self.storage.validate()
+
self.queue = Queue(100000)
self.terminate = threading.Event()
self.start()