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

Add in the access keys needed by localfuncs

Browse Source
This commit is contained in:
Thomas S Hatch 2014-03-11 22:54:10 -06:00
parent 311dba60f9
commit 9e6b2dbeea
2 changed files with 5 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
salt/daemons/flo/__init__.py
View File

@ -57,7 +57,7 @@ class IofloMaster(object):
'''
Spin up a process for each worker thread
'''
for ind in range(int(1)):
for ind in range(int(self.opts['worker_threads'])):
proc = multiprocessing.Process(
target=self._worker, kwargs={'yid': ind + 1}
)

5
salt/daemons/flo/worker.py
View File

@ -34,7 +34,10 @@ class RouterWorker(ioflo.base.deeding.Deed):
dirpath=self.opts.value['sock_dir'])
self.uxd_stack.value.addRemoteYard(manor_yard)
self.remote = salt.daemons.masterapi.RemoteFuncs(self.opts.value)
self.local = salt.daemons.masterapi.LocalFuncs(self.opts.value)
self.access_keys = salt.daemons.masterapi.access_keys(self.opts.value)
self.local = salt.daemons.masterapi.LocalFuncs(
self.opts.value,
self.access_keys)
def action(self):
'''