/usr/lib/python2.7/dist-packages/cobbler/item_system.py is in python-cobbler 2.4.1-0ubuntu2.
This file is owned by root:root, with mode 0o644.
The actual contents of the file can be viewed below.
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 108 109 110 111 112 113 114 115 116 117 118 119 120 121 122 123 124 125 126 127 128 129 130 131 132 133 134 135 136 137 138 139 140 141 142 143 144 145 146 147 148 149 150 151 152 153 154 155 156 157 158 159 160 161 162 163 164 165 166 167 168 169 170 171 172 173 174 175 176 177 178 179 180 181 182 183 184 185 186 187 188 189 190 191 192 193 194 195 196 197 198 199 200 201 202 203 204 205 206 207 208 209 210 211 212 213 214 215 216 217 218 219 220 221 222 223 224 225 226 227 228 229 230 231 232 233 234 235 236 237 238 239 240 241 242 243 244 245 246 247 248 249 250 251 252 253 254 255 256 257 258 259 260 261 262 263 264 265 266 267 268 269 270 271 272 273 274 275 276 277 278 279 280 281 282 283 284 285 286 287 288 289 290 291 292 293 294 295 296 297 298 299 300 301 302 303 304 305 306 307 308 309 310 311 312 313 314 315 316 317 318 319 320 321 322 323 324 325 326 327 328 329 330 331 332 333 334 335 336 337 338 339 340 341 342 343 344 345 346 347 348 349 350 351 352 353 354 355 356 357 358 359 360 361 362 363 364 365 366 367 368 369 370 371 372 373 374 375 376 377 378 379 380 381 382 383 384 385 386 387 388 389 390 391 392 393 394 395 396 397 398 399 400 401 402 403 404 405 406 407 408 409 410 411 412 413 414 415 416 417 418 419 420 421 422 423 424 425 426 427 428 429 430 431 432 433 434 435 436 437 438 439 440 441 442 443 444 445 446 447 448 449 450 451 452 453 454 455 456 457 458 459 460 461 462 463 464 465 466 467 468 469 470 471 472 473 474 475 476 477 478 479 480 481 482 483 484 485 486 487 488 489 490 491 492 493 494 495 496 497 498 499 500 501 502 503 504 505 506 507 508 509 510 511 512 513 514 515 516 517 518 519 520 521 522 523 524 525 526 527 528 529 530 531 532 533 534 535 536 537 538 539 540 541 542 543 544 545 546 547 548 549 550 551 552 553 554 555 556 557 558 559 560 561 562 563 564 565 566 567 568 569 570 571 572 573 574 575 576 577 578 579 580 581 582 583 584 585 586 587 588 589 590 591 592 593 594 595 596 597 598 599 600 601 602 603 604 605 606 607 608 609 610 611 612 613 614 615 616 617 618 619 620 621 622 623 624 625 626 627 628 629 630 631 632 633 634 635 636 637 638 639 640 641 642 643 644 645 646 647 648 649 650 651 652 653 654 655 656 657 658 659 660 661 662 663 664 665 666 667 668 669 670 671 672 673 674 675 676 677 678 679 680 681 682 683 684 685 686 687 688 689 690 691 692 693 694 695 696 697 698 699 700 701 702 703 704 705 706 707 708 709 710 711 712 713 714 715 716 717 718 719 720 721 722 723 724 725 726 727 728 729 730 731 732 733 734 735 736 737 738 739 740 741 742 743 744 745 746 747 748 749 750 751 752 753 754 755 756 757 758 759 760 761 762 763 764 765 766 767 768 769 770 771 772 773 774 775 | """
A Cobbler System.
Copyright 2006-2009, Red Hat, Inc and Others
Michael DeHaan <michael.dehaan AT gmail>
This program is free software; you can redistribute it and/or modify
it under the terms of the GNU General Public License as published by
the Free Software Foundation; either version 2 of the License, or
(at your option) any later version.
This program is distributed in the hope that it will be useful,
but WITHOUT ANY WARRANTY; without even the implied warranty of
MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
GNU General Public License for more details.
You should have received a copy of the GNU General Public License
along with this program; if not, write to the Free Software
Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA
02110-1301 USA
"""
import utils
import item
import time
from cexceptions import *
from utils import _
import sys
# this datastructure is described in great detail in item_distro.py -- read the comments there.
FIELDS = [
["name","",0,"Name",True,"Ex: vanhalen.example.org",0,"str"],
["uid","",0,"",False,"",0,"str"],
["owners","SETTINGS:default_ownership",0,"Owners",True,"Owners list for authz_ownership (space delimited)",0,"list"],
["profile",None,0,"Profile",True,"Parent profile",[],"str"],
["image",None,0,"Image",True,"Parent image (if not a profile)",0,"str"],
["status","production",0,"Status",True,"System status",["development","testing","acceptance","production"],"str"],
["kernel_options",{},0,"Kernel Options",True,"Ex: selinux=permissive",0,"dict"],
["kernel_options_post",{},0,"Kernel Options (Post Install)",True,"Ex: clocksource=pit noapic",0,"dict"],
["ks_meta",{},0,"Kickstart Metadata",True,"Ex: dog=fang agent=86",0,"dict"],
["enable_gpxe","SETTINGS:enable_gpxe",0,"Enable gPXE?",True,"Use gPXE instead of PXELINUX for advanced booting options",0,"bool"],
["proxy","<<inherit>>",0,"Proxy",True,"Proxy URL",0,"str"],
["netboot_enabled",True,0,"Netboot Enabled",True,"PXE (re)install this machine at next boot?",0,"bool"],
["kickstart","<<inherit>>",0,"Kickstart",True,"Path to kickstart template",0,"str"],
["comment","",0,"Comment",True,"Free form text description",0,"str"],
["depth",2,0,"",False,"",0,"int"],
["server","<<inherit>>",0,"Server Override",True,"See manpage or leave blank",0,"str"],
["virt_path","<<inherit>>",0,"Virt Path",True,"Ex: /directory or VolGroup00",0,"str"],
["virt_type","<<inherit>>",0,"Virt Type",True,"Virtualization technology to use",["xenpv","xenfv","qemu","kvm","vmware","openvz"],"str"],
["virt_cpus","<<inherit>>",0,"Virt CPUs",True,"",0,"int"],
["virt_file_size","<<inherit>>",0,"Virt File Size(GB)",True,"",0,"float"],
["virt_disk_driver","<<inherit>>",0,"Virt Disk Driver Type",True,"The on-disk format for the virtualization disk","raw","str"],
["virt_ram","<<inherit>>",0,"Virt RAM (MB)",True,"",0,"int"],
["virt_auto_boot","<<inherit>>",0,"Virt Auto Boot",True,"Auto boot this VM?",0,"bool"],
["virt_pxe_boot",0,0,"Virt PXE Boot",True,"Use PXE to build this VM?",0,"bool"],
["ctime",0,0,"",False,"",0,"float"],
["mtime",0,0,"",False,"",0,"float"],
["power_type","SETTINGS:power_management_default_type",0,"Power Management Type",True,"Power management script to use",utils.get_power_types(),"str"],
["power_address","",0,"Power Management Address",True,"Ex: power-device.example.org",0,"str"],
["power_user","",0,"Power Management Username ",True,"",0,"str"],
["power_pass","",0,"Power Management Password",True,"",0,"str"],
["power_id","",0,"Power Management ID",True,"Usually a plug number or blade name, if power type requires it",0,"str"],
["hostname","",0,"Hostname",True,"",0,"str"],
["gateway","",0,"Gateway",True,"",0,"str"],
["name_servers",[],0,"Name Servers",True,"space delimited",0,"list"],
["name_servers_search",[],0,"Name Servers Search Path",True,"space delimited",0,"list"],
["ipv6_default_device","",0,"IPv6 Default Device",True,"",0,"str"],
["ipv6_autoconfiguration",False,0,"IPv6 Autoconfiguration",True,"",0,"bool"],
["network_widget_a","",0,"Add Interface",True,"",0,"str"], # not a real field, a marker for the web app
["network_widget_b","",0,"Edit Interface",True,"",0,"str"], # not a real field, a marker for the web app
["*mac_address","",0,"MAC Address",True,"(Place \"random\" in this field for a random MAC Address.)",0,"str"],
["network_widget_c","",0,"",True,"",0,"str"], # not a real field, a marker for the web app
["*mtu","",0,"MTU",True,"",0,"str"],
["*ip_address","",0,"IP Address",True,"Should be used with --interface",0,"str"],
["*interface_type","na",0,"Interface Type",True,"Should be used with --interface",["na","master","slave","bond","bond_slave","bridge","bridge_slave","bonded_bridge_slave"],"str"],
["*interface_master","",0,"Master Interface",True,"Should be used with --interface",0,"str"],
["*bonding_opts","",0,"Bonding Opts",True,"Should be used with --interface",0,"str"],
["*bridge_opts","",0,"Bridge Opts",True,"Should be used with --interface",0,"str"],
["*management",False,0,"Management Interface",True,"Is this the management interface? Should be used with --interface",0,"bool"],
["*static",False,0,"Static",True,"Is this interface static? Should be used with --interface",0,"bool"],
["*netmask","",0,"Subnet Mask",True,"Should be used with --interface",0,"str"],
["*if_gateway","",0,"Per-Interface Gateway",True,"Should be used with --interface",0,"str"],
["*dhcp_tag","",0,"DHCP Tag",True,"Should be used with --interface",0,"str"],
["*dns_name","",0,"DNS Name",True,"Should be used with --interface",0,"str"],
["*static_routes",[],0,"Static Routes",True,"Should be used with --interface",0,"list"],
["*virt_bridge","",0,"Virt Bridge",True,"Should be used with --interface",0,"str"],
["*ipv6_address","",0,"IPv6 Address",True,"Should be used with --interface",0,"str"],
["*ipv6_secondaries",[],0,"IPv6 Secondaries",True,"Space delimited. Should be used with --interface",0,"list"],
["*ipv6_mtu","",0,"IPv6 MTU",True,"Should be used with --interface",0,"str"],
["*ipv6_static_routes",[],0,"IPv6 Static Routes",True,"Should be used with --interface",0,"list"],
["*ipv6_default_gateway","",0,"IPv6 Default Gateway",True,"Should be used with --interface",0,"str"],
["mgmt_classes",[],0,"Management Classes",True,"For external config management",0,"list"],
["mgmt_parameters","<<inherit>>",0,"Management Parameters",True,"Parameters which will be handed to your management application (Must be valid YAML dictionary)", 0,"str"],
[ "boot_files",{},'<<inherit>>',"TFTP Boot Files",True,"Files copied into tftpboot beyond the kernel/initrd",0,"list"],
["fetchable_files",{},'<<inherit>>',"Fetchable Files",True,"Templates for tftp or wget",0,"dict"],
["template_files",{},0,"Template Files",True,"File mappings for built-in configuration management",0,"dict"],
["redhat_management_key","<<inherit>>",0,"Red Hat Management Key",True,"Registration key for RHN, Satellite, or Spacewalk",0,"str"],
["redhat_management_server","<<inherit>>",0,"Red Hat Management Server",True,"Address of Satellite or Spacewalk Server",0,"str"],
["template_remote_kickstarts", "SETTINGS:template_remote_kickstarts", "SETTINGS:template_remote_kickstarts", "", False, "", 0, "bool"],
["repos_enabled",False,0,"Repos Enabled",True,"(re)configure local repos on this machine at next config update?",0,"bool"],
["ldap_enabled",False,0,"LDAP Enabled",True,"(re)configure LDAP on this machine at next config update?",0,"bool"],
["ldap_type","SETTINGS:ldap_management_default_type",0,"LDAP Management Type",True,"Ex: authconfig",0,"str"],
["monit_enabled",False,0,"Monit Enabled",True,"(re)configure monit on this machine at next config update?",0,"bool"],
["*cnames",[],0,"CNAMES",True,"Cannonical Name Records, should be used with --interface, In quotes, space delimited",0,"list"],
]
class System(item.Item):
TYPE_NAME = _("system")
COLLECTION_TYPE = "system"
def get_fields(self):
return FIELDS
def make_clone(self):
ds = self.to_datastruct()
cloned = System(self.config)
cloned.from_datastruct(ds)
return cloned
def delete_interface(self,name):
"""
Used to remove an interface.
"""
if self.interfaces.has_key(name) and len(self.interfaces) > 1:
del self.interfaces[name]
else:
if not self.interfaces.has_key(name):
# no interface here to delete
pass
else:
raise CX(_("At least one interface needs to be defined."))
return True
def rename_interface(self,names):
"""
Used to rename an interface.
"""
(name,newname) = names
if not self.interfaces.has_key(name):
raise CX(_("Interface %s does not exist" % name))
if self.interfaces.has_key(newname):
raise CX(_("Interface %s already exists" % newname))
else:
self.interfaces[newname] = self.interfaces[name]
del self.interfaces[name]
return True
def __get_interface(self,name):
if name == "" and len(self.interfaces.keys()) == 0:
raise CX(_("No interfaces defined. Please use --interface <interface_name>"))
elif name == "" and len(self.interfaces.keys()) == 1:
name = self.interfaces.keys()[0]
elif name == "" and len(self.interfaces.keys()) > 1:
raise CX(_("Multiple interfaces defined. Please use --interface <interface_name>"))
elif not self.interfaces.has_key(name):
self.interfaces[name] = {
"mac_address" : "",
"mtu" : "",
"ip_address" : "",
"dhcp_tag" : "",
"subnet" : "", # deprecated
"netmask" : "",
"if_gateway" : "",
"virt_bridge" : "",
"static" : False,
"interface_type" : "",
"interface_master" : "",
"bonding" : "", # deprecated
"bonding_master" : "", # deprecated
"bonding_opts" : "",
"bridge_opts" : "",
"management" : False,
"dns_name" : "",
"static_routes" : [],
"ipv6_address" : "",
"ipv6_secondaries" : [],
"ipv6_mtu" : "",
"ipv6_static_routes" : [],
"ipv6_default_gateway" : "",
"cnames" : [],
}
return self.interfaces[name]
def from_datastruct(self,seed_data):
# FIXME: most definitely doesn't grok interfaces yet.
return utils.from_datastruct_from_fields(self,seed_data,FIELDS)
def get_parent(self):
"""
Return object next highest up the tree.
"""
if (self.parent is None or self.parent == '') and self.profile:
return self.config.profiles().find(name=self.profile)
elif (self.parent is None or self.parent == '') and self.image:
return self.config.images().find(name=self.image)
else:
return self.config.systems().find(name=self.parent)
def set_name(self,name):
"""
Set the name. If the name is a MAC or IP, and the first MAC and/or IP is not defined, go ahead
and fill that value in.
"""
if self.name not in ["",None] and self.parent not in ["",None] and self.name == self.parent:
raise CX(_("self parentage is weird"))
if not isinstance(name, basestring):
raise CX(_("name must be a string"))
for x in name:
if not x.isalnum() and not x in [ "_", "-", ".", ":", "+" ] :
raise CX(_("invalid characters in name: %s") % x)
# Stuff here defaults to eth0. Yes, it's ugly and hardcoded, but so was
# the default interface behaviour that's now removed. ;)
# --Jasper Capel
if utils.is_mac(name):
intf = self.__get_interface("eth0")
if intf["mac_address"] == "":
intf["mac_address"] = name
elif utils.is_ip(name):
intf = self.__get_interface("eth0")
if intf["ip_address"] == "":
intf["ip_address"] = name
self.name = name
return True
def set_redhat_management_key(self,key):
return utils.set_redhat_management_key(self,key)
def set_redhat_management_server(self,server):
return utils.set_redhat_management_server(self,server)
def set_server(self,server):
"""
If a system can't reach the boot server at the value configured in settings
because it doesn't have the same name on it's subnet this is there for an override.
"""
if server is None or server == "":
server = "<<inherit>>"
self.server = server
return True
def set_proxy(self,proxy):
if proxy is None or proxy == "":
proxy = "<<inherit>>"
self.proxy = proxy
return True
def get_mac_address(self,interface):
"""
Get the mac address, which may be implicit in the object name or explicit with --mac-address.
Use the explicit location first.
"""
intf = self.__get_interface(interface)
if intf["mac_address"] != "":
return intf["mac_address"].strip()
else:
return None
def get_ip_address(self,interface):
"""
Get the IP address, which may be implicit in the object name or explict with --ip-address.
Use the explicit location first.
"""
intf = self.__get_interface(interface)
if intf["ip_address"] != "":
return intf["ip_address"].strip()
else:
return ""
def is_management_supported(self,cidr_ok=True):
"""
Can only add system PXE records if a MAC or IP address is available, else it's a koan
only record. Actually Itanium goes beyond all this and needs the IP all of the time
though this is enforced elsewhere (action_sync.py).
"""
if self.name == "default":
return True
for (name,x) in self.interfaces.iteritems():
mac = x.get("mac_address",None)
ip = x.get("ip_address",None)
if ip is not None and not cidr_ok and ip.find("/") != -1:
# ip is in CIDR notation
return False
if mac is not None or ip is not None:
# has ip and/or mac
return True
return False
def set_dhcp_tag(self,dhcp_tag,interface):
intf = self.__get_interface(interface)
intf["dhcp_tag"] = dhcp_tag
return True
def set_dns_name(self,dns_name,interface):
intf = self.__get_interface(interface)
# FIXME: move duplicate supression code to the object validation
# functions to take a harder line on supression?
if dns_name != "" and not str(self.config._settings.allow_duplicate_hostnames).lower() in [ "1", "y", "yes"]:
matched = self.config.api.find_items("system", {"dns_name" : dns_name})
for x in matched:
if x.name != self.name:
raise CX("dns-name duplicated: %s" % dns_name)
intf["dns_name"] = dns_name
return True
def set_cnames(self,cnames,interface):
intf = self.__get_interface(interface)
data = utils.input_string_or_list(cnames)
intf["cnames"] = data
return True
def set_static_routes(self,routes,interface):
intf = self.__get_interface(interface)
data = utils.input_string_or_list(routes)
intf["static_routes"] = data
return True
def set_hostname(self,hostname):
if hostname is None:
hostname = ""
self.hostname = hostname
return True
def set_status(self,status):
self.status = status
return True
def set_static(self,truthiness,interface):
intf = self.__get_interface(interface)
intf["static"] = utils.input_boolean(truthiness)
return True
def set_management(self,truthiness,interface):
intf = self.__get_interface(interface)
intf["management"] = utils.input_boolean(truthiness)
return True
def set_ip_address(self,address,interface):
"""
Assign a IP or hostname in DHCP when this MAC boots.
Only works if manage_dhcp is set in /etc/cobbler/settings
"""
intf = self.__get_interface(interface)
# FIXME: move duplicate supression code to the object validation
# functions to take a harder line on supression?
if address != "" and not str(self.config._settings.allow_duplicate_ips).lower() in [ "1", "y", "yes"]:
matched = self.config.api.find_items("system", {"ip_address" : address})
for x in matched:
if x.name != self.name:
raise CX("IP address duplicated: %s" % address)
if address == "" or utils.is_ip(address):
intf["ip_address"] = address.strip()
return True
raise CX(_("invalid format for IP address (%s)") % address)
def set_mac_address(self,address,interface):
if address == "random":
address = utils.get_random_mac(self.config.api)
# FIXME: move duplicate supression code to the object validation
# functions to take a harder line on supression?
if address != "" and not str(self.config._settings.allow_duplicate_macs).lower() in [ "1", "y", "yes"]:
matched = self.config.api.find_items("system", {"mac_address" : address})
for x in matched:
if x.name != self.name:
raise CX("MAC address duplicated: %s" % address)
intf = self.__get_interface(interface)
if address == "" or utils.is_mac(address):
intf["mac_address"] = address.strip()
return True
raise CX(_("invalid format for MAC address (%s)" % address))
def set_gateway(self,gateway):
if gateway is None:
gateway = ""
if utils.is_ip(gateway) or gateway == "":
self.gateway = gateway
else:
raise CX(_("invalid format for gateway IP address (%s)") % gateway)
return True
def set_name_servers(self,data):
if data == "<<inherit>>":
data = []
data = utils.input_string_or_list(data)
self.name_servers = data
return True
def set_name_servers_search(self,data):
if data == "<<inherit>>":
data = []
data = utils.input_string_or_list(data)
self.name_servers_search = data
return True
def set_netmask(self,netmask,interface):
intf = self.__get_interface(interface)
intf["netmask"] = netmask
return True
def set_if_gateway(self,gateway,interface):
intf = self.__get_interface(interface)
if gateway == "" or utils.is_ip(gateway):
intf["if_gateway"] = gateway
return True
raise CX(_("invalid gateway: %s" % gateway))
def set_virt_bridge(self,bridge,interface):
if bridge == "":
bridge = self.settings.default_virt_bridge
intf = self.__get_interface(interface)
intf["virt_bridge"] = bridge
return True
def set_interface_type(self,type,interface):
# master and slave are deprecated, and will
# be assumed to mean bonding slave/master
interface_types = ["bridge","bridge_slave","bond","bond_slave","bonded_bridge_slave","master","slave","na",""]
if type not in interface_types:
raise CX(_("interface type value must be one of: %s or blank" % interface_types.join(",")))
if type == "na":
type = ""
elif type == "master":
type = "bond"
elif type == "slave":
type = "bond_slave"
intf = self.__get_interface(interface)
intf["interface_type"] = type
return True
def set_interface_master(self,interface_master,interface):
intf = self.__get_interface(interface)
intf["interface_master"] = interface_master
return True
def set_bonding_opts(self,bonding_opts,interface):
intf = self.__get_interface(interface)
intf["bonding_opts"] = bonding_opts
return True
def set_bridge_opts(self,bridge_opts,interface):
intf = self.__get_interface(interface)
intf["bridge_opts"] = bridge_opts
return True
def set_ipv6_autoconfiguration(self,truthiness):
self.ipv6_autoconfiguration = utils.input_boolean(truthiness)
return True
def set_ipv6_default_device(self,interface_name):
if interface_name is None:
interface_name = ""
self.ipv6_default_device = interface_name
return True
def set_ipv6_address(self,address,interface):
"""
Assign a IP or hostname in DHCP when this MAC boots.
Only works if manage_dhcp is set in /etc/cobbler/settings
"""
intf = self.__get_interface(interface)
if address == "" or utils.is_ip(address):
intf["ipv6_address"] = address.strip()
return True
raise CX(_("invalid format for IPv6 IP address (%s)") % address)
def set_ipv6_secondaries(self,addresses,interface):
intf = self.__get_interface(interface)
data = utils.input_string_or_list(addresses)
secondaries = []
for address in data:
if address == "" or utils.is_ip(address):
secondaries.append(address)
else:
raise CX(_("invalid format for IPv6 IP address (%s)") % address)
intf["ipv6_secondaries"] = secondaries
return True
def set_ipv6_default_gateway(self,address,interface):
intf = self.__get_interface(interface)
if address == "" or utils.is_ip(address):
intf["ipv6_default_gateway"] = address.strip()
return True
raise CX(_("invalid format for IPv6 IP address (%s)") % address)
def set_ipv6_static_routes(self,routes,interface):
intf = self.__get_interface(interface)
data = utils.input_string_or_list(routes)
intf["ipv6_static_routes"] = data
return True
def set_ipv6_mtu(self,mtu,interface):
intf = self.__get_interface(interface)
intf["ipv6_mtu"] = mtu
return True
def set_mtu(self,mtu,interface):
intf = self.__get_interface(interface)
intf["mtu"] = mtu
return True
def set_enable_gpxe(self,enable_gpxe):
"""
Sets whether or not the system will use gPXE for booting.
"""
self.enable_gpxe = utils.input_boolean(enable_gpxe)
return True
def set_profile(self,profile_name):
"""
Set the system to use a certain named profile. The profile
must have already been loaded into the Profiles collection.
"""
old_parent = self.get_parent()
if profile_name in [ "delete", "None", "~", ""] or profile_name is None:
self.profile = ""
if isinstance(old_parent, item.Item):
old_parent.children.pop(self.name, 'pass')
return True
self.image = "" # mutual exclusion rule
p = self.config.profiles().find(name=profile_name)
if p is not None:
self.profile = profile_name
self.depth = p.depth + 1 # subprofiles have varying depths.
if isinstance(old_parent, item.Item):
old_parent.children.pop(self.name, 'pass')
new_parent = self.get_parent()
if isinstance(new_parent, item.Item):
new_parent.children[self.name] = self
return True
raise CX(_("invalid profile name: %s") % profile_name)
def set_image(self,image_name):
"""
Set the system to use a certain named image. Works like set_profile
but cannot be used at the same time. It's one or the other.
"""
old_parent = self.get_parent()
if image_name in [ "delete", "None", "~", ""] or image_name is None:
self.image = ""
if isinstance(old_parent, item.Item):
old_parent.children.pop(self.name, 'pass')
return True
self.profile = "" # mutual exclusion rule
img = self.config.images().find(name=image_name)
if img is not None:
self.image = image_name
self.depth = img.depth + 1
if isinstance(old_parent, item.Item):
old_parent.children.pop(self.name, 'pass')
new_parent = self.get_parent()
if isinstance(new_parent, item.Item):
new_parent.children[self.name] = self
return True
raise CX(_("invalid image name (%s)") % image_name)
def set_virt_cpus(self,num):
return utils.set_virt_cpus(self,num)
def set_virt_file_size(self,num):
return utils.set_virt_file_size(self,num)
def set_virt_disk_driver(self,driver):
return utils.set_virt_disk_driver(self,driver)
def set_virt_auto_boot(self,num):
return utils.set_virt_auto_boot(self,num)
def set_virt_pxe_boot(self,num):
return utils.set_virt_pxe_boot(self,num)
def set_virt_ram(self,num):
return utils.set_virt_ram(self,num)
def set_virt_type(self,vtype):
return utils.set_virt_type(self,vtype)
def set_virt_path(self,path):
return utils.set_virt_path(self,path,for_system=True)
def set_netboot_enabled(self,netboot_enabled):
"""
If true, allows per-system PXE files to be generated on sync (or add). If false,
these files are not generated, thus eliminating the potential for an infinite install
loop when systems are set to PXE boot first in the boot order. In general, users
who are PXE booting first in the boot order won't create system definitions, so this
feature primarily comes into play for programmatic users of the API, who want to
initially create a system with netboot enabled and then disable it after the system installs,
as triggered by some action in kickstart %post. For this reason, this option is not
surfaced in the CLI, output, or documentation (yet).
Use of this option does not affect the ability to use PXE menus. If an admin has machines
set up to PXE only after local boot fails, this option isn't even relevant.
"""
self.netboot_enabled = utils.input_boolean(netboot_enabled)
return True
def set_kickstart(self,kickstart):
"""
Sets the kickstart. This must be a NFS, HTTP, or FTP URL.
Or filesystem path. Minor checking of the URL is performed here.
NOTE -- usage of the --kickstart parameter in the profile
is STRONGLY encouraged. This is only for exception cases
where a user already has kickstarts made for each system
and can't leverage templating. Profiles provide an important
abstraction layer -- assigning systems to defined and repeatable
roles.
"""
if kickstart == "":
self.kickstart = kickstart
return True
if kickstart is None or kickstart in [ "delete", "<<inherit>>" ]:
self.kickstart = "<<inherit>>"
return True
kickstart = utils.find_kickstart(kickstart)
if kickstart:
self.kickstart = kickstart
return True
raise CX(_("kickstart not found: %s" % kickstart))
def set_power_type(self, power_type):
# FIXME: modularize this better
if power_type is None:
power_type = ""
choices = utils.get_power_types()
choices.sort()
if power_type not in choices:
raise CX("power management type must be one of: %s" % ",".join(choices))
self.power_type = power_type
return True
def set_power_user(self, power_user):
if power_user is None:
power_user = ""
utils.safe_filter(power_user)
self.power_user = power_user
return True
def set_power_pass(self, power_pass):
if power_pass is None:
power_pass = ""
utils.safe_filter(power_pass)
self.power_pass = power_pass
return True
def set_power_address(self, power_address):
if power_address is None:
power_address = ""
utils.safe_filter(power_address)
self.power_address = power_address
return True
def set_power_id(self, power_id):
if power_id is None:
power_id = ""
utils.safe_filter(power_id)
self.power_id = power_id
return True
def modify_interface(self, hash):
"""
Used by the WUI to modify an interface more-efficiently
"""
for (key,value) in hash.iteritems():
(field,interface) = key.split("-",1)
field = field.replace("_","").replace("-","")
if field == "macaddress" : self.set_mac_address(value, interface)
if field == "mtu" : self.set_mtu(value, interface)
if field == "ipaddress" : self.set_ip_address(value, interface)
if field == "dnsname" : self.set_dns_name(value, interface)
if field == "static" : self.set_static(value, interface)
if field == "dhcptag" : self.set_dhcp_tag(value, interface)
if field == "netmask" : self.set_netmask(value, interface)
if field == "subnet" : self.set_netmask(value, interface)
if field == "ifgateway" : self.set_if_gateway(value, interface)
if field == "virtbridge" : self.set_virt_bridge(value, interface)
if field == "interfacetype" : self.set_interface_type(value, interface)
if field == "interfacemaster" : self.set_interface_master(value, interface)
if field == "bonding" : self.set_interface_type(value, interface) # deprecated
if field == "bondingmaster" : self.set_interface_master(value, interface) # deprecated
if field == "bondingopts" : self.set_bonding_opts(value, interface)
if field == "bridgeopts" : self.set_bridge_opts(value, interface)
if field == "management" : self.set_management(value, interface)
if field == "staticroutes" : self.set_static_routes(value, interface)
if field == "ipv6address" : self.set_ipv6_address(value, interface)
if field == "ipv6secondaries" : self.set_ipv6_secondaries(value, interface)
if field == "ipv6mtu" : self.set_ipv6_mtu(value, interface)
if field == "ipv6staticroutes" : self.set_ipv6_static_routes(value, interface)
if field == "ipv6defaultgateway" : self.set_ipv6_default_gateway(value, interface)
if field == "cnames" : self.set_cnames(value, interface)
return True
def check_if_valid(self):
if self.name is None or self.name == "":
raise CX("name is required")
if self.profile is None or self.profile == "":
if self.image is None or self.image == "":
raise CX("Error with system %s - profile or image is required" % (self.name))
def set_template_remote_kickstarts(self, template):
"""
Sets whether or not the server is configured to template remote
kickstarts.
"""
self.template_remote_kickstarts = utils.input_boolean(template)
return True
def set_monit_enabled(self,monit_enabled):
"""
If true, allows per-system to start Monit to monitor system services such as apache.
If monit is not running it will start the service.
If false, no management of monit will take place. If monit is not running it will not
be started. If monit is running it will not be stopped or restarted.
"""
self.monit_enabled = utils.input_boolean(monit_enabled)
return True
def set_ldap_enabled(self,ldap_enabled):
"""
If true, allows per-system to start Monit to monitor system services such as apache.
If monit is not running it will start the service.
If false, no management of monit will take place. If monit is not running it will not
be started. If monit is running it will not be stopped or restarted.
"""
self.ldap_enabled = utils.input_boolean(ldap_enabled)
return True
def set_repos_enabled(self,repos_enabled):
"""
If true, allows per-system to start Monit to monitor system services such as apache.
If monit is not running it will start the service.
If false, no management of monit will take place. If monit is not running it will not
be started. If monit is running it will not be stopped or restarted.
"""
self.repos_enabled = utils.input_boolean(repos_enabled)
return True
def set_ldap_type(self, ldap_type):
if ldap_type is None:
ldap_type = ""
ldap_type = ldap_type.lower()
self.ldap_type = ldap_type
return True
|