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

change to always use popleft

Browse Source
This commit is contained in:
Thomas S Hatch 2014-03-04 22:01:12 -07:00
parent 4917bccf99
commit 7f9488f1e2
1 changed files with 8 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

19
salt/daemons/flo/master.py
View File

@ -118,15 +118,12 @@ class UxdRouter(ioflo.base.deeding.Deed): # pylint: disable=W0232
'''
self.stack.value.serviceAll()
# Process inboud communication stack
for msg in self.stack.value.rxMsgs:
self._process_rxmsg(msg)
self.stack.value.rxMsgs.clear()
for event in self.events.value:
self._fire_event(event)
self.events.value.clear()
for ret in self.local_ret.value:
self.stack.value.transmit(ret)
self.local_ret.value.clear()
while self.stack.value.rxMsgs:
self._process_rxmsg(self.stack.value.rxMsgs.popleft())
while self.events.value:
self._fire_event(self.events.value.popleft())
while self.local_ret.value:
self.stack.value.transmit(self.local_ret.value.popleft())
self.stack.value.serviceAll()
@ -180,7 +177,8 @@ class LocalCmd(ioflo.base.deeding.Deed): # pylint: disable=W0232
'''
Perform an action
'''
for cmd in self.local_cmd.value:
while self.local_cmd.value:
cmd = self.local_cmd.value.popleft()
ret = {}
load = cmd.get('load')
# If the load is invalid, just ignore the request
@ -194,4 +192,3 @@ class LocalCmd(ioflo.base.deeding.Deed): # pylint: disable=W0232
'dst': cmd['route']['src']}
self.local_ret.value.append(ret)
self.local_cmd.value.clear()