diff options
author | Morgan Richomme <morgan.richomme@orange.com> | 2018-09-19 08:24:11 +0000 |
---|---|---|
committer | Gerrit Code Review <gerrit@opnfv.org> | 2018-09-19 08:24:11 +0000 |
commit | 27830b0d5e7601612069b65e69f79292ab849f7a (patch) | |
tree | 63fa539948c36ced7cfe96b46a537cb1a958e861 /reporting/api/extension/client.py | |
parent | fda356248fc00a07893f55c2913bb6ea222a528f (diff) | |
parent | 6ffbb81ec808aa615c7dad95fe6328ea5cc9c7b5 (diff) |
Merge "Add testing gating reporting page"
Diffstat (limited to 'reporting/api/extension/client.py')
-rw-r--r-- | reporting/api/extension/client.py | 15 |
1 files changed, 15 insertions, 0 deletions
diff --git a/reporting/api/extension/client.py b/reporting/api/extension/client.py new file mode 100644 index 0000000..03371fd --- /dev/null +++ b/reporting/api/extension/client.py @@ -0,0 +1,15 @@ +from tornado.simple_httpclient import SimpleAsyncHTTPClient +from tornado.log import gen_log + + +class NoQueueTimeoutHTTPClient(SimpleAsyncHTTPClient): + def fetch_impl(self, request, callback): + key = object() + + self.queue.append((key, request, callback)) + self.waiting[key] = (request, callback, None) + + self._process_queue() + + if self.queue: + gen_log.debug("max_clients limit reached, request queued.") |