+ self.updateView()
+ self.parent().signalAll("rspecUpdated")
+
+ 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 search(self, search_string):
+ self.filterModel.setHostNameFilter(str(search_string))
+
+ def filter(self, filter_string):
+ self.filterModel.setNodeStatusFilter(str(filter_string))
+
+ def itemStatus(self, item):
+ statusItem = item.parent().child(item.row(), MEMBERSHIP_STATUS_COLUMN)
+ return str(statusItem.data(Qt.DisplayRole).toString())
+
+ def itemText(self, item):
+ return str(item.data(Qt.DisplayRole).toString())
+
+ # Recursively walk the tree, making changes to the RSpec
+ def process_subtree(self, rspec, rspec_node_names, resource_node_names, item, depth = 0):
+ changeAdd = 0
+ changeRemove = 0
+ changeAddTag = 0
+ changeRemoveTag = 0
+ model = self.nodeModel
+
+ if depth in [0, 1]:
+ pass
+ elif depth == 2: # Hostname
+ hostname = self.itemText(item)
+ testbed = self.itemText(item.parent())
+ status = self.itemStatus(item)
+ if status == node_status['add']:
+ print "Add hostname: %s" % hostname
+
+ resource_node = resource_node_names.get(hostname, None)
+
+ if resource_node==None:
+ print "Error: Failed to find %s in resources rspec" % hostname
+ else:
+ if not (hostname in rspec_node_names):
+ network_name = Xrn(resource_node['component_manager_id']).get_hrn()
+ rspec.version.add_network(network_name)
+ rspec.version.add_nodes([resource_node])
+ rspec.version.add_slivers([str(hostname)])
+ changeAdd += 1
+ elif status == node_status['remove']:
+ print "Remove hostname: %s" % hostname
+ rspec.version.remove_slivers([str(hostname)])
+ changeRemove += 1
+ elif depth == 3: # Tag
+ tag, value = self.itemText(item).split(": ")
+ status = self.itemStatus(item)
+ tag = "%s" % tag # Prevent weird error from lxml
+ value = "%s" % value # Prevent weird error from lxml
+ hostname = self.itemText(item.parent())
+ testbed = self.itemText(item.parent().parent())
+ if status == tag_status['add']:
+ print "Add tag to (%s, %s): %s/%s " % (testbed, hostname, tag, value)
+ if hostname.startswith(default_tags):
+ rspec.version.add_default_sliver_attribute(tag, value, testbed)
+ else:
+ node = rspec_node_names.get(hostname, None)
+ if node:
+ rspec.version.add_sliver_attribute(node['component_id'], tag, value, testbed)
+ changeAddTag += 1
+ elif status == tag_status['remove']:
+ print "Remove tag from (%s, %s): %s/%s " % (testbed, hostname, tag, value)
+ if hostname.startswith(default_tags):
+ rspec.version.remove_default_sliver_attribute(tag, value, testbed)
+ else:
+ node = rspec_node_names.get(hostname, None)
+ if node:
+ rspec.version.remove_sliver_attribute(node['component_id'], tag, value, testbed)
+ changeRemoveTag += 1
+
+ children = item.rowCount()
+ for row in range(0, children):
+ (c, ca, cr, cat, crt) = self.process_subtree(rspec, rspec_node_names, resource_node_names, item.child(row), depth + 1)
+ changeAdd = changeAdd + ca
+ changeRemove = changeRemove + cr
+ changeAddTag = changeAddTag + cat
+ changeRemoveTag = changeRemoveTag + crt
+
+ change = changeAdd + changeRemove + changeAddTag + changeRemoveTag
+
+ return (change, changeAdd, changeRemove, changeAddTag, changeRemoveTag)