Lines Matching refs:pq
1423 struct xfrm_policy_queue *pq = &old->polq; in xfrm_policy_requeue() local
1426 if (skb_queue_empty(&pq->hold_queue)) in xfrm_policy_requeue()
1431 spin_lock_bh(&pq->hold_queue.lock); in xfrm_policy_requeue()
1432 skb_queue_splice_init(&pq->hold_queue, &list); in xfrm_policy_requeue()
1433 if (del_timer(&pq->hold_timer)) in xfrm_policy_requeue()
1435 spin_unlock_bh(&pq->hold_queue.lock); in xfrm_policy_requeue()
1437 pq = &new->polq; in xfrm_policy_requeue()
1439 spin_lock_bh(&pq->hold_queue.lock); in xfrm_policy_requeue()
1440 skb_queue_splice(&list, &pq->hold_queue); in xfrm_policy_requeue()
1441 pq->timeout = XFRM_QUEUE_TMO_MIN; in xfrm_policy_requeue()
1442 if (!mod_timer(&pq->hold_timer, jiffies)) in xfrm_policy_requeue()
1444 spin_unlock_bh(&pq->hold_queue.lock); in xfrm_policy_requeue()
2765 struct xfrm_policy_queue *pq = &pol->polq; in xfrm_policy_queue_process() local
2770 spin_lock(&pq->hold_queue.lock); in xfrm_policy_queue_process()
2771 skb = skb_peek(&pq->hold_queue); in xfrm_policy_queue_process()
2773 spin_unlock(&pq->hold_queue.lock); in xfrm_policy_queue_process()
2784 spin_unlock(&pq->hold_queue.lock); in xfrm_policy_queue_process()
2794 if (pq->timeout >= XFRM_QUEUE_TMO_MAX) in xfrm_policy_queue_process()
2797 pq->timeout = pq->timeout << 1; in xfrm_policy_queue_process()
2798 if (!mod_timer(&pq->hold_timer, jiffies + pq->timeout)) in xfrm_policy_queue_process()
2807 spin_lock(&pq->hold_queue.lock); in xfrm_policy_queue_process()
2808 pq->timeout = 0; in xfrm_policy_queue_process()
2809 skb_queue_splice_init(&pq->hold_queue, &list); in xfrm_policy_queue_process()
2810 spin_unlock(&pq->hold_queue.lock); in xfrm_policy_queue_process()
2840 pq->timeout = 0; in xfrm_policy_queue_process()
2841 skb_queue_purge(&pq->hold_queue); in xfrm_policy_queue_process()
2851 struct xfrm_policy_queue *pq = &pol->polq; in xdst_queue_output() local
2858 if (pq->hold_queue.qlen > XFRM_MAX_QUEUE_LEN) { in xdst_queue_output()
2865 spin_lock_bh(&pq->hold_queue.lock); in xdst_queue_output()
2867 if (!pq->timeout) in xdst_queue_output()
2868 pq->timeout = XFRM_QUEUE_TMO_MIN; in xdst_queue_output()
2870 sched_next = jiffies + pq->timeout; in xdst_queue_output()
2872 if (del_timer(&pq->hold_timer)) { in xdst_queue_output()
2873 if (time_before(pq->hold_timer.expires, sched_next)) in xdst_queue_output()
2874 sched_next = pq->hold_timer.expires; in xdst_queue_output()
2878 __skb_queue_tail(&pq->hold_queue, skb); in xdst_queue_output()
2879 if (!mod_timer(&pq->hold_timer, sched_next)) in xdst_queue_output()
2882 spin_unlock_bh(&pq->hold_queue.lock); in xdst_queue_output()