|
@@ -91,9 +91,10 @@ class SessionSinglePool(requests.Session):
|
|
self.adapters.clear()
|
|
self.adapters.clear()
|
|
|
|
|
|
https_adapter = threadLocal.__dict__.setdefault('https_adapter', next(https_adapters))
|
|
https_adapter = threadLocal.__dict__.setdefault('https_adapter', next(https_adapters))
|
|
- http_adapter = threadLocal.__dict__.setdefault('http_adapter', next(http_adapters))
|
|
|
|
self.mount('https://', https_adapter)
|
|
self.mount('https://', https_adapter)
|
|
- self.mount('http://', http_adapter)
|
|
|
|
|
|
+ if get_enable_http_protocol():
|
|
|
|
+ http_adapter = threadLocal.__dict__.setdefault('http_adapter', next(http_adapters))
|
|
|
|
+ self.mount('http://', http_adapter)
|
|
|
|
|
|
def close(self):
|
|
def close(self):
|
|
"""Call super, but clear adapters since there are managed globaly"""
|
|
"""Call super, but clear adapters since there are managed globaly"""
|
|
@@ -106,6 +107,17 @@ def set_timeout_for_thread(timeout, start_time=None):
|
|
threadLocal.start_time = start_time
|
|
threadLocal.start_time = start_time
|
|
|
|
|
|
|
|
|
|
|
|
+def set_enable_http_protocol(enable_http):
|
|
|
|
+ threadLocal.enable_http = enable_http
|
|
|
|
+
|
|
|
|
+
|
|
|
|
+def get_enable_http_protocol():
|
|
|
|
+ try:
|
|
|
|
+ return threadLocal.enable_http
|
|
|
|
+ except AttributeError:
|
|
|
|
+ return False
|
|
|
|
+
|
|
|
|
+
|
|
def reset_time_for_thread():
|
|
def reset_time_for_thread():
|
|
threadLocal.total_time = 0
|
|
threadLocal.total_time = 0
|
|
|
|
|