6 from sfa.client.sfi import Sfi
7 from sfa.util.sfalogging import sfa_logger,sfa_logger_goes_to_console
8 import sfa.util.xmlrpcprotocol as xmlrpcprotocol
10 m_url_with_proto=re.compile("\w+://(?P<hostname>[\w\-\.]+):(?P<port>[0-9]+)/.*")
11 m_url_without_proto=re.compile("(?P<hostname>[\w\-\.]+):(?P<port>[0-9]+).*")
12 def url_to_hostname_port (url):
14 match=m_url_with_proto.match(url)
16 return (match.group('hostname'),match.group('port'))
17 match=m_url_without_proto.match(url)
19 return (match.group('hostname'),match.group('port'))
20 return ('undefined','???')
24 def __init__ (self,url,name=None):
28 (self.hostname,self.port)=url_to_hostname_port(url)
29 self.ip=socket.gethostbyname(self.hostname)
34 self.hostname="undefined"
39 def equal (self,against):
40 return (self.ip == against.ip) and (self.port == against.port)
42 def set_name (self,name):
43 if name and name not in self.names:
44 self.names.append(name)
47 return "http://%s:%s"%(self.hostname,self.port)
49 # connect to server and trigger GetVersion
50 def get_version(self):
53 # dummy to meet Sfi's expectations for its 'options' field
56 options=DummyOptions()
61 key_file = client.get_key_file()
62 cert_file = client.get_cert_file(key_file)
63 url="http://%s:%s/"%(self.hostname,self.port)
64 sfa_logger().info('issuing get version at %s'%url)
65 server=xmlrpcprotocol.get_server(url, key_file, cert_file, options)
66 self._version=server.GetVersion()
75 # provide the entry points (a list of interfaces)
79 # scan from the given interfaces as entry points
80 def scan(self,interfaces):
83 if not isinstance(interfaces,list):
84 interfaces=[interfaces]
85 # should add nodes, but with what name ?
88 def was_scanned (interface):
90 if interface.equal(i): return i
92 # keep on looping until we reach a fixed point
94 for interface in to_scan:
95 version=interface.get_version()
96 if 'peers' in version:
97 for (next_name,next_url) in version['peers'].items():
99 next_interface=Interface(next_url)
100 seen_interface=was_scanned(next_interface)
103 seen_interface.set_name(next_name)
105 sfa_logger().info('adding %s'%next_interface.url())
106 to_scan.append(next_interface)
108 scanned.append(interface)
109 to_scan.remove(interface)
113 sfa_logger_goes_to_console()
115 entry=Interface("http://www.planet-lab.eu:12345/")
118 if __name__ == '__main__':