| /include/drm/ |
| D | spsc_queue.h | 48 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 tail = (struct spsc_node **)atomic_long_xchg(&queue->tail, (long)&node->next); in spsc_queue_push()
[all …]
|
| D | drm_vblank.h | 99 wait_queue_head_t queue; member
|
| /include/linux/soc/ixp4xx/ |
| D | qmgr.h | 57 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/ |
| D | request_sock.h | 190 void reqsk_queue_alloc(struct request_sock_queue *queue);
195 static inline bool reqsk_queue_empty(const struct request_sock_queue *queue) in reqsk_queue_empty() argument
197 return READ_ONCE(queue->rskq_accept_head) == NULL; in reqsk_queue_empty()
200 static inline struct request_sock *reqsk_queue_remove(struct request_sock_queue *queue, in reqsk_queue_remove() argument
205 spin_lock_bh(&queue->rskq_lock); in reqsk_queue_remove()
206 req = queue->rskq_accept_head; in reqsk_queue_remove()
209 WRITE_ONCE(queue->rskq_accept_head, req->dl_next); in reqsk_queue_remove()
210 if (queue->rskq_accept_head == NULL) in reqsk_queue_remove()
211 queue->rskq_accept_tail = NULL; in reqsk_queue_remove()
213 spin_unlock_bh(&queue->rskq_lock); in reqsk_queue_remove()
[all …]
|
| D | netdev_rx_queue.h | 36 ssize_t (*show)(struct netdev_rx_queue *queue, char *buf);
37 ssize_t (*store)(struct netdev_rx_queue *queue,
49 get_netdev_rx_queue_index(struct netdev_rx_queue *queue) in get_netdev_rx_queue_index() argument
51 struct net_device *dev = queue->dev; in get_netdev_rx_queue_index()
52 int index = queue - dev->_rx; in get_netdev_rx_queue_index()
|
| D | fq_impl.h | 54 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()
|
| D | pkt_sched.h | 152 s32 queue; member
161 s32 queue; member
212 int queue; member
|
| D | fq.h | 34 struct sk_buff_head queue; member
|
| D | garp.h | 107 struct sk_buff_head queue; member
|
| /include/linux/iio/ |
| D | buffer-dma.h | 59 struct iio_dma_buffer_queue *queue; member
121 int (*submit)(struct iio_dma_buffer_queue *queue,
123 void (*abort)(struct iio_dma_buffer_queue *queue);
127 void iio_dma_buffer_block_list_abort(struct iio_dma_buffer_queue *queue,
141 int iio_dma_buffer_init(struct iio_dma_buffer_queue *queue,
143 void iio_dma_buffer_exit(struct iio_dma_buffer_queue *queue);
144 void iio_dma_buffer_release(struct iio_dma_buffer_queue *queue);
|
| /include/linux/ |
| D | ptr_ring.h | 40 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(size, gfp); in ptr_ring_init()
490 if (!r->queue) in ptr_ring_init()
[all …]
|
| D | if_eql.h | 45 slave_queue_t queue; member
|
| D | pps_kernel.h | 55 wait_queue_head_t queue; /* PPS event queue */ member
|
| D | watch_queue.h | 59 struct watch_queue __rcu *queue; /* Queue to post events to */ member
|
| /include/crypto/ |
| D | algapi.h | 171 void crypto_init_queue(struct crypto_queue *queue, unsigned int max_qlen);
172 int crypto_enqueue_request(struct crypto_queue *queue,
174 void crypto_enqueue_request_head(struct crypto_queue *queue,
176 struct crypto_async_request *crypto_dequeue_request(struct crypto_queue *queue);
177 static inline unsigned int crypto_queue_len(struct crypto_queue *queue) in crypto_queue_len() argument
179 return queue->qlen; in crypto_queue_len()
230 struct crypto_queue *queue) in crypto_get_backlog() argument
232 return queue->backlog == &queue->list ? NULL : in crypto_get_backlog()
233 container_of(queue->backlog, struct crypto_async_request, list); in crypto_get_backlog()
|
| /include/uapi/sound/ |
| D | asequencer.h | 237 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
497 int queue; /* queue id */ member
513 int queue; /* queue id */ member
525 int queue; /* sequencer queue */ member
541 int queue; /* sequencer queue */ member
554 int queue; /* sequencer queue */ member
[all …]
|
| /include/net/netfilter/ |
| D | nf_queue.h | 106 nfqueue_hash(const struct sk_buff *skb, u16 queue, u16 queues_total, u8 family, in nfqueue_hash() argument
111 queue += reciprocal_scale(hash_v4(ip_hdr(skb), initval), in nfqueue_hash()
115 queue += reciprocal_scale(hash_v6(ipv6_hdr(skb), initval), in nfqueue_hash()
119 queue += reciprocal_scale(hash_bridge(skb, initval), in nfqueue_hash()
124 return queue; in nfqueue_hash()
|
| /include/crypto/internal/ |
| D | engine.h | 57 struct crypto_queue queue; member
|
| D | hash.h | 226 static inline int ahash_enqueue_request(struct crypto_queue *queue, in ahash_enqueue_request() argument
229 return crypto_enqueue_request(queue, &request->base); in ahash_enqueue_request()
233 struct crypto_queue *queue) in ahash_dequeue_request() argument
235 return ahash_request_cast(crypto_dequeue_request(queue)); in ahash_dequeue_request()
|
| D | aead.h | 133 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/ |
| D | rdmavt_cq.h | 55 struct rvt_cq_wc *queue; member
|
| /include/linux/mfd/ |
| D | ipaq-micro.h | 118 struct list_head queue; member
|
| /include/sound/ |
| D | asequencer.h | 44 #define snd_seq_ev_is_direct(ev) ((ev)->queue == SNDRV_SEQ_QUEUE_DIRECT)
|
| /include/linux/dma/ |
| D | ipu-dma.h | 162 struct list_head queue; /* queued tx-descriptors */ member
|
| /include/media/ |
| D | dvb_ringbuffer.h | 48 wait_queue_head_t queue; member
|