#!/usr/bin/python

import sys, os
try:
	import pygtk
	pygtk.require("2.0")
except:
	pass

try:
	import gtk
	import gtk.glade
except:
	print "Failed to import gtk.glade"
	sys.exit(1)

top_window = None

totem_option_table = {
	"version":{"doc":"The only valid version is 2", 
		   "type":"int",
		   "default_value":2,
		   "suggested_value":2},
	"nodeid":{"doc":"The fixed 32 bit value to indentify node to cluster membership. Optional for IPv4, and required for IPv6. 0 is reserved for other usage", 
		  "type":"int",
		  "default_value":70912},
	"clear_node_high_bit":{"doc":"To make sure the auto-generated nodeid is positive", 
			       "default_value":"yes"},
	"secauth":{"doc":"HMAC/SHA1 should be used to authenticate all message", 
		   "default_value":"off"},
	"rrp_mode":{"doc":"The mode for redundant ring. None is used when only 1 interface specified, otherwise, only active or passive may be choosen", 
		    "type":"select[none,active,passive]", "default_value":"none"},
	"netmtu":{"doc":"Size of MTU", "type":"int", "default_value":1500},
	"threads":{"doc":"How many threads should be used to encypt and sending message. Only have meanings when secauth is turned on", 
		   "type":"int", "default_value":0},
	"vsftype":{"doc":"The virtual synchrony filter type used to indentify a primary component. Change with care.", 
		   "default_value":"ykd",
		   "suggested_value":"none"},
	"token":{"doc":"Timeout for a token lost. in ms", 
		 "type":"int", "default_value":1000,
		 "suggested_value":10000},
	"token_retransmit":{"doc":"How long before receving a token then token is retransmitted. Don't change this value.", 
			    "type":"int", "default_value":238},
	"hold":{"doc":"How long the token should be held by representative when protocol is under low utilization. Don't change this value.", 
		"type":"int", "default_value":180},
	"token_retransmits_before_loss_const":{"doc":"How many token retransmits should be attempted before forming a new configuration.", 
					       "type":"int", "default_value":4,
					       "suggested_value":20},
	"join":{"doc":"How long to wait for join messages in membership protocol. in ms", 
		"type":"int", "default_value":50,
		"suggested_value":60},
	"send_join":{"doc":"This timeout specifies in milliseconds an upper range between 0 and send_join to wait before sending a join message.", 
		     "type":"int", "default_value":0},
	"consensus":{"doc":"How long to wait for consensus to be achieved before starting a new round of membership configuration.", 
		     "type":"int", "default_value":800,
		     "suggested_value":4800},
	"merge":{"doc":"How long to wait before checking for a partition when no multicast traffic is being sent.", 
		 "type":"int", "default_value":200},
	"downcheck":{"doc":"How long to wait before checking that a network interface is back up after it has been downed.", 
		     "type":"int", "default_value":1000},
	"fail_to_recv_const":{"doc":"How many rotations of the token without receiving any of the messages when messages should be received may occur before a new configuration is formed", 
			      "type":"int", "default_value":50},
	"seqno_unchanged_const":{"doc":"How many rotations of the token without any multicast traffic should occur before the merge detection timeout is started.", 
				 "type":"int", "default_value":30},
	"heartbeat_failure_allowed":{"doc":"Configures the optional HeartBeating mechanism for faster failure detection. 0 for disable.", "type":"int", "default_value":0},
	"max_network_delay":{"doc":"The approximate delay that your network takes to transport one packet from one machine to another.", 
			     "type":"int", "default_value":50},
	"window_size":{"doc":"The maximum number of messages that may be sent on one token rotation.", 
		       "type":"int", "default_value":50},
	"max_messages":{"doc":"The maximum number of messages that may be sent by one processor on receipt of the token.", 
			"type":"int", "default_value":17,
			"suggested_value":20},
	"rrp_problem_count_timeout":{"doc":"The time in milliseconds to wait before decrementing the problem count by 1 for a particular ring to ensure a link is not marked faulty for transient network failures.", 
				     "type":"int", "default_value":2000},
	"rrp_problem_count_threshhold":{"doc":"The number of times a problem is detected with a link before setting the link faulty.", 
					"type":"int", "default_value":10},
	"rrp_token_expired_timeout":{"doc":"This specifies the time in milliseconds to increment the problem counter for the redundant ring protocol after not having received a token from all rings for a particular processor.", "type":"int", "default_value":47},
	"keyfile":{"doc":"Location of key file. If not set, it defaults to the environoment OPENAIS_TOTEM_AUTHKEY_FILE, then /etc/ais/authkey", "default_value":"/etc/ais/authkey"},
	"key":{"doc":"The key itself in the configuration file. Should be 128 characters. Dont use the default value", "default_value":"CatchMeeCatchMeeCatchMeeCatchMeeCatchMeeCatchMeeCatchMeeCatchMeeCatchMeeCatchMeeCatchMeeCatchMeeCatchMeeCatchMeeCatchMeeCatchMee"}
}


aisexec_option_table = {
	"user":{"doc":"User to run aisexec as. Needs to be root for Pacemaker", "default_value":"root"}, 
	"group":{"doc":"Group to run aisexec as. Needs to be root for Pacemaker", "default_value":"root"}}

service_option_table = {
	"name":{"doc":"The name of the service", "default_value":"pacemaker"},
	"ver":{"doc":"Version", "default_value":"0"},
	"use_mgmtd":{"doc":"Default to start mgmtd with pacemaker", "default_value":"yes"},
	"expected_nodes":{"doc":"Nodes we expected to see in the cluster", "default_value":2},
	"expected_votes":{"doc":"Votes we expected to see in the cluster", "default_value":2},
	"quorum_votes":{"doc":"Votes needed to have the quorum", "default_value":1},
	"use_logd":{"doc":"Use logd for pacemaker", "default_value":"no"},
}

interface_option_table = {
	"ringnumber":{"doc":"The ringnumber assigned to this interface setting", "default_value":0, "type":"int"},
	"bindnetaddr":{"doc":"Network Address to be bind for this interface setting", "default_value":0},
	"mcastaddr":{"doc":"The multicast address to be used", "default_value":0},
	"mcastport":{"doc":"The multicast port to be used", "default_value":0, "type":"int"},
	}

event_option_table = {
	"delivery_queue_size":{"doc":"The full size of the outgoing  delivery queue to  the application", "default_value":1000},
	"delivery_queue_resume":{"doc":"When new events can be accepted by the event service when the delivery queue count of pending messages has reached this value",
				 "default_value":500},
}

amf_option_table = {
	"mode":{"doc":"Enable or disable AMF ", "default_value":"disable", "suggested_value":"disable"},
}
logging_option_table = {
	"debug":{"doc":"Whether or not turning on the debug information in the log", "default_value":"off",
		 "suggested_value":"off"},
	"fileline":{"doc":"Logging file line in the source code as well", "default_value":"off",
		    "suggested_value":"off"},
	"to_syslog":{"doc":"Log to syslog", "default_value":"yes",
		     "suggested_value":"yes"},
	"to_stderr":{"doc":"Log to the standard error output", "default_value":"yes", "suggested_value":"yes"},
	"to_file":{"doc":"Log to a specified file", "default_value":"no", "suggested_value":"no"},
	"logfile":{"doc":"Log to be saved in this specified file", "default_value":"/tmp/saved_pacemaker_log"},
	"syslog_facility":{"doc":"Facility in syslog", "default_value":"daemon", "suggested_value":"daemon"},
	"timestamp":{"doc":"Log timestamp as well", "default_value":"on", "suggested_value":"on"},
}
logger_option_table = {
	"ident":{"doc":"Ident for the logger, i.e. AMF", "default_value":"AMF"},
	"debug":{"doc":"Enable debug for this logger.", "default_value":"on"},
	"tags":{"doc":"Tags used for this logger.", "default_value":"enter|leave|trace1"},
	}

totem_options = {"interface":[]}
ais_options = {}
pacemaker_service_options = {}
service_options = {}
logging_options = {"logger":[]}
amf_options = {}
event_options = {}

def strip_comments_and_pending_space(line):
	return line.split('#')[0].rstrip()

def get_next_line(ff):
	l = ff.next()
	return strip_comments_and_pending_space(l)

def is_ais_true(s):
	return (s == "true" or s == "on" or s == "yes" or s == "y" or s == "1")

def generate_default_ais_options():
	ais_options["user"] = "root"
	ais_options["group"] = "root"

def fulfill_default_amf_options():
	if amf_options.get("mode", None) == None:
		amf_options["mode"] = "disable"

def fulfill_default_pacemaker_options ():
	pacemaker_service_options["name"] = "pacemaker"
	pacemaker_service_options["ver"] = "0"
	
def fulfill_default_logging_options ():
	for opt in logging_option_table.keys():
		if opt == "logger": continue
		sv = logging_option_table[opt].get("suggested_value", None)
		v = logging_options.get(opt, None)
		if v == None and sv != None:
			logging_options[opt] = sv

def fulfill_suggested_totem_options():
	totem_options["version"] = 2
	for opt in totem_option_table.keys():
		if opt == "interface": continue
		sv = totem_option_table[opt].get("suggested_value", None)
		v = totem_options.get(opt, None)
		if v == None and sv != None:
			totem_options[opt] = sv
			
def print_ais_options(f):
	f.write("aisexec {\n")
	for key in ais_options.keys():
		f.write("\t#%s\n\n" % (aisexec_option_table[key]["doc"]))
		f.write("\t%s:\t%s\n\n" % (key, ais_options[key]))
	f.write("}\n")	
	
def print_amf_options(f):
	f.write("amf {\n")
	for key in amf_options.keys ():
		f.write("\t#%s\n\n" % (amf_option_table[key]["doc"]))
		f.write("\t%s:\t%s\n\n" % (key, amf_options[key]))
	f.write("}\n")

def print_event_options(f):
	if event_options == {}: return
	f.write("event {\n")
	for key in event_options.keys ():
		f.write("\t#%s\n\n" % (event_option_table[key]["doc"]))
		f.write("\t%s:\t%s\n\n" % (key, event_options[key]))
	f.write("}\n")
		
def print_service_options(f):
	for key in service_options.keys():
		f.write("service {\n")
		for k1 in service_options[key].keys():
			f.write("\t%s:\t%s\n\n" % (k1, service_options[key][k1]))
		f.write("}\n")
		
def print_pacemaker_service_options(f):
	f.write("service {\n")
	for key in pacemaker_service_options.keys():
		if service_option_table.get(key, None) != None:
			f.write("\t#%s\n\n" % (service_option_table[key]["doc"]))
		f.write("\t%s:\t%s\n\n" % (key, pacemaker_service_options[key]))
	f.write("}\n")	
			
def print_logging_options(f):
	f.write("logging {\n")
	for key in logging_options.keys():
		if key == "logger":
			for log in logging_options["logger"]:
				f.write("\tlogger {\n")
				for l in log.keys():
					f.write("\t\t#%s\n\n" % (logger_option_table[l]["doc"]))
					f.write("\t\t%s:\t%s\n\n" % (l, log[l]))
				f.write("\t}\n")
			continue
		f.write("\t#%s\n\n" % (logging_option_table[key]["doc"]))
		f.write("\t%s:\t%s\n\n" % (key, logging_options[key]))
	f.write("}\n")

def print_totem_options(f):
	f.write("totem {\n")
	for key in totem_options.keys():
		if key == "interface":
			for inf in totem_options["interface"]:
				f.write("\tinterface {\n")
				for k in inf.keys():
					f.write("\t\t#%s\n\n" % (interface_option_table[k]["doc"]))
					f.write("\t\t%s:\t%s\n\n" % (k, inf[k]))
				f.write("\t}\n")
			continue
		f.write("\t#%s\n\n" % (totem_option_table[key]["doc"]))
		f.write("\t%s:\t%s\n\n" % (key, totem_options[key]))
	# We print out all possible configurations as well
	for opt in totem_option_table.keys():
		v = totem_options.get(opt, None)
		if v == None:
			f.write("\t#%s\n\n" % (totem_option_table[opt]["doc"]))
			f.write("\t#%s:\t%s\n\n" % (opt, totem_option_table[opt]["default_value"]))
	f.write("}\n")


def file_parser(file):
	global ais_options
	global totem_options
	global pacemaker_service_options
	global service_options
	global logging_options
	global amf_options
	global event_options
	
	for l in file:
		i = strip_comments_and_pending_space(l)
		if i == "":
			continue

		if i[-1] == "{":
			i = i.lstrip().split(" ")[0]
			if i == "aisexec":
				ais_options = opt_parser(file, aisexec_option_table)
			elif i == "service":
				o = opt_parser(file, service_option_table)
				if o.get("name", "") == "pacemaker":
					pacemaker_service_options = o
				elif o.get("name", "") != "":
					service_options[o["name"]] = o
				else:
					pass
			elif i == "totem":
				totem_options = opt_parser(file, totem_option_table)
			elif i == "logging":
				logging_options = opt_parser(file, logging_option_table)
			elif i == "amf":
				amf_options = opt_parser(file, amf_option_table)
			elif i == "event":
				event_options = opt_parser(file, event_option_table)
			else:
				pass
	
def opt_parser(file, options):
	result = {}
	i = ""
	while (i == ""):
		i = get_next_line(file)

	while (i[-1] != "}"):
		if (i[-1] == "{"):
			if i.lstrip().split(" ")[0] == "interface":
				infs = result.get("interface", [])
				infs.append(opt_parser(file, interface_option_table))
				result["interface"] = infs		
			elif i.lstrip().split(" ")[0] == "logger":
				logs = result.get("logger", [])
				logs.append(opt_parser(file, logger_option_table))
				result["logger"] = logs
			else:
				msgbox("Unknown sub-directive %s found. Ignore it" % (i.lstrip().split(" ")[0]))
				while (i[-1] != "}"):
					i = get_next_line(file)
				
			i = get_next_line(file)
			while ( i == ""):
				i = get_next_line(file)
			continue
		
		opt = i.split(":")
		try:
			doc = options[opt[0].strip()]["doc"]
		except KeyError:
			print "Unknown options", opt[0].strip()
			if options == service_option_table:
				result[opt[0].strip()] = opt[1].strip()
			else:
				msgbox("Unknown options %s found, ignore it" % (opt[0].strip()))
		else:
			if options[opt[0].strip()].get("type", "string") == "int":
				try:
					result[opt[0].strip()] = int(opt[1].strip())
				except ValueError:
					msgbox("Invalid option %s found, default to %s" % (opt[0].strip(), options[opt[0].strip()]["default_value"]))
					result[opt[0].strip()] = options[opt[0].strip()]["default_value"]
			else:
				result[opt[0].strip()] = opt[1].strip()
		i = ""
		while (i == ""):
			i = get_next_line(file)
	return result.copy()

def validate_conf():
	if totem_options.get("version", 0) != 2:
		return 1, "Version has to be set to 2"
	inf1 = get_interface0()
	inf2 = get_interface1()
	if inf1 == None and inf2 != None:
		return 1, "Ringnumber 1 is specified while ringnumber 0 is not"
	if len(totem_options.get("interface", [])) == 0:
		return 1, "No interface specified"
	if len(totem_options.get("interface", []))>2:
		return 1, "More then 2 interfaces specified"
	for inf in totem_options["interface"]:
		if inf.get("mcastaddr", "") == "":
			return 1, "No multicast address specified"
		if inf.get("mcastport", 0) == 0:
			return 1, "No multicast port specified"
		if inf.get("ringnumber", -1) != 0 and inf.get("ringnumber", -1) != 1:
			return 1, "Ring Number must be 0 or 1, but got %d" %(inf.get("ringnumber", -1))
		try:
			inf.get("mcastaddr", "").index(':')
			if totem_options.get("nodeid", 0) == 0:
				return 1, "Node ID must be specified for IPv6"
		except ValueError:
			pass
	return 0, "OK"

def get_interface0():
	for inf in totem_options.get("interface", []):
		if inf["ringnumber"] == 0:
			return inf
	else:
		return None

def get_interface1():
	for inf in totem_options.get("interface", []):
		if inf["ringnumber"] == 1:
			return inf
	else:
		return None
	
def init_options():
	generate_default_ais_options()
		
	fulfill_default_amf_options()
	fulfill_default_pacemaker_options()
	fulfill_default_logging_options()		
	fulfill_suggested_totem_options()
		
def load_ais_conf(filename):
	try:
		f = open(filename, "r")
		file_parser(f)
		f.close()
	except IOError:
		f = open(filename, "w")
		f.write(" ")
		f.close()
		load_ais_conf(filename)

		top_window = None

def msgbox(msg) :
	global top_window
	dialog = gtk.Dialog("Message", top_window, gtk.DIALOG_MODAL, (gtk.STOCK_OK, True))
	dialog.set_border_width(5)
	im=gtk.Image()
	im.set_from_stock(gtk.STOCK_DIALOG_INFO, gtk.ICON_SIZE_DIALOG)
	hb=gtk.HBox()
	hb.pack_start(im)
	label = gtk.Label(msg)
	label.set_selectable(True)
	label.set_line_wrap(True)
	hb.pack_start(label)
	dialog.vbox.pack_start(hb)
	dialog.show_all()
	save_top_window = top_window
	top_window = dialog
	dialog.run()
	top_window = save_top_window
	dialog.destroy()
	
class OpenAISConfDialog:
	def toggle_interface2(self, interface2):
		if self.wTree.get_widget("chk_interface2").get_active():
			self.wTree.get_widget("text_bindnetaddr2").set_sensitive(True)
			self.wTree.get_widget("text_mcastaddr2").set_sensitive(True)
			self.wTree.get_widget("text_mcastport2").set_sensitive(True)
		else:
			self.wTree.get_widget("text_bindnetaddr2").set_sensitive(False)
			self.wTree.get_widget("text_mcastaddr2").set_sensitive(False)
			self.wTree.get_widget("text_mcastport2").set_sensitive(False)			

	def toggle_secauth(self, secauth):
		if secauth.get_active():
			self.wTree.get_widget("text_threads").set_sensitive(True)
		else:
			self.wTree.get_widget("text_threads").set_sensitive(False)
			self.wTree.get_widget("text_threads").set_text(str(0))
			
	def toggle_clearbit(self, clearbit):
		if clearbit.get_active():
			self.wTree.get_widget("text_nodeid").set_sensitive(False)
		else:
			self.wTree.get_widget("text_nodeid").set_sensitive(True)
			
	def quit(self, menu):
		self.window.destroy()
		
	def __init__(self):
		self.gladefile="/usr/share/heartbeat-gui/pacemaker-starter.glade"
		self.wTree = gtk.glade.XML(self.gladefile)
		self.window = self.wTree.get_widget("top_window")

		if (self.window):
			self.window.connect("destroy", gtk.main_quit)

		self.wTree.get_widget("SaveMenu").connect("activate", self.save_configuration)
		self.wTree.get_widget("QuitMenu").connect("activate", self.quit)
		
		# Setup tooltips
		
		self.wTree.get_widget("text_bindnetaddr").set_tooltip_text(interface_option_table["bindnetaddr"]["doc"])
		self.wTree.get_widget("text_mcastaddr").set_tooltip_text(interface_option_table["mcastaddr"]["doc"])
		self.wTree.get_widget("text_mcastport").set_tooltip_text(interface_option_table["mcastport"]["doc"])
		self.wTree.get_widget("text_bindnetaddr2").set_tooltip_text(interface_option_table["bindnetaddr"]["doc"])
		self.wTree.get_widget("text_mcastaddr2").set_tooltip_text(interface_option_table["mcastaddr"]["doc"])
		self.wTree.get_widget("text_mcastport2").set_tooltip_text(interface_option_table["mcastport"]["doc"])

		self.wTree.get_widget("text_nodeid").set_tooltip_text(totem_option_table["nodeid"]["doc"])
		self.wTree.get_widget("text_threads").set_tooltip_text(totem_option_table["threads"]["doc"])
		self.wTree.get_widget("chk_clear_high_bit").set_tooltip_text(totem_option_table["clear_node_high_bit"]["doc"])
		self.wTree.get_widget("chk_secauth").set_tooltip_text(totem_option_table["secauth"]["doc"])
		
		self.wTree.get_widget("chk_mgmtd").set_tooltip_text(service_option_table["use_mgmtd"]["doc"])
		
		#Setup interface
		
		# if only 1 interface specified, it must be ringnumber 0
		if len(totem_options["interface"]) == 1:
			totem_options["interface"][0]["ringnumber"] = 0
			
		inf = get_interface0()
		if inf != None:
			self.wTree.get_widget("text_bindnetaddr").set_text(inf.get("bindnetaddr", ""))
			self.wTree.get_widget("text_mcastaddr").set_text(inf.get("mcastaddr", ""))
			self.wTree.get_widget("text_mcastport").set_text(str(inf.get("mcastport", "")))
		
		inf = get_interface1()
		self.wTree.get_widget("chk_interface2").connect("toggled", self.toggle_interface2)

		if inf != None:
			self.wTree.get_widget("text_bindnetaddr2").set_text(inf.get("bindnetaddr", ""))
			self.wTree.get_widget("text_mcastaddr2").set_text(inf.get("mcastaddr", ""))
			self.wTree.get_widget("text_mcastport2").set_text(str(inf.get("mcastport", "")))
			self.wTree.get_widget("chk_interface2").set_active(True)
		else:
			self.wTree.get_widget("chk_interface2").set_active(False)
			
		self.wTree.get_widget("chk_interface2").toggled()

		#setup totem
		if totem_options.get("nodeid", 0) != 0:
			self.wTree.get_widget("text_nodeid").set_text(str(totem_options.get("nodeid", 0)))
		else:
			self.wTree.get_widget("text_nodeid").set_sensitive(False)
			
		if self.wTree.get_widget("text_nodeid").get_text() != "":
			self.wTree.get_widget("chk_clear_high_bit").set_active(False)
		else:
			self.wTree.get_widget("chk_clear_high_bit").set_active(True)
		self.wTree.get_widget("chk_clear_high_bit").connect("toggled", self.toggle_clearbit)
			
			
		self.wTree.get_widget("text_threads").set_text(str(totem_options.get("threads", 0)))
			
		if int(self.wTree.get_widget("text_threads").get_text()) != 0:
			self.wTree.get_widget("chk_secauth").set_active(True)
		else:
			self.wTree.get_widget("chk_secauth").set_active(False)
			self.wTree.get_widget("text_threads").set_sensitive(False)
		self.wTree.get_widget("chk_secauth").connect("toggled", self.toggle_secauth)
		
		mg = pacemaker_service_options.get("use_mgmtd", "no")
		if is_ais_true(mg):
			self.wTree.get_widget("chk_mgmtd").set_active(True)
		else:
			self.wTree.get_widget("chk_mgmtd").set_active(False)
			
		
	def sync_setting(self):
		if get_interface0() == None:
			totem_options["interface"].append({"ringnumber":0})
			
		s = self.wTree.get_widget("text_bindnetaddr").get_text()
		if s != "":
			get_interface0()["bindnetaddr"] = s
		else:
			return 1, "Bind Network Address has to be assigned for the first interface"
		s = self.wTree.get_widget("text_mcastaddr").get_text()
		if s != "":
			get_interface0()["mcastaddr"] = s
		else:
			return 1, "Multicast address has to be assigned for the first interface"
		s = self.wTree.get_widget("text_mcastport").get_text()
		if s == "":
			return 1, "Multicast port has to be assigned for the first interface"
		try:
			i = int(s)
			get_interface0()["mcastport"] = i
		except ValueError:
			return 1, "Multicast Port has to be integer, but got a %s for the first interface" % (s)

		if self.wTree.get_widget("chk_interface2").get_active():
			if get_interface1() == None:
				# We dont have second interface yet. Create it first.
				totem_options["interface"].append({"ringnumber":1})
			s = self.wTree.get_widget("text_bindnetaddr2").get_text()
			if s != "":
				get_interface1()["bindnetaddr"] = s
			else:
				return 1, "Bind Network Address has to be assigned for the second interface"
			s = self.wTree.get_widget("text_mcastaddr2").get_text()
			if s != "":
				get_interface1()["mcastaddr"] = s
			else:
				return 1, "Multicast address has to be assigned for the second interface"
			s = self.wTree.get_widget("text_mcastport2").get_text()
			if s == "":
				return 1, "Multicast port has to be assigned for the second interface"
			try:
				i = int(s)
				get_interface1()["mcastport"] = i
			except ValueError:
				return 1, "Multicast Port has to be integer, but got a %s for the second interface" % (s)

		else:
			# Dont use the redudent interface anymore, delete it 
			for i in range(len(totem_options["interface"])):
				if totem_options["interface"][i]["ringnumber"] == 1:
					del totem_options["interface"][i]
					break
		
		if len(totem_options["interface"]) == 1:
			totem_options["rrp_mode"] = "none"
		elif len(totem_options["interface"]) == 2:
			rr = totem_options.get("rrp_mode", None)
			if rr == "active" or rr == "passive":
				pass
			else:
				totem_options["rrp_mode"] = "passive"
		else:
			if totem_options.get("rrp_mode", None) != None:
				del totem_options["rrp_mode"]
		
		if self.wTree.get_widget("chk_clear_high_bit").get_active():
			totem_options["clear_node_high_bit"] = "yes"
			try:
				del totem_options["nodeid"]
			except KeyError:
				pass
		else:
			s = self.wTree.get_widget("text_nodeid").get_text()
			try:
				i = int(s)
				totem_options["nodeid"] = i
			except ValueError:
				return 1, "Node ID must be assigned as a integer"
			try:
				del totem_options["clear_node_high_bit"]
			except KeyError:
				pass
			
		if not self.wTree.get_widget("chk_secauth").get_active():
			totem_options["secauth"] = "off"
			try:
				del totem_options["threads"]
			except KeyError:
				pass
		else:
			s = self.wTree.get_widget("text_threads").get_text()
			try:
				i = int(s)
				if i == 0:
					return 1, "Number of threads must bigger than 0"
				totem_options["threads"] = i
				totem_options["secauth"] = "on"
			except ValueError:
				return 1, "Number of threads must be integer"
			if totem_options.get("keyfile", None) == None:
				totem_options["keyfile"] = totem_option_table["keyfile"]["default_value"]
			
		if self.wTree.get_widget("chk_mgmtd").get_active():
			pacemaker_service_options["use_mgmtd"] = "yes"
		else:
			pacemaker_service_options["use_mgmtd"] = "no"
			
		return 0, "Everything's OK"
	
	def save_configuration(self, menu):
		generate_default_ais_options()
		
		fulfill_default_amf_options()
		fulfill_default_pacemaker_options()
		fulfill_default_logging_options()		
		fulfill_suggested_totem_options()

		r, reason = self.sync_setting()
		if r == 1:
			msgbox(reason)
			return 1
	
		r, reason = validate_conf()
		if r == 1:
			msgbox(reason)
			return 1
		
		f = open("/etc/ais/openais.conf.tmp", "w")
		print_ais_options(f)
		print_pacemaker_service_options(f)
		print_service_options(f)
		print_totem_options(f)
		print_logging_options(f)
		print_amf_options(f)
		print_event_options(f)
		f.close()
		if totem_options.get("secauth", "off") == "on":
			msgbox("Security Authrization is turned on.\nKeyfile is /etc/ais/authkey, with 128-bytes random characters.\nYou can either create it manually or copy over from other nodes in the cluster.")
		try:
			os.rename("/etc/ais/openais.conf", "/etc/ais/openais.conf.bak")
			os.rename("/etc/ais/openais.conf.tmp", "/etc/ais/openais.conf")
		except OSError:
			pass
		else:
			msgbox("New configuration saved")
		
if __name__ == "__main__":
	
	if os.getuid() != 0:
		msgbox("You must be ROOT to use this tool")
		sys.exit(1)
		
	load_ais_conf("/etc/ais/openais.conf")
	r, reason = validate_conf()
	if r == 1:
		msgbox(reason)
	hwg = OpenAISConfDialog()
	gtk.main()