510 	BUG_ON(atomic_read(&pd->cdrw.pending_bios) <= 0);  in pkt_bio_finished()
511 	if (atomic_dec_and_test(&pd->cdrw.pending_bios)) {  in pkt_bio_finished()
594 	BUG_ON(!list_empty(&pd->cdrw.pkt_active_list));  in pkt_shrink_pktlist()
596 	list_for_each_entry_safe(pkt, next, &pd->cdrw.pkt_free_list, list) {  in pkt_shrink_pktlist()
599 	INIT_LIST_HEAD(&pd->cdrw.pkt_free_list);  in pkt_shrink_pktlist()
606 	BUG_ON(!list_empty(&pd->cdrw.pkt_free_list));  in pkt_grow_pktlist()
616 		list_add(&pkt->list, &pd->cdrw.pkt_free_list);  in pkt_grow_pktlist()
868 				if (atomic_read(&pd->cdrw.pending_bios) > 0) {  in pkt_iosched_process_queue()
877 				if (atomic_read(&pd->cdrw.pending_bios) > 0) {  in pkt_iosched_process_queue()
914 		atomic_inc(&pd->cdrw.pending_bios);  in pkt_iosched_process_queue()
1096 	list_for_each_entry(pkt, &pd->cdrw.pkt_free_list, list) {  in pkt_get_packet_data()
1097 		if (pkt->sector == zone || pkt->list.next == &pd->cdrw.pkt_free_list) {  in pkt_get_packet_data()
1111 		list_add(&pkt->list, &pd->cdrw.pkt_free_list);  in pkt_put_packet_data()
1113 		list_add_tail(&pkt->list, &pd->cdrw.pkt_free_list);  in pkt_put_packet_data()
1205 	if (list_empty(&pd->cdrw.pkt_free_list)) {  in pkt_handle_queue()
1224 		list_for_each_entry(p, &pd->cdrw.pkt_active_list, list) {  in pkt_handle_queue()
1286 	spin_lock(&pd->cdrw.active_list_lock);  in pkt_handle_queue()
1287 	list_add(&pkt->list, &pd->cdrw.pkt_active_list);  in pkt_handle_queue()
1288 	spin_unlock(&pd->cdrw.active_list_lock);  in pkt_handle_queue()
1421 	list_for_each_entry(pkt, &pd->cdrw.pkt_active_list, list) {  in pkt_handle_packets()
1431 	spin_lock(&pd->cdrw.active_list_lock);  in pkt_handle_packets()
1432 	list_for_each_entry_safe(pkt, next, &pd->cdrw.pkt_active_list, list) {  in pkt_handle_packets()
1440 	spin_unlock(&pd->cdrw.active_list_lock);  in pkt_handle_packets()
1451 	spin_lock(&pd->cdrw.active_list_lock);  in pkt_count_states()
1452 	list_for_each_entry(pkt, &pd->cdrw.pkt_active_list, list) {  in pkt_count_states()
1455 	spin_unlock(&pd->cdrw.active_list_lock);  in pkt_count_states()
1486 			list_for_each_entry(pkt, &pd->cdrw.pkt_active_list, list) {  in kcdrwd()
1505 			list_for_each_entry(pkt, &pd->cdrw.pkt_active_list, list) {  in kcdrwd()
1517 			list_for_each_entry(pkt, &pd->cdrw.pkt_active_list, list) {  in kcdrwd()
2373 	spin_lock(&pd->cdrw.active_list_lock);  in pkt_make_request_write()
2375 	list_for_each_entry(pkt, &pd->cdrw.pkt_active_list, list) {  in pkt_make_request_write()
2389 				spin_unlock(&pd->cdrw.active_list_lock);  in pkt_make_request_write()
2397 	spin_unlock(&pd->cdrw.active_list_lock);  in pkt_make_request_write()
2434 	} else if (!list_empty(&pd->cdrw.pkt_free_list) && !blocked_bio) {  in pkt_make_request_write()
2586 	seq_printf(m, "\tbios pending:\t\t%d\n", atomic_read(&pd->cdrw.pending_bios));  in pkt_seq_show()
2652 	atomic_set(&pd->cdrw.pending_bios, 0);  in pkt_new_dev()
2653 	pd->cdrw.thread = kthread_run(kcdrwd, pd, "%s", pd->name);  in pkt_new_dev()
2654 	if (IS_ERR(pd->cdrw.thread)) {  in pkt_new_dev()
2768 	INIT_LIST_HEAD(&pd->cdrw.pkt_free_list);  in pkt_setup_dev()
2769 	INIT_LIST_HEAD(&pd->cdrw.pkt_active_list);  in pkt_setup_dev()
2770 	spin_lock_init(&pd->cdrw.active_list_lock);  in pkt_setup_dev()
2859 	if (!IS_ERR(pd->cdrw.thread))  in pkt_remove_dev()
2860 		kthread_stop(pd->cdrw.thread);  in pkt_remove_dev()