Skip to content

Commit

Permalink
---
Browse files Browse the repository at this point in the history
yaml
---
r: 66072
b: refs/heads/master
c: d24517d
h: refs/heads/master
v: v3
  • Loading branch information
NeilBrown authored and Jens Axboe committed Oct 10, 2007
1 parent 8a72dec commit af20e43
Show file tree
Hide file tree
Showing 3 changed files with 3 additions and 39 deletions.
2 changes: 1 addition & 1 deletion [refs]
Original file line number Diff line number Diff line change
@@ -1,2 +1,2 @@
---
refs/heads/master: f5ff8422bbdd59f8c1f699df248e1b7a11073027
refs/heads/master: d24517d793f21edab1a411da95f2c45cb88a84aa
39 changes: 2 additions & 37 deletions trunk/block/ll_rw_blk.c
Original file line number Diff line number Diff line change
Expand Up @@ -431,7 +431,6 @@ static void queue_flush(struct request_queue *q, unsigned which)
static inline struct request *start_ordered(struct request_queue *q,
struct request *rq)
{
q->bi_size = 0;
q->orderr = 0;
q->ordered = q->next_ordered;
q->ordseq |= QUEUE_ORDSEQ_STARTED;
Expand Down Expand Up @@ -528,55 +527,21 @@ int blk_do_ordered(struct request_queue *q, struct request **rqp)
return 1;
}

static int flush_dry_bio_endio(struct bio *bio, unsigned int bytes, int error)
{
struct request_queue *q = bio->bi_private;

/*
* This is dry run, restore bio_sector and size. We'll finish
* this request again with the original bi_end_io after an
* error occurs or post flush is complete.
*/
q->bi_size += bytes;

if (bio->bi_size)
return 1;

/* Reset bio */
set_bit(BIO_UPTODATE, &bio->bi_flags);
bio->bi_size = q->bi_size;
bio->bi_sector -= (q->bi_size >> 9);
q->bi_size = 0;

return 0;
}

static int ordered_bio_endio(struct request *rq, struct bio *bio,
unsigned int nbytes, int error)
{
struct request_queue *q = rq->q;
bio_end_io_t *endio;
void *private;

if (&q->bar_rq != rq)
return 0;

/*
* Okay, this is the barrier request in progress, dry finish it.
* Okay, this is the barrier request in progress, just
* record the error;
*/
if (error && !q->orderr)
q->orderr = error;

endio = bio->bi_end_io;
private = bio->bi_private;
bio->bi_end_io = flush_dry_bio_endio;
bio->bi_private = q;

bio_endio(bio, nbytes, error);

bio->bi_end_io = endio;
bio->bi_private = private;

return 1;
}

Expand Down
1 change: 0 additions & 1 deletion trunk/include/linux/blkdev.h
Original file line number Diff line number Diff line change
Expand Up @@ -471,7 +471,6 @@ struct request_queue
int orderr, ordcolor;
struct request pre_flush_rq, bar_rq, post_flush_rq;
struct request *orig_bar_rq;
unsigned int bi_size;

struct mutex sysfs_lock;

Expand Down

0 comments on commit af20e43

Please sign in to comment.