Gitweb:
http://git.kernel.org/git/?p=linux/kernel/git/torvalds/linux-2.6.git;a=commit;h=dec1cedf9d4eabe43f3c7d6af095eff40c139a89
Commit: dec1cedf9d4eabe43f3c7d6af095eff40c139a89
Parent: 0c395b0f8dd7aee394df95b46963fc0f3401cf90
Author: Milan Broz <[EMAIL PROTECTED]>
AuthorDate: Fri Feb 8 02:10:57 2008 +0000
Committer: Alasdair G Kergon <[EMAIL PROTECTED]>
CommitDate: Fri Feb 8 02:10:57 2008 +0000
dm crypt: abstract crypt_write_done
Process write request in separate function and queue
final bio through io workqueue.
Signed-off-by: Milan Broz <[EMAIL PROTECTED]>
Signed-off-by: Alasdair G Kergon <[EMAIL PROTECTED]>
---
drivers/md/dm-crypt.c | 41 +++++++++++++++++++++++++----------------
1 files changed, 25 insertions(+), 16 deletions(-)
diff --git a/drivers/md/dm-crypt.c b/drivers/md/dm-crypt.c
index d3c48ad..4df7d2f 100644
--- a/drivers/md/dm-crypt.c
+++ b/drivers/md/dm-crypt.c
@@ -577,18 +577,34 @@ static void kcryptd_queue_io(struct dm_crypt_io *io)
static void kcryptd_crypt_write_io_submit(struct dm_crypt_io *io, int error)
{
+ struct bio *clone = io->ctx.bio_out;
+ struct crypt_config *cc = io->target->private;
+
+ if (unlikely(error < 0)) {
+ crypt_free_buffer_pages(cc, clone);
+ bio_put(clone);
+ io->error = -EIO;
+ crypt_dec_pending(io);
+ return;
+ }
+
+ /* crypt_convert should have filled the clone bio */
+ BUG_ON(io->ctx.idx_out < clone->bi_vcnt);
+
+ clone->bi_sector = cc->start + io->sector;
+ io->sector += bio_sectors(clone);
}
static void kcryptd_crypt_write_convert(struct dm_crypt_io *io)
{
struct crypt_config *cc = io->target->private;
- struct bio *base_bio = io->base_bio;
struct bio *clone;
- unsigned remaining = base_bio->bi_size;
+ unsigned remaining = io->base_bio->bi_size;
+ int r;
atomic_inc(&io->pending);
- crypt_convert_init(cc, &io->ctx, NULL, base_bio, io->sector);
+ crypt_convert_init(cc, &io->ctx, NULL, io->base_bio, io->sector);
/*
* The allocated buffers can be smaller than the whole bio,
@@ -605,20 +621,13 @@ static void kcryptd_crypt_write_convert(struct
dm_crypt_io *io)
io->ctx.bio_out = clone;
io->ctx.idx_out = 0;
- if (unlikely(crypt_convert(cc, &io->ctx) < 0)) {
- crypt_free_buffer_pages(cc, clone);
- bio_put(clone);
- io->error = -EIO;
- crypt_dec_pending(io);
- return;
- }
+ remaining -= clone->bi_size;
- /* crypt_convert should have filled the clone bio */
- BUG_ON(io->ctx.idx_out < clone->bi_vcnt);
+ r = crypt_convert(cc, &io->ctx);
- clone->bi_sector = cc->start + io->sector;
- remaining -= clone->bi_size;
- io->sector += bio_sectors(clone);
+ kcryptd_crypt_write_io_submit(io, r);
+ if (unlikely(r < 0))
+ return;
/* Grab another reference to the io struct
* before we kick off the request */
@@ -631,7 +640,7 @@ static void kcryptd_crypt_write_convert(struct dm_crypt_io
*io)
* may be gone already. */
/* out of memory -> run queues */
- if (remaining)
+ if (unlikely(remaining))
congestion_wait(WRITE, HZ/100);
}
}
-
To unsubscribe from this list: send the line "unsubscribe git-commits-head" in
the body of a message to [EMAIL PROTECTED]
More majordomo info at http://vger.kernel.org/majordomo-info.html
