Home
last modified time | relevance | path

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

1234567

/linux/drivers/accel/ivpu/
A Divpu_ipc.c160 spin_lock(&cons->rx_lock); in ivpu_ipc_rx_msg_add()
163 wake_up(&cons->rx_msg_wq); in ivpu_ipc_rx_msg_add()
182 cons->channel = channel; in ivpu_ipc_consumer_add()
183 cons->tx_vpu_addr = 0; in ivpu_ipc_consumer_add()
184 cons->request_id = 0; in ivpu_ipc_consumer_add()
185 cons->aborted = false; in ivpu_ipc_consumer_add()
202 list_del(&cons->link); in ivpu_ipc_consumer_del()
241 ret = !list_empty(&cons->rx_msg_list) || cons->aborted; in ivpu_ipc_rx_need_wakeup()
265 if (cons->aborted) { in ivpu_ipc_receive()
553 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,
/linux/virt/lib/
A Dirqbypass.c37 if (cons->stop) in __connect()
38 cons->stop(cons); in __connect()
44 ret = cons->add_producer(cons, prod); in __connect()
49 if (cons->start) in __connect()
50 cons->start(cons); in __connect()
63 if (cons->stop) in __disconnect()
64 cons->stop(cons); in __disconnect()
66 cons->del_producer(cons, prod); in __disconnect()
69 prod->del_consumer(prod, cons); in __disconnect()
71 if (cons->start) in __disconnect()
[all …]
/linux/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()
/linux/drivers/tty/serial/
A Dkgdboc.c175 if (kgdboc_earlycon_io_ops.cons) in cleanup_earlycon()
201 struct console *cons; in configure_kgdboc() local
209 kgdboc_io_ops.cons = NULL; in configure_kgdboc()
233 for_each_console_srcu(cons) { in configure_kgdboc()
235 if (cons->device && cons->device(cons, &idx) == p && in configure_kgdboc()
237 kgdboc_io_ops.cons = cons; in configure_kgdboc()
475 if (!kgdboc_earlycon_io_ops.cons->read(kgdboc_earlycon_io_ops.cons, in kgdboc_earlycon_get_char()
484 kgdboc_earlycon_io_ops.cons->write(kgdboc_earlycon_io_ops.cons, &chr, in kgdboc_earlycon_put_char()
534 if (!kgdboc_earlycon_io_ops.cons) in kgdboc_earlycon_deinit()
550 kgdboc_earlycon_io_ops.cons->exit(kgdboc_earlycon_io_ops.cons); in kgdboc_earlycon_deinit()
[all …]
/linux/drivers/usb/gadget/function/
A Du_serial.c976 if (cons->req && !cons->req->length) in gs_console_write()
994 if (!cons) in gs_console_connect()
1006 cons->req = req; in gs_console_connect()
1023 if (!cons) in gs_console_disconnect()
1028 req = cons->req; in gs_console_disconnect()
1030 cons->req = NULL; in gs_console_disconnect()
1050 if (!cons) in gs_console_init()
1065 kfree(cons); in gs_console_init()
1084 if (!cons) in gs_console_exit()
1090 if (cons->req) in gs_console_exit()
[all …]
/linux/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 …]
/linux/net/smc/
A Dsmc_rx.c91 smc_curs_copy(&conn->local_tx_ctrl.cons, &cons, conn); in smc_rx_update_consumer()
103 union smc_host_cursor cons; in smc_rx_update_cons() local
105 smc_curs_copy(&cons, &conn->local_tx_ctrl.cons, conn); in smc_rx_update_cons()
106 smc_rx_update_consumer(smc, cons, len); in smc_rx_update_cons()
285 union smc_host_cursor cons; in smc_rx_recv_urg() local
303 smc_curs_copy(&cons, &conn->local_tx_ctrl.cons, conn); in smc_rx_recv_urg()
311 smc_rx_update_consumer(smc, cons, 0); in smc_rx_recv_urg()
351 union smc_host_cursor cons; in smc_rx_recvmsg() local
447 smc_curs_copy(&cons, &conn->local_tx_ctrl.cons, conn); in smc_rx_recvmsg()
460 cons.count); in smc_rx_recvmsg()
[all …]
A 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()
A Dsmc_cdc.c249 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/tools/testing/selftests/bpf/
A Dxsk.h142 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/drivers/platform/mellanox/
A Dmlxbf-tmfifo.c466 seg = CIRC_SPACE_TO_END(cons->tx_buf.head, cons->tx_buf.tail, in mlxbf_tmfifo_console_output_one()
469 memcpy(cons->tx_buf.buf + cons->tx_buf.head, addr, len); in mlxbf_tmfifo_console_output_one()
471 memcpy(cons->tx_buf.buf + cons->tx_buf.head, addr, seg); in mlxbf_tmfifo_console_output_one()
475 cons->tx_buf.head = (cons->tx_buf.head + len) % in mlxbf_tmfifo_console_output_one()
496 avail = CIRC_SPACE(cons->tx_buf.head, cons->tx_buf.tail, in mlxbf_tmfifo_console_output()
551 if (!cons || !cons->tx_buf.buf) in mlxbf_tmfifo_console_tx()
555 size = CIRC_CNT(cons->tx_buf.head, cons->tx_buf.tail, in mlxbf_tmfifo_console_tx()
573 addr = cons->tx_buf.buf + cons->tx_buf.tail; in mlxbf_tmfifo_console_tx()
575 seg = CIRC_CNT_TO_END(cons->tx_buf.head, cons->tx_buf.tail, in mlxbf_tmfifo_console_tx()
587 cons->tx_buf.tail = (cons->tx_buf.tail + sizeof(u64)) % in mlxbf_tmfifo_console_tx()
[all …]
/linux/net/9p/
A Dtrans_xen.c105 RING_IDX cons, prod; in p9_xen_write_todo() local
107 cons = ring->intf->out_cons; in p9_xen_write_todo()
118 RING_IDX cons, prod, masked_cons, masked_prod; in p9_xen_request() local
142 cons = ring->intf->out_cons; in p9_xen_request()
153 masked_cons = xen_9pfs_mask(cons, XEN_9PFS_RING_SIZE(ring)); in p9_xen_request()
174 RING_IDX cons, prod, masked_cons, masked_prod; in p9_xen_response() local
183 cons = ring->intf->in_cons; in p9_xen_response()
204 cons += h.size; in p9_xen_response()
206 ring->intf->in_cons = cons; in p9_xen_response()
231 cons += h.size; in p9_xen_response()
[all …]
/linux/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()
355 if (vc_sel.cons != vc) { in vc_selection()
357 vc_sel.cons = vc; in vc_selection()
/linux/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 …]
/linux/include/xen/interface/io/
A Dring.h406 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/
A Dvirtio_console.c203 struct console cons; member
236 struct console *cons; in find_port_by_vtermno() local
242 port = container_of(cons, struct port, cons); in find_port_by_vtermno()
324 if (port->cons.hvc) in is_console_port()
1161 hvc_resize(port->cons.hvc, port->cons.ws); in resize_console()
1218 port->cons.vtermno = ret; in init_port_console()
1219 port->cons.hvc = hvc_alloc(port->cons.vtermno, 0, &hv_ops, PAGE_SIZE); in init_port_console()
1224 port->cons.hvc = NULL; in init_port_console()
1341 port->cons.hvc = NULL; in add_port()
1344 port->cons.ws.ws_row = port->cons.ws.ws_col = 0; in add_port()
[all …]
/linux/include/linux/
A Dserial_core.h25 ((port)->cons && (port)->cons->index == (port)->line)
494 struct console *cons; /* struct console, if any */ member
627 up->cons = con; in uart_port_set_cons()
647 if (hlist_unhashed_lockless(&up->cons->node) || in __uart_port_using_nbcon()
648 !(up->cons->flags & CON_NBCON) || in __uart_port_using_nbcon()
649 !up->cons->write_atomic) { in __uart_port_using_nbcon()
662 return nbcon_device_try_acquire(up->cons); in __uart_port_nbcon_try_acquire()
671 while (!nbcon_device_try_acquire(up->cons)) in __uart_port_nbcon_acquire()
681 nbcon_device_release(up->cons); in __uart_port_nbcon_release()
876 struct console *cons; member
[all …]
/linux/drivers/infiniband/hw/bnxt_re/
A Dqplib_res.h100 - HWQ_CMP(hwq->cons, hwq))\
188 u32 cons; /* raw */ member
448 static inline void bnxt_qplib_hwq_incr_cons(u32 max_elements, u32 *cons, u32 cnt, in bnxt_qplib_hwq_incr_cons() argument
452 *cons += cnt; in bnxt_qplib_hwq_incr_cons()
453 if (*cons >= max_elements) { in bnxt_qplib_hwq_incr_cons()
454 *cons %= max_elements; in bnxt_qplib_hwq_incr_cons()
464 key |= info->hwq->cons | (CMPL_DOORBELL_IDX_VALID | in bnxt_qplib_ring_db32()
487 indx = (info->hwq->cons & DBC_DBC_INDEX_MASK) | in bnxt_qplib_ring_db()
/linux/include/linux/qed/
A Dqed_chain.h209 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/
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()
/linux/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()
/linux/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()
/linux/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 …]

Completed in 57 milliseconds

1234567