Home
last modified time | relevance | path

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

123

/include/drm/
Dspsc_queue.h48 static inline void spsc_queue_init(struct spsc_queue *queue) in spsc_queue_init() argument
50 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()
55 static inline struct spsc_node *spsc_queue_peek(struct spsc_queue *queue) in spsc_queue_peek() argument
57 return queue->head; in spsc_queue_peek()
60 static inline int spsc_queue_count(struct spsc_queue *queue) in spsc_queue_count() argument
62 return atomic_read(&queue->job_count); in spsc_queue_count()
65 static inline bool spsc_queue_push(struct spsc_queue *queue, struct spsc_node *node) in spsc_queue_push() argument
73 atomic_inc(&queue->job_count); in spsc_queue_push()
[all …]
/include/linux/soc/ixp4xx/
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/
Drequest_sock.h204 void reqsk_queue_alloc(struct request_sock_queue *queue);
209 static inline bool reqsk_queue_empty(const struct request_sock_queue *queue) in reqsk_queue_empty() argument
211 return READ_ONCE(queue->rskq_accept_head) == NULL; in reqsk_queue_empty()
214 static inline struct request_sock *reqsk_queue_remove(struct request_sock_queue *queue, in reqsk_queue_remove() argument
219 spin_lock_bh(&queue->rskq_lock); in reqsk_queue_remove()
220 req = queue->rskq_accept_head; in reqsk_queue_remove()
223 WRITE_ONCE(queue->rskq_accept_head, req->dl_next); in reqsk_queue_remove()
224 if (queue->rskq_accept_head == NULL) in reqsk_queue_remove()
225 queue->rskq_accept_tail = NULL; in reqsk_queue_remove()
227 spin_unlock_bh(&queue->rskq_lock); in reqsk_queue_remove()
[all …]
Dnetdev_rx_queue.h42 ssize_t (*show)(struct netdev_rx_queue *queue, char *buf);
43 ssize_t (*store)(struct netdev_rx_queue *queue,
54 get_netdev_rx_queue_index(struct netdev_rx_queue *queue) in get_netdev_rx_queue_index() argument
56 struct net_device *dev = queue->dev; in get_netdev_rx_queue_index()
57 int index = queue - dev->_rx; in get_netdev_rx_queue_index()
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()
Dpkt_sched.h154 s32 queue; member
163 s32 queue; member
214 int queue; member
Dfq.h34 struct sk_buff_head queue; member
Dgarp.h107 struct sk_buff_head queue; member
/include/linux/iio/
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/crypto/
Dalgapi.h168 void crypto_init_queue(struct crypto_queue *queue, unsigned int max_qlen);
169 int crypto_enqueue_request(struct crypto_queue *queue,
171 void crypto_enqueue_request_head(struct crypto_queue *queue,
173 struct crypto_async_request *crypto_dequeue_request(struct crypto_queue *queue);
174 static inline unsigned int crypto_queue_len(struct crypto_queue *queue) in crypto_queue_len() argument
176 return queue->qlen; in crypto_queue_len()
222 struct crypto_queue *queue) in crypto_get_backlog() argument
224 return queue->backlog == &queue->list ? NULL : in crypto_get_backlog()
225 container_of(queue->backlog, struct crypto_async_request, list); in crypto_get_backlog()
/include/linux/
Dptr_ring.h40 void **queue; member
51 return r->queue[r->producer]; in __ptr_ring_full()
106 if (unlikely(!r->size) || r->queue[r->producer]) in __ptr_ring_produce()
113 WRITE_ONCE(r->queue[r->producer++], ptr); in __ptr_ring_produce()
172 return READ_ONCE(r->queue[r->consumer_head]); in __ptr_ring_peek()
197 return !r->queue[READ_ONCE(r->consumer_head)]; in __ptr_ring_empty()
280 r->queue[head--] = NULL; in __ptr_ring_discard_one()
477 r->batch = SMP_CACHE_BYTES * 2 / sizeof(*(r->queue)); in __ptr_ring_set_size()
489 r->queue = __ptr_ring_init_queue_alloc_noprof(size, gfp); in ptr_ring_init_noprof()
490 if (!r->queue) in ptr_ring_init_noprof()
[all …]
Dblk-integrity.h24 return queue_limits_stack_integrity(t, &bdev->bd_disk->queue->limits); in queue_limits_stack_integrity_bdev()
41 if (!blk_integrity_queue_supports_integrity(disk->queue)) in blk_get_integrity()
43 return &disk->queue->limits.integrity; in blk_get_integrity()
Dif_eql.h45 slave_queue_t queue; member
Dpps_kernel.h55 wait_queue_head_t queue; /* PPS event queue */ member
Diommu.h739 struct iopf_queue *queue; member
1595 int iopf_queue_add_device(struct iopf_queue *queue, struct device *dev);
1596 void iopf_queue_remove_device(struct iopf_queue *queue, struct device *dev);
1599 void iopf_queue_free(struct iopf_queue *queue);
1600 int iopf_queue_discard_partial(struct iopf_queue *queue);
1607 iopf_queue_add_device(struct iopf_queue *queue, struct device *dev) in iopf_queue_add_device() argument
1613 iopf_queue_remove_device(struct iopf_queue *queue, struct device *dev) in iopf_queue_remove_device() argument
1627 static inline void iopf_queue_free(struct iopf_queue *queue) in iopf_queue_free() argument
1631 static inline int iopf_queue_discard_partial(struct iopf_queue *queue) in iopf_queue_discard_partial() argument
Dwatch_queue.h59 struct watch_queue __rcu *queue; /* Queue to post events to */ member
/include/uapi/sound/
Dasequencer.h237 unsigned char queue; /* affected queue */ member
262 struct snd_seq_ev_queue_control queue; member
276 unsigned char queue; /* schedule queue */ member
290 unsigned char queue; /* schedule queue */ member
407 unsigned char queue; /* Queue for REMOVE_DEST */ member
499 int queue; /* queue id */ member
515 int queue; /* queue id */ member
527 int queue; /* sequencer queue */ member
544 int queue; /* sequencer queue */ member
557 int queue; /* sequencer queue */ member
[all …]
/include/net/netfilter/
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/
Dhash.h222 static inline int ahash_enqueue_request(struct crypto_queue *queue, in ahash_enqueue_request() argument
225 return crypto_enqueue_request(queue, &request->base); in ahash_enqueue_request()
229 struct crypto_queue *queue) in ahash_dequeue_request() argument
231 return ahash_request_cast(crypto_dequeue_request(queue)); in ahash_dequeue_request()
Dengine.h57 struct crypto_queue queue; member
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()
/include/rdma/
Drdmavt_cq.h55 struct rvt_cq_wc *queue; member
/include/linux/mfd/
Dipaq-micro.h118 struct list_head queue; member
/include/sound/
Dasequencer.h44 #define snd_seq_ev_is_direct(ev) ((ev)->queue == SNDRV_SEQ_QUEUE_DIRECT)
/include/media/
Ddvb_ringbuffer.h48 wait_queue_head_t queue; member

123