valitydev/salt
14
0
Fork 0
mirror of https://github.com/valitydev/salt.git synced 2024-11-08 17:33:54 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

Added routing logic for 'fun' on master and syndic

Browse Source
This commit is contained in:
Samuel M Smith 2014-11-17 16:27:55 -07:00
parent 5d96c80b9e
commit 323ed767a7
1 changed files with 6 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
salt/daemons/flo/core.py
View File

@ -879,7 +879,10 @@ class SaltRaetRouter(ioflo.base.deeding.Deed):
self.lane_stack.value.transmit(msg,
self.lane_stack.value.fetchUidByName(next(self.workers.value)))
elif d_share == 'fun':
self.fun.value.append(msg)
if self.road_stack.value.kind == kinds.applKinds.minion:
self.fun.value.append(msg)
elif self.road_stack.value.kind == kinds.applKinds.syndic:
self.self.publish.value.append(msg)
def _process_uxd_rxmsg(self, msg, sender):
'''
@ -1085,7 +1088,8 @@ class SaltRaetPublisher(ioflo.base.deeding.Deed):
minions = (self.availables.value &
set((remote.name for remote in stack.remotes.values()
if remote.kind == kinds.applKinds.minion)))
if remote.kind in [kinds.applKinds.minion,
kinds.applKinds.syndic])))
for minion in minions:
uid = self.stack.value.fetchUidByName(minion)
if uid: