diff options
| author | Chris St. Pierre <chris.a.st.pierre@gmail.com> | 2012-11-26 13:20:45 -0500 |
|---|---|---|
| committer | Chris St. Pierre <chris.a.st.pierre@gmail.com> | 2012-11-26 13:21:18 -0500 |
| commit | 62bc304fe0ea0457dd1707420acd01b3e2fb3b37 (patch) | |
| tree | 978d560cd71d546a67a6de3cc32a7ede45f4a4fa | |
| parent | 68e9746830026c9ad6f6e9c972097c2436055629 (diff) | |
| download | bcfg2-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.py | 3 |
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() |