-
- # Leave 2048 blocks at the end
- new_end = last.end + 2048
-
- if last.mpoint:
- stat = statvfs(last.mpoint)
- occupied_blocks = stat.f_blocks - stat.f_bavail
- new_size = (occupied * stat.f_frsize) // src_dev.sectorSize
- # Add 10% just to be on the safe side
- last.end = last.start + (new_size * 11) // 10
-
- # Alighn to 2048
- last.end = ((last.end + 2047) // 2048) * 2048
-
- # Leave 2048 blocks at the end.
- new_end = new_size + 2048
-
- img_disk.setPartitionGeometry(
- img_disk.getPartitionBySector(last.start),
- parted.Constraint(device=img_dev), start=last.star, end=last.end)
-
- if last.type == parted.PARTITION_LOGICAL:
- # Fix the extended partition
- ext = disk.getExtendedPartition()
-
- img_disk.setPartitionGeometry(ext,
- parted.Constraint(device=img_dev), ext.geometry.start,
- end=last.end)
-
- # Check if we have the available space on the filesystem hosting /mnt
- # for the image.
- out.output("Examining available space in /mnt ... ", False)
- stat = os.statvfs('/mnt')
- image_size = (new_end + 1) * src_dev.sectorSize
- available = stat.f_bavail * stat.f_frsize
-
- if available <= image_size:
- raise FatalError('Not enough space in /mnt to host the image')
-
- out.success("sufficient")
-
- return img
+ new_end = src_disk.device.getLength()
+ if last.fs == 'linux-swap(v1)':
+ MB = 2 ** 20
+ size = (last.end - last.start + 1) * src_disk.device.sectorSize
+ self.meta['SWAP'] = "%d:%s" % (last.num, (size + MB - 1) // MB)
+
+ image_disk.deletePartition(
+ image_disk.getPartitionBySector(last.start))
+ image_disk.commit()
+
+ if is_logical(last) and last.num == 5:
+ extended = image_disk.getExtendedPartition()
+ image_disk.deletePartition(extended)
+ image_disk.commit()
+ partitions.remove(filter(is_extended, partitions)[0])
+
+ partitions.remove(last)
+ last = partitions[-1]
+
+ # Leave 2048 blocks at the end
+ new_end = last.end + 2048
+
+ if last.mopts.mpoint:
+ stat = os.statvfs(last.mopts.mpoint)
+ # Shrink the last partition. The new size should be the
+ # size of the occupied blocks
+ blcks = stat.f_blocks - stat.f_bavail
+ new_size = (blcks * stat.f_frsize) // src_disk.device.sectorSize
+
+ # Add 10% just to be on the safe side
+ part_end = last.start + (new_size * 11) // 10
+ # Alighn to 2048
+ part_end = ((part_end + 2047) // 2048) * 2048
+ last = last._replace(end=part_end)
+ partitions[-1] = last
+
+ # Leave 2048 blocks at the end.
+ new_end = new_size + 2048
+
+ image_disk.setPartitionGeometry(
+ image_disk.getPartitionBySector(last.start),
+ parted.Constraint(device=image_disk.device),
+ start=last.start, end=last.end)
+ image_disk.commit()
+
+ if last.type == parted.PARTITION_LOGICAL:
+ # Fix the extended partition
+ extended = disk.getExtendedPartition()
+
+ image_disk.setPartitionGeometry(extended,
+ parted.Constraint(device=img_dev),
+ ext.geometry.start, end=last.end)
+ image_disk.commit()
+
+ # Check if the available space is enough to host the image
+ location = os.path.dirname(image_file)
+ size = (new_end + 1) * src_disk.device.sectorSize
+ self.out.output("Examining available space in %s..." % location, False)
+ stat = os.statvfs(location)
+ available = stat.f_bavail * stat.f_frsize
+ if available <= size:
+ raise FatalError('Not enough space in %s to host the image' % \
+ location)
+ self.out.success("sufficient")
+
+ return partitions
+
+ def _fill_partitions(self, src_disk, image, partitions):
+ pass
+
+ def create_image(self):
+
+ image_file = '/mnt/%s.diskdump' % uuid.uuid4().hex
+
+ src_dev = parted.Device(self.disk)
+
+ size = src_dev.getLength() * src_dev.sectorSize
+
+ # Create sparse file to host the image
+ truncate("-s", "%d" % size, image_file)
+
+ src_disk = parted.Disk(src_dev)
+ self._create_partition_table(src_disk, image_file)
+ partitions = self._shrink_partitions(src_disk, image_file)
+ self._fill_partitions(src_disk, image_file, partitions)
+
+ return image_file
+
+# unmounted = filter(lambda p: not p.mopts.mpoint, partitions)
+# mounted = filter(lambda p: p.mopts.mpoint, partitions)
+#
+# for p in unmounted:
+# dd('if=%s' % src_dev.path, 'of=%s' % img_dev.path,
+# 'count=%d' % (p.end - p.start + 1), 'conv=notrunc',
+# 'seek=%d' % p.start, 'skip=%d' % p.start)
+#
+# partition_devices = create_devices(dest, partitions)
+#
+# mounted.sort(key=lambda p: p.mopts.mpoint)
+#
+# return img