Commit 9980df2ea9847aaf1348f31e6b3f158e54a79c71
- Date: Tue May 13 20:07:59 +0000 2008
- Committer: Rodrigo Lazo (rlazo.paz@gmail.com)
- Author: Rodrigo Lazo (rlazo.paz@gmail.com)
- Commit SHA1: 9980df2ea9847aaf1348f31e6b3f158e54a79c71
- Tree SHA1: 687f2d0296e6fe026a00b86f75c80c88a6bc8ca3
Signals and plugins using threads (too easy?)
Commit diff
| |   |
| 26 | 26 | import os, sys |
| 27 | 27 | import traceback |
| 28 | 28 | import logging |
| 29 | import thread |
| 29 | 30 | |
| 30 | 31 | class PluginBase (object): |
| 31 | 32 | """ Base class for plugins. """ |
| … | … | |
| 123 | 123 | try: |
| 124 | 124 | logging.info("[PluginManager] Signal %s -> plugin %s", signal, |
| 125 | 125 | plugin.NAME) |
| 126 | | method(**kwargs) |
| 126 | thread.start_new_thread(method,(), kwargs) |
| 127 | 127 | except PluginRunException: |
| 128 | 128 | logging.error("[PluginManager] Signal error. Signal: %s, plugin %s", |
| 129 | 129 | signal, plugin.NAME, exc_info=True) |
| toggle raw diff |
--- a/gsentinel/plugin.py
+++ b/gsentinel/plugin.py
@@ -26,6 +26,7 @@ from itertools import ifilter
import os, sys
import traceback
import logging
+import thread
class PluginBase (object):
""" Base class for plugins. """
@@ -122,7 +123,7 @@ class PluginManager(object):
try:
logging.info("[PluginManager] Signal %s -> plugin %s", signal,
plugin.NAME)
- method(**kwargs)
+ thread.start_new_thread(method,(), kwargs)
except PluginRunException:
logging.error("[PluginManager] Signal error. Signal: %s, plugin %s",
signal, plugin.NAME, exc_info=True) |