From acb4df1b7646175077d82cebb7335ba599fde8c8 Mon Sep 17 00:00:00 2001 From: FUJITA Tomonori Date: Fri, 15 Aug 2008 10:43:54 +0900 Subject: [PATCH] dm snapshot: add snapshot id argument to prepare_exception and lookup_completed_exception With the current two exception store implementations (persistent and transient), snapshots are independent. Each snapshot has own cow disk and dm_snapshot struct. With shared exception store code, snapshots are not independent. They are stored in a single cow disk and has only one dm_snapshot struct. So the shared exception store code needs to identify snapshot in prepare_exception() and lookup_completed_exception(). Signed-off-by: FUJITA Tomonori --- drivers/md/dm-exception-store.c | 4 ++-- drivers/md/dm-snap.c | 22 ++++++++++++---------- drivers/md/dm-snap.h | 6 ++++-- 3 files changed, 18 insertions(+), 14 deletions(-) diff --git a/drivers/md/dm-exception-store.c b/drivers/md/dm-exception-store.c index 8931364..60f33da 100644 --- a/drivers/md/dm-exception-store.c +++ b/drivers/md/dm-exception-store.c @@ -514,7 +514,7 @@ static int persistent_read_metadata(struct exception_store *store) } static int persistent_prepare(struct exception_store *store, - struct dm_snap_exception *e) + struct dm_snap_exception *e, u64 snapid) { struct pstore *ps = get_info(store); uint32_t stride; @@ -658,7 +658,7 @@ static int transient_read_metadata(struct exception_store *store) } static int transient_prepare(struct exception_store *store, - struct dm_snap_exception *e) + struct dm_snap_exception *e, u64 snapid) { struct transient_c *tc = (struct transient_c *) store->context; sector_t size = get_dev_size(store->snap->cow->bdev); diff --git a/drivers/md/dm-snap.c b/drivers/md/dm-snap.c index fa0e9f7..bea98b4 100644 --- a/drivers/md/dm-snap.c +++ b/drivers/md/dm-snap.c @@ -348,10 +348,12 @@ static struct dm_snap_exception *lookup_exception(struct exception_table *et, } struct dm_snap_exception *lookup_complete_exception(struct dm_snapshot *s, - chunk_t chunk) + chunk_t chunk, + u64 snapid) { if (s->store.lookup_completed_exception) - return s->store.lookup_completed_exception(&s->store, chunk); + return s->store.lookup_completed_exception(&s->store, chunk, + snapid); else return lookup_exception(&s->complete, chunk); } @@ -975,7 +977,7 @@ static void start_copy(struct dm_snap_pending_exception *pe) * this. */ static struct dm_snap_pending_exception * -__find_pending_exception(struct dm_snapshot *s, struct bio *bio) +__find_pending_exception(struct dm_snapshot *s, struct bio *bio, u64 snapid) { struct dm_snap_exception *e; struct dm_snap_pending_exception *pe; @@ -1018,7 +1020,7 @@ __find_pending_exception(struct dm_snapshot *s, struct bio *bio) atomic_set(&pe->ref_count, 0); pe->started = 0; - if (s->store.prepare_exception(&s->store, &pe->e)) { + if (s->store.prepare_exception(&s->store, &pe->e, snapid)) { free_pending_exception(pe); return NULL; } @@ -1040,7 +1042,7 @@ static void remap_exception(struct dm_snapshot *s, struct dm_snap_exception *e, } static int do_snapshot_map(struct dm_snapshot *s, struct bio *bio, - union map_info *map_context) + union map_info *map_context, u64 snapid) { struct dm_snap_exception *e; int r = DM_MAPIO_REMAPPED; @@ -1064,7 +1066,7 @@ static int do_snapshot_map(struct dm_snapshot *s, struct bio *bio, } /* If the block is already remapped - use that, else remap it */ - e = lookup_complete_exception(s, chunk); + e = lookup_complete_exception(s, chunk, snapid); if (e) { remap_exception(s, e, bio, chunk); goto out_unlock; @@ -1076,7 +1078,7 @@ static int do_snapshot_map(struct dm_snapshot *s, struct bio *bio, * writeable. */ if (bio_rw(bio) == WRITE) { - pe = __find_pending_exception(s, bio); + pe = __find_pending_exception(s, bio, snapid); if (!pe) { __invalidate_snapshot(s, -ENOMEM); r = -EIO; @@ -1111,7 +1113,7 @@ static int snapshot_map(struct dm_target *ti, struct bio *bio, { struct dm_snapshot *s = ti->private; - return do_snapshot_map(s, bio, map_context); + return do_snapshot_map(s, bio, map_context, 0); } static int do_snapshot_end_io(struct dm_snapshot *s, struct bio *bio, @@ -1220,11 +1222,11 @@ static int __origin_write(struct list_head *snapshots, struct bio *bio) * ref_count is initialised to 1 so pending_complete() * won't destroy the primary_pe while we're inside this loop. */ - e = lookup_complete_exception(snap, chunk); + e = lookup_complete_exception(snap, chunk, ORIGIN_SNAPID); if (e) goto next_snapshot; - pe = __find_pending_exception(snap, bio); + pe = __find_pending_exception(snap, bio, ORIGIN_SNAPID); if (!pe) { __invalidate_snapshot(snap, -ENOMEM); goto next_snapshot; diff --git a/drivers/md/dm-snap.h b/drivers/md/dm-snap.h index 4eefb90..dfbef9b 100644 --- a/drivers/md/dm-snap.h +++ b/drivers/md/dm-snap.h @@ -83,6 +83,8 @@ static inline void dm_consecutive_chunk_count_inc(struct dm_snap_exception *e) # endif +#define ORIGIN_SNAPID ULLONG_MAX + /* * Abstraction to handle the meta/layout of exception stores (the * COW device). @@ -104,7 +106,7 @@ struct exception_store { * Find somewhere to store the next exception. */ int (*prepare_exception) (struct exception_store *store, - struct dm_snap_exception *e); + struct dm_snap_exception *e, u64 snapid); /* * Update the metadata with this exception. @@ -130,7 +132,7 @@ struct exception_store { * look up if a chunk is in completed exception. */ struct dm_snap_exception *(*lookup_completed_exception) - (struct exception_store *store, chunk_t chunk); + (struct exception_store *store, chunk_t chunk, u64 snapid); /* * let exception store code to handle the message hook in -- 1.5.5.GIT