+ # 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