diff options
| author | Chris St. Pierre <chris.a.st.pierre@gmail.com> | 2012-10-29 08:57:02 -0400 |
|---|---|---|
| committer | Chris St. Pierre <chris.a.st.pierre@gmail.com> | 2012-10-29 09:03:34 -0400 |
| commit | 1e627fa685ea356807aeec5b2f3c6a3e9358fe6a (patch) | |
| tree | d48eb536a4fd7fefffd1468a2d78cfa1480078b6 /src/lib/Bcfg2/Server/Core.py | |
| parent | 847e344d019a23f673d4e91e46a951e279ca73a3 (diff) | |
| download | bcfg2-1e627fa685ea356807aeec5b2f3c6a3e9358fe6a.tar.gz bcfg2-1e627fa685ea356807aeec5b2f3c6a3e9358fe6a.tar.bz2 bcfg2-1e627fa685ea356807aeec5b2f3c6a3e9358fe6a.zip | |
fixed repeat processing of probe data
Diffstat (limited to 'src/lib/Bcfg2/Server/Core.py')
| -rw-r--r-- | src/lib/Bcfg2/Server/Core.py | 19 |
1 files changed, 10 insertions, 9 deletions
diff --git a/src/lib/Bcfg2/Server/Core.py b/src/lib/Bcfg2/Server/Core.py index d8634a569..a5fda6f0d 100644 --- a/src/lib/Bcfg2/Server/Core.py +++ b/src/lib/Bcfg2/Server/Core.py @@ -956,16 +956,17 @@ class BaseCore(object): if source not in self.plugins: self.logger.warning("Failed to locate plugin %s" % source) continue - datalist = [data for data in xpdata - if data.get('source') == source] - try: - self.plugins[source].ReceiveData(metadata, datalist) - except: - err = sys.exc_info()[1] - self.critical_error("Failed to process probe data from " - "client %s: %s" % - (client, err)) sources.append(source) + + for source in sources: + datalist = [data for data in xpdata + if data.get('source') == source] + try: + self.plugins[source].ReceiveData(metadata, datalist) + except: + err = sys.exc_info()[1] + self.critical_error("Failed to process probe data from client " + "%s: %s" % (client, err)) return True @exposed |