| /linux/virt/lib/ |
| H A D | irqbypass.c | 84 int irq_bypass_register_producer(struct irq_bypass_producer *producer) in irq_bypass_register_producer() argument
90 if (!producer->token) in irq_bypass_register_producer()
101 if (tmp->token == producer->token) { in irq_bypass_register_producer()
108 if (consumer->token == producer->token) { in irq_bypass_register_producer()
109 ret = __connect(producer, consumer); in irq_bypass_register_producer()
116 list_add(&producer->node, &producers); in irq_bypass_register_producer()
135 void irq_bypass_unregister_producer(struct irq_bypass_producer *producer) in irq_bypass_unregister_producer() argument
140 if (!producer->token) in irq_bypass_unregister_producer()
151 if (tmp->token != producer->token) in irq_bypass_unregister_producer()
155 if (consumer->token == producer->token) { in irq_bypass_unregister_producer()
[all …]
|
| /linux/tools/testing/selftests/bpf/benchs/ |
| H A D | bench_rename.c | 26 static void *producer(void *input) in producer() function
113 .producer_thread = producer,
123 .producer_thread = producer,
133 .producer_thread = producer,
143 .producer_thread = producer,
153 .producer_thread = producer,
163 .producer_thread = producer,
|
| H A D | bench_bloom_filter_map.c | 122 static void *producer(void *input) in producer() function
429 .producer_thread = producer,
440 .producer_thread = producer,
451 .producer_thread = producer,
462 .producer_thread = producer,
473 .producer_thread = producer,
|
| H A D | bench_local_storage.c | 233 static void *producer(void *input) in producer() function
256 .producer_thread = producer,
267 .producer_thread = producer,
278 .producer_thread = producer,
|
| H A D | bench_bpf_loop.c | 56 static void *producer(void *input) in producer() function
96 .producer_thread = producer,
|
| H A D | bench_bpf_hashmap_full_update.c | 23 static void *producer(void *input) in producer() function
85 .producer_thread = producer,
|
| H A D | bench_local_storage_rcu_tasks_trace.c | 200 static void *producer(void *input) in producer() function
259 .producer_thread = producer,
|
| H A D | bench_local_storage_create.c | 196 static void *producer(void *input) in producer() function
254 .producer_thread = producer,
|
| H A D | bench_bpf_hashmap_lookup.c | 128 static void *producer(void *input) in producer() function
273 .producer_thread = producer,
|
| /linux/drivers/net/ethernet/qlogic/qlcnic/ |
| H A D | qlcnic_io.c | 277 u32 producer; in qlcnic_82xx_change_filter() local
280 producer = tx_ring->producer; in qlcnic_82xx_change_filter()
281 hwdesc = &tx_ring->desc_head[tx_ring->producer]; in qlcnic_82xx_change_filter()
297 tx_ring->producer = get_next_index(producer, tx_ring->num_desc); in qlcnic_82xx_change_filter()
377 u32 producer = tx_ring->producer; in qlcnic_tx_encap_pkt() local
407 hwdesc = &tx_ring->desc_head[producer]; in qlcnic_tx_encap_pkt()
408 tx_ring->cmd_buf_arr[producer].skb = NULL; in qlcnic_tx_encap_pkt()
413 producer = get_next_index(producer, tx_ring->num_desc); in qlcnic_tx_encap_pkt()
416 tx_ring->producer = producer; in qlcnic_tx_encap_pkt()
467 u32 producer = tx_ring->producer; in qlcnic_tx_pkt() local
[all …]
|
| H A D | qlcnic_hw.c | 384 u32 i, producer; in qlcnic_send_cmd_descs() local
397 producer = tx_ring->producer; in qlcnic_send_cmd_descs()
415 pbuf = &tx_ring->cmd_buf_arr[producer]; in qlcnic_send_cmd_descs()
419 memcpy(&tx_ring->desc_head[producer], in qlcnic_send_cmd_descs()
422 producer = get_next_index(producer, tx_ring->num_desc); in qlcnic_send_cmd_descs()
427 tx_ring->producer = producer; in qlcnic_send_cmd_descs()
|
| /linux/Documentation/core-api/ |
| H A D | circular-buffers.rst | 15 (2) Memory barriers for when the producer and the consumer of objects in the
19 producer and just one consumer. It is possible to handle multiple producers by
30 - The producer.
41 (1) A 'head' index - the point at which the producer inserts items into the
113 (1) CIRC_SPACE*() are intended to be used in the producer. To the producer
114 they will return a lower bound as the producer controls the head index,
118 To the consumer it will show an upper bound as the producer may be busy
123 producer may still be filling the buffer on another CPU and moving the
126 To the producer it will show an upper bound as the consumer may be busy
130 producer and consumer become visible cannot be guaranteed as they are
[all …]
|
| /linux/kernel/trace/ |
| H A D | ring_buffer_benchmark.c | 33 static struct task_struct *producer; variable
449 producer = kthread_run(ring_buffer_producer_thread, in ring_buffer_benchmark_init()
451 ret = PTR_ERR(producer); in ring_buffer_benchmark_init()
453 if (IS_ERR(producer)) in ring_buffer_benchmark_init()
469 sched_set_fifo(producer); in ring_buffer_benchmark_init()
471 sched_set_fifo_low(producer); in ring_buffer_benchmark_init()
473 set_user_nice(producer, producer_nice); in ring_buffer_benchmark_init()
488 kthread_stop(producer); in ring_buffer_benchmark_exit()
|
| /linux/net/xdp/ |
| H A D | xsk_queue.h | 17 u32 producer ____cacheline_aligned_in_smp;
287 q->cached_prod = smp_load_acquire(&q->ring->producer); /* C, matches B */ in __xskq_cons_peek()
342 return READ_ONCE(q->ring->producer) - READ_ONCE(q->ring->consumer); in xskq_cons_present_entries()
426 smp_store_release(&q->ring->producer, idx); /* B, matches C */ in __xskq_prod_submit()
436 __xskq_prod_submit(q, q->ring->producer + nb_entries); in xskq_prod_submit_n()
442 return READ_ONCE(q->ring->consumer) == READ_ONCE(q->ring->producer); in xskq_prod_is_empty()
|
| H A D | xsk.h | 15 __u64 producer; member
|
| /linux/tools/testing/selftests/bpf/ |
| H A D | xsk.h | 33 __u32 *producer; \
111 r->cached_prod = __atomic_load_n(r->producer, __ATOMIC_ACQUIRE); in xsk_cons_nb_avail()
134 __atomic_store_n(prod->producer, *prod->producer + nb, __ATOMIC_RELEASE); in xsk_ring_prod__submit()
|
| H A D | xsk.c | 195 fill->producer = map + off.fr.producer; in xsk_create_umem_rings()
211 comp->producer = map + off.cr.producer; in xsk_create_umem_rings()
636 rx->producer = rx_map + off.rx.producer; in xsk_socket__create_shared()
640 rx->cached_prod = *rx->producer; in xsk_socket__create_shared()
657 tx->producer = tx_map + off.tx.producer; in xsk_socket__create_shared()
661 tx->cached_prod = *tx->producer; in xsk_socket__create_shared()
|
| /linux/drivers/mailbox/ |
| H A D | tegra-hsp.c | 86 bool producer; member
236 if (mb->producer) { in tegra_hsp_shared_irq()
262 if (!mb->producer) in tegra_hsp_shared_irq()
459 if (WARN_ON(!mb->producer)) in tegra_hsp_mailbox_send_data()
524 if (mb->producer) in tegra_hsp_mailbox_startup()
534 if (mb->producer) in tegra_hsp_mailbox_startup()
553 if (mb->producer) in tegra_hsp_mailbox_shutdown()
563 if (mb->producer) in tegra_hsp_mailbox_shutdown()
644 mb->producer = false; in tegra_hsp_sm_xlate()
646 mb->producer = true; in tegra_hsp_sm_xlate()
|
| /linux/drivers/net/ethernet/qlogic/netxen/ |
| H A D | netxen_nic_init.c | 1811 int producer, count = 0; in netxen_post_rx_buffers() local
1815 producer = rds_ring->producer; in netxen_post_rx_buffers()
1831 pdesc = &rds_ring->desc_head[producer]; in netxen_post_rx_buffers()
1836 producer = get_next_index(producer, rds_ring->num_desc); in netxen_post_rx_buffers()
1840 rds_ring->producer = producer; in netxen_post_rx_buffers()
1842 (producer-1) & (rds_ring->num_desc-1)); in netxen_post_rx_buffers()
1853 ((producer - 1) & in netxen_post_rx_buffers()
1869 int producer, count = 0; in netxen_post_rx_buffers_nodb() local
1875 producer = rds_ring->producer; in netxen_post_rx_buffers_nodb()
1891 pdesc = &rds_ring->desc_head[producer]; in netxen_post_rx_buffers_nodb()
[all …]
|
| H A D | netxen_nic_main.c | 105 NXWRIO(adapter, tx_ring->crb_cmd_producer, tx_ring->producer); in netxen_nic_update_cmd_producer()
1239 tx_ring->producer = 0; in netxen_nic_attach()
1848 u32 producer; in netxen_tso_check() local
1915 producer = tx_ring->producer; in netxen_tso_check()
1922 hwdesc = &tx_ring->desc_head[producer]; in netxen_tso_check()
1923 tx_ring->cmd_buf_arr[producer].skb = NULL; in netxen_tso_check()
1938 producer = get_next_index(producer, tx_ring->num_desc); in netxen_tso_check()
1946 hwdesc = &tx_ring->desc_head[producer]; in netxen_tso_check()
1947 tx_ring->cmd_buf_arr[producer].skb = NULL; in netxen_tso_check()
1955 producer = get_next_index(producer, tx_ring->num_desc); in netxen_tso_check()
[all …]
|
| /linux/include/linux/ |
| H A D | kvm_irqfd.h | 61 struct irq_bypass_producer *producer; member
|
| /linux/tools/include/uapi/linux/ |
| H A D | if_xdp.h | 60 __u64 producer; member
|
| /linux/include/uapi/linux/ |
| H A D | if_xdp.h | 60 __u64 producer; member
|
| /linux/Documentation/driver-api/ |
| H A D | sync_file.rst | 14 of attaching a fence to the buffer a producer driver (such as a GPU or V4L
21 producer part of the cycle.
|
| /linux/tools/testing/selftests/net/af_unix/ |
| H A D | test_unix_oob.c | |