aboutsummaryrefslogtreecommitdiffstats
path: root/block
diff options
context:
space:
mode:
Diffstat (limited to 'block')
-rw-r--r--block/cfq-iosched.c14
1 files changed, 13 insertions, 1 deletions
diff --git a/block/cfq-iosched.c b/block/cfq-iosched.c
index 63bfe4b494ba..3bacf4bb7dd2 100644
--- a/block/cfq-iosched.c
+++ b/block/cfq-iosched.c
@@ -47,6 +47,8 @@ static int cfq_slice_idle = HZ / 100;
47 */ 47 */
48static const int cfq_max_depth = 2; 48static const int cfq_max_depth = 2;
49 49
50static DEFINE_RWLOCK(cfq_exit_lock);
51
50/* 52/*
51 * for the hash of cfqq inside the cfqd 53 * for the hash of cfqq inside the cfqd
52 */ 54 */
@@ -1354,13 +1356,19 @@ static inline void changed_ioprio(struct cfq_io_context *cic)
1354 */ 1356 */
1355static int cfq_ioc_set_ioprio(struct io_context *ioc, unsigned int ioprio) 1357static int cfq_ioc_set_ioprio(struct io_context *ioc, unsigned int ioprio)
1356{ 1358{
1357 struct cfq_io_context *cic = ioc->cic; 1359 struct cfq_io_context *cic;
1360
1361 write_lock(&cfq_exit_lock);
1362
1363 cic = ioc->cic;
1358 1364
1359 changed_ioprio(cic); 1365 changed_ioprio(cic);
1360 1366
1361 list_for_each_entry(cic, &cic->list, list) 1367 list_for_each_entry(cic, &cic->list, list)
1362 changed_ioprio(cic); 1368 changed_ioprio(cic);
1363 1369
1370 write_unlock(&cfq_exit_lock);
1371
1364 return 0; 1372 return 0;
1365} 1373}
1366 1374
@@ -1450,8 +1458,10 @@ cfq_get_io_context(struct cfq_data *cfqd, pid_t pid, gfp_t gfp_mask)
1450 */ 1458 */
1451 cic->ioc = ioc; 1459 cic->ioc = ioc;
1452 cic->key = cfqd; 1460 cic->key = cfqd;
1461 read_lock(&cfq_exit_lock);
1453 ioc->set_ioprio = cfq_ioc_set_ioprio; 1462 ioc->set_ioprio = cfq_ioc_set_ioprio;
1454 ioc->cic = cic; 1463 ioc->cic = cic;
1464 read_unlock(&cfq_exit_lock);
1455 } else { 1465 } else {
1456 struct cfq_io_context *__cic; 1466 struct cfq_io_context *__cic;
1457 1467
@@ -1487,7 +1497,9 @@ cfq_get_io_context(struct cfq_data *cfqd, pid_t pid, gfp_t gfp_mask)
1487 1497
1488 __cic->ioc = ioc; 1498 __cic->ioc = ioc;
1489 __cic->key = cfqd; 1499 __cic->key = cfqd;
1500 read_lock(&cfq_exit_lock);
1490 list_add(&__cic->list, &cic->list); 1501 list_add(&__cic->list, &cic->list);
1502 read_unlock(&cfq_exit_lock);
1491 cic = __cic; 1503 cic = __cic;
1492 } 1504 }
1493 1505