Lines Matching refs:qs
436 struct queue_set *qs;
443 qs = nic->qs;
445 if ((qs == NULL) || (rbdr == NULL))
501 for (idx = 0; idx < qs->rbdr_len; idx++) {
532 struct queue_set *qs;
545 qs = nic->qs;
556 if (qcount >= (qs->rbdr_len - 1)) {
560 refill_rb_cnt = qs->rbdr_len - qcount - 1;
649 rq = &nic->qs->rq[rq_idx];
707 sq = &nic->qs->sq[cqe_tx->sq_idx];
738 struct queue_set *qs = nic->qs;
739 struct cmp_queue *cq = &qs->cq[cq_idx];
740 struct snd_queue *sq = &qs->sq[cq_idx];
818 rq = &nic->qs->rq[rq_idx];
844 struct queue_set *qs;
850 qs = nic->qs;
856 for (qidx = 0; qidx < qs->cq_cnt; qidx++) {
865 nicvf_cmp_queue_config(nic, qs, qidx, enable);
866 nicvf_sq_free_used_descs(nic, &qs->sq[qidx], qidx);
867 nicvf_sq_enable(nic, &qs->sq[qidx], qidx);
1143 struct queue_set *qs = nic->qs;
1162 for (i = 0; i < qs->sq_len; i++) {
1202 nicvf_reclaim_snd_queue(struct nicvf *nic, struct queue_set *qs, int qidx)
1215 nicvf_reclaim_rcv_queue(struct nicvf *nic, struct queue_set *qs, int qidx)
1225 nicvf_reclaim_cmp_queue(struct nicvf *nic, struct queue_set *qs, int qidx)
1288 nicvf_rcv_queue_config(struct nicvf *nic, struct queue_set *qs,
1299 rq = &qs->rq[qidx];
1308 nicvf_reclaim_rcv_queue(nic, qs, qidx);
1327 rq->cq_qs = qs->vnic_id;
1329 rq->start_rbdr_qs = qs->vnic_id;
1330 rq->start_qs_rbdr_idx = qs->rbdr_cnt - 1;
1331 rq->cont_rbdr_qs = qs->vnic_id;
1332 rq->cont_qs_rbdr_idx = qs->rbdr_cnt - 1;
1338 mbx.rq.qs_num = qs->vnic_id;
1347 mbx.rq.cfg = (1UL << 63) | (1UL << 62) | (qs->vnic_id << 0);
1369 nicvf_cmp_queue_config(struct nicvf *nic, struct queue_set *qs,
1375 cq = &qs->cq[qidx];
1379 nicvf_reclaim_cmp_queue(nic, qs, qidx);
1406 nicvf_snd_queue_config(struct nicvf *nic, struct queue_set *qs, int qidx,
1413 sq = &qs->sq[qidx];
1417 nicvf_reclaim_snd_queue(nic, qs, qidx);
1424 sq->cq_qs = qs->vnic_id;
1429 mbx.sq.qs_num = qs->vnic_id;
1453 nicvf_rbdr_config(struct nicvf *nic, struct queue_set *qs, int qidx,
1459 rbdr = &qs->rbdr[qidx];
1481 qs->rbdr_len - 1);
1493 struct queue_set *qs;
1496 qs = nic->qs;
1497 if (qs == NULL) {
1503 qs->enable = enable;
1504 qs->vnic_id = nic->vf_id;
1507 mbx.qs.msg = NIC_MBOX_MSG_QS_CFG;
1508 mbx.qs.num = qs->vnic_id;
1510 mbx.qs.cfg = 0;
1511 qs_cfg = (struct qs_cfg *)&mbx.qs.cfg;
1512 if (qs->enable) {
1514 qs_cfg->vnic = qs->vnic_id;
1523 struct queue_set *qs;
1525 qs = nic->qs;
1530 if (qs->qs_err_taskq != NULL) {
1532 while (taskqueue_cancel(qs->qs_err_taskq,
1533 &qs->qs_err_task, NULL) != 0) {
1534 taskqueue_drain(qs->qs_err_taskq, &qs->qs_err_task);
1536 taskqueue_free(qs->qs_err_taskq);
1537 qs->qs_err_taskq = NULL;
1540 for (qidx = 0; qidx < qs->rbdr_cnt; qidx++)
1541 nicvf_free_rbdr(nic, &qs->rbdr[qidx]);
1544 for (qidx = 0; qidx < qs->cq_cnt; qidx++)
1545 nicvf_free_cmp_queue(nic, &qs->cq[qidx]);
1548 for (qidx = 0; qidx < qs->sq_cnt; qidx++)
1549 nicvf_free_snd_queue(nic, &qs->sq[qidx]);
1555 struct queue_set *qs = nic->qs;
1559 for (qidx = 0; qidx < qs->rbdr_cnt; qidx++) {
1560 if (nicvf_init_rbdr(nic, &qs->rbdr[qidx], qs->rbdr_len,
1566 for (qidx = 0; qidx < qs->sq_cnt; qidx++) {
1567 if (nicvf_init_snd_queue(nic, &qs->sq[qidx], qs->sq_len, qidx))
1572 for (qidx = 0; qidx < qs->cq_cnt; qidx++) {
1573 if (nicvf_init_cmp_queue(nic, &qs->cq[qidx], qs->cq_len, qidx))
1578 NET_TASK_INIT(&qs->qs_err_task, 0, nicvf_qs_err_task, nic);
1579 qs->qs_err_taskq = taskqueue_create_fast("nicvf_qs_err_taskq", M_WAITOK,
1580 taskqueue_thread_enqueue, &qs->qs_err_taskq);
1581 taskqueue_start_threads(&qs->qs_err_taskq, 1, PI_NET, "%s: qs_taskq",
1593 struct queue_set *qs;
1595 qs = malloc(sizeof(*qs), M_NICVF, (M_ZERO | M_WAITOK));
1596 nic->qs = qs;
1599 qs->rbdr_cnt = RBDR_CNT;
1600 qs->rq_cnt = RCV_QUEUE_CNT;
1602 qs->sq_cnt = SND_QUEUE_CNT;
1603 qs->cq_cnt = CMP_QUEUE_CNT;
1606 qs->rbdr_len = RCV_BUF_COUNT;
1607 qs->sq_len = SND_QUEUE_LEN;
1608 qs->cq_len = CMP_QUEUE_LEN;
1610 nic->rx_queues = qs->rq_cnt;
1611 nic->tx_queues = qs->sq_cnt;
1620 struct queue_set *qs;
1623 qs = nic->qs;
1624 if (qs == NULL)
1631 for (qidx = 0; qidx < qs->sq_cnt; qidx++)
1632 nicvf_snd_queue_config(nic, qs, qidx, enable);
1633 for (qidx = 0; qidx < qs->cq_cnt; qidx++)
1634 nicvf_cmp_queue_config(nic, qs, qidx, enable);
1635 for (qidx = 0; qidx < qs->rbdr_cnt; qidx++)
1636 nicvf_rbdr_config(nic, qs, qidx, enable);
1637 for (qidx = 0; qidx < qs->rq_cnt; qidx++)
1638 nicvf_rcv_queue_config(nic, qs, qidx, enable);
1640 for (qidx = 0; qidx < qs->rq_cnt; qidx++)
1641 nicvf_rcv_queue_config(nic, qs, qidx, disable);
1642 for (qidx = 0; qidx < qs->rbdr_cnt; qidx++)
1643 nicvf_rbdr_config(nic, qs, qidx, disable);
1644 for (qidx = 0; qidx < qs->sq_cnt; qidx++)
1645 nicvf_snd_queue_config(nic, qs, qidx, disable);
1646 for (qidx = 0; qidx < qs->cq_cnt; qidx++)
1647 nicvf_cmp_queue_config(nic, qs, qidx, disable);
2201 rq = &nic->qs->rq[rq_idx];
2215 sq = &nic->qs->sq[sq_idx];