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

Add salt specific udp stack behavior

Browse Source
This commit is contained in:
Thomas S Hatch 2014-03-12 22:17:53 -06:00
parent 2a79b489fe
commit ec401a8b1f
1 changed files with 57 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -17,6 +17,8 @@ from collections import deque
# Import salt libs
import salt.daemons.masterapi
from salt.transport.road.raet import stacking
from salt.transport.road.raet import estating
from salt.transport.road.raet import raeting
from salt.transport.road.raet import yarding
from salt.exceptions import (
CommandExecutionError, CommandNotFoundError, SaltInvocationError)
@ -41,6 +43,59 @@ except ImportError:
log = logging.getLogger(__name__)
class StackUdpRaetSalt(ioflo.base.deeding.Deed):
'''
Initialize and run raet udp stack for Salt
'''
Ioinits = dict(
inode='raet.udp.stack.',
stack='stack',
txmsgs=dict(ipath='txmsgs', ival=deque()),
rxmsgs=dict(ipath='rxmsgs', ival=deque()),
local=dict(ipath='local', ival=dict(name='master',
dirpath='raet/test/keep',
main=False,
auto=True,
eid=0,
host='0.0.0.0',
port=raeting.RAET_PORT,
sigkey=None,
prikey=None)),)
def postinitio(self):
'''
Setup stack instance
'''
sigkey = self.local.data.sigkey
prikey = self.local.data.prikey
name = self.local.data.name
dirpath = os.path.abspath(os.path.join(self.local.data.dirpath, name))
auto = self.local.data.auto
main = self.local.data.main
ha = (self.local.data.host, self.local.data.port)
eid = self.local.data.eid
estate = estating.LocalEstate(
eid=eid,
name=name,
ha=ha,
sigkey=sigkey,
prikey=prikey)
txMsgs = self.txmsgs.value
rxMsgs = self.rxmsgs.value
self.stack.value = stacking.StackUdp(
estate=estate,
store=self.store,
name=name,
auto=auto,
main=main,
dirpath=dirpath,
txMsgs=txMsgs,
rxMsgs=rxMsgs)
self.stack.value.Bk = raeting.bodyKinds.msgpack
class ModulesLoad(ioflo.base.deeding.Deed):
'''
Reload the minion modules
@ -134,6 +189,7 @@ class Setup(ioflo.base.deeding.Deed):
lanename=self.opts.value['id'],
yid=0,
dirpath=self.opts.value['sock_dir'])
self.uxd_stack.value.Pk = raeting.packKinds.pack
self.event_yards.value = set()
self.local_cmd.value = deque()
self.remote_cmd.value = deque()
@ -384,6 +440,7 @@ class ExecutorNix(ioflo.base.deeding.Deed):
lanename=self.opts['id'],
yid=ret['jid'],
dirpath=self.opts['sock_dir'])
ret_stack.Pk = raeting.packKinds.pack
main_yard = yarding.Yard(
yid=0,
prefix=self.opts['id'],