6 def retrieve(uc, endpoints):
9 retriever = arc.ComputingServiceRetriever(uc, endpoints)
12 print "ComputingServiceRetriever created with the following endpoints:"
13 for endpoint
in endpoints:
14 print "-", endpoint.str()
16 print "Waiting for the results..."
24 uc.ProxyPath(
"/tmp/x509up_u%s" % os.getuid())
25 uc.CACertificatesDirectory(
"/etc/grid-security/certificates")
30 arc.Endpoint(
"index1.nordugrid.org:2135/Mds-Vo-name=NorduGrid,o=grid", arc.Endpoint.REGISTRY,
"org.nordugrid.ldapegiis"),
33 arc.Endpoint(
"arc-emi.grid.upjs.sk/O=Grid/Mds-Vo-Name=ARC-EMI", arc.Endpoint.REGISTRY)
36 retriever = retrieve(uc, registries)
39 print "Discovered ComputingServices:",
", ".
join([service.Name
for service
in retriever])
42 targets = retriever.GetExecutionTargets()
43 print "Number of ExecutionTargets on these ComputingServices:", len(targets)
46 computing_elements = [
48 arc.Endpoint(
"piff.hep.lu.se", arc.Endpoint.COMPUTINGINFO,
"org.nordugrid.ldapglue2"),
50 arc.Endpoint(
"pgs03.grid.upjs.sk", arc.Endpoint.COMPUTINGINFO)
53 retriever2 = retrieve(uc, computing_elements)
56 targets2 = retriever2.GetExecutionTargets()
58 print "The discovered ExecutionTargets:"
59 for target
in targets2:
65 arc.Endpoint(
"arc-emi.grid.upjs.sk/O=Grid/Mds-Vo-Name=ARC-EMI", arc.Endpoint.REGISTRY),
66 arc.Endpoint(
"piff.hep.lu.se", arc.Endpoint.COMPUTINGINFO,
"org.nordugrid.ldapglue2")
69 retriever3 = retrieve(uc, endpoints)
71 print "Discovered ComputingServices:",
", ".
join([service.Name
for service
in retriever3])
78 arc.ThreadInitializer().waitExit()