X-Git-Url: http://git.onelab.eu/?a=blobdiff_plain;f=safexmlrpc.py;fp=safexmlrpc.py;h=71799ff2e2169e4e72d9bee610e078c73a05102d;hb=347202d6aab0acc9126767ceaf89df28a29a82ad;hp=f4bd5afe3baf562f5c4d42b855d194af63987cff;hpb=d99180f837ae3fcd754a5cdc0a17a9efbe16a2fe;p=nodemanager.git diff --git a/safexmlrpc.py b/safexmlrpc.py index f4bd5af..71799ff 100644 --- a/safexmlrpc.py +++ b/safexmlrpc.py @@ -4,15 +4,24 @@ import curlwrapper import xmlrpclib -CURL = '/usr/bin/curl' - class CertificateCheckingSafeTransport(xmlrpclib.Transport): + def __init__(self, cacert, timeout): + self.cacert = cacert + self.timeout = timeout + def request(self, host, handler, request_body, verbose=0): self.verbose = verbose try: - contents = curlwrapper.retrieve('https://%s%s' % (host, handler), request_body) + contents = curlwrapper.retrieve('https://%s%s' % (host, handler), + cacert = self.cacert, + postdata = request_body, + timeout = self.timeout) return xmlrpclib.loads(contents)[0] - except curlwrapper.CurlException, e: raise xmlrpclib.ProtocolError(host + handler, -1, str(e), '') + except curlwrapper.CurlException, e: + raise xmlrpclib.ProtocolError(host + handler, -1, str(e), '') class ServerProxy(xmlrpclib.ServerProxy): - def __init__(self, handler, *args, **kw_args): xmlrpclib.ServerProxy.__init__(self, handler, CertificateCheckingSafeTransport()) + def __init__(self, uri, cacert, timeout = 300, **kwds): + xmlrpclib.ServerProxy.__init__(self, uri, + CertificateCheckingSafeTransport(cacert, timeout), + **kwds)