+ def setStatus(self, msg, timeout=None):
+ self.parent().setStatus(msg, timeout)
+
+ def checkRunningProcess(self):
+ if self.process.isRunning():
+ self.setStatus("<font color='red'>There is already a process running. Please wait.</font>")
+ return True
+ return False
+
+ def filter(self, filter_string):
+ # for hierarchical models QSortFilterProxyModel applies the
+ # sort recursively. if the parent doesn't match the criteria
+ # we won't be able to match the children. so we need to match
+ # parent (by matching the network_names)
+ networks = ["^%s$" % n for n in self.network_names]
+ filters = networks + [str(filter_string)]
+ self.filterModel.setFilterRegExp(QRegExp('|'.join(filters)))
+
+ def submit(self):
+ if self.checkRunningProcess():
+ return
+
+ rspec = RSpec(self.readSliceRSpec())
+
+ no_change = True
+ all_child = self.nodeModel.rootItem.allChildItems()
+ for c in all_child:
+ testbed, hostname, status = c.itemData
+ if isinstance(status, QVariant):
+ status = status.toString()
+
+ if status == node_status['add']:
+ rspec.add_sliver(hostname)
+ no_change = False
+ elif str(status) == node_status['remove']:
+ rspec.remove_sliver(hostname)
+ no_change = False
+
+ if no_change:
+ self.setStatus("<font color=red>No change in slice data. Not submitting!</font>", timeout=3000)
+ return
+
+ self.disconnect(self.process, SIGNAL('finished()'), self.refreshFinished)
+ self.connect(self.process, SIGNAL('finished()'), self.submitFinished)
+
+ self.process.applyRSpec(rspec)
+ self.setStatus("Sending slice data (RSpec). This will take some time...")
+
+