net/classq/classq_sfb.c

186 static struct zone *sfb_zone;		/* zone for sfb */
189 static u_int32_t sfb_random(struct sfb *);
190 static struct mbuf *sfb_getq_flow(struct sfb *, class_queue_t *, u_int32_t,
192 static void sfb_resetq(struct sfb *, cqev_t);
193 static void sfb_calc_holdtime(struct sfb *, u_int64_t);
194 static void sfb_calc_pboxtime(struct sfb *, u_int64_t);
195 static void sfb_calc_hinterval(struct sfb *, u_int64_t *);
196 static void sfb_swap_bins(struct sfb *, u_int32_t);
197 static inline int sfb_pcheck(struct sfb *, struct pf_mtag *);
198 static int sfb_penalize(struct sfb *, struct pf_mtag *, struct timespec *);
199 static void sfb_adjust_bin(struct sfb *, struct sfbbinstats *,
201 static void sfb_decrement_bin(struct sfb *, struct sfbbinstats *,
203 static void sfb_increment_bin(struct sfb *, struct sfbbinstats *,
205 static inline void sfb_dq_update_bins(struct sfb *, struct pf_mtag *,
207 static inline void sfb_eq_update_bins(struct sfb *, struct pf_mtag *);
208 static int sfb_drop_early(struct sfb *, struct pf_mtag *, u_int16_t *,
210 static boolean_t sfb_bin_addfcentry(struct sfb *, struct pf_mtag *);
211 static void sfb_fclist_append(struct sfb *, struct sfb_fc_list *);
212 static void sfb_fclists_clean(struct sfb *sp);
214 SYSCTL_NODE(_net_classq, OID_AUTO, sfb, CTLFLAG_RW|CTLFLAG_LOCKED, 0, "SFB");
269 	sfb_size = sizeof (struct sfb);
281 sfb_random(struct sfb *sp)
288 sfb_calc_holdtime(struct sfb *sp, u_int64_t outbw)
311 sfb_calc_pboxtime(struct sfb *sp, u_int64_t outbw)
335 sfb_calc_hinterval(struct sfb *sp, u_int64_t *t)
359  * sfb support routines
361 struct sfb *
364 	struct sfb *sp;
401 sfb_fclist_append(struct sfb *sp, struct sfb_fc_list *fcl)
408 sfb_fclists_clean(struct sfb *sp)
421 sfb_destroy(struct sfb *sp)
436 sfb_resetq(struct sfb *sp, cqev_t ev)
483 sfb_getstats(struct sfb *sp, struct sfb_stats *sps)
505 sfb_swap_bins(struct sfb *sp, u_int32_t len)
560 sfb_pcheck(struct sfb *sp, struct pf_mtag *t)
599 sfb_penalize(struct sfb *sp, struct pf_mtag *t, struct timespec *now)
658 sfb_adjust_bin(struct sfb *sp, struct sfbbinstats *bin, struct timespec *ft,
683 sfb_decrement_bin(struct sfb *sp, struct sfbbinstats *bin, struct timespec *ft,
690 sfb_increment_bin(struct sfb *sp, struct sfbbinstats *bin, struct timespec *ft,
697 sfb_dq_update_bins(struct sfb *sp, struct pf_mtag *t, struct timespec *now)
762 sfb_eq_update_bins(struct sfb *sp, struct pf_mtag *t)
794 sfb_bin_addfcentry(struct sfb *sp, struct pf_mtag *t)
838 sfb_drop_early(struct sfb *sp, struct pf_mtag *t, u_int16_t *pmin,
910 sfb_addq(struct sfb *sp, class_queue_t *q, struct mbuf *m, struct pf_mtag *t)
942 		/* flow control, mark or drop by sfb */
960 			/* unforced drop by sfb */
1012 sfb_getq_flow(struct sfb *sp, class_queue_t *q, u_int32_t flow, boolean_t purge)
1085 sfb_getq(struct sfb *sp, class_queue_t *q)
1091 sfb_purgeq(struct sfb *sp, class_queue_t *q, u_int32_t flow, u_int32_t *packets,
1112 sfb_updateq(struct sfb *sp, cqev_t ev)
1153 sfb_suspendq(struct sfb *sp, class_queue_t *q, boolean_t on)