| /linux/virt/lib/ |
| H A D | irqbypass.c | 31 struct irq_bypass_consumer *cons) in __connect() argument
37 if (cons->stop) in __connect()
38 cons->stop(cons); in __connect()
41 ret = prod->add_consumer(prod, cons); in __connect()
44 ret = cons->add_producer(cons, prod); in __connect()
46 prod->del_consumer(prod, cons); in __connect()
49 if (cons->start) in __connect()
50 cons->start(cons); in __connect()
55 prod->consumer = cons; in __connect()
56 cons->producer = prod; in __connect()
[all …]
|
| /linux/drivers/infiniband/sw/rxe/ |
| H A D | rxe_queue.h | 130 u32 cons; in queue_get_consumer() local
135 cons = q->index; in queue_get_consumer()
139 cons = smp_load_acquire(&q->buf->consumer_index); in queue_get_consumer()
143 cons = smp_load_acquire(&q->buf->consumer_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
159 return ((prod - cons) & q->index_mask) == 0; in queue_empty()
165 u32 cons = queue_get_consumer(q, type); in queue_full() local
167 return ((prod + 1 - cons) & q->index_mask) == 0; in queue_full()
[all …]
|
| H A D | rxe_queue.c | 116 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()
|
| /linux/drivers/tty/serial/ |
| H A D | kgdboc.c | 175 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()
499 if (con == kgdboc_earlycon_io_ops.cons) in kgdboc_earlycon_pre_exp_handler()
526 if (!kgdboc_earlycon_io_ops.cons) in kgdboc_earlycon_deinit()
[all …]
|
| H A D | tegra-utc.c | 414 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()
|
| H A D | tegra-tcu.c | 148 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()
|
| /linux/drivers/usb/gadget/function/ |
| H A D | u_serial.c | 932 struct gs_console *cons = req->context; in gs_console_complete_out() local
941 spin_lock(&cons->lock); in gs_console_complete_out()
943 schedule_work(&cons->work); in gs_console_complete_out()
944 spin_unlock(&cons->lock); in gs_console_complete_out()
954 static void __gs_console_push(struct gs_console *cons) in __gs_console_push() argument
956 struct usb_request *req = cons->req; in __gs_console_push()
966 ep = cons->console.data; in __gs_console_push()
967 size = kfifo_out(&cons->buf, req->buf, ep->maxpacket); in __gs_console_push()
971 if (cons->missed && ep->maxpacket >= 64) { in __gs_console_push()
975 len = sprintf(buf, "\n[missed %zu bytes]\n", cons->missed); in __gs_console_push()
[all …]
|
| /linux/drivers/xen/xenbus/ |
| H A D | xenbus_comms.c | 66 static int check_indexes(XENSTORE_RING_IDX cons, XENSTORE_RING_IDX prod) in check_indexes() argument
68 return ((prod - cons) <= XENSTORE_RING_SIZE); in check_indexes()
71 static void *get_output_chunk(XENSTORE_RING_IDX cons, in get_output_chunk() argument
76 if ((XENSTORE_RING_SIZE - (prod - cons)) < *len) in get_output_chunk()
77 *len = XENSTORE_RING_SIZE - (prod - cons); in get_output_chunk()
81 static const void *get_input_chunk(XENSTORE_RING_IDX cons, in get_input_chunk() argument
85 *len = XENSTORE_RING_SIZE - MASK_XENSTORE_IDX(cons); in get_input_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()
[all …]
|
| /linux/tools/testing/selftests/bpf/ |
| H A D | xsk.h | 142 static inline __u32 xsk_ring_cons__peek(struct xsk_ring_cons *cons, __u32 nb, __u32 *idx) in xsk_ring_cons__peek() argument
144 __u32 entries = xsk_cons_nb_avail(cons, nb); in xsk_ring_cons__peek()
147 *idx = cons->cached_cons; in xsk_ring_cons__peek()
148 cons->cached_cons += entries; in xsk_ring_cons__peek()
154 static inline void xsk_ring_cons__cancel(struct xsk_ring_cons *cons, __u32 nb) in xsk_ring_cons__cancel() argument
156 cons->cached_cons -= nb; in xsk_ring_cons__cancel()
159 static inline void xsk_ring_cons__release(struct xsk_ring_cons *cons, __u32 nb) in xsk_ring_cons__release() argument
164 __atomic_store_n(cons->consumer, *cons->consumer + nb, __ATOMIC_RELEASE); in xsk_ring_cons__release()
|
| /linux/net/smc/ |
| H A D | smc_cdc.h | 47 union smc_cdc_cursor cons; /* piggy backed "ack" */ member
73 union smcd_cdc_cursor cons; member
217 smc_host_cursor_to_cdc(&peer->cons, &local->cons, save, conn); in smc_host_msg_to_cdc()
250 smc_cdc_cursor_to_host(&local->cons, &peer->cons, conn); in smcr_cdc_msg_to_host()
265 temp.wrap = peer->cons.wrap; in smcd_cdc_msg_to_host()
266 temp.count = peer->cons.count; in smcd_cdc_msg_to_host()
267 smc_curs_copy(&local->cons, &temp, conn); in smcd_cdc_msg_to_host()
268 local->prod_flags = peer->cons.prod_flags; in smcd_cdc_msg_to_host()
269 local->conn_state_flags = peer->cons.conn_state_flags; in smcd_cdc_msg_to_host()
|
| H A D | smc_cdc.c | 249 curs.acurs.counter = atomic64_read(&conn->local_tx_ctrl.cons.acurs); in smcd_cdc_msg_send()
250 cdc.cons.wrap = curs.wrap; in smcd_cdc_msg_send()
251 cdc.cons.count = curs.count; in smcd_cdc_msg_send()
252 cdc.cons.prod_flags = conn->local_tx_ctrl.prod_flags; in smcd_cdc_msg_send()
253 cdc.cons.conn_state_flags = conn->local_tx_ctrl.conn_state_flags; in smcd_cdc_msg_send()
338 smc_curs_copy(&cons_old, &conn->local_rx_ctrl.cons, conn); in smc_cdc_msg_recv_action()
342 &conn->local_rx_ctrl.cons); in smc_cdc_msg_recv_action()
363 &conn->local_rx_ctrl.cons); in smc_cdc_msg_recv_action()
370 &conn->local_rx_ctrl.cons, conn); in smc_cdc_msg_recv_action()
454 smcd_curs_copy(&cdc.cons, &data_cdc->cons, conn); in smcd_cdc_rx_tsklet()
|
| /linux/drivers/platform/mellanox/ |
| H A D | mlxbf-tmfifo.c | 142 struct virtio_console_config cons; member
454 static void mlxbf_tmfifo_console_output_one(struct mlxbf_tmfifo_vdev *cons, in mlxbf_tmfifo_console_output_one() argument
459 struct virtio_device *vdev = &cons->vdev; in mlxbf_tmfifo_console_output_one()
467 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()
474 memcpy(cons->tx_buf.buf, addr, len - seg); in mlxbf_tmfifo_console_output_one()
476 cons->tx_buf.head = (cons->tx_buf.head + len) % in mlxbf_tmfifo_console_output_one()
487 static void mlxbf_tmfifo_console_output(struct mlxbf_tmfifo_vdev *cons, in mlxbf_tmfifo_console_output() argument
497 avail = CIRC_SPACE(cons->tx_buf.head, cons->tx_buf.tail, in mlxbf_tmfifo_console_output()
[all …]
|
| /linux/drivers/infiniband/hw/bng_re/ |
| H A D | bng_res.h | 19 - HWQ_CMP(hwq->cons, hwq))\
123 u32 cons; member
169 indx = (info->hwq->cons & DBC_DBC_INDEX_MASK) | in bng_re_ring_db()
187 static inline void bng_re_hwq_incr_cons(u32 max_elements, u32 *cons, u32 cnt, in bng_re_hwq_incr_cons() argument
191 *cons += cnt; in bng_re_hwq_incr_cons()
192 if (*cons >= max_elements) { in bng_re_hwq_incr_cons()
193 *cons %= max_elements; in bng_re_hwq_incr_cons()
|
| /linux/net/9p/ |
| H A D | trans_xen.c | 107 RING_IDX cons, prod; in p9_xen_write_todo() local
109 cons = ring->intf->out_cons; in p9_xen_write_todo()
114 xen_9pfs_queued(prod, cons, XEN_9PFS_RING_SIZE(ring)) >= size; in p9_xen_write_todo()
120 RING_IDX cons, prod, masked_cons, masked_prod; in p9_xen_request() local
144 cons = ring->intf->out_cons; in p9_xen_request()
149 xen_9pfs_queued(prod, cons, XEN_9PFS_RING_SIZE(ring)) < size) { in p9_xen_request()
155 masked_cons = xen_9pfs_mask(cons, XEN_9PFS_RING_SIZE(ring)); in p9_xen_request()
176 RING_IDX cons, prod, masked_cons, masked_prod; in p9_xen_response() local
185 cons = ring->intf->in_cons; in p9_xen_response()
189 if (xen_9pfs_queued(prod, cons, XEN_9PFS_RING_SIZE(ring)) < in p9_xen_response()
[all …]
|
| /linux/drivers/tty/vt/ |
| H A D | selection.c | 41 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()
|
| /linux/include/xen/interface/io/ |
| H A D | ring.h | 406 RING_IDX cons, \
411 if (prod == cons) \
415 cons = name##_mask(cons, ring_size); \
417 if (prod == cons) \
420 if (prod > cons) \
421 size = prod - cons; \
423 size = ring_size - (cons - prod); \
|
| /linux/drivers/char/ |
| H A D | virtio_console.c | 204 struct console cons; member
237 struct console *cons; in find_port_by_vtermno() local
241 list_for_each_entry(cons, &pdrvdata.consoles, list) { in find_port_by_vtermno()
242 if (cons->vtermno == vtermno) { in find_port_by_vtermno()
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()
1221 if (IS_ERR(port->cons.hvc)) { in init_port_console()
[all …]
|
| /linux/include/linux/qed/ |
| H A D | qed_chain.h | 209 u32 cons = qed_chain_get_cons_idx(chain); in qed_chain_get_elem_used() local
213 if (prod < cons) in qed_chain_get_elem_used()
216 used = (u16)(prod - cons); in qed_chain_get_elem_used()
218 used -= (u16)(prod / elem_per_page - cons / elem_per_page); in qed_chain_get_elem_used()
231 u64 cons = qed_chain_get_cons_idx_u32(chain); in qed_chain_get_elem_used_u32() local
235 if (prod < cons) in qed_chain_get_elem_used_u32()
238 used = (u32)(prod - cons); in qed_chain_get_elem_used_u32()
240 used -= (u32)(prod / elem_per_page - cons / elem_per_page); in qed_chain_get_elem_used_u32()
|
| /linux/drivers/gpu/drm/xen/ |
| H A D | xen_drm_front_evtchnl.c | 86 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()
|
| /linux/drivers/net/ethernet/broadcom/bnxt/ |
| H A D | bnxt_ptp.c | 755 u16 cons = ptp->txts_cons; in bnxt_ptp_ts_aux_work() local
762 if (IS_ERR(ptp->txts_req[cons].tx_skb)) in bnxt_ptp_ts_aux_work()
764 if (!ptp->txts_req[cons].tx_skb) in bnxt_ptp_ts_aux_work()
766 rc = bnxt_stamp_tx_skb(bp, cons); in bnxt_ptp_ts_aux_work()
771 cons = NEXT_TXTS(cons); in bnxt_ptp_ts_aux_work()
773 ptp->txts_cons = cons; in bnxt_ptp_ts_aux_work()
797 u16 cons = ptp->txts_cons; in bnxt_ptp_free_txts_skbs() local
805 while (cons != ptp->txts_prod) { in bnxt_ptp_free_txts_skbs()
806 txts_req = &ptp->txts_req[cons]; in bnxt_ptp_free_txts_skbs()
809 cons = NEXT_TXTS(cons); in bnxt_ptp_free_txts_skbs()
[all …]
|
| H A D | bnxt_xdp.h | 20 bool bnxt_rx_xdp(struct bnxt *bp, struct bnxt_rx_ring_info *rxr, u16 cons,
30 u16 cons, u8 *data_ptr, unsigned int len,
|
| /linux/drivers/tty/ |
| H A D | mips_ejtag_fdc.c | 293 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
360 container_of(c, struct mips_ejtag_fdc_console, cons); in mips_ejtag_fdc_console_device()
363 return cons->tty_drv; in mips_ejtag_fdc_console_device()
386 register_console(&c->cons); in mips_ejtag_fdc_console_init()
393 .cons = {
[all …]
|
| /linux/drivers/infiniband/hw/qedr/ |
| H A D | qedr_roce_cm.c | 681 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()
|
| /linux/arch/mips/sibyte/common/ |
| H A D | cfe_console.c | 13 static void cfe_console_write(struct console *cons, const char *str, in cfe_console_write() argument
44 static int cfe_console_setup(struct console *cons, char *str) in cfe_console_setup() argument
|
| /linux/drivers/infiniband/hw/bnxt_re/ |
| H A D | qplib_fp.h | 368 int cons, prod, avail; in __bnxt_qplib_get_avail() local
370 cons = hwq->cons; in __bnxt_qplib_get_avail()
372 avail = cons - prod; in __bnxt_qplib_get_avail()
373 if (cons <= prod) in __bnxt_qplib_get_avail()
386 avail = hwq->cons - hwq->prod; in bnxt_qplib_queue_full()
387 if (hwq->cons <= hwq->prod) in bnxt_qplib_queue_full()
|