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
|
"""RPC client access to cobalt components.
Classes:
ComponentProxy -- an RPC client proxy to Cobalt components
Functions:
load_config -- read configuration files
"""
__revision__ = '$Revision: $'
from xmlrpclib import _Method
import httplib
import logging
import socket
import ssl
import time
import urlparse
import xmlrpclib
__all__ = ["ComponentProxy", "RetryMethod", "SSLHTTPConnection", "XMLRPCTransport"]
class RetryMethod(_Method):
"""Method with error handling and retries built in"""
log = logging.getLogger('xmlrpc')
def __call__(self, *args):
max_retries = 4
for retry in range(max_retries):
try:
return _Method.__call__(self, *args)
except xmlrpclib.ProtocolError, err:
self.log.error("Server failure: Protocol Error: %s %s" % \
(err.errcode, err.errmsg))
raise xmlrpclib.Fault(20, "Server Failure")
except xmlrpclib.Fault:
raise
except socket.error, err:
if retry == 3:
self.log.error("Server failure: %s" % err)
raise xmlrpclib.Fault(20, err)
except:
self.log.error("Unknown failure", exc_info=1)
break
time.sleep(0.5)
raise xmlrpclib.Fault(20, "Server Failure")
# sorry jon
xmlrpclib._Method = RetryMethod
class SSLHTTPConnection(httplib.HTTPConnection):
def connect(self):
rawsock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
rawsock.settimeout(90)
self.sock = ssl.SSLSocket(rawsock,
suppress_ragged_eofs=True)
self.sock.connect((self.host, self.port))
self.sock.closeSocket = True
class XMLRPCTransport(xmlrpclib.Transport):
def make_connection(self, host):
host = self.get_host_info(host)[0]
http = SSLHTTPConnection(host)
https = httplib.HTTP()
https._setup(http)
return https
def ComponentProxy (url, user=None, password=None, fingerprint=None,
key=None, cert=None):
"""Constructs proxies to components.
Arguments:
component_name -- name of the component to connect to
Additional arguments are passed to the ServerProxy constructor.
"""
if user and password:
method, path = urlparse.urlparse(url)[:2]
newurl = "%s://%s:%s@%s" % (method, user, password, path)
else:
newurl = url
ssl_trans = XMLRPCTransport()
return xmlrpclib.ServerProxy(newurl, allow_none=True, transport=ssl_trans)
|
