Lines Matching refs:qs
432 struct queue_set *qs; in nicvf_free_rbdr() local
439 qs = nic->qs; in nicvf_free_rbdr()
441 if ((qs == NULL) || (rbdr == NULL)) in nicvf_free_rbdr()
497 for (idx = 0; idx < qs->rbdr_len; idx++) { in nicvf_free_rbdr()
528 struct queue_set *qs; in nicvf_refill_rbdr() local
541 qs = nic->qs; in nicvf_refill_rbdr()
552 if (qcount >= (qs->rbdr_len - 1)) { in nicvf_refill_rbdr()
556 refill_rb_cnt = qs->rbdr_len - qcount - 1; in nicvf_refill_rbdr()
645 rq = &nic->qs->rq[rq_idx]; in nicvf_rcv_pkt_handler()
703 sq = &nic->qs->sq[cqe_tx->sq_idx]; in nicvf_snd_pkt_handler()
737 struct queue_set *qs = nic->qs; in nicvf_cq_intr_handler() local
738 struct cmp_queue *cq = &qs->cq[cq_idx]; in nicvf_cq_intr_handler()
739 struct snd_queue *sq = &qs->sq[cq_idx]; in nicvf_cq_intr_handler()
819 rq = &nic->qs->rq[rq_idx]; in nicvf_cq_intr_handler()
845 struct queue_set *qs; in nicvf_qs_err_task() local
851 qs = nic->qs; in nicvf_qs_err_task()
857 for (qidx = 0; qidx < qs->cq_cnt; qidx++) { in nicvf_qs_err_task()
866 nicvf_cmp_queue_config(nic, qs, qidx, enable); in nicvf_qs_err_task()
867 nicvf_sq_free_used_descs(nic, &qs->sq[qidx], qidx); in nicvf_qs_err_task()
868 nicvf_sq_enable(nic, &qs->sq[qidx], qidx); in nicvf_qs_err_task()
1144 struct queue_set *qs = nic->qs; in nicvf_free_snd_queue() local
1163 for (i = 0; i < qs->sq_len; i++) { in nicvf_free_snd_queue()
1203 nicvf_reclaim_snd_queue(struct nicvf *nic, struct queue_set *qs, int qidx) in nicvf_reclaim_snd_queue() argument
1216 nicvf_reclaim_rcv_queue(struct nicvf *nic, struct queue_set *qs, int qidx) in nicvf_reclaim_rcv_queue() argument
1226 nicvf_reclaim_cmp_queue(struct nicvf *nic, struct queue_set *qs, int qidx) in nicvf_reclaim_cmp_queue() argument
1289 nicvf_rcv_queue_config(struct nicvf *nic, struct queue_set *qs, in nicvf_rcv_queue_config() argument
1300 rq = &qs->rq[qidx]; in nicvf_rcv_queue_config()
1309 nicvf_reclaim_rcv_queue(nic, qs, qidx); in nicvf_rcv_queue_config()
1328 rq->cq_qs = qs->vnic_id; in nicvf_rcv_queue_config()
1330 rq->start_rbdr_qs = qs->vnic_id; in nicvf_rcv_queue_config()
1331 rq->start_qs_rbdr_idx = qs->rbdr_cnt - 1; in nicvf_rcv_queue_config()
1332 rq->cont_rbdr_qs = qs->vnic_id; in nicvf_rcv_queue_config()
1333 rq->cont_qs_rbdr_idx = qs->rbdr_cnt - 1; in nicvf_rcv_queue_config()
1339 mbx.rq.qs_num = qs->vnic_id; in nicvf_rcv_queue_config()
1348 mbx.rq.cfg = (1UL << 63) | (1UL << 62) | (qs->vnic_id << 0); in nicvf_rcv_queue_config()
1370 nicvf_cmp_queue_config(struct nicvf *nic, struct queue_set *qs, in nicvf_cmp_queue_config() argument
1376 cq = &qs->cq[qidx]; in nicvf_cmp_queue_config()
1380 nicvf_reclaim_cmp_queue(nic, qs, qidx); in nicvf_cmp_queue_config()
1407 nicvf_snd_queue_config(struct nicvf *nic, struct queue_set *qs, int qidx, in nicvf_snd_queue_config() argument
1414 sq = &qs->sq[qidx]; in nicvf_snd_queue_config()
1418 nicvf_reclaim_snd_queue(nic, qs, qidx); in nicvf_snd_queue_config()
1425 sq->cq_qs = qs->vnic_id; in nicvf_snd_queue_config()
1430 mbx.sq.qs_num = qs->vnic_id; in nicvf_snd_queue_config()
1454 nicvf_rbdr_config(struct nicvf *nic, struct queue_set *qs, int qidx, in nicvf_rbdr_config() argument
1460 rbdr = &qs->rbdr[qidx]; in nicvf_rbdr_config()
1482 qs->rbdr_len - 1); in nicvf_rbdr_config()
1494 struct queue_set *qs; in nicvf_qset_config() local
1497 qs = nic->qs; in nicvf_qset_config()
1498 if (qs == NULL) { in nicvf_qset_config()
1504 qs->enable = enable; in nicvf_qset_config()
1505 qs->vnic_id = nic->vf_id; in nicvf_qset_config()
1508 mbx.qs.msg = NIC_MBOX_MSG_QS_CFG; in nicvf_qset_config()
1509 mbx.qs.num = qs->vnic_id; in nicvf_qset_config()
1511 mbx.qs.cfg = 0; in nicvf_qset_config()
1512 qs_cfg = (struct qs_cfg *)&mbx.qs.cfg; in nicvf_qset_config()
1513 if (qs->enable) { in nicvf_qset_config()
1515 qs_cfg->vnic = qs->vnic_id; in nicvf_qset_config()
1524 struct queue_set *qs; in nicvf_free_resources() local
1526 qs = nic->qs; in nicvf_free_resources()
1531 if (qs->qs_err_taskq != NULL) { in nicvf_free_resources()
1533 while (taskqueue_cancel(qs->qs_err_taskq, in nicvf_free_resources()
1534 &qs->qs_err_task, NULL) != 0) { in nicvf_free_resources()
1535 taskqueue_drain(qs->qs_err_taskq, &qs->qs_err_task); in nicvf_free_resources()
1537 taskqueue_free(qs->qs_err_taskq); in nicvf_free_resources()
1538 qs->qs_err_taskq = NULL; in nicvf_free_resources()
1541 for (qidx = 0; qidx < qs->rbdr_cnt; qidx++) in nicvf_free_resources()
1542 nicvf_free_rbdr(nic, &qs->rbdr[qidx]); in nicvf_free_resources()
1545 for (qidx = 0; qidx < qs->cq_cnt; qidx++) in nicvf_free_resources()
1546 nicvf_free_cmp_queue(nic, &qs->cq[qidx]); in nicvf_free_resources()
1549 for (qidx = 0; qidx < qs->sq_cnt; qidx++) in nicvf_free_resources()
1550 nicvf_free_snd_queue(nic, &qs->sq[qidx]); in nicvf_free_resources()
1556 struct queue_set *qs = nic->qs; in nicvf_alloc_resources() local
1560 for (qidx = 0; qidx < qs->rbdr_cnt; qidx++) { in nicvf_alloc_resources()
1561 if (nicvf_init_rbdr(nic, &qs->rbdr[qidx], qs->rbdr_len, in nicvf_alloc_resources()
1567 for (qidx = 0; qidx < qs->sq_cnt; qidx++) { in nicvf_alloc_resources()
1568 if (nicvf_init_snd_queue(nic, &qs->sq[qidx], qs->sq_len, qidx)) in nicvf_alloc_resources()
1573 for (qidx = 0; qidx < qs->cq_cnt; qidx++) { in nicvf_alloc_resources()
1574 if (nicvf_init_cmp_queue(nic, &qs->cq[qidx], qs->cq_len, qidx)) in nicvf_alloc_resources()
1579 NET_TASK_INIT(&qs->qs_err_task, 0, nicvf_qs_err_task, nic); in nicvf_alloc_resources()
1580 qs->qs_err_taskq = taskqueue_create_fast("nicvf_qs_err_taskq", M_WAITOK, in nicvf_alloc_resources()
1581 taskqueue_thread_enqueue, &qs->qs_err_taskq); in nicvf_alloc_resources()
1582 taskqueue_start_threads(&qs->qs_err_taskq, 1, PI_NET, "%s: qs_taskq", in nicvf_alloc_resources()
1594 struct queue_set *qs; in nicvf_set_qset_resources() local
1596 qs = malloc(sizeof(*qs), M_NICVF, (M_ZERO | M_WAITOK)); in nicvf_set_qset_resources()
1597 nic->qs = qs; in nicvf_set_qset_resources()
1600 qs->rbdr_cnt = RBDR_CNT; in nicvf_set_qset_resources()
1601 qs->rq_cnt = RCV_QUEUE_CNT; in nicvf_set_qset_resources()
1603 qs->sq_cnt = SND_QUEUE_CNT; in nicvf_set_qset_resources()
1604 qs->cq_cnt = CMP_QUEUE_CNT; in nicvf_set_qset_resources()
1607 qs->rbdr_len = RCV_BUF_COUNT; in nicvf_set_qset_resources()
1608 qs->sq_len = SND_QUEUE_LEN; in nicvf_set_qset_resources()
1609 qs->cq_len = CMP_QUEUE_LEN; in nicvf_set_qset_resources()
1611 nic->rx_queues = qs->rq_cnt; in nicvf_set_qset_resources()
1612 nic->tx_queues = qs->sq_cnt; in nicvf_set_qset_resources()
1621 struct queue_set *qs; in nicvf_config_data_transfer() local
1624 qs = nic->qs; in nicvf_config_data_transfer()
1625 if (qs == NULL) in nicvf_config_data_transfer()
1632 for (qidx = 0; qidx < qs->sq_cnt; qidx++) in nicvf_config_data_transfer()
1633 nicvf_snd_queue_config(nic, qs, qidx, enable); in nicvf_config_data_transfer()
1634 for (qidx = 0; qidx < qs->cq_cnt; qidx++) in nicvf_config_data_transfer()
1635 nicvf_cmp_queue_config(nic, qs, qidx, enable); in nicvf_config_data_transfer()
1636 for (qidx = 0; qidx < qs->rbdr_cnt; qidx++) in nicvf_config_data_transfer()
1637 nicvf_rbdr_config(nic, qs, qidx, enable); in nicvf_config_data_transfer()
1638 for (qidx = 0; qidx < qs->rq_cnt; qidx++) in nicvf_config_data_transfer()
1639 nicvf_rcv_queue_config(nic, qs, qidx, enable); in nicvf_config_data_transfer()
1641 for (qidx = 0; qidx < qs->rq_cnt; qidx++) in nicvf_config_data_transfer()
1642 nicvf_rcv_queue_config(nic, qs, qidx, disable); in nicvf_config_data_transfer()
1643 for (qidx = 0; qidx < qs->rbdr_cnt; qidx++) in nicvf_config_data_transfer()
1644 nicvf_rbdr_config(nic, qs, qidx, disable); in nicvf_config_data_transfer()
1645 for (qidx = 0; qidx < qs->sq_cnt; qidx++) in nicvf_config_data_transfer()
1646 nicvf_snd_queue_config(nic, qs, qidx, disable); in nicvf_config_data_transfer()
1647 for (qidx = 0; qidx < qs->cq_cnt; qidx++) in nicvf_config_data_transfer()
1648 nicvf_cmp_queue_config(nic, qs, qidx, disable); in nicvf_config_data_transfer()
2207 rq = &nic->qs->rq[rq_idx]; in nicvf_update_rq_stats()
2221 sq = &nic->qs->sq[sq_idx]; in nicvf_update_sq_stats()