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

added support for auto, main, dirpath for persistence to stack behavior

Browse Source
This commit is contained in:
Samuel M Smith 2014-03-07 09:52:08 -07:00
parent 78c59c5f7b
commit 69f521e7f3
2 changed files with 102 additions and 88 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
salt/transport/road/raet.flo
View File

@ -2,7 +2,8 @@
house master
init .raet.udp.stack.local to eid 1 name "master" host "" port 7530
init .raet.udp.stack.local to eid 1 name "master" host "" port 7530 \
dirpath "raet/test/keep/" main True auto True
framer masterudpstack be active first start
@ -23,7 +24,8 @@ framer receiver be active first start
house minion1
init .raet.udp.stack.local to eid 0 name "minion1" host "" port 7531
init .raet.udp.stack.local to eid 0 name "minion1" host "" port 7531 \
dirpath "raet/test/keep/" main False auto True
framer minionudpstack be active first start

14
salt/transport/road/raet/behaving.py
View File

@ -25,6 +25,8 @@ raet.udp.stack.destination
# pylint: skip-file
# pylint: disable=W0611
import os
# Import Python libs
from collections import deque
try:
@ -57,6 +59,9 @@ class StackUdpRaet(deeding.Deed): # pylint: disable=W0232
txmsgs=odict(ipath='txmsgs', ival=deque()),
rxmsgs=odict(ipath='rxmsgs', ival=deque()),
local=odict(ipath='local', ival=odict( name='master',
dirpath='raet/test/keep',
main=False,
auto=True,
eid=0,
host='0.0.0.0',
port=raeting.RAET_PORT,
@ -69,8 +74,12 @@ class StackUdpRaet(deeding.Deed): # pylint: disable=W0232
'''
sigkey = self.local.data.sigkey
prikey = self.local.data.prikey
ha = (self.local.data.host, self.local.data.port)
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,
@ -83,6 +92,9 @@ class StackUdpRaet(deeding.Deed): # pylint: disable=W0232
self.stack.value = stacking.StackUdp(estate=estate,
store=self.store,
name=name,
auto=auto,
main=main,
dirpath=dirpath,
txMsgs=txMsgs,
rxMsgs=rxMsgs, )