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

Pop oldest jid if we hit the jid_forward_cache_hwm

Browse Source
This commit is contained in:
Colton Myers 2015-03-19 10:42:06 -06:00
parent 46c097389c
commit 30f9d08aa8
1 changed files with 5 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
salt/minion.py
View File

@ -2313,6 +2313,11 @@ class MultiSyndic(MinionBase):
if event['data']['jid'] not in self.jid_forward_cache:
fstr = '{0}.get_load'.format(self.opts['master_job_cache'])
self.jid_forward_cache.add(event['data']['jid'])
if len(self.jid_forward_cache) > self.opts['syndic_jid_forward_cache_hwm']:
# Pop the oldest jid from the cache
tmp = sorted(list(self.jid_forward_cache))
tmp.pop(0)
self.jid_forward_cache = set(tmp)
jdict['__load__'].update(
self.mminion.returners[fstr](event['data']['jid'])
)