diff options
author | chenjiankun <chenjiankun1@huawei.com> | 2018-04-21 08:53:03 +0000 |
---|---|---|
committer | chenjiankun <chenjiankun1@huawei.com> | 2018-04-21 09:03:09 +0000 |
commit | 6ffbb81ec808aa615c7dad95fe6328ea5cc9c7b5 (patch) | |
tree | 0630754b3a6a8bf89c441392ef59d4e83db6c76a /reporting/api/extension | |
parent | c77cf76cbf31e65aa599f71f33d59abc267b4e50 (diff) |
Add testing gating reporting page
Change-Id: I9f46d684a11b7999defffe983fc3224ef1a50412
Signed-off-by: chenjiankun <chenjiankun1@huawei.com>
Diffstat (limited to 'reporting/api/extension')
-rw-r--r-- | reporting/api/extension/__init__.py | 0 | ||||
-rw-r--r-- | reporting/api/extension/client.py | 15 |
2 files changed, 15 insertions, 0 deletions
diff --git a/reporting/api/extension/__init__.py b/reporting/api/extension/__init__.py new file mode 100644 index 0000000..e69de29 --- /dev/null +++ b/reporting/api/extension/__init__.py 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.") |