Lines Matching refs:qr
497 struct iscsi_queue_req *qr; in iscsit_add_cmd_to_immediate_queue() local
499 qr = kmem_cache_zalloc(lio_qr_cache, GFP_ATOMIC); in iscsit_add_cmd_to_immediate_queue()
500 if (!qr) { in iscsit_add_cmd_to_immediate_queue()
505 INIT_LIST_HEAD(&qr->qr_list); in iscsit_add_cmd_to_immediate_queue()
506 qr->cmd = cmd; in iscsit_add_cmd_to_immediate_queue()
507 qr->state = state; in iscsit_add_cmd_to_immediate_queue()
510 list_add_tail(&qr->qr_list, &conn->immed_queue_list); in iscsit_add_cmd_to_immediate_queue()
520 struct iscsi_queue_req *qr; in iscsit_get_cmd_from_immediate_queue() local
527 qr = list_first_entry(&conn->immed_queue_list, in iscsit_get_cmd_from_immediate_queue()
530 list_del(&qr->qr_list); in iscsit_get_cmd_from_immediate_queue()
531 if (qr->cmd) in iscsit_get_cmd_from_immediate_queue()
532 atomic_dec(&qr->cmd->immed_queue_count); in iscsit_get_cmd_from_immediate_queue()
535 return qr; in iscsit_get_cmd_from_immediate_queue()
542 struct iscsi_queue_req *qr, *qr_tmp; in iscsit_remove_cmd_from_immediate_queue() local
550 list_for_each_entry_safe(qr, qr_tmp, &conn->immed_queue_list, qr_list) { in iscsit_remove_cmd_from_immediate_queue()
551 if (qr->cmd != cmd) in iscsit_remove_cmd_from_immediate_queue()
554 atomic_dec(&qr->cmd->immed_queue_count); in iscsit_remove_cmd_from_immediate_queue()
555 list_del(&qr->qr_list); in iscsit_remove_cmd_from_immediate_queue()
556 kmem_cache_free(lio_qr_cache, qr); in iscsit_remove_cmd_from_immediate_queue()
572 struct iscsi_queue_req *qr; in iscsit_add_cmd_to_response_queue() local
574 qr = kmem_cache_zalloc(lio_qr_cache, GFP_ATOMIC); in iscsit_add_cmd_to_response_queue()
575 if (!qr) { in iscsit_add_cmd_to_response_queue()
580 INIT_LIST_HEAD(&qr->qr_list); in iscsit_add_cmd_to_response_queue()
581 qr->cmd = cmd; in iscsit_add_cmd_to_response_queue()
582 qr->state = state; in iscsit_add_cmd_to_response_queue()
585 list_add_tail(&qr->qr_list, &conn->response_queue_list); in iscsit_add_cmd_to_response_queue()
594 struct iscsi_queue_req *qr; in iscsit_get_cmd_from_response_queue() local
602 qr = list_first_entry(&conn->response_queue_list, in iscsit_get_cmd_from_response_queue()
605 list_del(&qr->qr_list); in iscsit_get_cmd_from_response_queue()
606 if (qr->cmd) in iscsit_get_cmd_from_response_queue()
607 atomic_dec(&qr->cmd->response_queue_count); in iscsit_get_cmd_from_response_queue()
610 return qr; in iscsit_get_cmd_from_response_queue()
617 struct iscsi_queue_req *qr, *qr_tmp; in iscsit_remove_cmd_from_response_queue() local
625 list_for_each_entry_safe(qr, qr_tmp, &conn->response_queue_list, in iscsit_remove_cmd_from_response_queue()
627 if (qr->cmd != cmd) in iscsit_remove_cmd_from_response_queue()
630 atomic_dec(&qr->cmd->response_queue_count); in iscsit_remove_cmd_from_response_queue()
631 list_del(&qr->qr_list); in iscsit_remove_cmd_from_response_queue()
632 kmem_cache_free(lio_qr_cache, qr); in iscsit_remove_cmd_from_response_queue()
663 struct iscsi_queue_req *qr, *qr_tmp; in iscsit_free_queue_reqs_for_conn() local
666 list_for_each_entry_safe(qr, qr_tmp, &conn->immed_queue_list, qr_list) { in iscsit_free_queue_reqs_for_conn()
667 list_del(&qr->qr_list); in iscsit_free_queue_reqs_for_conn()
668 if (qr->cmd) in iscsit_free_queue_reqs_for_conn()
669 atomic_dec(&qr->cmd->immed_queue_count); in iscsit_free_queue_reqs_for_conn()
671 kmem_cache_free(lio_qr_cache, qr); in iscsit_free_queue_reqs_for_conn()
676 list_for_each_entry_safe(qr, qr_tmp, &conn->response_queue_list, in iscsit_free_queue_reqs_for_conn()
678 list_del(&qr->qr_list); in iscsit_free_queue_reqs_for_conn()
679 if (qr->cmd) in iscsit_free_queue_reqs_for_conn()
680 atomic_dec(&qr->cmd->response_queue_count); in iscsit_free_queue_reqs_for_conn()
682 kmem_cache_free(lio_qr_cache, qr); in iscsit_free_queue_reqs_for_conn()