diff options
| author | Tim Laszlo <tim.laszlo@gmail.com> | 2012-10-15 11:02:24 -0500 |
|---|---|---|
| committer | Tim Laszlo <tim.laszlo@gmail.com> | 2012-10-15 11:02:35 -0500 |
| commit | cc4b4e645158f26313a306b0f445987164a2e472 (patch) | |
| tree | f0e118142ab640c2b83a2071005df519c99d477f /src/lib/Bcfg2/Reporting/Transport | |
| parent | 904bffc08634d6f393f2e253a6c31bedd3239e04 (diff) | |
| download | bcfg2-cc4b4e645158f26313a306b0f445987164a2e472.tar.gz bcfg2-cc4b4e645158f26313a306b0f445987164a2e472.tar.bz2 bcfg2-cc4b4e645158f26313a306b0f445987164a2e472.zip | |
log imports when DirectStore is used
Diffstat (limited to 'src/lib/Bcfg2/Reporting/Transport')
| -rw-r--r-- | src/lib/Bcfg2/Reporting/Transport/DirectStore.py | 5 |
1 files changed, 5 insertions, 0 deletions
diff --git a/src/lib/Bcfg2/Reporting/Transport/DirectStore.py b/src/lib/Bcfg2/Reporting/Transport/DirectStore.py index 85d703102..8677efb5f 100644 --- a/src/lib/Bcfg2/Reporting/Transport/DirectStore.py +++ b/src/lib/Bcfg2/Reporting/Transport/DirectStore.py @@ -3,6 +3,7 @@ storage backend """ import os import sys +import time import threading from Bcfg2.Reporting.Transport.base import TransportBase, TransportError from Bcfg2.Reporting.Storage import load_storage_from_config @@ -39,7 +40,11 @@ class DirectStore(TransportBase, threading.Thread): try: interaction = self.queue.get(block=True, timeout=self.timeout) + start = time.time() self.storage.import_interaction(interaction) + self.logger.info("Imported data for %s in %s seconds" \ + % (interaction.get('hostname', '<unknown>'), \ + time.time() - start)) except Empty: continue except: |