Lines Matching refs:cdrw
511 BUG_ON(atomic_read(&pd->cdrw.pending_bios) <= 0); in pkt_bio_finished()
512 if (atomic_dec_and_test(&pd->cdrw.pending_bios)) { in pkt_bio_finished()
595 BUG_ON(!list_empty(&pd->cdrw.pkt_active_list)); in pkt_shrink_pktlist()
597 list_for_each_entry_safe(pkt, next, &pd->cdrw.pkt_free_list, list) { in pkt_shrink_pktlist()
600 INIT_LIST_HEAD(&pd->cdrw.pkt_free_list); in pkt_shrink_pktlist()
607 BUG_ON(!list_empty(&pd->cdrw.pkt_free_list)); in pkt_grow_pktlist()
617 list_add(&pkt->list, &pd->cdrw.pkt_free_list); in pkt_grow_pktlist()
869 if (atomic_read(&pd->cdrw.pending_bios) > 0) { in pkt_iosched_process_queue()
878 if (atomic_read(&pd->cdrw.pending_bios) > 0) { in pkt_iosched_process_queue()
915 atomic_inc(&pd->cdrw.pending_bios); in pkt_iosched_process_queue()
1064 list_for_each_entry(pkt, &pd->cdrw.pkt_free_list, list) { in pkt_get_packet_data()
1065 if (pkt->sector == zone || pkt->list.next == &pd->cdrw.pkt_free_list) { in pkt_get_packet_data()
1079 list_add(&pkt->list, &pd->cdrw.pkt_free_list); in pkt_put_packet_data()
1081 list_add_tail(&pkt->list, &pd->cdrw.pkt_free_list); in pkt_put_packet_data()
1173 if (list_empty(&pd->cdrw.pkt_free_list)) { in pkt_handle_queue()
1192 list_for_each_entry(p, &pd->cdrw.pkt_active_list, list) { in pkt_handle_queue()
1254 spin_lock(&pd->cdrw.active_list_lock); in pkt_handle_queue()
1255 list_add(&pkt->list, &pd->cdrw.pkt_active_list); in pkt_handle_queue()
1256 spin_unlock(&pd->cdrw.active_list_lock); in pkt_handle_queue()
1386 list_for_each_entry(pkt, &pd->cdrw.pkt_active_list, list) { in pkt_handle_packets()
1396 spin_lock(&pd->cdrw.active_list_lock); in pkt_handle_packets()
1397 list_for_each_entry_safe(pkt, next, &pd->cdrw.pkt_active_list, list) { in pkt_handle_packets()
1405 spin_unlock(&pd->cdrw.active_list_lock); in pkt_handle_packets()
1416 spin_lock(&pd->cdrw.active_list_lock); in pkt_count_states()
1417 list_for_each_entry(pkt, &pd->cdrw.pkt_active_list, list) { in pkt_count_states()
1420 spin_unlock(&pd->cdrw.active_list_lock); in pkt_count_states()
1451 list_for_each_entry(pkt, &pd->cdrw.pkt_active_list, list) { in kcdrwd()
1470 list_for_each_entry(pkt, &pd->cdrw.pkt_active_list, list) { in kcdrwd()
1482 list_for_each_entry(pkt, &pd->cdrw.pkt_active_list, list) { in kcdrwd()
2363 spin_lock(&pd->cdrw.active_list_lock); in pkt_make_request_write()
2365 list_for_each_entry(pkt, &pd->cdrw.pkt_active_list, list) { in pkt_make_request_write()
2379 spin_unlock(&pd->cdrw.active_list_lock); in pkt_make_request_write()
2387 spin_unlock(&pd->cdrw.active_list_lock); in pkt_make_request_write()
2424 } else if (!list_empty(&pd->cdrw.pkt_free_list) && !blocked_bio) { in pkt_make_request_write()
2553 seq_printf(m, "\tbios pending:\t\t%d\n", atomic_read(&pd->cdrw.pending_bios)); in pkt_seq_show()
2612 atomic_set(&pd->cdrw.pending_bios, 0); in pkt_new_dev()
2613 pd->cdrw.thread = kthread_run(kcdrwd, pd, "%s", pd->name); in pkt_new_dev()
2614 if (IS_ERR(pd->cdrw.thread)) { in pkt_new_dev()
2728 INIT_LIST_HEAD(&pd->cdrw.pkt_free_list); in pkt_setup_dev()
2729 INIT_LIST_HEAD(&pd->cdrw.pkt_active_list); in pkt_setup_dev()
2730 spin_lock_init(&pd->cdrw.active_list_lock); in pkt_setup_dev()
2817 if (!IS_ERR(pd->cdrw.thread)) in pkt_remove_dev()
2818 kthread_stop(pd->cdrw.thread); in pkt_remove_dev()