@ -91,9 +91,10 @@ class SessionSinglePool(requests.Session):
self . adapters . clear ( )
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 ( ' 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 ) :
""" 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
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 ( ) :
threadLocal . total_time = 0