Home
last modified time | relevance | path

Searched refs:cons (Results 1 – 25 of 145) sorted by relevance

123456

/drivers/accel/ivpu/
A Divpu_ipc.c161 spin_lock(&cons->rx_lock); in ivpu_ipc_rx_msg_add()
164 wake_up(&cons->rx_msg_wq); in ivpu_ipc_rx_msg_add()
183 cons->channel = channel; in ivpu_ipc_consumer_add()
184 cons->tx_vpu_addr = 0; in ivpu_ipc_consumer_add()
185 cons->request_id = 0; in ivpu_ipc_consumer_add()
186 cons->aborted = false; in ivpu_ipc_consumer_add()
203 list_del(&cons->link); in ivpu_ipc_consumer_del()
243 ret = !list_empty(&cons->rx_msg_list) || cons->aborted; in ivpu_ipc_rx_need_wakeup()
267 if (cons->aborted) { in ivpu_ipc_receive()
570 if (!cons->rx_callback) in ivpu_ipc_disable()
[all …]
A Divpu_ipc.h95 void ivpu_ipc_consumer_add(struct ivpu_device *vdev, struct ivpu_ipc_consumer *cons,
97 void ivpu_ipc_consumer_del(struct ivpu_device *vdev, struct ivpu_ipc_consumer *cons);
99 int ivpu_ipc_send(struct ivpu_device *vdev, struct ivpu_ipc_consumer *cons,
101 int ivpu_ipc_receive(struct ivpu_device *vdev, struct ivpu_ipc_consumer *cons,
A Divpu_mmu.c473 cmdq->cons = cmdq->prod; in ivpu_mmu_cmdq_wait_for_cons()
480 return ((IVPU_MMU_Q_IDX(q->prod) == IVPU_MMU_Q_IDX(q->cons)) && in ivpu_mmu_queue_is_full()
481 (IVPU_MMU_Q_WRP(q->prod) != IVPU_MMU_Q_WRP(q->cons))); in ivpu_mmu_queue_is_full()
486 return ((IVPU_MMU_Q_IDX(q->prod) == IVPU_MMU_Q_IDX(q->cons)) && in ivpu_mmu_queue_is_empty()
487 (IVPU_MMU_Q_WRP(q->prod) == IVPU_MMU_Q_WRP(q->cons))); in ivpu_mmu_queue_is_empty()
574 mmu->cmdq.cons = 0; in ivpu_mmu_reset()
578 mmu->evtq.cons = 0; in ivpu_mmu_reset()
862 u32 idx = IVPU_MMU_Q_IDX(evtq->cons); in ivpu_mmu_get_event()
869 evtq->cons = (evtq->cons + 1) & IVPU_MMU_Q_WRAP_MASK; in ivpu_mmu_get_event()
907 vdev->mmu->evtq.cons = REGV_RD32(IVPU_MMU_REG_EVTQ_PROD_SEC); in ivpu_mmu_discard_events()
[all …]
/drivers/infiniband/sw/rxe/
A Drxe_queue.h130 u32 cons; in queue_get_consumer() local
135 cons = q->index; in queue_get_consumer()
147 cons = q->buf->consumer_index; in queue_get_consumer()
151 return cons; in queue_get_consumer()
157 u32 cons = queue_get_consumer(q, type); in queue_empty() local
165 u32 cons = queue_get_consumer(q, type); in queue_full() local
176 return (prod - cons) & q->index_mask; in queue_count()
218 u32 cons; in queue_advance_consumer() local
224 q->index = cons; in queue_advance_consumer()
242 cons = q->buf->consumer_index; in queue_advance_consumer()
[all …]
A Drxe_queue.c116 u32 cons; in resize_finish() local
123 cons = queue_get_consumer(q, type); in resize_finish()
125 while ((prod - cons) & q->index_mask) { in resize_finish()
127 queue_addr_from_index(q, cons), new_q->elem_size); in resize_finish()
129 cons = queue_next_index(q, cons); in resize_finish()
133 q->buf->consumer_index = cons; in resize_finish()
/drivers/tty/serial/
A Dkgdboc.c175 if (kgdboc_earlycon_io_ops.cons) in cleanup_earlycon()
199 struct console *cons; in configure_kgdboc() local
207 kgdboc_io_ops.cons = NULL; in configure_kgdboc()
231 for_each_console_srcu(cons) { in configure_kgdboc()
233 if (cons->device && cons->device(cons, &idx) == p && in configure_kgdboc()
235 kgdboc_io_ops.cons = cons; in configure_kgdboc()
467 if (!kgdboc_earlycon_io_ops.cons->read(kgdboc_earlycon_io_ops.cons, in kgdboc_earlycon_get_char()
476 kgdboc_earlycon_io_ops.cons->write(kgdboc_earlycon_io_ops.cons, &chr, in kgdboc_earlycon_put_char()
526 if (!kgdboc_earlycon_io_ops.cons) in kgdboc_earlycon_deinit()
542 kgdboc_earlycon_io_ops.cons->exit(kgdboc_earlycon_io_ops.cons); in kgdboc_earlycon_deinit()
[all …]
A Dtegra-utc.c414 static void tegra_utc_console_write_atomic(struct console *cons, struct nbcon_write_context *wctxt) in tegra_utc_console_write_atomic() argument
416 struct tegra_utc_port *tup = container_of(cons, struct tegra_utc_port, console); in tegra_utc_console_write_atomic()
442 static void tegra_utc_console_write_thread(struct console *cons, struct nbcon_write_context *wctxt) in tegra_utc_console_write_thread() argument
444 struct tegra_utc_port *tup = container_of(cons, struct tegra_utc_port, console); in tegra_utc_console_write_thread()
462 static void tegra_utc_console_device_lock(struct console *cons, unsigned long *flags) in tegra_utc_console_device_lock() argument
464 struct tegra_utc_port *tup = container_of(cons, struct tegra_utc_port, console); in tegra_utc_console_device_lock()
470 static void tegra_utc_console_device_unlock(struct console *cons, unsigned long flags) in tegra_utc_console_device_unlock() argument
472 struct tegra_utc_port *tup = container_of(cons, struct tegra_utc_port, console); in tegra_utc_console_device_unlock()
478 static int tegra_utc_console_setup(struct console *cons, char *options) in tegra_utc_console_setup() argument
480 struct tegra_utc_port *tup = container_of(cons, struct tegra_utc_port, console); in tegra_utc_console_setup()
A Dtegra-tcu.c148 static void tegra_tcu_console_write(struct console *cons, const char *s, in tegra_tcu_console_write() argument
151 struct tegra_tcu *tcu = container_of(cons, struct tegra_tcu, console); in tegra_tcu_console_write()
156 static int tegra_tcu_console_setup(struct console *cons, char *options) in tegra_tcu_console_setup() argument
215 tcu->driver.cons = &tcu->console; in tegra_tcu_probe()
/drivers/usb/gadget/function/
A Du_serial.c1012 if (cons->req && !cons->req->length) in gs_console_write()
1030 if (!cons) in gs_console_connect()
1042 cons->req = req; in gs_console_connect()
1059 if (!cons) in gs_console_disconnect()
1064 req = cons->req; in gs_console_disconnect()
1066 cons->req = NULL; in gs_console_disconnect()
1086 if (!cons) in gs_console_init()
1101 kfree(cons); in gs_console_init()
1120 if (!cons) in gs_console_exit()
1126 if (cons->req) in gs_console_exit()
[all …]
/drivers/xen/xenbus/
A Dxenbus_comms.c77 *len = XENSTORE_RING_SIZE - (prod - cons); in get_output_chunk()
86 if ((prod - cons) < *len) in get_input_chunk()
87 *len = prod - cons; in get_input_chunk()
88 return buf + MASK_XENSTORE_IDX(cons); in get_input_chunk()
109 XENSTORE_RING_IDX cons, prod; in xb_write() local
117 cons = intf->req_cons; in xb_write()
119 if (!check_indexes(cons, prod)) { in xb_write()
161 XENSTORE_RING_IDX cons, prod; in xb_read() local
169 cons = intf->rsp_cons; in xb_read()
171 if (cons == prod) in xb_read()
[all …]
/drivers/platform/mellanox/
A Dmlxbf-tmfifo.c467 seg = CIRC_SPACE_TO_END(cons->tx_buf.head, cons->tx_buf.tail, in mlxbf_tmfifo_console_output_one()
470 memcpy(cons->tx_buf.buf + cons->tx_buf.head, addr, len); in mlxbf_tmfifo_console_output_one()
472 memcpy(cons->tx_buf.buf + cons->tx_buf.head, addr, seg); in mlxbf_tmfifo_console_output_one()
476 cons->tx_buf.head = (cons->tx_buf.head + len) % in mlxbf_tmfifo_console_output_one()
497 avail = CIRC_SPACE(cons->tx_buf.head, cons->tx_buf.tail, in mlxbf_tmfifo_console_output()
552 if (!cons || !cons->tx_buf.buf) in mlxbf_tmfifo_console_tx()
556 size = CIRC_CNT(cons->tx_buf.head, cons->tx_buf.tail, in mlxbf_tmfifo_console_tx()
574 addr = cons->tx_buf.buf + cons->tx_buf.tail; in mlxbf_tmfifo_console_tx()
576 seg = CIRC_CNT_TO_END(cons->tx_buf.head, cons->tx_buf.tail, in mlxbf_tmfifo_console_tx()
588 cons->tx_buf.tail = (cons->tx_buf.tail + sizeof(u64)) % in mlxbf_tmfifo_console_tx()
[all …]
/drivers/tty/hvc/
A Dhvc_xen.c84 notify_remote_via_evtchn(cons->evtchn); in notify_daemon()
90 XENCONS_RING_IDX cons, prod; in __write_console() local
96 cons = intf->out_cons; in __write_console()
100 if ((prod - cons) > sizeof(intf->out)) { in __write_console()
123 if (cons == NULL) in domU_write_console()
133 ssize_t sent = __write_console(cons, data, len); in domU_write_console()
151 XENCONS_RING_IDX cons, prod; in domU_read_console() local
162 cons = intf->in_cons; in domU_read_console()
166 if ((prod - cons) > sizeof(intf->in)) { in domU_read_console()
172 while (cons != prod && recv < len) in domU_read_console()
[all …]
/drivers/tty/vt/
A Dselection.c41 struct vc_data *cons; /* must not be deallocated */ member
57 invert_screen(vc_sel.cons, s, e-s+2, true); in highlight()
63 complement_pos(vc_sel.cons, where); in highlight_pointer()
70 return screen_glyph_unicode(vc_sel.cons, n / 2); in sel_pos()
71 return inverse_translate(vc_sel.cons, screen_glyph(vc_sel.cons, n), in sel_pos()
95 return vc == vc_sel.cons; in vc_is_sel()
368 if (vc_sel.cons != vc) { in vc_selection()
370 vc_sel.cons = vc; in vc_selection()
/drivers/char/
A Dvirtio_console.c204 struct console cons; member
237 struct console *cons; in find_port_by_vtermno() local
243 port = container_of(cons, struct port, cons); in find_port_by_vtermno()
325 if (port->cons.hvc) in is_console_port()
1162 hvc_resize(port->cons.hvc, port->cons.ws); in resize_console()
1219 port->cons.vtermno = ret; in init_port_console()
1220 port->cons.hvc = hvc_alloc(port->cons.vtermno, 0, &hv_ops, PAGE_SIZE); in init_port_console()
1225 port->cons.hvc = NULL; in init_port_console()
1340 port->cons.hvc = NULL; in add_port()
1343 port->cons.ws.ws_row = port->cons.ws.ws_col = 0; in add_port()
[all …]
/drivers/infiniband/hw/bnxt_re/
A Dqplib_res.h109 - HWQ_CMP(hwq->cons, hwq))\
197 u32 cons; /* raw */ member
456 static inline void bnxt_qplib_hwq_incr_cons(u32 max_elements, u32 *cons, u32 cnt, in bnxt_qplib_hwq_incr_cons() argument
460 *cons += cnt; in bnxt_qplib_hwq_incr_cons()
461 if (*cons >= max_elements) { in bnxt_qplib_hwq_incr_cons()
462 *cons %= max_elements; in bnxt_qplib_hwq_incr_cons()
472 key |= info->hwq->cons | (CMPL_DOORBELL_IDX_VALID | in bnxt_qplib_ring_db32()
495 indx = (info->hwq->cons & DBC_DBC_INDEX_MASK) | in bnxt_qplib_ring_db()
A Dqplib_fp.h366 int cons, prod, avail; in __bnxt_qplib_get_avail() local
368 cons = hwq->cons; in __bnxt_qplib_get_avail()
370 avail = cons - prod; in __bnxt_qplib_get_avail()
371 if (cons <= prod) in __bnxt_qplib_get_avail()
384 avail = hwq->cons - hwq->prod; in bnxt_qplib_queue_full()
385 if (hwq->cons <= hwq->prod) in bnxt_qplib_queue_full()
/drivers/net/ethernet/broadcom/bnxt/
A Dbnxt_xdp.c183 u16 cons, u8 *data_ptr, unsigned int len, in bnxt_xdp_buff_init() argument
193 rx_buf = &rxr->rx_buf_ring[cons]; in bnxt_xdp_buff_init()
224 bool bnxt_rx_xdp(struct bnxt *bp, struct bnxt_rx_ring_info *rxr, u16 cons, in bnxt_rx_xdp() argument
269 rx_buf = &rxr->rx_buf_ring[cons]; in bnxt_rx_xdp()
283 bnxt_reuse_rx_data(rxr, cons, page); in bnxt_rx_xdp()
293 bnxt_reuse_rx_data(rxr, cons, page); in bnxt_rx_xdp()
305 bnxt_reuse_rx_data(rxr, cons, page); in bnxt_rx_xdp()
325 bnxt_reuse_rx_data(rxr, cons, page); in bnxt_rx_xdp()
A Dbnxt_ptp.c758 u16 cons = ptp->txts_cons; in bnxt_ptp_ts_aux_work() local
767 if (!ptp->txts_req[cons].tx_skb) in bnxt_ptp_ts_aux_work()
774 cons = NEXT_TXTS(cons); in bnxt_ptp_ts_aux_work()
776 ptp->txts_cons = cons; in bnxt_ptp_ts_aux_work()
800 u16 cons = ptp->txts_cons; in bnxt_ptp_free_txts_skbs() local
808 while (cons != ptp->txts_prod) { in bnxt_ptp_free_txts_skbs()
809 txts_req = &ptp->txts_req[cons]; in bnxt_ptp_free_txts_skbs()
812 cons = NEXT_TXTS(cons); in bnxt_ptp_free_txts_skbs()
814 ptp->txts_cons = cons; in bnxt_ptp_free_txts_skbs()
867 u16 cons; in bnxt_tx_ts_cmp() local
[all …]
/drivers/gpu/drm/qxl/
A Dqxl_cmd.c85 ret = header->prod - header->cons < header->num_items; in qxl_check_header()
87 header->notify_on_cons = header->cons + 1; in qxl_check_header()
99 ret = header->prod == header->cons; in qxl_check_idle()
113 if (header->prod - header->cons == header->num_items) { in qxl_ring_push()
114 header->notify_on_cons = header->cons + 1; in qxl_ring_push()
160 if (header->cons == header->prod) { in qxl_ring_pop()
161 header->notify_on_prod = header->cons + 1; in qxl_ring_pop()
166 idx = header->cons & (ring->n_elements - 1); in qxl_ring_pop()
171 header->cons++; in qxl_ring_pop()
/drivers/gpu/drm/xen/
A Dxen_drm_front_evtchnl.c86 u32 cons, prod; in evtchnl_interrupt_evt() local
100 for (cons = page->in_cons; cons != prod; cons++) { in evtchnl_interrupt_evt()
103 event = &XENDISPL_IN_RING_REF(page, cons); in evtchnl_interrupt_evt()
114 page->in_cons = cons; in evtchnl_interrupt_evt()
/drivers/tty/
A Dmips_ejtag_fdc.c293 struct console cons; member
304 struct mips_ejtag_fdc_console *cons = in mips_ejtag_fdc_console_write() local
305 container_of(c, struct mips_ejtag_fdc_console, cons); in mips_ejtag_fdc_console_write()
318 regs = cons->regs[cpu]; in mips_ejtag_fdc_console_write()
322 cons->regs[cpu] = regs; in mips_ejtag_fdc_console_write()
359 struct mips_ejtag_fdc_console *cons = in mips_ejtag_fdc_console_device() local
363 return cons->tty_drv; in mips_ejtag_fdc_console_device()
386 register_console(&c->cons); in mips_ejtag_fdc_console_init()
393 .cons = {
594 if (channel == mips_ejtag_fdc_con.cons.index) { in mips_ejtag_fdc_handle()
[all …]
/drivers/infiniband/hw/qedr/
A Dqedr_roce_cm.c681 while (i < num_entries && qp->rq.cons != qp->rq.gsi_cons) { in qedr_gsi_poll_cq()
685 wc[i].wr_id = qp->rqe_wr_id[qp->rq.cons].wr_id; in qedr_gsi_poll_cq()
688 wc[i].status = (qp->rqe_wr_id[qp->rq.cons].rc) ? in qedr_gsi_poll_cq()
691 wc[i].byte_len = qp->rqe_wr_id[qp->rq.cons].sg_list[0].length; in qedr_gsi_poll_cq()
693 ether_addr_copy(wc[i].smac, qp->rqe_wr_id[qp->rq.cons].smac); in qedr_gsi_poll_cq()
696 vlan_id = qp->rqe_wr_id[qp->rq.cons].vlan & in qedr_gsi_poll_cq()
701 wc[i].sl = (qp->rqe_wr_id[qp->rq.cons].vlan & in qedr_gsi_poll_cq()
709 while (i < num_entries && qp->sq.cons != qp->sq.gsi_cons) { in qedr_gsi_poll_cq()
713 wc[i].wr_id = qp->wqe_wr_id[qp->sq.cons].wr_id; in qedr_gsi_poll_cq()
725 num_entries, i, qp->rq.cons, qp->rq.gsi_cons, qp->sq.cons, in qedr_gsi_poll_cq()
/drivers/s390/cio/
A Ddevice_status.c185 cdev_irb->esw.esw0.erw.cons = irb->esw.esw0.erw.cons; in ccw_device_accumulate_esw()
186 if (irb->esw.esw0.erw.cons) in ccw_device_accumulate_esw()
304 !(cdev_irb->esw.esw0.erw.cons)) in ccw_device_accumulate_irb()
368 cdev->private->dma_area->irb.esw.esw0.erw.cons = 1; in ccw_device_accumulate_basic_sense()
390 cdev->private->dma_area->irb.esw.esw0.erw.cons = 1; in ccw_device_accumulate_and_sense()
/drivers/net/
A Dxen-netfront.c392 RING_IDX cons, prod; in xennet_tx_buf_gc() local
410 for (cons = queue->tx.rsp_cons; cons != prod; cons++) { in xennet_tx_buf_gc()
932 RING_IDX cons = queue->rx.rsp_cons; in xennet_get_extras() local
939 if (unlikely(cons + 1 == rp)) { in xennet_get_extras()
958 skb = xennet_get_rx_skb(queue, cons); in xennet_get_extras()
963 xennet_set_rx_rsp_cons(queue, cons); in xennet_get_extras()
1028 RING_IDX cons = queue->rx.rsp_cons; in xennet_get_responses() local
1049 cons = queue->rx.rsp_cons; in xennet_get_responses()
1109 if (cons + slots == rp) { in xennet_get_responses()
1168 RING_IDX cons = queue->rx.rsp_cons; in xennet_fill_frags() local
[all …]
/drivers/iommu/arm/arm-smmu-v3/
A Darm-smmu-v3.c128 u32 space, prod, cons; in queue_has_space() local
131 cons = Q_IDX(q, q->cons); in queue_has_space()
136 space = cons - prod; in queue_has_space()
173 u32 cons = (Q_WRP(q, q->cons) | Q_IDX(q, q->cons)) + 1; in queue_inc_cons() local
174 q->cons = Q_OVF(q->cons) | Q_WRP(q, cons) | Q_IDX(q, cons); in queue_inc_cons()
184 llq->cons = Q_OVF(llq->prod) | Q_WRP(llq, llq->cons) | in queue_sync_cons_ovf()
185 Q_IDX(llq, llq->cons); in queue_sync_cons_ovf()
740 llq->cons = readl(cmdq->q.cons_reg); in __arm_smmu_cmdq_poll_until_consumed()
816 head.cons = llq.cons; in arm_smmu_cmdq_issue_cmdlist()
901 WRITE_ONCE(cmdq->q.llq.cons, llq.cons); in arm_smmu_cmdq_issue_cmdlist()
[all …]

Completed in 72 milliseconds

123456