Home
last modified time | relevance | path

Searched refs:queue (Results 1 – 25 of 61) sorted by relevance

123

/include/drm/
A Dspsc_queue.h50 queue->head = NULL; in spsc_queue_init()
51 atomic_long_set(&queue->tail, (long)&queue->head); in spsc_queue_init()
52 atomic_set(&queue->job_count, 0); in spsc_queue_init()
57 return queue->head; in spsc_queue_peek()
62 return atomic_read(&queue->job_count); in spsc_queue_count()
73 atomic_inc(&queue->job_count); in spsc_queue_push()
87 return tail == &queue->head; in spsc_queue_push()
98 node = READ_ONCE(queue->head); in spsc_queue_pop()
104 WRITE_ONCE(queue->head, next); in spsc_queue_pop()
109 if (atomic_long_cmpxchg(&queue->tail, in spsc_queue_pop()
[all …]
/include/linux/soc/ixp4xx/
A Dqmgr.h57 void qmgr_put_entry(unsigned int queue, u32 val);
58 u32 qmgr_get_entry(unsigned int queue);
59 int qmgr_stat_empty(unsigned int queue);
60 int qmgr_stat_below_low_watermark(unsigned int queue);
61 int qmgr_stat_full(unsigned int queue);
62 int qmgr_stat_overflow(unsigned int queue);
63 void qmgr_release_queue(unsigned int queue);
64 void qmgr_set_irq(unsigned int queue, int src,
66 void qmgr_enable_irq(unsigned int queue);
67 void qmgr_disable_irq(unsigned int queue);
[all …]
/include/net/
A Drequest_sock.h215 spin_lock_bh(&queue->rskq_lock); in reqsk_queue_remove()
216 req = queue->rskq_accept_head; in reqsk_queue_remove()
220 if (queue->rskq_accept_head == NULL) in reqsk_queue_remove()
221 queue->rskq_accept_tail = NULL; in reqsk_queue_remove()
223 spin_unlock_bh(&queue->rskq_lock); in reqsk_queue_remove()
231 atomic_dec(&queue->young); in reqsk_queue_removed()
232 atomic_dec(&queue->qlen); in reqsk_queue_removed()
237 atomic_inc(&queue->young); in reqsk_queue_added()
238 atomic_inc(&queue->qlen); in reqsk_queue_added()
243 return atomic_read(&queue->qlen); in reqsk_queue_len()
[all …]
A Dnetdev_rx_queue.h38 ssize_t (*show)(struct netdev_rx_queue *queue, char *buf);
39 ssize_t (*store)(struct netdev_rx_queue *queue,
50 get_netdev_rx_queue_index(struct netdev_rx_queue *queue) in get_netdev_rx_queue_index() argument
52 struct net_device *dev = queue->dev; in get_netdev_rx_queue_index()
53 int index = queue - dev->_rx; in get_netdev_rx_queue_index()
A Dfq_impl.h54 skb = __skb_dequeue(&flow->queue); in fq_flow_dequeue()
73 pending = min_t(int, 32, skb_queue_len(&flow->queue) / 2); in fq_flow_drop()
75 skb = __skb_dequeue(&flow->queue); in fq_flow_drop()
225 __skb_queue_tail(&flow->queue, skb); in fq_tin_enqueue()
263 skb_queue_walk_safe(&flow->queue, skb, tmp) { in fq_flow_filter()
267 __skb_unlink(skb, &flow->queue); in fq_flow_filter()
338 __skb_queue_head_init(&flow->queue); in fq_flow_init()
A Dfq.h34 struct sk_buff_head queue; member
A Dpkt_sched.h153 s32 queue; member
162 s32 queue; member
213 int queue; member
A Dgarp.h107 struct sk_buff_head queue; member
/include/linux/iio/
A Dbuffer-dma.h65 struct iio_dma_buffer_queue *queue; member
138 int (*submit)(struct iio_dma_buffer_queue *queue,
140 void (*abort)(struct iio_dma_buffer_queue *queue);
144 void iio_dma_buffer_block_list_abort(struct iio_dma_buffer_queue *queue,
160 int iio_dma_buffer_init(struct iio_dma_buffer_queue *queue,
162 void iio_dma_buffer_exit(struct iio_dma_buffer_queue *queue);
163 void iio_dma_buffer_release(struct iio_dma_buffer_queue *queue);
/include/linux/
A Dptr_ring.h40 void **queue; member
51 return r->queue[r->producer]; in __ptr_ring_full()
280 r->queue[head--] = NULL; in __ptr_ring_discard_one()
490 if (!r->queue) in ptr_ring_init_noprof()
530 r->queue[head--] = NULL; in ptr_ring_unconsume()
541 if (r->queue[head]) { in ptr_ring_unconsume()
569 queue[producer++] = ptr; in __ptr_ring_swap_queue()
579 old = r->queue; in __ptr_ring_swap_queue()
580 r->queue = queue; in __ptr_ring_swap_queue()
598 if (!queue) in ptr_ring_resize_noprof()
[all …]
A Dblk-integrity.h24 return queue_limits_stack_integrity(t, &bdev->bd_disk->queue->limits); in queue_limits_stack_integrity_bdev()
43 if (!blk_integrity_queue_supports_integrity(disk->queue)) in blk_get_integrity()
45 return &disk->queue->limits.integrity; in blk_get_integrity()
A Dif_eql.h45 slave_queue_t queue; member
A Dpps_gen_kernel.h53 wait_queue_head_t queue; /* PPS event queue */ member
A Dpps_kernel.h56 wait_queue_head_t queue; /* PPS event queue */ member
A Diommu.h821 struct iopf_queue *queue; member
1645 int iopf_queue_add_device(struct iopf_queue *queue, struct device *dev);
1646 void iopf_queue_remove_device(struct iopf_queue *queue, struct device *dev);
1649 void iopf_queue_free(struct iopf_queue *queue);
1650 int iopf_queue_discard_partial(struct iopf_queue *queue);
1657 iopf_queue_add_device(struct iopf_queue *queue, struct device *dev) in iopf_queue_add_device() argument
1663 iopf_queue_remove_device(struct iopf_queue *queue, struct device *dev) in iopf_queue_remove_device() argument
1677 static inline void iopf_queue_free(struct iopf_queue *queue) in iopf_queue_free() argument
1681 static inline int iopf_queue_discard_partial(struct iopf_queue *queue) in iopf_queue_discard_partial() argument
/include/crypto/
A Dalgapi.h160 void crypto_init_queue(struct crypto_queue *queue, unsigned int max_qlen);
161 int crypto_enqueue_request(struct crypto_queue *queue,
163 void crypto_enqueue_request_head(struct crypto_queue *queue,
165 struct crypto_async_request *crypto_dequeue_request(struct crypto_queue *queue);
166 static inline unsigned int crypto_queue_len(struct crypto_queue *queue) in crypto_queue_len() argument
168 return queue->qlen; in crypto_queue_len()
214 struct crypto_queue *queue) in crypto_get_backlog() argument
216 return queue->backlog == &queue->list ? NULL : in crypto_get_backlog()
217 container_of(queue->backlog, struct crypto_async_request, list); in crypto_get_backlog()
/include/uapi/sound/
A Dasequencer.h240 unsigned char queue; /* affected queue */ member
271 struct snd_seq_ev_queue_control queue; member
286 unsigned char queue; /* schedule queue */ member
300 unsigned char queue; /* schedule queue */ member
417 unsigned char queue; /* Queue for REMOVE_DEST */ member
509 int queue; /* queue id */ member
525 int queue; /* queue id */ member
537 int queue; /* sequencer queue */ member
554 int queue; /* sequencer queue */ member
567 int queue; /* sequencer queue */ member
[all …]
/include/net/netfilter/
A Dnf_queue.h105 nfqueue_hash(const struct sk_buff *skb, u16 queue, u16 queues_total, u8 family, in nfqueue_hash() argument
110 queue += reciprocal_scale(hash_v4(ip_hdr(skb), initval), in nfqueue_hash()
114 queue += reciprocal_scale(hash_v6(ipv6_hdr(skb), initval), in nfqueue_hash()
118 queue += reciprocal_scale(hash_bridge(skb, initval), in nfqueue_hash()
123 return queue; in nfqueue_hash()
/include/crypto/internal/
A Dengine.h48 struct crypto_queue queue; member
A Daead.h133 static inline void aead_init_queue(struct aead_queue *queue, in aead_init_queue() argument
136 crypto_init_queue(&queue->base, max_qlen); in aead_init_queue()
A Dhash.h262 static inline int ahash_enqueue_request(struct crypto_queue *queue, in ahash_enqueue_request() argument
265 return crypto_enqueue_request(queue, &request->base); in ahash_enqueue_request()
269 struct crypto_queue *queue) in ahash_dequeue_request() argument
271 return ahash_request_cast(crypto_dequeue_request(queue)); in ahash_dequeue_request()
/include/rdma/
A Drdmavt_cq.h55 struct rvt_cq_wc *queue; member
/include/linux/mfd/
A Dipaq-micro.h118 struct list_head queue; member
/include/sound/
A Dasequencer.h44 #define snd_seq_ev_is_direct(ev) ((ev)->queue == SNDRV_SEQ_QUEUE_DIRECT)
/include/media/
A Ddvb_ringbuffer.h48 wait_queue_head_t queue; member

Completed in 41 milliseconds

123