Bug #59580 » 0001-mgr-restful-trim-reslts-finished-and-failed-lists-to.patch
| src/pybind/mgr/restful/module.py | ||
|---|---|---|
|
import traceback
|
||
|
import socket
|
||
|
import fcntl
|
||
|
from typing import cast
|
||
|
from . import common
|
||
|
from . import context
|
||
| ... | ... | |
|
if self.running[index].tag == tag:
|
||
|
if self.running[index].r == 0:
|
||
|
self.finished.append(self.running.pop(index))
|
||
|
else:
|
||
|
self.failed.append(self.running.pop(index))
|
||
|
return True
|
||
|
# No such tag found
|
||
| ... | ... | |
|
{'name': 'server_port'},
|
||
|
{'name': 'key_file'},
|
||
|
{'name': 'enable_auth', 'type': 'bool', 'default': True},
|
||
|
{'name': 'max_requests', 'type': 'int', 'default': 5000},
|
||
|
]
|
||
|
COMMANDS = [
|
||
| ... | ... | |
|
self.stop_server = False
|
||
|
self.serve_event = threading.Event()
|
||
|
self.max_requests = cast(int, self.get_localized_module_option('max_requests', 5000))
|
||
|
|
||
|
def serve(self):
|
||
|
self.log.debug('serve enter')
|
||
| ... | ... | |
|
with self.requests_lock:
|
||
|
request = CommandsRequest(_request)
|
||
|
self.requests.append(request)
|
||
|
self.requests = self.requests[-self.max_requests:]
|
||
|
if kwargs.get('wait', 0):
|
||
|
while not request.is_finished():
|
||
|
time.sleep(0.001)
|
||
