Lines Matching refs:crq
474 struct carm_request *crq)
477 u32 msg = (u32) carm_ref_msg_dma(host, crq->tag);
478 u32 cm_bucket = crq->msg_bucket;
506 struct carm_request *crq = &host->req[i];
507 crq->port = NULL;
508 crq->n_elem = 0;
514 return crq;
521 static int carm_put_request(struct carm_host *host, struct carm_request *crq)
523 assert(crq->tag < max_queue);
525 if (unlikely((host->msg_alloc & (1ULL << crq->tag)) == 0))
528 assert(host->hw_sg_used >= crq->n_elem);
530 host->msg_alloc &= ~(1ULL << crq->tag);
531 host->hw_sg_used -= crq->n_elem;
540 struct carm_request *crq = NULL;
546 crq = carm_get_request(host);
549 if (crq)
554 if (!crq)
560 carm_put_request(host, crq);
565 crq->rq = rq;
566 return crq;
575 struct carm_request *crq;
578 crq = carm_get_special(host);
579 if (!crq) {
584 idx = crq->tag;
590 crq->msg_type = CARM_MSG_ARRAY;
591 crq->msg_subtype = CARM_ARRAY_INFO;
595 crq->msg_bucket = (u32) rc;
610 blk_insert_request(host->oob_q, crq->rq, 1, crq);
625 struct carm_request *crq;
631 crq = carm_get_special(host);
632 if (!crq)
635 idx = crq->tag;
642 crq->msg_type = ioc->type;
643 crq->msg_subtype = ioc->subtype;
646 crq->msg_bucket = (u32) rc;
649 blk_insert_request(host->oob_q, crq->rq, 1, crq);
733 struct carm_request *crq,
736 struct request *req = crq->rq;
744 rc = carm_put_request(host, crq);
782 static inline void carm_end_rq(struct carm_host *host, struct carm_request *crq,
785 carm_end_request_queued(host, crq, is_ok);
797 struct carm_request *crq;
809 crq = rq->special;
810 assert(crq != NULL);
811 assert(crq->rq == rq);
813 crq->n_elem = 0;
816 rc = carm_send_msg(host, crq);
830 struct carm_request *crq;
843 crq = carm_get_request(host);
844 if (!crq) {
848 crq->rq = rq;
860 sg = &crq->sg[0];
863 carm_end_rq(host, crq, 0);
870 carm_end_rq(host, crq, 0);
873 crq->n_elem = n_elem;
874 crq->port = port;
882 msg = (struct carm_msg_rw *) carm_ref_msg(host, crq->tag);
886 crq->msg_type = CARM_MSG_WRITE;
889 crq->msg_type = CARM_MSG_READ;
895 msg->handle = cpu_to_le32(TAG_ENCODE(crq->tag));
904 carm_sg->start = cpu_to_le32(sg_dma_address(&crq->sg[i]));
905 carm_sg->len = cpu_to_le32(sg_dma_len(&crq->sg[i]));
911 crq->msg_bucket = (u32) rc;
917 VPRINTK("send msg, tag == %u\n", crq->tag);
918 rc = carm_send_msg(host, crq);
920 carm_put_request(host, crq);
930 struct carm_request *crq, u8 *mem,
942 carm_end_rq(host, crq, is_ok);
990 struct carm_request *crq, u8 *mem,
999 carm_end_rq(host, crq, is_ok);
1023 struct carm_request *crq, int is_ok,
1028 carm_end_rq(host, crq, is_ok);
1039 struct carm_request *crq, int is_ok)
1045 if (rq_data_dir(crq->rq) == WRITE)
1050 pci_unmap_sg(host->pdev, &crq->sg[0], crq->n_elem, pci_dir);
1052 carm_end_rq(host, crq, is_ok);
1060 struct carm_request *crq;
1075 crq = &host->req[msg_idx];
1078 if (likely(crq->msg_type == CARM_MSG_READ ||
1079 crq->msg_type == CARM_MSG_WRITE)) {
1080 carm_handle_rw(host, crq, is_ok);
1086 switch (crq->msg_type) {
1088 switch (crq->msg_subtype) {
1090 carm_handle_scan_chan(host, crq, mem, is_ok);
1100 switch (crq->msg_subtype) {
1102 carm_handle_generic(host, crq, is_ok,
1106 carm_handle_generic(host, crq, is_ok,
1116 carm_handle_generic(host, crq, is_ok,
1128 switch (crq->msg_subtype) {
1130 carm_handle_array_info(host, crq, mem, is_ok);
1148 pci_name(host->pdev), crq->msg_type, crq->msg_subtype);
1149 carm_end_rq(host, crq, 0);