+ self.setStatus("<font color='red'>getSliceMgrVersion failed: %s</font>" % (faultString))
+
+ def deleteNextAgg(self, statusStr=""):
+ if (self.delete_aggs == []):
+ self.submitNextAgg(statusStr)
+ return
+
+ self.delete_agg = self.delete_aggs.pop()
+
+ urlParts = urlparse.urlsplit(self.delete_agg[1])
+ amPort = urlParts.port
+ amAddr = urlParts.hostname+urlParts.path
+
+ self.setStatus(statusStr + "Deleting slivers on %s..." % (self.delete_agg[0]))
+
+ self.connect(self.process, SIGNAL('finished()'), self.deleteNextAggFinished)
+ self.process.deleteSlivers(aggAddr = amAddr, aggPort = amPort)
+
+ def submitNextAgg(self, statusStr=""):
+ if (self.submit_aggs == []):
+ self.setStatus(statusStr + "<font color='green'>Finished submitting. %d/%d aggs succeeded.</font>" %
+ (self.submit_aggSuccessCount,self.submit_aggSuccessCount+self.submit_aggFailCount))
+ QTimer.singleShot(2500, self.refresh)
+ return
+
+ 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)
+
+ self.deleteNextAgg(str)
+
+ def renew(self):
+ dlg = RenewWindow(parent=self)
+ dlg.exec_()