Skip to content

Commit

Permalink
---
Browse files Browse the repository at this point in the history
yaml
---
r: 285108
b: refs/heads/master
c: 1238033
h: refs/heads/master
v: v3
  • Loading branch information
Tejun Heo authored and Jens Axboe committed Dec 13, 2011
1 parent afecf7d commit 8858071
Show file tree
Hide file tree
Showing 3 changed files with 6 additions and 23 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: b50b636bce6293fa858cc7ff6c3ffe4920d90006
refs/heads/master: 1238033c79e92e5c315af12e45396f1a78c73dec
26 changes: 5 additions & 21 deletions trunk/block/cfq-iosched.c
Original file line number Diff line number Diff line change
Expand Up @@ -472,22 +472,9 @@ static inline void cic_set_cfqq(struct cfq_io_context *cic,
cic->cfqq[is_sync] = cfqq;
}

#define CIC_DEAD_KEY 1ul
#define CIC_DEAD_INDEX_SHIFT 1

static inline void *cfqd_dead_key(struct cfq_data *cfqd)
{
return (void *)(cfqd->queue->id << CIC_DEAD_INDEX_SHIFT | CIC_DEAD_KEY);
}

static inline struct cfq_data *cic_to_cfqd(struct cfq_io_context *cic)
{
struct cfq_data *cfqd = cic->key;

if (unlikely((unsigned long) cfqd & CIC_DEAD_KEY))
return NULL;

return cfqd;
return cic->q->elevator->elevator_data;
}

/*
Expand Down Expand Up @@ -2679,10 +2666,8 @@ static void cfq_cic_free(struct cfq_io_context *cic)
static void cfq_release_cic(struct cfq_io_context *cic)
{
struct io_context *ioc = cic->ioc;
unsigned long dead_key = (unsigned long) cic->key;

BUG_ON(!(dead_key & CIC_DEAD_KEY));
radix_tree_delete(&ioc->radix_root, dead_key >> CIC_DEAD_INDEX_SHIFT);
radix_tree_delete(&ioc->radix_root, cic->q->id);
hlist_del(&cic->cic_list);
cfq_cic_free(cic);
}
Expand Down Expand Up @@ -2726,7 +2711,6 @@ static void cfq_exit_cic(struct cfq_io_context *cic)
struct io_context *ioc = cic->ioc;

list_del_init(&cic->queue_list);
cic->key = cfqd_dead_key(cfqd);

/*
* Both setting lookup hint to and clearing it from @cic are done
Expand Down Expand Up @@ -2982,6 +2966,7 @@ cfq_get_queue(struct cfq_data *cfqd, bool is_sync, struct io_context *ioc,
static struct cfq_io_context *
cfq_cic_lookup(struct cfq_data *cfqd, struct io_context *ioc)
{
struct request_queue *q = cfqd->queue;
struct cfq_io_context *cic;

lockdep_assert_held(cfqd->queue->queue_lock);
Expand All @@ -2996,11 +2981,11 @@ cfq_cic_lookup(struct cfq_data *cfqd, struct io_context *ioc)
*/
rcu_read_lock();
cic = rcu_dereference(ioc->ioc_data);
if (cic && cic->key == cfqd)
if (cic && cic->q == q)
goto out;

cic = radix_tree_lookup(&ioc->radix_root, cfqd->queue->id);
if (cic && cic->key == cfqd)
if (cic && cic->q == q)
rcu_assign_pointer(ioc->ioc_data, cic); /* allowed to race */
else
cic = NULL;
Expand Down Expand Up @@ -3040,7 +3025,6 @@ static int cfq_create_cic(struct cfq_data *cfqd, gfp_t gfp_mask)
goto out;

cic->ioc = ioc;
cic->key = cfqd;
cic->q = cfqd->queue;

/* lock both q and ioc and try to link @cic */
Expand Down
1 change: 0 additions & 1 deletion trunk/include/linux/iocontext.h
Original file line number Diff line number Diff line change
Expand Up @@ -20,7 +20,6 @@ enum {
};

struct cfq_io_context {
void *key;
struct request_queue *q;

struct cfq_queue *cfqq[2];
Expand Down

0 comments on commit 8858071

Please sign in to comment.