Lines Matching refs:bucket

114 ipq_timeout(struct ipqbucket *bucket, struct ipq *fp)  in ipq_timeout()  argument
118 ipq_free(bucket, fp); in ipq_timeout()
122 ipq_drop(struct ipqbucket *bucket, struct ipq *fp) in ipq_drop() argument
126 ipq_free(bucket, fp); in ipq_drop()
127 ipreass_reschedule(bucket); in ipq_drop()
591 struct ipqbucket *bucket = arg; in ipreass_callout() local
594 IPQ_BUCKET_LOCK_ASSERT(bucket); in ipreass_callout()
597 CURVNET_SET(bucket->vnet); in ipreass_callout()
598 fp = TAILQ_LAST(&bucket->head, ipqhead); in ipreass_callout()
600 ("%s: stray callout on bucket %p, %ju < %ju", __func__, bucket, in ipreass_callout()
604 ipq_timeout(bucket, fp); in ipreass_callout()
605 fp = TAILQ_LAST(&bucket->head, ipqhead); in ipreass_callout()
607 ipreass_reschedule(bucket); in ipreass_callout()
612 ipreass_reschedule(struct ipqbucket *bucket) in ipreass_reschedule() argument
616 IPQ_BUCKET_LOCK_ASSERT(bucket); in ipreass_reschedule()
618 if ((fp = TAILQ_LAST(&bucket->head, ipqhead)) != NULL) { in ipreass_reschedule()
624 callout_reset_sbt(&bucket->timer, SBT_1S * t, SBT_1S, in ipreass_reschedule()
625 ipreass_callout, bucket, 0); in ipreass_reschedule()
627 callout_stop(&bucket->timer); in ipreass_reschedule()
894 int bucket, i; in ipq_reuse() local
899 bucket = (start + i) % V_ipq_hashsize; in ipq_reuse()
900 if (bucket != start && IPQ_TRYLOCK(bucket) == 0) in ipq_reuse()
902 fp = TAILQ_LAST(&V_ipq[bucket].head, ipqhead); in ipq_reuse()
913 TAILQ_REMOVE(&V_ipq[bucket].head, fp, ipq_list); in ipq_reuse()
914 V_ipq[bucket].count--; in ipq_reuse()
915 ipreass_reschedule(&V_ipq[bucket]); in ipq_reuse()
916 if (bucket != start) in ipq_reuse()
917 IPQ_UNLOCK(bucket); in ipq_reuse()
920 if (bucket != start) in ipq_reuse()
921 IPQ_UNLOCK(bucket); in ipq_reuse()
931 ipq_free(struct ipqbucket *bucket, struct ipq *fp) in ipq_free() argument
941 TAILQ_REMOVE(&bucket->head, fp, ipq_list); in ipq_free()
942 bucket->count--; in ipq_free()