| /kernel/linux/linux-6.6/drivers/accel/ivpu/ |
| H A D | ivpu_ipc.c | 72 ivpu_ipc_tx_prepare(struct ivpu_device *vdev, struct ivpu_ipc_consumer *cons, in ivpu_ipc_tx_prepare() argument
107 tx_buf->ipc.channel = cons->channel; in ivpu_ipc_tx_prepare()
117 cons->request_id = req->request_id; in ivpu_ipc_tx_prepare()
120 cons->tx_vpu_addr = tx_buf_vpu_addr; in ivpu_ipc_tx_prepare()
142 ivpu_ipc_consumer_add(struct ivpu_device *vdev, struct ivpu_ipc_consumer *cons, u32 channel) in ivpu_ipc_consumer_add() argument
146 INIT_LIST_HEAD(&cons->link); in ivpu_ipc_consumer_add()
147 cons->channel = channel; in ivpu_ipc_consumer_add()
148 cons->tx_vpu_addr = 0; in ivpu_ipc_consumer_add()
149 cons->request_id = 0; in ivpu_ipc_consumer_add()
150 spin_lock_init(&cons in ivpu_ipc_consumer_add()
159 ivpu_ipc_consumer_del(struct ivpu_device *vdev, struct ivpu_ipc_consumer *cons) ivpu_ipc_consumer_del() argument
181 ivpu_ipc_send(struct ivpu_device *vdev, struct ivpu_ipc_consumer *cons, struct vpu_jsm_msg *req) ivpu_ipc_send() argument
204 ivpu_ipc_receive(struct ivpu_device *vdev, struct ivpu_ipc_consumer *cons, struct ivpu_ipc_hdr *ipc_buf, struct vpu_jsm_msg *ipc_payload, unsigned long timeout_ms) ivpu_ipc_receive() argument
259 struct ivpu_ipc_consumer cons; ivpu_ipc_send_receive_internal() local
318 ivpu_ipc_match_consumer(struct ivpu_device *vdev, struct ivpu_ipc_consumer *cons, struct ivpu_ipc_hdr *ipc_hdr, struct vpu_jsm_msg *jsm_msg) ivpu_ipc_match_consumer() argument
331 ivpu_ipc_dispatch(struct ivpu_device *vdev, struct ivpu_ipc_consumer *cons, struct ivpu_ipc_hdr *ipc_hdr, struct vpu_jsm_msg *jsm_msg) ivpu_ipc_dispatch() argument
361 struct ivpu_ipc_consumer *cons; ivpu_ipc_irq_handler() local
481 struct ivpu_ipc_consumer *cons, *c; ivpu_ipc_disable() local
[all...] |
| /kernel/linux/linux-5.10/virt/lib/ |
| H A D | irqbypass.c | 31 struct irq_bypass_consumer *cons) in __connect()
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 in __connect()
30 __connect(struct irq_bypass_producer *prod, struct irq_bypass_consumer *cons) __connect() argument
58 __disconnect(struct irq_bypass_producer *prod, struct irq_bypass_consumer *cons) __disconnect() argument
[all...] |
| /kernel/linux/linux-6.6/virt/lib/ |
| H A D | irqbypass.c | 31 struct irq_bypass_consumer *cons) in __connect()
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 in __connect()
30 __connect(struct irq_bypass_producer *prod, struct irq_bypass_consumer *cons) __connect() argument
58 __disconnect(struct irq_bypass_producer *prod, struct irq_bypass_consumer *cons) __disconnect() argument
[all...] |
| /kernel/linux/linux-6.6/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) in queue_full()
174 u32 cons = queue_get_consumer(q, type); queue_count() local
218 u32 cons; queue_advance_consumer() local
261 u32 cons = queue_get_consumer(q, type); queue_consumer_addr() local
[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()
|
| /kernel/linux/linux-5.10/drivers/tty/serial/ |
| H A D | kgdboc.c | 147 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 in kgdboc_earlycon_get_char()
[all...] |
| /kernel/linux/linux-6.6/drivers/tty/serial/ |
| H A D | kgdboc.c | 147 if (kgdboc_earlycon_io_ops.cons) in cleanup_earlycon()
173 struct console *cons; in configure_kgdboc() local
181 kgdboc_io_ops.cons = NULL; in configure_kgdboc()
205 for_each_console_srcu(cons) { in configure_kgdboc()
207 if (cons->device && cons->device(cons, &idx) == p && in configure_kgdboc()
209 kgdboc_io_ops.cons = cons; in configure_kgdboc()
447 if (!kgdboc_earlycon_io_ops.cons in kgdboc_earlycon_get_char()
[all...] |
| /kernel/linux/linux-5.10/drivers/usb/gadget/function/ |
| H A D | u_serial.c | 871 struct gs_console *cons = req->context; in gs_console_complete_out() local
880 spin_lock(&cons->lock); in gs_console_complete_out()
882 schedule_work(&cons->work); in gs_console_complete_out()
883 spin_unlock(&cons->lock); in gs_console_complete_out()
893 static void __gs_console_push(struct gs_console *cons) in __gs_console_push() argument
895 struct usb_request *req = cons->req; in __gs_console_push()
905 ep = cons->console.data; in __gs_console_push()
906 size = kfifo_out(&cons->buf, req->buf, ep->maxpacket); in __gs_console_push()
910 if (cons->missed && ep->maxpacket >= 64) { in __gs_console_push()
914 len = sprintf(buf, "\n[missed %zu bytes]\n", cons in __gs_console_push()
929 struct gs_console *cons = container_of(work, struct gs_console, work); gs_console_work() local
941 struct gs_console *cons = container_of(co, struct gs_console, console); gs_console_write() local
965 struct gs_console *cons = port->console; gs_console_connect() local
994 struct gs_console *cons = port->console; gs_console_disconnect() local
1018 struct gs_console *cons; gs_console_init() local
1057 struct gs_console *cons = port->console; gs_console_exit() local
[all...] |
| /kernel/linux/linux-6.6/drivers/usb/gadget/function/ |
| H A D | u_serial.c | 874 struct gs_console *cons = req->context; in gs_console_complete_out() local
883 spin_lock(&cons->lock); in gs_console_complete_out()
885 schedule_work(&cons->work); in gs_console_complete_out()
886 spin_unlock(&cons->lock); in gs_console_complete_out()
896 static void __gs_console_push(struct gs_console *cons) in __gs_console_push() argument
898 struct usb_request *req = cons->req; in __gs_console_push()
908 ep = cons->console.data; in __gs_console_push()
909 size = kfifo_out(&cons->buf, req->buf, ep->maxpacket); in __gs_console_push()
913 if (cons->missed && ep->maxpacket >= 64) { in __gs_console_push()
917 len = sprintf(buf, "\n[missed %zu bytes]\n", cons in __gs_console_push()
932 struct gs_console *cons = container_of(work, struct gs_console, work); gs_console_work() local
944 struct gs_console *cons = container_of(co, struct gs_console, console); gs_console_write() local
968 struct gs_console *cons = port->console; gs_console_connect() local
997 struct gs_console *cons = port->console; gs_console_disconnect() local
1021 struct gs_console *cons; gs_console_init() local
1060 struct gs_console *cons = port->console; gs_console_exit() local
[all...] |
| /kernel/linux/linux-5.10/net/smc/ |
| H A D | smc_rx.c | 48 * @cons consumer cursor
54 union smc_host_cursor cons, size_t len) in smc_rx_update_consumer()
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, con in smc_rx_update_cons()
53 smc_rx_update_consumer(struct smc_sock *smc, union smc_host_cursor cons, size_t len) smc_rx_update_consumer() argument
221 union smc_host_cursor cons; smc_rx_recv_urg() local
286 union smc_host_cursor cons; smc_rx_recvmsg() local
[all...] |
| 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 in smcd_cdc_msg_to_host()
[all...] |
| /kernel/linux/linux-6.6/net/smc/ |
| H A D | smc_rx.c | 54 * @cons consumer cursor
60 union smc_host_cursor cons, size_t len) in smc_rx_update_consumer()
67 smc_curs_add(conn->rmb_desc->len, &cons, len); in smc_rx_update_consumer()
71 diff = smc_curs_comp(conn->rmb_desc->len, &cons, in smc_rx_update_consumer()
83 smc_curs_add(conn->rmb_desc->len, &cons, 1); in smc_rx_update_consumer()
91 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, con in smc_rx_update_cons()
59 smc_rx_update_consumer(struct smc_sock *smc, union smc_host_cursor cons, size_t len) smc_rx_update_consumer() argument
285 union smc_host_cursor cons; smc_rx_recv_urg() local
351 union smc_host_cursor cons; smc_rx_recvmsg() local
[all...] |
| 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 in smcd_cdc_msg_to_host()
[all...] |
| /kernel/linux/linux-5.10/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()
109 XENSTORE_RING_IDX cons, prod; xb_write() local
161 XENSTORE_RING_IDX cons, prod; xb_read() local
[all...] |
| /kernel/linux/linux-6.6/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()
109 XENSTORE_RING_IDX cons, prod; xb_write() local
161 XENSTORE_RING_IDX cons, prod; xb_read() local
[all...] |
| /kernel/linux/linux-6.6/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()
|
| /kernel/linux/linux-5.10/net/9p/ |
| H A D | trans_xen.c | 129 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_SIZ in p9_xen_response()
[all...] |
| /kernel/linux/linux-5.10/drivers/platform/mellanox/ |
| H A D | mlxbf-tmfifo.c | 119 * @config.cons: virtual console config -
131 struct virtio_console_config cons; member
425 static void mlxbf_tmfifo_console_output_one(struct mlxbf_tmfifo_vdev *cons, in mlxbf_tmfifo_console_output_one() argument
430 struct virtio_device *vdev = &cons->vdev; in mlxbf_tmfifo_console_output_one()
438 seg = CIRC_SPACE_TO_END(cons->tx_buf.head, cons->tx_buf.tail, in mlxbf_tmfifo_console_output_one()
441 memcpy(cons->tx_buf.buf + cons->tx_buf.head, addr, len); in mlxbf_tmfifo_console_output_one()
443 memcpy(cons->tx_buf.buf + cons in mlxbf_tmfifo_console_output_one()
458 mlxbf_tmfifo_console_output(struct mlxbf_tmfifo_vdev *cons, struct mlxbf_tmfifo_vring *vring) mlxbf_tmfifo_console_output() argument
512 struct mlxbf_tmfifo_vdev *cons; mlxbf_tmfifo_console_tx() local
[all...] |
| /kernel/linux/linux-6.6/drivers/platform/mellanox/ |
| H A D | mlxbf-tmfifo.c | 129 * @config: non-anonymous union for cons and net
130 * @config.cons: virtual console config -
142 struct virtio_console_config cons; member
453 static void mlxbf_tmfifo_console_output_one(struct mlxbf_tmfifo_vdev *cons, in mlxbf_tmfifo_console_output_one() argument
458 struct virtio_device *vdev = &cons->vdev; in mlxbf_tmfifo_console_output_one()
466 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 in mlxbf_tmfifo_console_output_one()
486 mlxbf_tmfifo_console_output(struct mlxbf_tmfifo_vdev *cons, struct mlxbf_tmfifo_vring *vring) mlxbf_tmfifo_console_output() argument
540 struct mlxbf_tmfifo_vdev *cons; mlxbf_tmfifo_console_tx() local
[all...] |
| /kernel/linux/linux-6.6/net/9p/ |
| H A D | trans_xen.c | 106 RING_IDX cons, prod; in p9_xen_write_todo() local
108 cons = ring->intf->out_cons; in p9_xen_write_todo()
113 xen_9pfs_queued(prod, cons, XEN_9PFS_RING_SIZE(ring)) >= size; in p9_xen_write_todo()
119 RING_IDX cons, prod, masked_cons, masked_prod; in p9_xen_request() local
143 cons = ring->intf->out_cons; in p9_xen_request()
148 xen_9pfs_queued(prod, cons, XEN_9PFS_RING_SIZE(ring)) < size) { in p9_xen_request()
154 masked_cons = xen_9pfs_mask(cons, XEN_9PFS_RING_SIZE(ring)); in p9_xen_request()
175 RING_IDX cons, prod, masked_cons, masked_prod; in p9_xen_response() local
184 cons = ring->intf->in_cons; in p9_xen_response()
188 if (xen_9pfs_queued(prod, cons, XEN_9PFS_RING_SIZ in p9_xen_response()
[all...] |
| /kernel/linux/linux-5.10/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), 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-6.6/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()
93 return vc == vc_sel.cons; in vc_is_sel()
346 if (vc_sel.cons != vc) { in vc_selection()
348 vc_sel.cons = vc; in vc_selection()
|
| /kernel/linux/linux-5.10/drivers/tty/hvc/ |
| H A D | hvc_xen.c | 80 static inline void notify_daemon(struct xencons_info *cons) in notify_daemon() argument
83 notify_remote_via_evtchn(cons->evtchn); in notify_daemon()
89 XENCONS_RING_IDX cons, prod; in __write_console() local
93 cons = intf->out_cons; in __write_console()
97 if ((prod - cons) > sizeof(intf->out)) { in __write_console()
102 while ((sent < len) && ((prod - cons) < sizeof(intf->out))) in __write_console()
116 struct xencons_info *cons = vtermno_to_xencons(vtermno); in domU_write_console() local
117 if (cons == NULL) in domU_write_console()
127 int sent = __write_console(cons, data, len); in domU_write_console()
145 XENCONS_RING_IDX cons, pro in domU_read_console() local
[all...] |
| /kernel/linux/linux-6.6/drivers/tty/hvc/ |
| H A D | hvc_xen.c | 81 static inline void notify_daemon(struct xencons_info *cons) in notify_daemon() argument
84 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()
106 while ((sent < len) && ((prod - cons) < sizeof(intf->out))) in __write_console()
121 struct xencons_info *cons = vtermno_to_xencons(vtermno); in domU_write_console() local
122 if (cons == NULL) in domU_write_console()
132 int sent = __write_console(cons, data, len); in domU_write_console()
150 XENCONS_RING_IDX cons, pro in domU_read_console() local
[all...] |
| /kernel/linux/linux-5.10/include/xen/interface/io/ |
| H A D | ring.h | 414 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); \
|