|
@@ -1644,14 +1644,20 @@ static void cfq_pd_offline(struct blkg_policy_data *pd)
|
|
|
int i;
|
|
|
|
|
|
for (i = 0; i < IOPRIO_BE_NR; i++) {
|
|
|
- if (cfqg->async_cfqq[0][i])
|
|
|
+ if (cfqg->async_cfqq[0][i]) {
|
|
|
cfq_put_queue(cfqg->async_cfqq[0][i]);
|
|
|
- if (cfqg->async_cfqq[1][i])
|
|
|
+ cfqg->async_cfqq[0][i] = NULL;
|
|
|
+ }
|
|
|
+ if (cfqg->async_cfqq[1][i]) {
|
|
|
cfq_put_queue(cfqg->async_cfqq[1][i]);
|
|
|
+ cfqg->async_cfqq[1][i] = NULL;
|
|
|
+ }
|
|
|
}
|
|
|
|
|
|
- if (cfqg->async_idle_cfqq)
|
|
|
+ if (cfqg->async_idle_cfqq) {
|
|
|
cfq_put_queue(cfqg->async_idle_cfqq);
|
|
|
+ cfqg->async_idle_cfqq = NULL;
|
|
|
+ }
|
|
|
|
|
|
/*
|
|
|
* @blkg is going offline and will be ignored by
|