Lines Matching refs:queue
200 void reqsk_queue_alloc(struct request_sock_queue *queue);
205 static inline bool reqsk_queue_empty(const struct request_sock_queue *queue) in reqsk_queue_empty() argument
207 return READ_ONCE(queue->rskq_accept_head) == NULL; in reqsk_queue_empty()
210 static inline struct request_sock *reqsk_queue_remove(struct request_sock_queue *queue, in reqsk_queue_remove() argument
215 spin_lock_bh(&queue->rskq_lock); in reqsk_queue_remove()
216 req = queue->rskq_accept_head; in reqsk_queue_remove()
219 WRITE_ONCE(queue->rskq_accept_head, req->dl_next); 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()
227 static inline void reqsk_queue_removed(struct request_sock_queue *queue, in reqsk_queue_removed() argument
231 atomic_dec(&queue->young); in reqsk_queue_removed()
232 atomic_dec(&queue->qlen); in reqsk_queue_removed()
235 static inline void reqsk_queue_added(struct request_sock_queue *queue) in reqsk_queue_added() argument
237 atomic_inc(&queue->young); in reqsk_queue_added()
238 atomic_inc(&queue->qlen); in reqsk_queue_added()
241 static inline int reqsk_queue_len(const struct request_sock_queue *queue) in reqsk_queue_len() argument
243 return atomic_read(&queue->qlen); in reqsk_queue_len()
246 static inline int reqsk_queue_len_young(const struct request_sock_queue *queue) in reqsk_queue_len_young() argument
248 return atomic_read(&queue->young); in reqsk_queue_len_young()