refs #945 put more info in ogAdmClient/status, make reply async
parent
2d6cd923a0
commit
58b7f0d406
|
@ -306,15 +306,26 @@ class ogAdmClientWorker (ogLiveWorker):
|
|||
|
||||
logger.info ('onActivation ok')
|
||||
|
||||
@check_secret
|
||||
def process_status (self, path, get_params, post_params, server):
|
||||
def do_status (self, post_params):
|
||||
cfg = self.LeeConfiguracion()
|
||||
thr_status = {}
|
||||
for k in self.thread_list:
|
||||
thr_status[k] = {
|
||||
'running': self.thread_list[k]['running'],
|
||||
'result': self.thread_list[k]['result'],
|
||||
}
|
||||
return thr_status
|
||||
return {
|
||||
'nfn': 'RESPUESTA_status',
|
||||
'mac': '12:23:34:45:56:67',
|
||||
'ip': self.IPlocal,
|
||||
'cfg': cfg,
|
||||
'threads': thr_status,
|
||||
}
|
||||
|
||||
@check_secret
|
||||
def process_status (self, path, get_params, post_params, server):
|
||||
logger.debug ('in process_status, path "{}" get_params "{}" post_params "{}" server "{}"'.format (path, get_params, post_params, server))
|
||||
return self._long_running_job ('status', self.do_status, args=(post_params,))
|
||||
|
||||
@check_secret
|
||||
def process_popup (self, path, get_params, post_params, server):
|
||||
|
|
Loading…
Reference in New Issue