Home
last modified time | relevance | path

Searched full:cons (Results 1 – 25 of 187) sorted by relevance

12345678

/kernel/linux/linux-5.10/virt/lib/
Dirqbypass.c31 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()
59 struct irq_bypass_consumer *cons) in __disconnect() argument
63 if (cons->stop) in __disconnect()
[all …]
/kernel/linux/linux-5.10/net/smc/
Dsmc_rx.c48 * @cons consumer cursor
54 union smc_host_cursor cons, size_t len) in smc_rx_update_consumer() argument
61 smc_curs_add(conn->rmb_desc->len, &cons, len); in smc_rx_update_consumer()
65 diff = smc_curs_comp(conn->rmb_desc->len, &cons, in smc_rx_update_consumer()
77 smc_curs_add(conn->rmb_desc->len, &cons, 1); in smc_rx_update_consumer()
85 smc_curs_copy(&conn->local_tx_ctrl.cons, &cons, conn); in smc_rx_update_consumer()
97 union smc_host_cursor cons; in smc_rx_update_cons() local
99 smc_curs_copy(&cons, &conn->local_tx_ctrl.cons, conn); in smc_rx_update_cons()
100 smc_rx_update_consumer(smc, cons, len); in smc_rx_update_cons()
221 union smc_host_cursor cons; in smc_rx_recv_urg() local
[all …]
Dsmc_cdc.h47 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()
Dsmc_cdc.c235 curs.acurs.counter = atomic64_read(&conn->local_tx_ctrl.cons.acurs); in smcd_cdc_msg_send()
236 cdc.cons.wrap = curs.wrap; in smcd_cdc_msg_send()
237 cdc.cons.count = curs.count; in smcd_cdc_msg_send()
238 cdc.cons.prod_flags = conn->local_tx_ctrl.prod_flags; in smcd_cdc_msg_send()
239 cdc.cons.conn_state_flags = conn->local_tx_ctrl.conn_state_flags; in smcd_cdc_msg_send()
316 smc_curs_copy(&cons_old, &conn->local_rx_ctrl.cons, conn); in smc_cdc_msg_recv_action()
320 &conn->local_rx_ctrl.cons); in smc_cdc_msg_recv_action()
405 smcd_curs_copy(&cdc.cons, &data_cdc->cons, conn); in smcd_cdc_rx_tsklet()
/kernel/linux/linux-5.10/drivers/tty/serial/
Dkgdboc.c147 if (kgdboc_earlycon_io_ops.cons) in cleanup_earlycon()
173 struct console *cons; in configure_kgdboc() local
180 kgdboc_io_ops.cons = NULL; in configure_kgdboc()
196 for_each_console(cons) { in configure_kgdboc()
198 if (cons->device && cons->device(cons, &idx) == p && in configure_kgdboc()
200 kgdboc_io_ops.cons = cons; in configure_kgdboc()
435 if (!kgdboc_earlycon_io_ops.cons->read(kgdboc_earlycon_io_ops.cons, in kgdboc_earlycon_get_char()
444 kgdboc_earlycon_io_ops.cons->write(kgdboc_earlycon_io_ops.cons, &chr, in kgdboc_earlycon_put_char()
465 if (con == kgdboc_earlycon_io_ops.cons) in kgdboc_earlycon_pre_exp_handler()
488 if (!kgdboc_earlycon_io_ops.cons) in kgdboc_earlycon_deinit()
[all …]
/kernel/linux/linux-5.10/drivers/usb/gadget/function/
Du_serial.c868 struct gs_console *cons = req->context; in gs_console_complete_out() local
877 spin_lock(&cons->lock); in gs_console_complete_out()
879 schedule_work(&cons->work); in gs_console_complete_out()
880 spin_unlock(&cons->lock); in gs_console_complete_out()
890 static void __gs_console_push(struct gs_console *cons) in __gs_console_push() argument
892 struct usb_request *req = cons->req; in __gs_console_push()
902 ep = cons->console.data; in __gs_console_push()
903 size = kfifo_out(&cons->buf, req->buf, ep->maxpacket); in __gs_console_push()
907 if (cons->missed && ep->maxpacket >= 64) { in __gs_console_push()
911 len = sprintf(buf, "\n[missed %zu bytes]\n", cons->missed); in __gs_console_push()
[all …]
/kernel/linux/linux-5.10/drivers/xen/xenbus/
Dxenbus_comms.c66 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 …]
/kernel/linux/linux-5.10/drivers/platform/mellanox/
Dmlxbf-tmfifo.c109 * @config.cons: virtual console config -
121 struct virtio_console_config cons; member
414 static void mlxbf_tmfifo_console_output_one(struct mlxbf_tmfifo_vdev *cons, in mlxbf_tmfifo_console_output_one() argument
419 struct virtio_device *vdev = &cons->vdev; in mlxbf_tmfifo_console_output_one()
427 seg = CIRC_SPACE_TO_END(cons->tx_buf.head, cons->tx_buf.tail, in mlxbf_tmfifo_console_output_one()
430 memcpy(cons->tx_buf.buf + cons->tx_buf.head, addr, len); in mlxbf_tmfifo_console_output_one()
432 memcpy(cons->tx_buf.buf + cons->tx_buf.head, addr, seg); in mlxbf_tmfifo_console_output_one()
434 memcpy(cons->tx_buf.buf, addr, len - seg); in mlxbf_tmfifo_console_output_one()
436 cons->tx_buf.head = (cons->tx_buf.head + len) % in mlxbf_tmfifo_console_output_one()
447 static void mlxbf_tmfifo_console_output(struct mlxbf_tmfifo_vdev *cons, in mlxbf_tmfifo_console_output() argument
[all …]
/kernel/linux/linux-5.10/net/9p/
Dtrans_xen.c129 RING_IDX cons, prod; in p9_xen_write_todo() local
131 cons = ring->intf->out_cons; in p9_xen_write_todo()
136 xen_9pfs_queued(prod, cons, XEN_9PFS_RING_SIZE(ring)) >= size; in p9_xen_write_todo()
142 RING_IDX cons, prod, masked_cons, masked_prod; in p9_xen_request() local
166 cons = ring->intf->out_cons; in p9_xen_request()
171 xen_9pfs_queued(prod, cons, XEN_9PFS_RING_SIZE(ring)) < size) { in p9_xen_request()
177 masked_cons = xen_9pfs_mask(cons, XEN_9PFS_RING_SIZE(ring)); in p9_xen_request()
198 RING_IDX cons, prod, masked_cons, masked_prod; in p9_xen_response() local
207 cons = ring->intf->in_cons; in p9_xen_response()
211 if (xen_9pfs_queued(prod, cons, XEN_9PFS_RING_SIZE(ring)) < in p9_xen_response()
[all …]
/kernel/linux/linux-5.10/lib/
Dasn1_decoder.c136 *_errmsg = "Missing EOC in indefinite len cons"; in asn1_find_indefinite_length()
159 * cons stack elements and length_too_long checking.
185 #define FLAG_CONS 0x20 /* Corresponds to CONS bit in the opcode tag in asn1_ber_decoder()
237 * - Either CONS or PRIM are permitted in the data if in asn1_ber_decoder()
238 * CONS is not set in the op stream, otherwise CONS in asn1_ber_decoder()
306 tag, len, flags & FLAG_CONS ? " CONS" : ""); in asn1_ber_decoder()
399 pr_debug("- end cons t=%zu dp=%zu l=%zu/%zu\n", in asn1_ber_decoder()
430 pr_debug("- cons len l=%zu d=%zu\n", len, dp - tdp); in asn1_ber_decoder()
489 errmsg = "Cons stack underflow"; in asn1_ber_decoder()
492 errmsg = "Cons stack overflow"; in asn1_ber_decoder()
[all …]
/kernel/linux/linux-5.10/drivers/tty/hvc/
Dhvc_xen.c75 static inline void notify_daemon(struct xencons_info *cons) in notify_daemon() argument
78 notify_remote_via_evtchn(cons->evtchn); in notify_daemon()
84 XENCONS_RING_IDX cons, prod; in __write_console() local
88 cons = intf->out_cons; in __write_console()
92 if ((prod - cons) > sizeof(intf->out)) { in __write_console()
97 while ((sent < len) && ((prod - cons) < sizeof(intf->out))) in __write_console()
111 struct xencons_info *cons = vtermno_to_xencons(vtermno); in domU_write_console() local
112 if (cons == NULL) in domU_write_console()
122 int sent = __write_console(cons, data, len); in domU_write_console()
140 XENCONS_RING_IDX cons, prod; in domU_read_console() local
[all …]
/kernel/linux/linux-5.10/tools/lib/bpf/
Dxsk.h138 static inline size_t xsk_ring_cons__peek(struct xsk_ring_cons *cons, in xsk_ring_cons__peek() argument
141 size_t entries = xsk_cons_nb_avail(cons, nb); in xsk_ring_cons__peek()
149 *idx = cons->cached_cons; in xsk_ring_cons__peek()
150 cons->cached_cons += entries; in xsk_ring_cons__peek()
156 static inline void xsk_ring_cons__release(struct xsk_ring_cons *cons, size_t nb) in xsk_ring_cons__release() argument
163 *cons->consumer += nb; in xsk_ring_cons__release()
/kernel/linux/linux-5.10/include/linux/qed/
Dqed_chain.h36 /* The chain's size/prod/cons are kept in 16-bit variables */
39 /* The chain's size/prod/cons are kept in 32-bit variables */
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()
[all …]
/kernel/linux/linux-5.10/drivers/iommu/arm/arm-smmu-v3/
Darm-smmu-v3.c116 u32 space, prod, cons; in queue_has_space() local
119 cons = Q_IDX(q, q->cons); in queue_has_space()
121 if (Q_WRP(q, q->prod) == Q_WRP(q, q->cons)) in queue_has_space()
122 space = (1 << q->max_n_shift) - (prod - cons); in queue_has_space()
124 space = cons - prod; in queue_has_space()
131 return Q_IDX(q, q->prod) == Q_IDX(q, q->cons) && in queue_full()
132 Q_WRP(q, q->prod) != Q_WRP(q, q->cons); in queue_full()
137 return Q_IDX(q, q->prod) == Q_IDX(q, q->cons) && in queue_empty()
138 Q_WRP(q, q->prod) == Q_WRP(q, q->cons); in queue_empty()
143 return ((Q_WRP(q, q->cons) == Q_WRP(q, prod)) && in queue_consumed()
[all …]
/kernel/linux/linux-5.10/drivers/tty/vt/
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), 0); in sel_pos()
92 return vc == vc_sel.cons; in vc_is_sel()
345 if (vc_sel.cons != vc) { in vc_selection()
347 vc_sel.cons = vc; in vc_selection()
/kernel/linux/linux-5.10/drivers/infiniband/hw/qedr/
Dqedr_roce_cm.c683 while (i < num_entries && qp->rq.cons != qp->rq.gsi_cons) { in qedr_gsi_poll_cq()
687 wc[i].wr_id = qp->rqe_wr_id[qp->rq.cons].wr_id; in qedr_gsi_poll_cq()
690 wc[i].status = (qp->rqe_wr_id[qp->rq.cons].rc) ? in qedr_gsi_poll_cq()
693 wc[i].byte_len = qp->rqe_wr_id[qp->rq.cons].sg_list[0].length; in qedr_gsi_poll_cq()
695 ether_addr_copy(wc[i].smac, qp->rqe_wr_id[qp->rq.cons].smac); in qedr_gsi_poll_cq()
698 vlan_id = qp->rqe_wr_id[qp->rq.cons].vlan & in qedr_gsi_poll_cq()
703 wc[i].sl = (qp->rqe_wr_id[qp->rq.cons].vlan & in qedr_gsi_poll_cq()
711 while (i < num_entries && qp->sq.cons != qp->sq.gsi_cons) { in qedr_gsi_poll_cq()
715 wc[i].wr_id = qp->wqe_wr_id[qp->sq.cons].wr_id; in qedr_gsi_poll_cq()
726 …"gsi poll_cq: requested entries=%d, actual=%d, qp->rq.cons=%d, qp->rq.gsi_cons=%x, qp->sq.cons=%d,… in qedr_gsi_poll_cq()
[all …]
/kernel/linux/linux-5.10/drivers/net/ethernet/broadcom/bnxt/
Dbnxt_xdp.c111 bool bnxt_rx_xdp(struct bnxt *bp, struct bnxt_rx_ring_info *rxr, u16 cons, in bnxt_rx_xdp() argument
129 rx_buf = &rxr->rx_buf_ring[cons]; in bnxt_rx_xdp()
167 bnxt_reuse_rx_data(rxr, cons, page); in bnxt_rx_xdp()
176 bnxt_reuse_rx_data(rxr, cons, page); in bnxt_rx_xdp()
190 bnxt_reuse_rx_data(rxr, cons, page); in bnxt_rx_xdp()
209 bnxt_reuse_rx_data(rxr, cons, page); in bnxt_rx_xdp()
/kernel/linux/linux-5.10/drivers/infiniband/hw/bnxt_re/
Dqplib_res.h76 - HWQ_CMP(hwq->cons, hwq))\
163 u32 cons; /* raw */ member
386 hwq->cons = (hwq->cons + cnt) % hwq->depth; in bnxt_qplib_hwq_incr_cons()
394 key = info->hwq->cons & (info->hwq->max_elements - 1); in bnxt_qplib_ring_db32()
409 key |= (info->hwq->cons & (info->hwq->max_elements - 1)) & in bnxt_qplib_ring_db()
/kernel/linux/linux-5.10/drivers/gpu/drm/xen/
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()
/kernel/linux/linux-5.10/drivers/gpu/drm/qxl/
Dqxl_cmd.c93 ret = header->prod - header->cons < header->num_items; in qxl_check_header()
95 header->notify_on_cons = header->cons + 1; in qxl_check_header()
107 ret = header->prod == header->cons; in qxl_check_idle()
121 if (header->prod - header->cons == header->num_items) { in qxl_ring_push()
122 header->notify_on_cons = header->cons + 1; in qxl_ring_push()
168 if (header->cons == header->prod) { in qxl_ring_pop()
169 header->notify_on_prod = header->cons + 1; in qxl_ring_pop()
174 idx = header->cons & (ring->n_elements - 1); in qxl_ring_pop()
179 header->cons++; in qxl_ring_pop()
/kernel/linux/linux-5.10/drivers/char/
Dvirtio_console.c209 struct console cons; member
245 struct console *cons; in find_port_by_vtermno() local
249 list_for_each_entry(cons, &pdrvdata.consoles, list) { in find_port_by_vtermno()
250 if (cons->vtermno == vtermno) { in find_port_by_vtermno()
251 port = container_of(cons, struct port, cons); in find_port_by_vtermno()
333 if (port->cons.hvc) in is_console_port()
1178 hvc_resize(port->cons.hvc, port->cons.ws); in resize_console()
1246 port->cons.vtermno = pdrvdata.next_vtermno; in init_port_console()
1248 port->cons.hvc = hvc_alloc(port->cons.vtermno, 0, &hv_ops, PAGE_SIZE); in init_port_console()
1249 if (IS_ERR(port->cons.hvc)) { in init_port_console()
[all …]
/kernel/linux/linux-5.10/include/xen/interface/io/
Dring.h414 RING_IDX cons, \
419 if (prod == cons) \
423 cons = name##_mask(cons, ring_size); \
425 if (prod == cons) \
428 if (prod > cons) \
429 size = prod - cons; \
431 size = ring_size - (cons - prod); \
/kernel/linux/linux-5.10/drivers/net/ethernet/mellanox/mlx4/
Den_tx.c191 ring->cons = 0xffffffff; in mlx4_en_activate_tx_ring()
228 return ring->prod - ring->cons > ring->full_size; in mlx4_en_is_tx_ring_full()
368 ring->cons += ring->last_nr_txbb; in mlx4_en_free_tx_buf()
369 en_dbg(DRV, priv, "Freeing Tx buf - cons:0x%x prod:0x%x\n", in mlx4_en_free_tx_buf()
370 ring->cons, ring->prod); in mlx4_en_free_tx_buf()
372 if ((u32) (ring->prod - ring->cons) > ring->size) { in mlx4_en_free_tx_buf()
378 while (ring->cons != ring->prod) { in mlx4_en_free_tx_buf()
380 ring->cons & ring->size_mask, in mlx4_en_free_tx_buf()
382 ring->cons += ring->last_nr_txbb; in mlx4_en_free_tx_buf()
454 ring_cons = READ_ONCE(ring->cons); in mlx4_en_process_tx_cq()
[all …]
/kernel/linux/linux-5.10/sound/xen/
Dxen_snd_front_evtchnl.c91 u32 cons, prod; in evtchnl_interrupt_evt() local
109 for (cons = page->in_cons; cons != prod; cons++) { in evtchnl_interrupt_evt()
112 event = &XENSND_IN_RING_REF(page, cons); in evtchnl_interrupt_evt()
124 page->in_cons = cons; in evtchnl_interrupt_evt()
/kernel/linux/linux-5.10/drivers/xen/
Dpvcalls-front.c137 RING_IDX cons, prod, size = XEN_FLEX_RING_SIZE(PVCALLS_RING_ORDER); in pvcalls_front_write_todo() local
146 cons = intf->out_cons; in pvcalls_front_write_todo()
148 return !!(size - pvcalls_queued(prod, cons, size)); in pvcalls_front_write_todo()
154 RING_IDX cons, prod; in pvcalls_front_read_todo() local
157 cons = intf->in_cons; in pvcalls_front_read_todo()
161 pvcalls_queued(prod, cons, in pvcalls_front_read_todo()
486 RING_IDX cons, prod, size, masked_prod, masked_cons; in __write_ring() local
493 cons = intf->out_cons; in __write_ring()
498 size = pvcalls_queued(prod, cons, array_size); in __write_ring()
507 masked_cons = pvcalls_mask(cons, array_size); in __write_ring()
[all …]

12345678