Lines Matching refs:qr
505 struct iscsi_queue_req *qr; in iscsit_add_cmd_to_immediate_queue() local
507 qr = kmem_cache_zalloc(lio_qr_cache, GFP_ATOMIC); in iscsit_add_cmd_to_immediate_queue()
508 if (!qr) { in iscsit_add_cmd_to_immediate_queue()
513 INIT_LIST_HEAD(&qr->qr_list); in iscsit_add_cmd_to_immediate_queue()
514 qr->cmd = cmd; in iscsit_add_cmd_to_immediate_queue()
515 qr->state = state; in iscsit_add_cmd_to_immediate_queue()
518 list_add_tail(&qr->qr_list, &conn->immed_queue_list); in iscsit_add_cmd_to_immediate_queue()
529 struct iscsi_queue_req *qr; in iscsit_get_cmd_from_immediate_queue() local
536 qr = list_first_entry(&conn->immed_queue_list, in iscsit_get_cmd_from_immediate_queue()
539 list_del(&qr->qr_list); in iscsit_get_cmd_from_immediate_queue()
540 if (qr->cmd) in iscsit_get_cmd_from_immediate_queue()
541 atomic_dec(&qr->cmd->immed_queue_count); in iscsit_get_cmd_from_immediate_queue()
544 return qr; in iscsit_get_cmd_from_immediate_queue()
551 struct iscsi_queue_req *qr, *qr_tmp; in iscsit_remove_cmd_from_immediate_queue() local
559 list_for_each_entry_safe(qr, qr_tmp, &conn->immed_queue_list, qr_list) { in iscsit_remove_cmd_from_immediate_queue()
560 if (qr->cmd != cmd) in iscsit_remove_cmd_from_immediate_queue()
563 atomic_dec(&qr->cmd->immed_queue_count); in iscsit_remove_cmd_from_immediate_queue()
564 list_del(&qr->qr_list); in iscsit_remove_cmd_from_immediate_queue()
565 kmem_cache_free(lio_qr_cache, qr); in iscsit_remove_cmd_from_immediate_queue()
581 struct iscsi_queue_req *qr; in iscsit_add_cmd_to_response_queue() local
583 qr = kmem_cache_zalloc(lio_qr_cache, GFP_ATOMIC); in iscsit_add_cmd_to_response_queue()
584 if (!qr) { in iscsit_add_cmd_to_response_queue()
589 INIT_LIST_HEAD(&qr->qr_list); in iscsit_add_cmd_to_response_queue()
590 qr->cmd = cmd; in iscsit_add_cmd_to_response_queue()
591 qr->state = state; in iscsit_add_cmd_to_response_queue()
594 list_add_tail(&qr->qr_list, &conn->response_queue_list); in iscsit_add_cmd_to_response_queue()
604 struct iscsi_queue_req *qr; in iscsit_get_cmd_from_response_queue() local
612 qr = list_first_entry(&conn->response_queue_list, in iscsit_get_cmd_from_response_queue()
615 list_del(&qr->qr_list); in iscsit_get_cmd_from_response_queue()
616 if (qr->cmd) in iscsit_get_cmd_from_response_queue()
617 atomic_dec(&qr->cmd->response_queue_count); in iscsit_get_cmd_from_response_queue()
620 return qr; in iscsit_get_cmd_from_response_queue()
627 struct iscsi_queue_req *qr, *qr_tmp; in iscsit_remove_cmd_from_response_queue() local
635 list_for_each_entry_safe(qr, qr_tmp, &conn->response_queue_list, in iscsit_remove_cmd_from_response_queue()
637 if (qr->cmd != cmd) in iscsit_remove_cmd_from_response_queue()
640 atomic_dec(&qr->cmd->response_queue_count); in iscsit_remove_cmd_from_response_queue()
641 list_del(&qr->qr_list); in iscsit_remove_cmd_from_response_queue()
642 kmem_cache_free(lio_qr_cache, qr); in iscsit_remove_cmd_from_response_queue()
673 struct iscsi_queue_req *qr, *qr_tmp; in iscsit_free_queue_reqs_for_conn() local
676 list_for_each_entry_safe(qr, qr_tmp, &conn->immed_queue_list, qr_list) { in iscsit_free_queue_reqs_for_conn()
677 list_del(&qr->qr_list); in iscsit_free_queue_reqs_for_conn()
678 if (qr->cmd) in iscsit_free_queue_reqs_for_conn()
679 atomic_dec(&qr->cmd->immed_queue_count); in iscsit_free_queue_reqs_for_conn()
681 kmem_cache_free(lio_qr_cache, qr); in iscsit_free_queue_reqs_for_conn()
686 list_for_each_entry_safe(qr, qr_tmp, &conn->response_queue_list, in iscsit_free_queue_reqs_for_conn()
688 list_del(&qr->qr_list); in iscsit_free_queue_reqs_for_conn()
689 if (qr->cmd) in iscsit_free_queue_reqs_for_conn()
690 atomic_dec(&qr->cmd->response_queue_count); in iscsit_free_queue_reqs_for_conn()
692 kmem_cache_free(lio_qr_cache, qr); in iscsit_free_queue_reqs_for_conn()