mirror of
https://github.com/saltstack/salt.git
synced 2025-04-17 10:10:20 +00:00
Merge pull request #48109 from rallytime/bp-47851
Back-port #47851 to 2018.3
This commit is contained in:
commit
2902ee0b14
1 changed files with 10 additions and 4 deletions
|
@ -342,8 +342,8 @@ class FileserverUpdate(salt.utils.process.SignalHandlingMultiprocessingProcess):
|
|||
'''
|
||||
A process from which to update any dynamic fileserver backends
|
||||
'''
|
||||
def __init__(self, opts, log_queue=None):
|
||||
super(FileserverUpdate, self).__init__(log_queue=log_queue)
|
||||
def __init__(self, opts, **kwargs):
|
||||
super(FileserverUpdate, self).__init__(**kwargs)
|
||||
self.opts = opts
|
||||
self.update_threads = {}
|
||||
# Avoid circular import
|
||||
|
@ -356,11 +356,17 @@ class FileserverUpdate(salt.utils.process.SignalHandlingMultiprocessingProcess):
|
|||
# process so that a register_after_fork() equivalent will work on Windows.
|
||||
def __setstate__(self, state):
|
||||
self._is_child = True
|
||||
self.__init__(state['opts'], log_queue=state['log_queue'])
|
||||
self.__init__(
|
||||
state['opts'],
|
||||
log_queue=state['log_queue'],
|
||||
log_queue_level=state['log_queue_level']
|
||||
)
|
||||
|
||||
def __getstate__(self):
|
||||
return {'opts': self.opts,
|
||||
'log_queue': self.log_queue}
|
||||
'log_queue': self.log_queue,
|
||||
'log_queue_level': self.log_queue_level
|
||||
}
|
||||
|
||||
def fill_buckets(self):
|
||||
'''
|
||||
|
|
Loading…
Add table
Reference in a new issue