saltstack/salt
1
0
Fork 0
mirror of https://github.com/saltstack/salt.git synced 2025-04-17 10:10:20 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions 2

Set up the processing and return of processed date within the minion

Browse source
This commit is contained in:
Thomas S Hatch 2011-03-08 00:18:37 -07:00
parent 50bde04bb4
commit b46848d451
1 changed files with 17 additions and 8 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

25
salt/minion.py
View file

@ -5,6 +5,7 @@ Routines to set up a minion
import os
import distutils.sysconfig
import importlib
import re
# Import zeromq libs
import zmq
@ -62,13 +63,6 @@ class Minion(object):
print functions
return functions
def _verify_tgt(self, tgt):
'''
Checks the tgt information sent with a publication to see if it
matches the minion, takes a tgt string, returns a bool
'''
self.opts['hostname']
def _handle_payload(self, payload):
'''
Takes a payload from the master publisher and does whatever the
@ -98,7 +92,7 @@ class Minion(object):
or not data.has_key('arg'):
return ret
# Verify that the publication applies to this minion
if not self._verify_tgt(data['tgt']):
if not re.match(data['tgt'], self.opts['hostname']):
return ret
if self.functions.has_key(data['fun']):
@ -106,6 +100,21 @@ class Minion(object):
ret['jid'] = data['jid']
return ret
def _return_pub(self, ret):
'''
Returnt the data from the executed command to the master server
'''
context = zmq.Context()
socket = context.socket(zmq.REQ)
socket.connect(self.opts['master_uri'])
payload = {'enc': 'aes'}
load = {'return': ret['return'],
'cmd': '_return',
'jid': ret['jid'],
'hostname': self.opts['hostname']}
payload['load'] = self.crypticle.dumps(load)
socket.send_pyobj(payload)
def authenticate(self):
'''
Authenticate with the master, this method breaks the functional