1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
|
# Licensed to the Apache Software Foundation (ASF) under one or more
# contributor license agreements. See the NOTICE file distributed with
# this work for additional information regarding copyright ownership.
# The ASF licenses this file to You under the Apache License, Version 2.0
# (the "License"); you may not use this file except in compliance with
# the License. You may obtain a copy of the License at
#
# http://www.apache.org/licenses/LICENSE-2.0
#
# Unless required by applicable law or agreed to in writing, software
# distributed under the License is distributed on an "AS IS" BASIS,
# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
# See the License for the specific language governing permissions and
# limitations under the License.
from urlparse import urlparse
import time
import logging
import httplib
from ssl import SSLError
ERROR_SSL_WRONG_VERSION = "SSLError: Failed to connect. Please check openssl library versions. \n" +\
"Refer to: https://bugzilla.redhat.com/show_bug.cgi?id=1022468 for more details."
LOG_REQUEST_MESSAGE = "GET %s -> %s, body: %s"
logger = logging.getLogger()
class NetUtil:
CONNECT_SERVER_RETRY_INTERVAL_SEC = 10
HEARTBEAT_IDDLE_INTERVAL_SEC = 10
MINIMUM_INTERVAL_BETWEEN_HEARTBEATS = 0.1
# Url within server to request during status check. This url
# should return HTTP code 200
SERVER_STATUS_REQUEST = "{0}/ca"
# For testing purposes
DEBUG_STOP_RETRIES_FLAG = False
def checkURL(self, url):
"""Try to connect to a given url. Result is True if url returns HTTP code 200, in any other case
(like unreachable server or wrong HTTP code) result will be False.
Additionally returns body of request, if available
"""
logger.info("Connecting to " + url)
responseBody = ""
try:
parsedurl = urlparse(url)
ca_connection = httplib.HTTPSConnection(parsedurl[1])
ca_connection.request("GET", parsedurl[2])
response = ca_connection.getresponse()
status = response.status
if status == 200:
responseBody = response.read()
logger.debug(LOG_REQUEST_MESSAGE, url, str(status), responseBody)
return True, responseBody
else:
logger.warning(LOG_REQUEST_MESSAGE, url, str(status), responseBody)
return False, responseBody
except SSLError as slerror:
logger.error(str(slerror))
logger.error(ERROR_SSL_WRONG_VERSION)
return False, responseBody
except Exception, e:
logger.warning("Failed to connect to " + str(url) + " due to " + str(e) + " ")
return False, responseBody
def try_to_connect(self, server_url, max_retries, logger=None):
"""Try to connect to a given url, sleeping for CONNECT_SERVER_RETRY_INTERVAL_SEC seconds
between retries. No more than max_retries is performed. If max_retries is -1, connection
attempts will be repeated forever until server is not reachable
Returns count of retries
"""
if logger is not None:
logger.debug("Trying to connect to %s", server_url)
retries = 0
while (max_retries == -1 or retries < max_retries) and not self.DEBUG_STOP_RETRIES_FLAG:
server_is_up, responseBody = self.checkURL(self.SERVER_STATUS_REQUEST.format(server_url))
if server_is_up:
break
else:
if logger is not None:
logger.warn('Server at {0} is not reachable, sleeping for {1} seconds...'.format(server_url,
self.CONNECT_SERVER_RETRY_INTERVAL_SEC))
retries += 1
time.sleep(self.CONNECT_SERVER_RETRY_INTERVAL_SEC)
return retries
|
