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 tail = (struct spsc_node **)atomic_long_xchg(&queue->tail, (long)&node->next); in spsc_queue_push()
[all …]
Ddrm_os_linux.h33 #define DRM_WAIT_ON( ret, queue, timeout, condition ) \ argument
37 add_wait_queue(&(queue), &entry); \
54 remove_wait_queue(&(queue), &entry); \
Ddrm_vblank.h97 wait_queue_head_t queue; member
/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.h181 void reqsk_queue_alloc(struct request_sock_queue *queue);
186 static inline bool reqsk_queue_empty(const struct request_sock_queue *queue) in reqsk_queue_empty() argument
188 return READ_ONCE(queue->rskq_accept_head) == NULL; in reqsk_queue_empty()
191 static inline struct request_sock *reqsk_queue_remove(struct request_sock_queue *queue, in reqsk_queue_remove() argument
196 spin_lock_bh(&queue->rskq_lock); in reqsk_queue_remove()
197 req = queue->rskq_accept_head; in reqsk_queue_remove()
200 WRITE_ONCE(queue->rskq_accept_head, req->dl_next); in reqsk_queue_remove()
201 if (queue->rskq_accept_head == NULL) in reqsk_queue_remove()
202 queue->rskq_accept_tail = NULL; in reqsk_queue_remove()
204 spin_unlock_bh(&queue->rskq_lock); in reqsk_queue_remove()
[all …]
Dfq_impl.h52 skb = __skb_dequeue(&flow->queue); in fq_flow_dequeue()
184 __skb_queue_tail(&flow->queue, skb); in fq_tin_enqueue()
219 skb_queue_walk_safe(&flow->queue, skb, tmp) { in fq_flow_filter()
223 __skb_unlink(skb, &flow->queue); in fq_flow_filter()
294 __skb_queue_head_init(&flow->queue); in fq_flow_init()
Dfq.h33 struct sk_buff_head queue; member
Dpkt_sched.h157 s32 queue; member
166 s32 queue; member
Dgarp.h105 struct sk_buff_head queue; member
/include/linux/iio/
Dbuffer-dma.h64 struct iio_dma_buffer_queue *queue; member
126 int (*submit)(struct iio_dma_buffer_queue *queue,
128 void (*abort)(struct iio_dma_buffer_queue *queue);
132 void iio_dma_buffer_block_list_abort(struct iio_dma_buffer_queue *queue,
146 int iio_dma_buffer_init(struct iio_dma_buffer_queue *queue,
148 void iio_dma_buffer_exit(struct iio_dma_buffer_queue *queue);
149 void iio_dma_buffer_release(struct iio_dma_buffer_queue *queue);
/include/crypto/internal/
Daead.h126 static inline void aead_init_queue(struct aead_queue *queue, in aead_init_queue() argument
129 crypto_init_queue(&queue->base, max_qlen); in aead_init_queue()
132 static inline int aead_enqueue_request(struct aead_queue *queue, in aead_enqueue_request() argument
135 return crypto_enqueue_request(&queue->base, &request->base); in aead_enqueue_request()
139 struct aead_queue *queue) in aead_dequeue_request() argument
143 req = crypto_dequeue_request(&queue->base); in aead_dequeue_request()
148 static inline struct aead_request *aead_get_backlog(struct aead_queue *queue) in aead_get_backlog() argument
152 req = crypto_get_backlog(&queue->base); in aead_get_backlog()
Dhash.h187 static inline int ahash_enqueue_request(struct crypto_queue *queue, in ahash_enqueue_request() argument
190 return crypto_enqueue_request(queue, &request->base); in ahash_enqueue_request()
194 struct crypto_queue *queue) in ahash_dequeue_request() argument
196 return ahash_request_cast(crypto_dequeue_request(queue)); in ahash_dequeue_request()
/include/linux/
Dptr_ring.h39 void **queue; member
50 return r->queue[r->producer]; in __ptr_ring_full()
105 if (unlikely(!r->size) || r->queue[r->producer]) in __ptr_ring_produce()
112 WRITE_ONCE(r->queue[r->producer++], ptr); in __ptr_ring_produce()
171 return READ_ONCE(r->queue[r->consumer_head]); in __ptr_ring_peek()
196 return !r->queue[READ_ONCE(r->consumer_head)]; in __ptr_ring_empty()
279 r->queue[head--] = NULL; in __ptr_ring_discard_one()
476 r->batch = SMP_CACHE_BYTES * 2 / sizeof(*(r->queue)); in __ptr_ring_set_size()
488 r->queue = __ptr_ring_init_queue_alloc(size, gfp); in ptr_ring_init()
489 if (!r->queue) in ptr_ring_init()
[all …]
Dif_eql.h43 slave_queue_t queue; member
Dvisorbus.h334 int visorchannel_signalremove(struct visorchannel *channel, u32 queue,
336 int visorchannel_signalinsert(struct visorchannel *channel, u32 queue,
338 bool visorchannel_signalempty(struct visorchannel *channel, u32 queue);
Dbsg.h21 struct request_queue *queue; member
Dpps_kernel.h55 wait_queue_head_t queue; /* PPS event queue */ member
/include/uapi/sound/
Dasequencer.h252 unsigned char queue; /* affected queue */ member
278 unsigned char queue; /* schedule queue */ member
291 struct snd_seq_ev_queue_control queue; member
397 unsigned char queue; /* Queue for REMOVE_DEST */ member
476 int queue; /* queue id */ member
492 int queue; /* queue id */ member
504 int queue; /* sequencer queue */ member
520 int queue; /* sequencer queue */ member
533 int queue; /* sequencer queue */ member
551 unsigned char queue; /* input time-stamp queue (optional) */ member
[all …]
/include/crypto/
Dalgapi.h188 void crypto_init_queue(struct crypto_queue *queue, unsigned int max_qlen);
189 int crypto_enqueue_request(struct crypto_queue *queue,
191 struct crypto_async_request *crypto_dequeue_request(struct crypto_queue *queue);
192 static inline unsigned int crypto_queue_len(struct crypto_queue *queue) in crypto_queue_len() argument
194 return queue->qlen; in crypto_queue_len()
350 struct crypto_queue *queue) in crypto_get_backlog() argument
352 return queue->backlog == &queue->list ? NULL : in crypto_get_backlog()
353 container_of(queue->backlog, struct crypto_async_request, list); in crypto_get_backlog()
356 static inline int ablkcipher_enqueue_request(struct crypto_queue *queue, in ablkcipher_enqueue_request() argument
359 return crypto_enqueue_request(queue, &request->base); in ablkcipher_enqueue_request()
[all …]
Dengine.h52 struct crypto_queue queue; member
/include/net/netfilter/
Dnf_queue.h103 nfqueue_hash(const struct sk_buff *skb, u16 queue, u16 queues_total, u8 family, in nfqueue_hash() argument
108 queue += reciprocal_scale(hash_v4(ip_hdr(skb), initval), in nfqueue_hash()
112 queue += reciprocal_scale(hash_v6(ipv6_hdr(skb), initval), in nfqueue_hash()
116 queue += reciprocal_scale(hash_bridge(skb, initval), in nfqueue_hash()
121 return queue; in nfqueue_hash()
/include/rdma/
Drdmavt_cq.h100 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/linux/dma/
Dipu-dma.h162 struct list_head queue; /* queued tx-descriptors */ member

123