Lines Matching refs:queue
204 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()
231 static inline void reqsk_queue_removed(struct request_sock_queue *queue, in reqsk_queue_removed() argument
235 atomic_dec(&queue->young); in reqsk_queue_removed()
236 atomic_dec(&queue->qlen); in reqsk_queue_removed()
239 static inline void reqsk_queue_added(struct request_sock_queue *queue) in reqsk_queue_added() argument
241 atomic_inc(&queue->young); in reqsk_queue_added()
242 atomic_inc(&queue->qlen); in reqsk_queue_added()
245 static inline int reqsk_queue_len(const struct request_sock_queue *queue) in reqsk_queue_len() argument
247 return atomic_read(&queue->qlen); in reqsk_queue_len()
250 static inline int reqsk_queue_len_young(const struct request_sock_queue *queue) in reqsk_queue_len_young() argument
252 return atomic_read(&queue->young); in reqsk_queue_len_young()