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

Merge pull request #18738 from SmithSamuelM/sam_20141204

Browse Source 
Fixed bugs in raetlane.py. Added changes to transport
This commit is contained in:
Thomas S Hatch 2014-12-04 16:49:02 -07:00
commit d4ae243b17
1 changed files with 7 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
salt/utils/raetlane.py
View File

@ -66,7 +66,7 @@ from raet.lane.yarding import RemoteYard
# Module globals for default shared LaneStack for a process.
rx_msgs = {} # module global dict of deques one for each receipient of msgs
lane_stack = None # module global that holds raet LaneStack
remote_yard = None # module global that holds raet
remote_yard = None # module global that holds raet remote Yard
master_estate_name = None # module global of motivating master estate name
master_yard_name = None # module global of motivating master yard name
@ -89,7 +89,7 @@ def _setup(opts, ryn='manor'):
'''
Setup the LaneStack lane_stack and RemoteYard lane_remote_yard global
'''
global lane_stack, lane_remote_yard # pylint: disable=W0602
global lane_stack, remote_yard # pylint: disable=W0602
role = opts.get('id')
if not role:
@ -119,13 +119,15 @@ def _setup(opts, ryn='manor'):
sockdirpath=opts['sock_dir'])
lane_stack.Pk = raeting.packKinds.pack
log.debug("Created new LaneStack and local Yard named {0} at {1}\n"
"".format(lane_stack.name, lane_stack.ha))
remote_yard = RemoteYard(stack=lane_stack,
name=ryn,
lanename=lanename,
dirpath=opts['sock_dir'])
lane_stack.addRemote(remote_yard)
log.debug("Created new LaneStack and local Yard named {0} at {1}\n".format(
lane_stack.name, lane_stack.ha))
log.debug("Added to LaneStack {0} remote Yard named {1} at {2}\n"
"".format(lane_stack.name, remote_yard.name, remote_yard.ha))
def transmit(msg):
@ -138,7 +140,7 @@ def transmit(msg):
def service():
'''
Service the lane_stack and move any received messages into their associated
deques in lane_rx_msgs keyed by the destination share in the msg route dict
deques in rx_msgs keyed by the destination share in the msg route dict
'''
lane_stack.serviceAll()
while lane_stack.rxMsgs: