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

add CacheWorker for ConnectedCache as multiprocessing.process

Browse Source
This commit is contained in:
vs 2015-04-17 15:24:42 +02:00
parent 3b17858052
commit e675dc7a3f
1 changed files with 25 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

25
salt/utils/master.py
View File

@ -25,6 +25,7 @@ import salt.utils.minions
import salt.payload
from salt.exceptions import SaltException
import salt.config
from salt.utils.cache import CacheCli as cache_cli
# Import third party libs
import salt.ext.six as six
@ -440,6 +441,30 @@ class CacheTimer(Thread):
if count >= 60:
count = 0
class CacheWorker(multiprocessing.Process):
'''
Worker for ConnectedCache updates which run in its
own process to prevent blocking of ConnectedCache
main-loop when refreshing minion-list
'''
def __init__(self, opts):
'''
Sets up the zmq-connection to the ConCache
'''
super(CacheWorker, self).__init__()
self.opts = opts
def run(self):
'''
Gather currently connected minions and update the cache
'''
new_mins = list(salt.utils.minions.CkMinions(self.opts).connected_ids())
cc = cache_cli(self.opts)
cc.put_cache(new_mins)
log.debug('ConCache CacheWorker update finished')
class ConnectedCache(multiprocessing.Process):
'''