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

Add cluser calls to the master

Browse Source
This commit is contained in:
Thomas S Hatch 2011-03-20 23:26:03 -06:00
parent 93739e9715
commit 770812929c
1 changed files with 18 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

18
salt/master.py
View File

@ -207,6 +207,8 @@ class ReqServer(threading.Thread):
'publish_port': self.opts['publish_port'],
}
ret['aes'] = key.public_encrypt(self.opts['aes'], 4)
if self.opts['cluster_masters']:
publish(self._cluster_load())
return ret
def _return(self, load):
@ -226,6 +228,22 @@ class ReqServer(threading.Thread):
os.makedirs(hn_dir)
pickle.dump(load['return'], open(os.path.join(hn_dir, 'return.p'), 'w+'))
def _cluster_load(self):
'''
Generates the data sent to the cluster nodes.
'''
load = {}
load['key'] = self.key
load['fun'] = 'cluster.sync'
load['tgt'] = self.opts['cluster_masters']
load['tgt_type'] = 'list'
minion_dir = os.path.join(self.opts['pki_dir'], 'minions')
load['arg'] = {}
for host in os.listdir(minion_dir):
pub = os.path.join(minion_dir, host)
load['arg'][host] = open(host, 'r').read()
return load
def publish(self, clear_load):
'''
This method sends out publications to the minions