summaryrefslogtreecommitdiffstats
path: root/src/lib/Bcfg2/Server/MultiprocessingCore.py
diff options
context:
space:
mode:
authorChris St. Pierre <chris.a.st.pierre@gmail.com>2013-08-12 08:47:04 -0400
committerChris St. Pierre <chris.a.st.pierre@gmail.com>2013-08-12 08:47:04 -0400
commite18ff0f6a6f4c35d47d4f344002878e2ebc0fecb (patch)
treeba7bf480f8cb23ec5f699f16ac4c9e16d189eefa /src/lib/Bcfg2/Server/MultiprocessingCore.py
parent5c573e00a168c90c5c718566c75aadf736566676 (diff)
parent4201e3b68f392869359493ab9462706f4956e387 (diff)
downloadbcfg2-e18ff0f6a6f4c35d47d4f344002878e2ebc0fecb.tar.gz
bcfg2-e18ff0f6a6f4c35d47d4f344002878e2ebc0fecb.tar.bz2
bcfg2-e18ff0f6a6f4c35d47d4f344002878e2ebc0fecb.zip
Merge branch 'maint'
Conflicts: src/lib/Bcfg2/Server/Admin/Viz.py src/lib/Bcfg2/Server/Plugins/Packages/__init__.py
Diffstat (limited to 'src/lib/Bcfg2/Server/MultiprocessingCore.py')
-rw-r--r--src/lib/Bcfg2/Server/MultiprocessingCore.py8
1 files changed, 4 insertions, 4 deletions
diff --git a/src/lib/Bcfg2/Server/MultiprocessingCore.py b/src/lib/Bcfg2/Server/MultiprocessingCore.py
index cce6bc0c3..517140178 100644
--- a/src/lib/Bcfg2/Server/MultiprocessingCore.py
+++ b/src/lib/Bcfg2/Server/MultiprocessingCore.py
@@ -294,8 +294,7 @@ class ChildCore(Core):
def _get_rmi(self):
rmi = dict()
- for pname, pinst in self.plugins.items() + \
- [(self.fam.__class__.__name__, self.fam)]:
+ for pname, pinst in self._get_rmi_objects().items():
for crmi in pinst.__child_rmi__:
if isinstance(crmi, tuple):
mname = crmi[1]
@@ -429,8 +428,7 @@ class MultiprocessingCore(BuiltinCore):
def _get_rmi(self):
child_rmi = dict()
- for pname, pinst in self.plugins.items() + \
- [(self.fam.__class__.__name__, self.fam)]:
+ for pname, pinst in self._get_rmi_objects().items():
for crmi in pinst.__child_rmi__:
if isinstance(crmi, tuple):
parentname, childname = crmi
@@ -453,6 +451,8 @@ class MultiprocessingCore(BuiltinCore):
(i.e., in the parent process). """
@wraps(parent_rmi)
def inner(*args, **kwargs):
+ """ Function that dispatches an RMI call to child
+ processes and to the (original) parent function. """
self.logger.debug("Dispatching RMI call to %s to children: %s" %
(method, child_rmi))
self.rpc_q.publish(child_rmi, args=args, kwargs=kwargs)