From 5214e54ff0b323a0093019362371f341abc02614 Mon Sep 17 00:00:00 2001 From: Yuming Zhu Date: Nov 27 2018 15:39:11 +0000 Subject: set default value for timeout and auth_timeout in read_config and do not override auth_timeout = 0 by default: 60 which means no timeout --- diff --git a/koji/__init__.py b/koji/__init__.py index d6ba9fe..f529eb7 100644 --- a/koji/__init__.py +++ b/koji/__init__.py @@ -268,6 +268,10 @@ BASEDIR = '/mnt/koji' # default task priority PRIO_DEFAULT = 20 +# default timeouts +DEFAULT_REQUEST_TIMEOUT = 60 * 60 * 12 +DEFAULT_AUTH_TIMEOUT = 60 + ## BEGIN kojikamid dup #Exceptions @@ -1647,8 +1651,8 @@ def read_config(profile_name, user_config=None): 'offline_retry' : None, 'offline_retry_interval' : None, 'keepalive' : True, - 'timeout' : None, - 'auth_timeout' : None, + 'timeout' : DEFAULT_REQUEST_TIMEOUT, + 'auth_timeout' : DEFAULT_AUTH_TIMEOUT, 'use_fast_upload': False, 'upload_blocksize': 1048576, 'poll_interval': 6, @@ -2077,7 +2081,7 @@ class ClientSession(object): self.logger = logging.getLogger('koji') self.rsession = None self.new_session() - self.opts.setdefault('timeout', 60 * 60 * 12) + self.opts.setdefault('timeout', DEFAULT_REQUEST_TIMEOUT) def new_session(self): @@ -2236,13 +2240,14 @@ class ClientSession(object): # Force a new session self.new_session() - # 60 second timeout during login sinfo = None old_env = {} old_opts = self.opts self.opts = old_opts.copy() try: - self.opts['timeout'] = self.opts.get('auth_timeout') or 60 + # temporary timeout value during login + self.opts['timeout'] = self.opts.get('auth_timeout', + DEFAULT_AUTH_TIMEOUT) kwargs = {} if keytab: old_env['KRB5_CLIENT_KTNAME'] = os.environ.get('KRB5_CLIENT_KTNAME') @@ -2304,10 +2309,11 @@ class ClientSession(object): # Force a new session self.new_session() - # 60 second timeout during login old_opts = self.opts self.opts = old_opts.copy() - self.opts['timeout'] = self.opts.get('auth_timeout') or 60 + # temporary timeout value during login + self.opts['timeout'] = self.opts.get('auth_timeout', + DEFAULT_AUTH_TIMEOUT) self.opts['cert'] = cert self.opts['serverca'] = serverca try: