summaryrefslogtreecommitdiffstats
path: root/reporting/api/extension
diff options
context:
space:
mode:
authorchenjiankun <chenjiankun1@huawei.com>2018-04-21 08:53:03 +0000
committerchenjiankun <chenjiankun1@huawei.com>2018-04-21 09:03:09 +0000
commit6ffbb81ec808aa615c7dad95fe6328ea5cc9c7b5 (patch)
tree0630754b3a6a8bf89c441392ef59d4e83db6c76a /reporting/api/extension
parentc77cf76cbf31e65aa599f71f33d59abc267b4e50 (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__.py0
-rw-r--r--reporting/api/extension/client.py15
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.")