- self.submit_agg = self.submit_aggs.pop()
-
- urlParts = urlparse.urlsplit(self.submit_agg[1])
- amPort = urlParts.port
- amAddr = urlParts.hostname+urlParts.path
-
- self.setStatus(statusStr + "Submitting to %s..." % (self.submit_agg[0]))
-
- self.connect(self.process, SIGNAL('finished()'), self.submitNextAggFinished)
- self.process.applyRSpec(self.submit_rspec, aggAddr = amAddr, aggPort = amPort, saveObtained=False)
-
- def submitNextAggFinished(self):
- self.disconnect(self.process, SIGNAL('finished()'), self.submitNextAggFinished)
-
- faultString = self.process.getFaultString()
- if not faultString:
- self.submit_aggSuccessCount+=1
- str = "<font color='green'>Succeeded on %s.</font> " % (self.submit_agg[0])
- else:
- self.submit_aggFailCount+=1
- str = "<font color='red'>Failed on %s.</font> " % (self.submit_agg[0]) # , faultString)
-
- self.submitNextAgg(str)
-
- def deleteNextAggFinished(self):
- self.disconnect(self.process, SIGNAL('finished()'), self.deleteNextAggFinished)
-
- faultString = self.process.getFaultString()
- if not faultString:
- str = "<font color='green'>Succeeded deleteslivers on %s.</font> " % (self.delete_agg[0])
- else:
- str = "<font color='red'>Failed deleteslivers on %s.</font> " % (self.delete_agg[0]) # , faultString)