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

switch to threading

Browse source
This commit is contained in:
Daniel Wallace 2017-12-04 10:17:26 -07:00
parent d100437639
commit 190110be8f
No known key found for this signature in database
GPG key ID: 5FA5E5544F010D48
1 changed files with 2 additions and 5 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

7
salt/master.py
View file

@ -19,6 +19,7 @@ import logging
import collections
import multiprocessing
import salt.serializers.msgpack
import threading
# Import third party libs
try:
@ -1965,11 +1966,7 @@ class ClearFuncs(object):
ssh_minions = ssh._prep_ssh(**clear_load).targets.keys()
if ssh_minions:
minions.extend(ssh_minions)
def wrap_ssh(**kwargs):
salt.utils.process.daemonize(False)
ssh.cmd(**kwargs)
salt.utils.process.SignalHandlingMultiprocessingProcess(target=wrap_ssh, kwargs=clear_load).start()
threading.Thread(target=ssh.cmd, kwargs=clear_load).start()
self._send_pub(payload)