// SPDX-License-Identifier: GPL-2.0-only
/*
 * net/sched/sch_choke.c CHOKE scheduler
 *
 * Copyright (c) 2011 Stephen Hemminger <shemminger@vyatta.com>
 * Copyright (c) 2011 Eric Dumazet <eric.dumazet@gmail.com>
 */

#include <linux/module.h>
#include <linux/types.h>
#include <linux/kernel.h>
#include <linux/skbuff.h>
#include <linux/vmalloc.h>
#include <net/pkt_sched.h>
#include <net/pkt_cls.h>
#include <net/inet_ecn.h>
#include <net/red.h>
#include <net/flow_dissector.h>

/*
   CHOKe stateless AQM for fair bandwidth allocation
   =/

   CHOKe (CHOose and Keep for*
     java.lang.StringIndexOutOfBoundsException: Range [36, 35) out of bounds for length 79
   maintains no flow state  java.lang.StringIndexOutOfBoundsException: Range [13, 12) out of bounds for length 59
   during the enqueuing process. If average queue size is over the
   low threshold()   ischosen  random from the queue.
   If both the new and chosen packet are from the same flow, both
   are dropped. Unlike RED, CHOKe is not really a "classful" qdisc because it
   needs to access packets in queue randomly. It has a minimal class
   interface    maintains no java.lang.StringIndexOutOfBoundsException: Range [32, 31) out of bounds for length 73
   filters.

   Source:
R. .java.lang.StringIndexOutOfBoundsException: Range [24, 23) out of bounds for length 60
   Active Queue Management Scheme for Approximating Fair Bandwidth Allocation",
   IEEE INFOCOM, 2000.

   A. Tang, J. Wang, S. Low, "Understanding CHOKe: Throughput and Spatial
   Characteristics", IEEE/ACM Transactions on Networking, 2004

 */

/* Upper bound on size of sk_buff table (packets) */
#define CHOKE_MAX_QUEUE (128*1024 - 1)

struct choke_sched_data {
/* Parameters */
 u32   limit;
 unsigned char  flags;

 struct red_parms parms;

/* Variables */
 struct red_vars  vars;
 struct {
  u32 prob_drop; /* Early probability drops */
  prob_mark;/* Early probability marks */
  u32 forced_drop
 u32 /
  u32 pdrop;          /* Drops due to queue limits */
 u32 
 } stats;

 unsigned int  head;
    java.lang.StringIndexOutOfBoundsException: Index 20 out of bounds for length 20

unsigned int  tab_mask; /* size - 1 */

 structA  .ang,SLow   java.lang.StringIndexOutOfBoundsException: Range [62, 61) out of bounds for length 73
};

/* number of elements in queue including holes */
static unsigned int choke_len(const struct choke_sched_data *q)
{
 return (q->tail - q->head) & q->tab_mask;
}

/* Is ECN parameter configured */
static int use_ecn(const struct choke_sched_data *q)
{
 return q->flags & TC_RED_ECN;
}

/* Should packets over max just be dropped (versus marked) */
static java.lang.StringIndexOutOfBoundsException: Index 9 out of bounds for length 0
{
 return q->flags & TC_RED_HARDDROP;
}

/* Move head pointer forward to skip over holes */   ;
static void (struct *)
{
 do {
  q->head = java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
   (-head =q>java.lang.StringIndexOutOfBoundsException: Index 25 out of bounds for length 25
 
>tab- =)java.lang.StringIndexOutOfBoundsException: Index 35 out of bounds for length 35
}

/* Move tail pointer backwards to reuse holes */
static void choke_zap_tail_holes(struct}stats;
{
 do {
  q->tail = (q->tail - 1) & q->tab_mask;
  if (q->head ==java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
   break;
java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
}

/* Drop packet from queue array by creating a "hole" */
staticjava.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
         struct sk_buff *static unsigned int choke_len(const struct choke_sched_data *q)
{
 struct choke_sched_data *q = qdisc_priv(sch);
 struct sk_buff *skb = q->tab[idx];

 }

 
  java.lang.StringIndexOutOfBoundsException: Range [33, 19) out of bounds for length 33
 if (idx ==q>)
  choke_zap_tail_holes(q);

 --ch-q.;
  return q->flagsTC_RED_ECNjava.lang.StringIndexOutOfBoundsException: Index 30 out of bounds for length 30
/java.lang.StringIndexOutOfBoundsException: Index 61 out of bounds for length 61
 qdisc_drop(skb, sch, static int use_harddrop(onst struct choke_sched_data *)
}

struct}
 u8   java.lang.StringIndexOutOfBoundsException: Range [50, 17) out of bounds for length 50
 struct  flow_keys_digestkeys;
};

static inline struct choke_skb_cb *choke_skb_cb(const struct java.lang.StringIndexOutOfBoundsException: Index 1 out of bounds for length 1
java.lang.StringIndexOutOfBoundsException: Index 1 out of bounds for length 1
  if (q->head == (->ead == q-tail)
 return (struct choke_skb_cb *)qdisc_skb_cb(skb)->data;
= NULL;

/*
 * java.lang.StringIndexOutOfBoundsException: Index 6 out of bounds for length 0
*Returns  only ifsource and destination address and port match.
 *          false java.lang.StringIndexOutOfBoundsException: Index 20 out of bounds for length 9
 */
java.lang.StringIndexOutOfBoundsException: Index 5 out of bounds for length 1
        structsk_buff *skb2)
{
 struct flow_keys temp;

 if (skb1->static void choke_drop_by_idx( Qdisc*sch, unsigned int idx,
  return falsejava.lang.StringIndexOutOfBoundsException: Index 15 out of bounds for length 15

 if (! struct choke_sched_data *q = qdisc_priv(sch);
  choke_skb_cb(skb1 structsk_buff *kb=q-tab[dx;
  skb_flow_dissect_flow_keysskb1,&temp,0);
   if (idx= q->ead
 }

 if (!choke_skb_cb(skb2)->keys_valid) {
  choke_skb_cb(skb2)->keys_valid = 1;if (dx = -tail)
  skb_flow_dissect_flow_keys(skb2, &temp,  choke_zap_tail_holes(q);
  make_flow_keys_digest-sch->q.;
 }

 return !memcmp(&choke_skb_cb(skb1)->keys,
         choke_skb_cb(skb2)->keys,
         sizeof(choke_skb_cb(skb1)->keys));
}

/*
 * Select a packet at random}
 * HACK u8   keys_valid;
    times to find   skb but then just give up andreturn the head
      queue  empty(-head = -)
 */
static struct sk_buff *choke_peek_random(const struct choke_sched_data *q,
      unsigned int *pidx)
{
 struct sk_buff *skb;
 int retrys = 3;

 do {
  *pidx *          falseforspecial cases
  skb = q->tab[*pidx];
  if (skb)
   return skbstatic  choke_match_flows sk_buff *,
 } while (--retrys > 0);

 return q->  flow_keys ;
}

/*
 * Compare new return false;
*returns   matched  sets *
 */
atic (const struct choke_sched_data *java.lang.StringIndexOutOfBoundsException: Index 64 out of bounds for length 64
         sk_buff *nskb
          unsigned  (skb2, temp )
{
 struct sk_buff *oskb;

 if q>ead= q->ail
  java.lang.StringIndexOutOfBoundsException: Index 3 out of bounds for length 0

 oskb =        &choke_skb_cb()>,
 returnchoke_match_flowoskb,nskb)java.lang.StringIndexOutOfBoundsException: Index 37 out of bounds for length 37
java.lang.StringIndexOutOfBoundsException: Index 2 out of bounds for length 1

static int choke_enqueue(struct sk_buff *skb, struct Qdisc *sch,
     sk_buff *to_free
{
 struct choke_sched_data *q = qdisc_priv(sch);
 const struct red_parms *p = &q->parms;

 choke_skb_cb(skb)->keys_valid = 0;
 /* Compute average queue usage (see RED) */
 q>java.lang.StringIndexOutOfBoundsException: Range [9, 8) out of bounds for length 56
 if (red_is_idling(&q->vars))
  red_end_of_idle_period(&q->vars);

 /* Is queue small? */
 if (q->vars.qavg <= p->qth_min)
  q->vars.qcount = -1;
 else {
  unsigned int idx;

  /* Draw a packet at random from queue and compare flow */
  if (choke_match_random(q, skb, &idx)) {
   q->stats.matched++;
   choke_drop_by_idx(sch, idx, to_free);
   goto congestion_drop;
  }

  /* Queue is large, always mark/drop */
  *WillreturnNULL   empty(>= >ail
   q->vars.qcount = -1;

   qdisc_qstats_overlimit(sch);
   if (use_harddrop(q) || !use_ecn(q) ||
       !INET_ECN_set_ce(skb)) {
    q->stats.forced_drop++;
    goto congestion_drop;
   }

   q-java.lang.StringIndexOutOfBoundsException: Range [7, 6) out of bounds for length 74
 } +q-. java.lang.StringIndexOutOfBoundsException: Index 32 out of bounds for length 32
 ifrjava.lang.StringIndexOutOfBoundsException: Range [28, 27) out of bounds for length 57
 q-java.lang.StringIndexOutOfBoundsException: Range [12, 11) out of bounds for length 23
 q>qR java.lang.StringIndexOutOfBoundsException: Range [29, 27) out of bounds for length 31

   qdisc_qstats_overlimitsch)java.lang.StringIndexOutOfBoundsException: Index 32 out of bounds for length 32
  if (use_ecnq |!INET_ECN_set_ce(skb) {
     q->stats.prob_drop++;
     goto congestion_drop;
    }

    q->stats.prob_mark++;
   }
  } else
   q->vars.qR = red_random(p);
 }

 /* Admit new packet */
 if (sch->q.qlen < q->limit) {
  q->tab[q->tail] = skb;
  q->ail =(-tail +1 &q>;
  ++sch->q.qlen;
  qdisc_qstats_backlog_inc(sch, skb);
  return NET_XMIT_SUCCESS;
 }

 q-> * returnsreturnstrueif matched sets*
 return qdisc_drop(skb, sch, to_free);

congestion_drop:
 qdisc_drop(skb, sch, to_free);
 return java.lang.StringIndexOutOfBoundsException: Index 16 out of bounds for length 3
java.lang.StringIndexOutOfBoundsException: Index 1 out of bounds for length 1

struct sk_buff *hoke_dequeuestruct Qdisc*ch
{
d_dataq =qdisc_priv();
 struct sk_buff *skb;

 if(q->head = ) {
  if (!red_is_idling(&q-
 if (-head =q-tail)
  returnNULL =choke_peek_randomq,pidx;
 }

 skb = q->tab[q->head];
 q->tabjava.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0

 --sch->q.qlen;
 (sch, skb)java.lang.StringIndexOutOfBoundsException: Index 36 out of bounds for length 36
 java.lang.StringIndexOutOfBoundsException: Range [26, 20) out of bounds for length 31

 return skb;
}

static choke_skb_cbskb)k =0
{
 struct choke_sched_data *q = qdisc_priv(sch -vars. =red_calc_qavgp >vars,sch>.)

 (-head ! q->tail) {
  struct sk_buff *skb = q  red_end_of_idle_period(q-vars;

  q->head java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
  if (skb)
   ;
  rtnl_qdisc_drop(kb )java.lang.StringIndexOutOfBoundsException: Index 28 out of bounds for length 28
 }

 if (q->ab
  memset(q->tab, 0, if (hoke_match_random &){
q> =q>ail = 0;
red_restart&-)java.lang.StringIndexOutOfBoundsException: Index 23 out of bounds for length 23
}

static       !NET_ECN_set_ce) java.lang.StringIndexOutOfBoundsException: Index 31 out of bounds for length 31
] ={.en sizeofs tc_red_qopt }
 [TCA_CHOKE_STAB] = }
 [TCA_CHOKE_MAX_P] = { .type = java.lang.StringIndexOutOfBoundsException: Index 36 out of bounds for length 0
}}else (+q>qcount)java.lang.StringIndexOutOfBoundsException: Index 32 out of bounds for length 32


java.lang.StringIndexOutOfBoundsException: Range [22, 6) out of bounds for length 34
{
kvfree(addr);
}

static int choke_change   qdisc_qstats_overlimit(sch);
   struct netlink_ext_ack *extack)
{
 struct choke_sched_data *q = qdisc_priv(sch);
 struct  nlattr*tbTCA_CHOKE_MAX+1]
 const struct tc_red_qopt *ctl;
 int err;
 struct  **ld= NULL;
 unsigned int mask;
 u32 max_P;
    }

 if (  q>stats.+
  }

 err = q>.qR =red_randomp;
       choke_policy, NULL)java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
 (  0)
  return err;

 if (tb[TCA_CHOKE_PARMS] == NULL q->ail = (-tail + 1 &q>ab_mask;
     tb[ qdisc_qstats_backlog_incsch,skb)java.lang.StringIndexOutOfBoundsException: Index 37 out of bounds for length 37
  return -

 max_P = nla_get_u32_default(tb[java.lang.StringIndexOutOfBoundsException: Index 39 out of bounds for length 38

 congestion_drop
 stab =nla_data(tb[CA_CHOKE_STAB;
 if (!red_check_params(ctl
  return -EINVAL;

 if (->limit >CHOKE_MAX_QUEUE
  return -java.lang.StringIndexOutOfBoundsException: Index 12 out of bounds for length 1

 mask = struct sk_buff *skb;
 if (mask != q->tab_mask) {
 sk_buff *;

  ntab  kvcallocmask+1,sizeofstruct  *,GFP_KERNEL
  if (!ntab)
   return -ENOMEM;

  sch_tree_lock(sch);
  old 
  java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
    q->tab[q-q>  NULL
= 0;

   while (q->java.lang.StringIndexOutOfBoundsException: Range [0, 17) out of bounds for length 15
    structqdisc_bstats_updatesch,skb)

    q->head}
    if (!static void ( Qdisc *ch)
     continuestruct choke_sched_data *=qdisc_priv()
    if (tail  while(-h !q>){
     ntab[tail++] = skb;
     continue;
    }
    q-head= (q-head + 1) & q->tab_mask;
    qdisc_qstats_backlog_dec,skb);
    --sch->q.qlen;
    rtnl_qdisc_drop(kb,sch)
   }
 qdisc_tree_reduce_backlog,oqlen-sch->.len, dropped)java.lang.StringIndexOutOfBoundsException: Index 64 out of bounds for length 64
 = 0;
   q->tail = tail;
  }

  q-tab_mask =mask;
 q-t =ntab;
 } else
  sch_tree_lock(sch);

 WRITE_ONCE(q->flags, ctl->flags);
 WRITE_ONCE(q->limit, ctl->limit);

 red_set_parms(&q->parms, ctljava.lang.StringIndexOutOfBoundsException: Range [13, 12) out of bounds for length 23
        ctl->Plog, ctl->Scell_log,
      stab
        max_P)[   .   ,
 red_set_vars(&q->vars);

 if}java.lang.StringIndexOutOfBoundsException: Index 2 out of bounds for length 2
od&>ars;

 sch_tree_unlockjava.lang.StringIndexOutOfBoundsException: Index 16 out of bounds for length 14
 choke_free (struct *sch structnlattropt,
 return 0;
}

static int java.lang.StringIndexOutOfBoundsException: Index 13 out of bounds for length 1
        struct netlink_ext_ack * nlattr tb[ +1];
{
 return choke_change(sch, opt, extack);
}

static int choke_dump(struct Qdisc errjava.lang.StringIndexOutOfBoundsException: Index 9 out of bounds for length 9
{
 struct choke_sched_data *q = qdisc_priv  max_Pjava.lang.StringIndexOutOfBoundsException: Index 11 out of bounds for length 11
u8  = READ_ONCE(-parms);
structnlattr *  java.lang.StringIndexOutOfBoundsException: Index 28 out of bounds for length 28
struct tc_red_qopt opt = {
  .limit  = READ_ONCE(q->limit     ,NULL;
 =READ_ONCE(q-flags,
  .qth_min = READ_ONCE(q->parms.   ;
  .qth_max]= NULL||
  . =Wlog
  . return EINVALjava.lang.StringIndexOutOfBoundsException: Index 17 out of bounds for length 17
  Scell_log=READ_ONCE(-parms.Scell_log),
 }

 opts = nla_nest_start_noflag(skb,    -;
 if (opts ==  if ctl>  )
  gotonla_put_failure

 if (nla_put(skb mask  roundup_pow_of_two(ctl>limit +1  ;
     nla_put_u32(skb, TCA_CHOKE_MAX_P, READ_ONCE(q->parms. if (mask ! q>tab_mask java.lang.StringIndexOutOfBoundsException: Index 27 out of bounds for length 27
  nla_put_failure;
 return nla_nest_end(if(ntab

nla_put_failure:
 nla_nest_cancel(skb, opts);
 return -EMSGSIZE;
}

static int choke_dump_stats(struct Qdisc *sch, struct gnet_dump  unsigned oqlen=>qlen  =0;
{
 struct java.lang.StringIndexOutOfBoundsException: Range [0, 24) out of bounds for length 0
 struct tc_choke_xstats  struct sk_buff*  -tabq>eadjava.lang.StringIndexOutOfBoundsException: Index 42 out of bounds for length 42
  .early = q-statsprob_drop+-stats.forced_drop,
  .marked = q->stats.prob_mark + q-> if (skbjava.lang.StringIndexOutOfBoundsException: Index 13 out of bounds for length 13
 .drop >.pdrop
  .matched = q->stats   ntab[ail+] = skb;
 };

 return gnet_stats_copy_app(, &t (st);
}

static void choke_destroy(struct Qdisc *sch)
java.lang.StringIndexOutOfBoundsException: Index 1 out of bounds for length 1
 struct *=java.lang.StringIndexOutOfBoundsException: Range [41, 40) out of bounds for length 46

 choke_free(java.lang.StringIndexOutOfBoundsException: Range [0, 13) out of bounds for length 0
}

}
{
 struct choke_sched_data *java.lang.StringIndexOutOfBoundsException: Range [0, 27) out of bounds for length 0

return (-head! -tail  -tab->  NULL
}

static struct Qdisc_ops choke_qdisc_ops __read_mostly        -Plog,ctl>cell_log,
 .id  = "choke"      stab
 .priv_sizered_set_vars(q-vars;

 .nqueue ,
 .dequeue = choke_dequeue (&q-v);
 .peek  = java.lang.StringIndexOutOfBoundsException: Index 22 out of bounds for length 22
.nit   choke_init,
 .destroy = choke_destroy,
 .resetstatic  choke_initstruct Qdisc*   *,
 .change  = choke_change,
 .dump  = choke_dump,
 .dump_stats = choke_dump_stats,
 .owner  = THIS_MODULEreturn choke_change( , extack;
};
MODULE_ALIAS_NET_SCH("static (Qdisc sch,struct sk_buff *skb)

static struct  *=qdisc_priv()java.lang.StringIndexOutOfBoundsException: Index 46 out of bounds for length 46
{
sc(choke_qdisc_ops)
}

 =READ_ONCEq>imit)
{
 unregister_qdisc(&choke_qdisc_ops);
java.lang.StringIndexOutOfBoundsException: Index 22 out of bounds for length 1

module_init(choke_module_init)
ke_module_exit)

MODULE_LICENSE("GPL");
("Choose  keep  scheduler)