X-Git-Url: http://git.onelab.eu/?a=blobdiff_plain;f=sfa%2Ffederica%2Ffdshell.py;h=179c8516d24f1133fe38e2d2991aec6a38634aae;hb=04a3f20dc71bf8b3f96b1e3172623aa346a638a7;hp=42ec030f198bbf05b276d53a95f65f2e9788a9cc;hpb=04255538dbacfa52a45e8439b9c9ea590a82dc47;p=sfa.git diff --git a/sfa/federica/fdshell.py b/sfa/federica/fdshell.py index 42ec030f..179c8516 100644 --- a/sfa/federica/fdshell.py +++ b/sfa/federica/fdshell.py @@ -1,6 +1,6 @@ -import xmlrpclib - from sfa.util.sfalogging import logger +from sfa.util.py23 import xmlrpc_client + class FdShell: """ @@ -8,21 +8,21 @@ class FdShell: This class can receive the XMLRPC calls to the federica testbed For safety this is limited to a set of hard-coded calls """ - - direct_calls = [ 'listAvailableResources', - 'listSliceResources', - 'createSlice', - 'deleteSlice', - 'getRSpecVersion', - 'listSlices', + + direct_calls = ['listAvailableResources', + 'listSliceResources', + 'createSlice', + 'deleteSlice', + 'getRSpecVersion', + 'listSlices', ] - def __init__ ( self, config ) : - url=config.SFA_FEDERICA_URL + def __init__(self, config): + url = config.SFA_FEDERICA_URL # xxx not sure if java xmlrpc has support for None - # self.proxy = xmlrpclib.Server(url, verbose = False, allow_none = True) + # self.proxy = xmlrpc_client.ServerProxy(url, verbose = False, allow_none = True) # xxx turn on verbosity - self.proxy = xmlrpclib.Server(url, verbose = True) + self.proxy = xmlrpc_client.ServerProxy(url, verbose=True) # xxx get credentials from the config ? # right now basic auth data goes into the URL @@ -30,12 +30,13 @@ class FdShell: def __getattr__(self, name): def func(*args, **kwds): if name not in FdShell.direct_calls: - raise Exception, "Illegal method call %s for FEDERICA driver"%(name) - logger.info("Issuing %s args=%s kwds=%s to federica"%\ - (name,args,kwds)) + raise Exception( + "Illegal method call %s for FEDERICA driver" % (name)) + logger.info("Issuing %s args=%s kwds=%s to federica" % + (name, args, kwds)) # result=getattr(self.proxy, "AggregateManager.%s"%name)(credential, *args, **kwds) - result=getattr(self.proxy, "AggregateManager.%s"%name)(*args, **kwds) - logger.debug('FdShell %s (%s) returned ... '%(name,name)) + result = getattr(self.proxy, "AggregateManager.%s" % + name)(*args, **kwds) + logger.debug('FdShell %s (%s) returned ... ' % (name, name)) return result return func -