no real change, just made prettier with a more standard layout - half of steps
[bootmanager.git] / source / steps / InstallPartitionDisks.py
index f36e2e9..ca86521 100644 (file)
@@ -1,58 +1,24 @@
+#!/usr/bin/python
+#
 # Copyright (c) 2003 Intel Corporation
 # All rights reserved.
-
-# Redistribution and use in source and binary forms, with or without
-# modification, are permitted provided that the following conditions are
-# met:
-
-#     * Redistributions of source code must retain the above copyright
-#       notice, this list of conditions and the following disclaimer.
-
-#     * Redistributions in binary form must reproduce the above
-#       copyright notice, this list of conditions and the following
-#       disclaimer in the documentation and/or other materials provided
-#       with the distribution.
-
-#     * Neither the name of the Intel Corporation nor the names of its
-#       contributors may be used to endorse or promote products derived
-#       from this software without specific prior written permission.
-
-# THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS
-# "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT
-# LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR
-# A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE INTEL OR
-# CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL,
-# EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO,
-# PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR
-# PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF
-# LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING
-# NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS
-# SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
-
-# EXPORT LAWS: THIS LICENSE ADDS NO RESTRICTIONS TO THE EXPORT LAWS OF
-# YOUR JURISDICTION. It is licensee's responsibility to comply with any
-# export regulations applicable in licensee's jurisdiction. Under
-# CURRENT (May 2000) U.S. export regulations this software is eligible
-# for export from the U.S. and can be downloaded by or otherwise
-# exported or reexported worldwide EXCEPT to U.S. embargoed destinations
-# which include Cuba, Iraq, Libya, North Korea, Iran, Syria, Sudan,
-# Afghanistan and any other country to which the U.S. has embargoed
-# goods and services.
-
+#
+# Copyright (c) 2004-2006 The Trustees of Princeton University
+# All rights reserved.
+# expected /proc/partitions format
 
 import os, sys
 import string
 import popen2
-
+import time
 
 from Exceptions import *
 import utils
 import BootServerRequest
-import compatibility
-
+import BootAPI
 import ModelOptions
 
-def Run( vars, log ):
+def Run(vars, log):
     """
     Setup the block devices for install, partition them w/ LVM
     
@@ -61,129 +27,131 @@ def Run( vars, log ):
     TEMP_PATH                somewhere to store what we need to run
     ROOT_SIZE                the size of the root logical volume
     SWAP_SIZE                the size of the swap partition
-    BOOT_CD_VERSION          A tuple of the current bootcd version
-    
-    Sets the following variables:
-    PARTITIONS               diction of generic part. types (root/swap)
-                             and their associated devices.
-                             Current keys/values:
-                                 root    /dev/planetlab/root
-                                 swap    /dev/planetlab/swap
-    
     """
 
-    log.write( "\n\nStep: Install: partitioning disks.\n" )
+    log.write("\n\nStep: Install: partitioning disks.\n")
         
     # make sure we have the variables we need
     try:
-        TEMP_PATH= vars["TEMP_PATH"]
+        TEMP_PATH = vars["TEMP_PATH"]
         if TEMP_PATH == "":
-            raise ValueError, "TEMP_PATH"
+            raise ValueError("TEMP_PATH")
 
-        INSTALL_BLOCK_DEVICES= vars["INSTALL_BLOCK_DEVICES"]
-        if( len(INSTALL_BLOCK_DEVICES) == 0 ):
-            raise ValueError, "INSTALL_BLOCK_DEVICES is empty"
+        INSTALL_BLOCK_DEVICES = vars["INSTALL_BLOCK_DEVICES"]
+        if(len(INSTALL_BLOCK_DEVICES) == 0):
+            raise ValueError("INSTALL_BLOCK_DEVICES is empty")
 
-        ROOT_SIZE= vars["ROOT_SIZE"]
+        # use vs_ROOT_SIZE or lxc_ROOT_SIZE as appropriate
+        varname = vars['virt'] + "_ROOT_SIZE"
+        ROOT_SIZE = vars[varname]
         if ROOT_SIZE == "" or ROOT_SIZE == 0:
-            raise ValueError, "ROOT_SIZE invalid"
+            raise ValueError("ROOT_SIZE invalid")
 
-        SWAP_SIZE= vars["SWAP_SIZE"]
+        SWAP_SIZE = vars["SWAP_SIZE"]
         if SWAP_SIZE == "" or SWAP_SIZE == 0:
-            raise ValueError, "SWAP_SIZE invalid"
+            raise ValueError("SWAP_SIZE invalid")
 
-        BOOT_CD_VERSION= vars["BOOT_CD_VERSION"]
-        if BOOT_CD_VERSION == "":
-            raise ValueError, "BOOT_CD_VERSION"
+        NODE_MODEL_OPTIONS = vars["NODE_MODEL_OPTIONS"]
 
-        NODE_MODEL_OPTIONS= vars["NODE_MODEL_OPTIONS"]
+        PARTITIONS = vars["PARTITIONS"]
+        if PARTITIONS == None:
+            raise ValueError("PARTITIONS")
 
-    except KeyError, var:
-        raise BootManagerException, "Missing variable in vars: %s\n" % var
-    except ValueError, var:
-        raise BootManagerException, "Variable in vars, shouldn't be: %s\n" % var
+        if NODE_MODEL_OPTIONS & ModelOptions.RAWDISK:
+            VSERVERS_SIZE = "-1"
+            if "VSERVERS_SIZE" in vars:
+                VSERVERS_SIZE = vars["VSERVERS_SIZE"]
+                if VSERVERS_SIZE == "" or VSERVERS_SIZE == 0:
+                    raise ValueError("VSERVERS_SIZE")
 
-    bs_request= BootServerRequest.BootServerRequest()
+    except KeyError as var:
+        raise BootManagerException("Missing variable in vars: {}\n".format(var))
+    except ValueError as var:
+        raise BootManagerException("Variable in vars, shouldn't be: {}\n".format(var))
 
-    
-    # old cds need extra utilities to partition disks and setup lvm
-    if BOOT_CD_VERSION[0] == 2:
-        compatibility.setup_partdisks_2x_cd( vars, log )
-
-    import parted
-        
-    # define the basic partition paths
-    PARTITIONS= {}
-    PARTITIONS["root"]= "/dev/planetlab/root"
-    PARTITIONS["swap"]= "/dev/planetlab/swap"
-    PARTITIONS["vservers"]= "/dev/planetlab/vservers"
-    # Linux 2.6 mounts LVM with device mapper
-    PARTITIONS["mapper-root"]= "/dev/mapper/planetlab-root"
-    PARTITIONS["mapper-swap"]= "/dev/mapper/planetlab-swap"
-    PARTITIONS["mapper-vservers"]= "/dev/mapper/planetlab-vservers"
-    vars["PARTITIONS"]= PARTITIONS
+    bs_request = BootServerRequest.BootServerRequest(vars)
 
     
     # disable swap if its on
-    utils.sysexec_noerr( "swapoff %s" % PARTITIONS["swap"], log )
+    utils.sysexec_noerr("swapoff {}".format(PARTITIONS["swap"]), log)
 
     # shutdown and remove any lvm groups/volumes
-    utils.sysexec_noerr( "vgscan", log )
-    utils.sysexec_noerr( "vgchange -ay", log )        
-    utils.sysexec_noerr( "lvremove -f /dev/planetlab/root", log )
-    utils.sysexec_noerr( "lvremove -f /dev/planetlab/swap", log )
-    utils.sysexec_noerr( "lvremove -f /dev/planetlab/vservers", log )
-    utils.sysexec_noerr( "vgchange -an", log )
-    utils.sysexec_noerr( "vgremove planetlab", log )
-
-    log.write( "Running vgscan for devices\n" )
-    utils.sysexec_noerr( "vgscan", log )
+    utils.sysexec_noerr("vgscan", log)
+    utils.sysexec_noerr("vgchange -ay", log)        
+    utils.sysexec_noerr("lvremove -f {}".format(PARTITIONS["root"]), log)
+    utils.sysexec_noerr("lvremove -f {}".format(PARTITIONS["swap"]), log)
+    utils.sysexec_noerr("lvremove -f {}".format(PARTITIONS["vservers"]), log)
+    utils.sysexec_noerr("vgchange -an", log)
+    utils.sysexec_noerr("vgremove -f planetlab", log)
+
+    log.write("Running vgscan for devices\n")
+    utils.sysexec_noerr("vgscan", log)
     
-    used_devices= []
+    used_devices = []
 
-    for device in INSTALL_BLOCK_DEVICES:
+    INSTALL_BLOCK_DEVICES.sort()
 
-        if single_partition_device( device, vars, log ):
-            used_devices.append( device )
-            log.write( "Successfully initialized %s\n" % device )
+    for device in INSTALL_BLOCK_DEVICES:
+        if single_partition_device(device, vars, log):
+            if (len(used_devices) > 0 and
+                (vars['NODE_MODEL_OPTIONS'] & ModelOptions.RAWDISK)):
+                log.write("Running in raw disk mode, not using {}.\n".format(device))
+            else:
+                used_devices.append(device)
+                log.write("Successfully initialized {}\n".format(device))
         else:
-            log.write( "Unable to partition %s, not using it.\n" % device )
+            log.write("Unable to partition {], not using it.\n".format(device))
             continue
 
     # list of devices to be used with vgcreate
-    vg_device_list= ""
+    vg_device_list = ""
 
-    # initialize the physical volumes
+    # get partitions
+    partitions = []
     for device in used_devices:
-
-        part_path= get_partition_path_from_device( device, vars, log )
-        
-        if not create_lvm_physical_volume( part_path, vars, log ):
-            raise BootManagerException, "Could not create lvm physical volume " \
-                  "on partition %s" % part_path
-        
+        part_path = get_partition_path_from_device(device, vars, log)
+        partitions.append(part_path)
+   
+    # create raid partition
+    raid_partition = create_raid_partition(partitions, vars, log)
+    if raid_partition != None:
+        partitions = [raid_partition]      
+    log.write("PARTITIONS {}\n".format(str(partitions)))
+    # initialize the physical volumes
+    for part_path in partitions:
+        if not create_lvm_physical_volume(part_path, vars, log):
+            raise BootManagerException("Could not create lvm physical volume "
+                                       "on partition {}".format(part_path))
         vg_device_list = vg_device_list + " " + part_path
 
     # create an lvm volume group
-    utils.sysexec( "vgcreate -s32M planetlab %s" % vg_device_list, log)
+    utils.sysexec("vgcreate -s32M planetlab {}".format(vg_device_list), log)
 
     # create swap logical volume
-    utils.sysexec( "lvcreate -L%s -nswap planetlab" % SWAP_SIZE, log )
+    utils.sysexec("lvcreate -L{} -nswap planetlab".format(SWAP_SIZE), log)
 
-    # create root logical volume
-    utils.sysexec( "lvcreate -L%s -nroot planetlab" % ROOT_SIZE, log )
-
-    # create vservers logical volume with all remaining space
-    # first, we need to get the number of remaining extents we can use
-    remaining_extents= get_remaining_extents_on_vg( vars, log )
-    
-    utils.sysexec( "lvcreate -l%s -nvservers planetlab" % remaining_extents, log )
+    # check if we want a separate partition for VMs
+    one_partition = vars['ONE_PARTITION']=='1'
+    if (one_partition):
+        remaining_extents = get_remaining_extents_on_vg(vars, log)
+        utils.sysexec("lvcreate -l{} -nroot planetlab".format(remaining_extents), log)
+    else:
+        utils.sysexec("lvcreate -L{} -nroot planetlab".format(ROOT_SIZE), log)
+        if vars['NODE_MODEL_OPTIONS'] & ModelOptions.RAWDISK and VSERVERS_SIZE != "-1":
+            utils.sysexec("lvcreate -L{} -nvservers planetlab".format(VSERVERS_SIZE), log)
+            remaining_extents = get_remaining_extents_on_vg(vars, log)
+            utils.sysexec("lvcreate -l{} -nrawdisk planetlab".format(remaining_extents), log)
+        else:
+            # create vservers logical volume with all remaining space
+            # first, we need to get the number of remaining extents we can use
+            remaining_extents = get_remaining_extents_on_vg(vars, log)
+            utils.sysexec("lvcreate -l{} -nvservers planetlab".format(remaining_extents), log)
 
     # activate volume group (should already be active)
-    #utils.sysexec( TEMP_PATH + "vgchange -ay planetlab", log )
+    #utils.sysexec(TEMP_PATH + "vgchange -ay planetlab", log)
 
     # make swap
-    utils.sysexec( "mkswap %s" % PARTITIONS["swap"], log )
+    utils.sysexec("mkswap -f {}".format(PARTITIONS["swap"]), log)
 
     # check if badhd option has been set
     option = ''
@@ -196,27 +164,46 @@ def Run( vars, log ):
     # reserved-blocks-percentages
     filesystems = {"root":5,"vservers":0}
 
-    # make the file systems
-    for fs in filesystems.keys():
-        # get the reserved blocks percentage
-        rbp = filesystems[fs]
-        devname = PARTITIONS[fs]
-        log.write("formatting %s partition (%s)%s.\n" % (fs,devname,txt))
-        utils.sysexec( "mkfs.ext2 -q %s -m %d -j %s" % (option,rbp,devname), log )
+    # ROOT filesystem is always with ext2
+    fs = 'root'
+    rbp = filesystems[fs]
+    devname = PARTITIONS[fs]
+    log.write("formatting {} partition ({}){}.\n".format(fs, devname, txt))
+    utils.sysexec("mkfs.ext2 -q {} -m {} -j {}".format(option, rbp, devname), log)
+    # disable time/count based filesystems checks
+    utils.sysexec_noerr("tune2fs -c -1 -i 0 {}".format(devname), log)
+
+    # VSERVER filesystem with btrfs to support snapshoting and stuff
+    fs = 'vservers'
+    rbp = filesystems[fs]
+    devname = PARTITIONS[fs]
+    if vars['virt'] == 'vs':
+        log.write("formatting {} partition ({}){}.\n".format(fs, devname, txt))
+        utils.sysexec("mkfs.ext2 -q {} -m {} -j {}".format(option, rbp, devname)), log)
+        # disable time/count based filesystems checks
+        utils.sysexec_noerr("tune2fs -c -1 -i 0 {}".format(devname), log)
+    elif not one_partition:
+        log.write("formatting {} btrfs partition ({}).\n".format(fs, devname))
+        # early BootCD's seem to come with a version of mkfs.btrfs that does not support -f
+        # let's check for that before invoking it
+        mkfs = "mkfs.btrfs"
+        if os.system("mkfs.btrfs --help 2>&1 | grep force") == 0:
+            mkfs += " -f"
+        mkfs +=" {}".format(devname)
+        utils.sysexec(mkfs, log)
+        # as of 2013/02 it looks like there's not yet an option to set fsck frequency with btrfs
 
     # save the list of block devices in the log
-    log.write( "Block devices used (in lvm):\n" )
-    log.write( repr(used_devices) + "\n" )
-    log.write( "End of block devices used (in lvm).\n" )
+    log.write("Block devices used (in lvm): {}\n".format(repr(used_devices)))
 
     # list of block devices used may be updated
-    vars["INSTALL_BLOCK_DEVICES"]= used_devices
+    vars["INSTALL_BLOCK_DEVICES"] = used_devices
 
     return 1
 
 
-
-def single_partition_device( device, vars, log ):
+import parted
+def single_partition_device(device, vars, log):
     """
     initialize a disk by removing the old partition tables,
     and creating a new single partition that fills the disk.
@@ -224,92 +211,113 @@ def single_partition_device( device, vars, log ):
     return 1 if sucessful, 0 otherwise
     """
 
-    BOOT_CD_VERSION= vars["BOOT_CD_VERSION"]
-    if BOOT_CD_VERSION[0] == 2:
-        compatibility.setup_partdisks_2x_cd( vars, log )
-
-    import parted
+    # two forms, depending on which version of pyparted we have
+    # v1 does not have a 'version' method
+    # v2 and above does, but to make it worse, 
+    # parted-3.4 on f14 has parted.version broken and raises SystemError
+    try:
+        parted.version()
+        return single_partition_device_2_x (device, vars, log)
+    except AttributeError:
+        # old parted does not have version at all
+        return single_partition_device_1_x (device, vars, log)
+    except SystemError:
+        # let's assume this is >=2
+        return single_partition_device_2_x (device, vars, log)
+    except:
+        raise
+
+def single_partition_device_1_x (device, vars, log):
     
-    lvm_flag= parted.partition_flag_get_by_name('lvm')
+    lvm_flag = parted.partition_flag_get_by_name('lvm')
     
     try:
+        log.write("Using pyparted 1.x\n")
         # wipe the old partition table
-        utils.sysexec( "dd if=/dev/zero of=%s bs=512 count=1" % device, log )
+        utils.sysexec("dd if=/dev/zero of={} bs=512 count=1".format(device), log)
 
         # get the device
-        dev= parted.PedDevice.get(device)
+        dev = parted.PedDevice.get(device)
 
-        # 2.x cds have different libparted that 3.x cds, and they have
-        # different interfaces
-        if BOOT_CD_VERSION[0] == 3:
+        # create a new partition table
+        disk = dev.disk_new_fresh(parted.disk_type_get("msdos"))
 
-            # create a new partition table
-            disk= dev.disk_new_fresh(parted.disk_type_get("msdos"))
+        # create one big partition on each block device
+        constraint = dev.constraint_any()
 
-            # create one big partition on each block device
-            constraint= dev.constraint_any()
+        new_part = disk.partition_new(
+            parted.PARTITION_PRIMARY,
+            parted.file_system_type_get("ext2"),
+            0, 1)
 
-            new_part= disk.partition_new(
-                parted.PARTITION_PRIMARY,
-                parted.file_system_type_get("ext2"),
-                0, 1 )
+        # make it an lvm partition
+        new_part.set_flag(lvm_flag,1)
 
-            # make it an lvm partition
-            new_part.set_flag(lvm_flag,1)
+        # actually add the partition to the disk
+        disk.add_partition(new_part, constraint)
 
-            # actually add the partition to the disk
-            disk.add_partition(new_part, constraint)
+        disk.maximize_partition(new_part,constraint)
 
-            disk.maximize_partition(new_part,constraint)
-
-            disk.commit()
-            del disk
-        else:
-            # create a new partition table
-            dev.disk_create(parted.disk_type_get("msdos"))
-
-            # get the disk
-            disk= parted.PedDisk.open(dev)
-
-                # create one big partition on each block device
-            part= disk.next_partition()
-            while part:
-                if part.type == parted.PARTITION_FREESPACE:
-                    new_part= disk.partition_new(
-                        parted.PARTITION_PRIMARY,
-                        parted.file_system_type_get("ext2"),
-                        part.geom.start,
-                        part.geom.end )
-
-                    constraint = disk.constraint_any()
-
-                    # make it an lvm partition
-                    new_part.set_flag(lvm_flag,1)
+        disk.commit()
+        del disk
+            
+    except BootManagerException as e:
+        log.write("BootManagerException while running: {}\n".format(str(e)))
+        return 0
 
-                    # actually add the partition to the disk
-                    disk.add_partition(new_part, constraint)
+    except parted.error as e:
+        log.write("parted exception while running: {}\n".format(str(e)))
+        return 0
+                   
+    return 1
 
-                    break
 
-                part= disk.next_partition(part)
 
-            disk.write()
-            disk.close()
+def single_partition_device_2_x (device, vars, log):
+    try:
+        log.write("Using pyparted 2.x\n")
+
+        # Thierry june 2012 -- for disks larger than 2TB
+        # calling this with part_type='msdos' would fail at the maximizePartition stage
+        # create a new partition table
+        def partition_table (device, part_type, fs_type):
+            # wipe the old partition table
+            utils.sysexec("dd if=/dev/zero of={} bs=512 count=1".format(device), log)
+            # get the device
+            dev = parted.Device(device)
+            disk = parted.freshDisk(dev, part_type)
+            # create one big partition on each block device
+            constraint = parted.constraint.Constraint (device=dev)
+            geometry = parted.geometry.Geometry (device=dev, start=0, end=1)
+            fs = parted.filesystem.FileSystem (type=fs_type, geometry=geometry)
+            new_part = parted.partition.Partition (disk, type=parted.PARTITION_NORMAL,
+                                                  fs=fs, geometry=geometry)
+            # make it an lvm partition
+            new_part.setFlag(parted.PARTITION_LVM)
+            # actually add the partition to the disk
+            disk.addPartition(new_part, constraint)
+            disk.maximizePartition(new_part, constraint)
+            disk.commit()
+            log.write ("Current disk for {} - partition type {}\n{}\n".format(device, part_type, disk))
+            log.write ("Current dev for {}\n{}\n".format(device, dev))
             del disk
-            
-    except BootManagerException, e:
-        log.write( "BootManagerException while running: %s\n" % str(e) )
-        return 0
 
-    except parted.error, e:
-        log.write( "parted exception while running: %s\n" % str(e) )
+        try:
+            partition_table (device, 'msdos', 'ext2')
+        except:
+            partition_table (device, 'gpt', 'ext2')
+
+    except Exception as e:
+        log.write("Exception inside single_partition_device_2_x : {}\n".format(str(e)))
+        import traceback
+        traceback.print_exc(file=log)
         return 0
                    
     return 1
 
 
 
-def create_lvm_physical_volume( part_path, vars, log ):
+def create_lvm_physical_volume(part_path, vars, log):
     """
     make the specificed partition a lvm physical volume.
 
@@ -318,53 +326,91 @@ def create_lvm_physical_volume( part_path, vars, log ):
 
     try:
         # again, wipe any old data, this time on the partition
-        utils.sysexec( "dd if=/dev/zero of=%s bs=512 count=1" % part_path, log )
+        utils.sysexec("dd if=/dev/zero of={} bs=512 count=1".format(part_path), log)
         ### patch Thierry Parmentelat, required on some hardware
         import time
         time.sleep(1)
-        utils.sysexec( "pvcreate -ffy %s" % part_path, log )
-    except BootManagerException, e:
-        log.write( "create_lvm_physical_volume failed.\n" )
+        utils.sysexec("pvcreate -ffy {}".format(part_path), log)
+    except BootManagerException as e:
+        log.write("create_lvm_physical_volume failed.\n")
         return 0
 
     return 1
 
 
+def create_raid_partition(partitions, vars, log):
+    """
+    create raid array using specified partitions.  
+    """ 
+    raid_part = None
+    raid_enabled = False
+    node_tags = BootAPI.call_api_function(vars, "GetNodeTags",
+                                          ({'node_id': vars['NODE_ID']},))
+    for node_tag in node_tags:
+        if node_tag['tagname'] == 'raid_enabled' and \
+           node_tag['value'] == '1':
+            raid_enabled = True
+            break
+    if not raid_enabled:
+        return raid_part
+
+    try:
+        log.write("Software raid enabled.\n")
+        # wipe everything
+        utils.sysexec_noerr("mdadm --stop /dev/md0", log)
+        time.sleep(1)
+        for part_path in partitions:
+            utils.sysexec_noerr("mdadm --zero-superblock {} ".format(part_path), log)
+
+        # assume each partiton is on a separate disk
+        num_parts = len(partitions)
+        if num_parts < 2:
+            log.write("Not enough disks for raid. Found: {}\n".format(partitions))
+            raise BootManagerException("Not enough disks for raid. Found: {}\n".format(partitions))
+        if num_parts == 2:
+            lvl = 1
+        else:
+            lvl = 5
+        
+        # make the array
+        part_list = " ".join(partitions)
+        raid_part = "/dev/md0"
+        cmd = "mdadm --create {raid_part} --chunk=128 --level=raid{lvl} "\
+              "--raid-devices={num_parts} {part_list}".format(**locals())
+        utils.sysexec(cmd, log)
+
+    except BootManagerException as e:
+        log.write("create_raid_partition failed.\n")
+        raid_part = None
+
+    return raid_part  
 
-def get_partition_path_from_device( device, vars, log ):
+
+def get_partition_path_from_device(device, vars, log):
     """
     given a device, return the path of the first partition on the device
     """
 
-    BOOT_CD_VERSION= vars["BOOT_CD_VERSION"]
-        
     # those who wrote the cciss driver just had to make it difficult
-    if BOOT_CD_VERSION[0] == 3:
-        cciss_test= "/dev/cciss"
-        if device[:len(cciss_test)] == cciss_test:
-            part_path= device + "p1"
-        else:
-            part_path= device + "1"
+    cciss_test = "/dev/cciss"
+    if device[:len(cciss_test)] == cciss_test:
+        part_path = device + "p1"
     else:
-        # since device ends in /disc, we need to make it end in
-        # /part1 to indicate the first partition (for devfs based 2.x cds)
-        dev_parts= string.split(device,"/")
-        dev_parts[len(dev_parts)-1]= "part1"
-        part_path= string.join(dev_parts,"/")
+        part_path = device + "1"
 
     return part_path
 
 
 
-def get_remaining_extents_on_vg( vars, log ):
+def get_remaining_extents_on_vg(vars, log):
     """
     return the free amount of extents on the planetlab volume group
     """
     
     c_stdout, c_stdin = popen2.popen2("vgdisplay -c planetlab")
-    result= string.strip(c_stdout.readline())
+    result = string.strip(c_stdout.readline())
     c_stdout.close()
     c_stdin.close()
-    remaining_extents= string.split(result,":")[15]
+    remaining_extents = string.split(result, ":")[15]
     
     return remaining_extents