[lvm-devel] LVM2 lib/snapshot/snapshot.c libdm/.exported_s ...
snitzer at sourceware.org
snitzer at sourceware.org
Wed Jan 13 01:39:45 UTC 2010
CVSROOT: /cvs/lvm2
Module name: LVM2
Changes by: snitzer at sourceware.org 2010-01-13 01:39:45
Modified files:
lib/snapshot : snapshot.c
libdm : .exported_symbols libdevmapper.h
libdm-deptree.c
Log message:
Add support for "snapshot-merge" target.
Introduces new libdevmapper function dm_tree_node_add_snapshot_merge_target
Verifies that the kernel (dm-snapshot) provides the 'snapshot-merge'
target.
Activate origin LV as snapshot-merge target. Using snapshot-origin
target would be pointless because the origin contains volatile data
while a merge is in progress.
Because snapshot-merge target is activated in place of the
snapshot-origin target it must be resumed after all other snapshots
(just like snapshot-origin does) --- otherwise small window for data
corruption would exist.
Ideally the merging snapshot would not be activated at all but if it is
to be activated (because snapshot was already active) it _must_ be done
after the snapshot-merge. This insures that DM's snapshot-merge target
will perform exception handover in the proper order (new->resume before
old->resume). DM's snapshot-merge does support handover if the reverse
sequence is used (old->resume before new->resume) but DM will fail to
resume the old snapshot; leaving it suspended.
To insure the proper activation sequence dm_tree_activate_children() was
updated to accommodate an additional 'activation_priority' level. All
regular snapshots are 0, snapshot-merge is 1, and merging snapshot is 2.
Patches:
http://sourceware.org/cgi-bin/cvsweb.cgi/LVM2/lib/snapshot/snapshot.c.diff?cvsroot=lvm2&r1=1.40&r2=1.41
http://sourceware.org/cgi-bin/cvsweb.cgi/LVM2/libdm/.exported_symbols.diff?cvsroot=lvm2&r1=1.47&r2=1.48
http://sourceware.org/cgi-bin/cvsweb.cgi/LVM2/libdm/libdevmapper.h.diff?cvsroot=lvm2&r1=1.105&r2=1.106
http://sourceware.org/cgi-bin/cvsweb.cgi/LVM2/libdm/libdm-deptree.c.diff?cvsroot=lvm2&r1=1.68&r2=1.69
--- LVM2/lib/snapshot/snapshot.c 2010/01/13 01:35:49 1.40
+++ LVM2/lib/snapshot/snapshot.c 2010/01/13 01:39:44 1.41
@@ -130,17 +130,25 @@
}
static int _snap_target_present(struct cmd_context *cmd,
- const struct lv_segment *seg __attribute((unused)),
+ const struct lv_segment *seg,
unsigned *attributes __attribute((unused)))
{
static int _snap_checked = 0;
+ static int _snap_merge_checked = 0;
static int _snap_present = 0;
+ static int _snap_merge_present = 0;
- if (!_snap_checked)
+ if (!_snap_checked) {
_snap_present = target_present(cmd, "snapshot", 1) &&
target_present(cmd, "snapshot-origin", 0);
+ _snap_checked = 1;
+ }
- _snap_checked = 1;
+ if (!_snap_merge_checked && seg && (seg->status & SNAPSHOT_MERGE)) {
+ _snap_merge_present = target_present(cmd, "snapshot-merge", 0);
+ _snap_merge_checked = 1;
+ return _snap_present && _snap_merge_present;
+ }
return _snap_present;
}
--- LVM2/libdm/.exported_symbols 2010/01/11 15:36:24 1.47
+++ LVM2/libdm/.exported_symbols 2010/01/13 01:39:45 1.48
@@ -71,6 +71,7 @@
dm_tree_children_use_uuid
dm_tree_node_add_snapshot_origin_target
dm_tree_node_add_snapshot_target
+dm_tree_node_add_snapshot_merge_target
dm_tree_node_add_error_target
dm_tree_node_add_zero_target
dm_tree_node_add_linear_target
--- LVM2/libdm/libdevmapper.h 2010/01/11 15:36:24 1.105
+++ LVM2/libdm/libdevmapper.h 2010/01/13 01:39:45 1.106
@@ -394,6 +394,12 @@
const char *cow_uuid,
int persistent,
uint32_t chunk_size);
+int dm_tree_node_add_snapshot_merge_target(struct dm_tree_node *node,
+ uint64_t size,
+ const char *origin_uuid,
+ const char *cow_uuid,
+ const char *merge_uuid,
+ uint32_t chunk_size);
int dm_tree_node_add_error_target(struct dm_tree_node *node,
uint64_t size);
int dm_tree_node_add_zero_target(struct dm_tree_node *node,
--- LVM2/libdm/libdm-deptree.c 2010/01/07 19:54:22 1.68
+++ LVM2/libdm/libdm-deptree.c 2010/01/13 01:39:45 1.69
@@ -35,6 +35,7 @@
SEG_MIRRORED,
SEG_SNAPSHOT,
SEG_SNAPSHOT_ORIGIN,
+ SEG_SNAPSHOT_MERGE,
SEG_STRIPED,
SEG_ZERO,
};
@@ -51,6 +52,7 @@
{ SEG_MIRRORED, "mirror" },
{ SEG_SNAPSHOT, "snapshot" },
{ SEG_SNAPSHOT_ORIGIN, "snapshot-origin" },
+ { SEG_SNAPSHOT_MERGE, "snapshot-merge" },
{ SEG_STRIPED, "striped" },
{ SEG_ZERO, "zero"},
};
@@ -81,6 +83,7 @@
uint32_t chunk_size; /* Snapshot */
struct dm_tree_node *cow; /* Snapshot */
struct dm_tree_node *origin; /* Snapshot + Snapshot origin */
+ struct dm_tree_node *merge; /* Snapshot */
struct dm_tree_node *log; /* Mirror */
uint32_t region_size; /* Mirror */
@@ -1179,7 +1182,7 @@
handle = NULL;
- for (priority = 0; priority < 2; priority++) {
+ for (priority = 0; priority < 3; priority++) {
while ((child = dm_tree_next_child(&handle, dnode, 0))) {
if (!(uuid = dm_tree_node_get_uuid(child))) {
stack;
@@ -1471,6 +1474,7 @@
return_0;
break;
case SEG_SNAPSHOT:
+ case SEG_SNAPSHOT_MERGE:
if (!_build_dev_string(originbuf, sizeof(originbuf), seg->origin))
return_0;
if (!_build_dev_string(cowbuf, sizeof(cowbuf), seg->cow))
@@ -1499,6 +1503,7 @@
case SEG_ERROR:
case SEG_SNAPSHOT:
case SEG_SNAPSHOT_ORIGIN:
+ case SEG_SNAPSHOT_MERGE:
case SEG_ZERO:
break;
case SEG_CRYPT:
@@ -1735,6 +1740,7 @@
seg->chunk_size = 0;
seg->cow = NULL;
seg->origin = NULL;
+ seg->merge = NULL;
dm_list_add(&dnode->props.segs, &seg->list);
dnode->props.segment_count++;
@@ -1767,17 +1773,21 @@
return 1;
}
-int dm_tree_node_add_snapshot_target(struct dm_tree_node *node,
- uint64_t size,
- const char *origin_uuid,
- const char *cow_uuid,
- int persistent,
- uint32_t chunk_size)
+static int _add_snapshot_target(struct dm_tree_node *node,
+ uint64_t size,
+ const char *origin_uuid,
+ const char *cow_uuid,
+ const char *merge_uuid,
+ int persistent,
+ uint32_t chunk_size)
{
struct load_segment *seg;
- struct dm_tree_node *origin_node, *cow_node;
+ struct dm_tree_node *origin_node, *cow_node, *merge_node;
+ unsigned seg_type;
+
+ seg_type = !merge_uuid ? SEG_SNAPSHOT : SEG_SNAPSHOT_MERGE;
- if (!(seg = _add_segment(node, SEG_SNAPSHOT, size)))
+ if (!(seg = _add_segment(node, seg_type, size)))
return_0;
if (!(origin_node = dm_tree_find_node_by_uuid(node->dtree, origin_uuid))) {
@@ -1790,7 +1800,7 @@
return_0;
if (!(cow_node = dm_tree_find_node_by_uuid(node->dtree, cow_uuid))) {
- log_error("Couldn't find snapshot origin uuid %s.", cow_uuid);
+ log_error("Couldn't find snapshot COW device uuid %s.", cow_uuid);
return 0;
}
@@ -1801,9 +1811,49 @@
seg->persistent = persistent ? 1 : 0;
seg->chunk_size = chunk_size;
+ if (merge_uuid) {
+ if (!(merge_node = dm_tree_find_node_by_uuid(node->dtree, merge_uuid))) {
+ /* not a pure error, merging snapshot may have been deactivated */
+ log_verbose("Couldn't find merging snapshot uuid %s.", merge_uuid);
+ } else {
+ seg->merge = merge_node;
+ /* must not link merging snapshot, would undermine activation_priority below */
+ }
+
+ /* Resume snapshot-merge (acting origin) after other snapshots */
+ node->activation_priority = 1;
+ if (seg->merge) {
+ /* Resume merging snapshot after snapshot-merge */
+ seg->merge->activation_priority = 2;
+ }
+ }
+
return 1;
}
+
+int dm_tree_node_add_snapshot_target(struct dm_tree_node *node,
+ uint64_t size,
+ const char *origin_uuid,
+ const char *cow_uuid,
+ int persistent,
+ uint32_t chunk_size)
+{
+ return _add_snapshot_target(node, size, origin_uuid, cow_uuid,
+ NULL, persistent, chunk_size);
+}
+
+int dm_tree_node_add_snapshot_merge_target(struct dm_tree_node *node,
+ uint64_t size,
+ const char *origin_uuid,
+ const char *cow_uuid,
+ const char *merge_uuid,
+ uint32_t chunk_size)
+{
+ return _add_snapshot_target(node, size, origin_uuid, cow_uuid,
+ merge_uuid, 1, chunk_size);
+}
+
int dm_tree_node_add_error_target(struct dm_tree_node *node,
uint64_t size)
{
More information about the lvm-devel
mailing list