OXIESEC PANEL
- Current Dir:
/
/
usr
/
src
/
linux-headers-4.15.0-197
/
include
/
net
Server IP: 139.59.38.164
Upload:
Create Dir:
Name
Size
Modified
Perms
📁
..
-
11/17/2022 06:42:18 AM
rwxr-xr-x
📄
6lowpan.h
10.03 KB
01/28/2018 09:20:33 PM
rw-r--r--
📁
9p
-
11/17/2022 06:42:23 AM
rwxr-xr-x
📄
Space.h
1.15 KB
01/28/2018 09:20:33 PM
rw-r--r--
📄
act_api.h
6.38 KB
11/01/2022 04:52:05 PM
rw-r--r--
📄
addrconf.h
12.63 KB
11/01/2022 04:52:05 PM
rw-r--r--
📄
af_ieee802154.h
1.55 KB
01/28/2018 09:20:33 PM
rw-r--r--
📄
af_rxrpc.h
2.79 KB
01/28/2018 09:20:33 PM
rw-r--r--
📄
af_unix.h
2.22 KB
11/01/2022 04:52:05 PM
rw-r--r--
📄
af_vsock.h
7.21 KB
11/01/2022 04:52:05 PM
rw-r--r--
📄
ah.h
382 bytes
01/28/2018 09:20:33 PM
rw-r--r--
📄
arp.h
2 KB
11/01/2022 04:52:05 PM
rw-r--r--
📄
atmclip.h
1.48 KB
01/28/2018 09:20:33 PM
rw-r--r--
📄
ax25.h
15.02 KB
11/01/2022 04:52:05 PM
rw-r--r--
📄
ax88796.h
998 bytes
01/28/2018 09:20:33 PM
rw-r--r--
📁
bluetooth
-
11/17/2022 06:42:23 AM
rwxr-xr-x
📄
bond_3ad.h
9.79 KB
11/01/2022 04:52:05 PM
rw-r--r--
📄
bond_alb.h
6.6 KB
11/01/2022 04:52:05 PM
rw-r--r--
📄
bond_options.h
3.92 KB
01/28/2018 09:20:33 PM
rw-r--r--
📄
bonding.h
19.1 KB
11/01/2022 04:52:05 PM
rw-r--r--
📄
busy_poll.h
3.8 KB
11/01/2022 04:52:05 PM
rw-r--r--
📁
caif
-
11/17/2022 06:42:23 AM
rwxr-xr-x
📄
calipso.h
2.15 KB
01/28/2018 09:20:33 PM
rw-r--r--
📄
cfg80211-wext.h
1.95 KB
01/28/2018 09:20:33 PM
rw-r--r--
📄
cfg80211.h
221.24 KB
11/01/2022 04:52:05 PM
rw-r--r--
📄
cfg802154.h
10.89 KB
01/28/2018 09:20:33 PM
rw-r--r--
📄
checksum.h
4.76 KB
11/01/2022 04:52:05 PM
rw-r--r--
📄
cipso_ipv4.h
8.2 KB
01/28/2018 09:20:33 PM
rw-r--r--
📄
cls_cgroup.h
2.15 KB
01/28/2018 09:20:33 PM
rw-r--r--
📄
codel.h
5.65 KB
01/28/2018 09:20:33 PM
rw-r--r--
📄
codel_impl.h
7.98 KB
01/28/2018 09:20:33 PM
rw-r--r--
📄
codel_qdisc.h
2.9 KB
01/28/2018 09:20:33 PM
rw-r--r--
📄
compat.h
2.11 KB
01/28/2018 09:20:33 PM
rw-r--r--
📄
datalink.h
619 bytes
01/28/2018 09:20:33 PM
rw-r--r--
📄
dcbevent.h
1.26 KB
01/28/2018 09:20:33 PM
rw-r--r--
📄
dcbnl.h
4.2 KB
01/28/2018 09:20:33 PM
rw-r--r--
📄
devlink.h
13.25 KB
01/28/2018 09:20:33 PM
rw-r--r--
📄
dn.h
6.88 KB
01/28/2018 09:20:33 PM
rw-r--r--
📄
dn_dev.h
5.36 KB
01/28/2018 09:20:33 PM
rw-r--r--
📄
dn_fib.h
3.98 KB
01/28/2018 09:20:33 PM
rw-r--r--
📄
dn_neigh.h
968 bytes
01/28/2018 09:20:33 PM
rw-r--r--
📄
dn_nsp.h
5.83 KB
01/28/2018 09:20:33 PM
rw-r--r--
📄
dn_route.h
4.36 KB
01/28/2018 09:20:33 PM
rw-r--r--
📄
dsa.h
13.94 KB
11/01/2022 04:52:05 PM
rw-r--r--
📄
dsfield.h
1.11 KB
01/28/2018 09:20:33 PM
rw-r--r--
📄
dst.h
13.48 KB
11/01/2022 04:52:05 PM
rw-r--r--
📄
dst_cache.h
2.53 KB
01/28/2018 09:20:33 PM
rw-r--r--
📄
dst_metadata.h
5.39 KB
11/01/2022 04:52:05 PM
rw-r--r--
📄
dst_ops.h
2 KB
11/01/2022 04:52:05 PM
rw-r--r--
📄
erspan.h
2.11 KB
01/28/2018 09:20:33 PM
rw-r--r--
📄
esp.h
877 bytes
01/28/2018 09:20:33 PM
rw-r--r--
📄
ethoc.h
538 bytes
01/28/2018 09:20:33 PM
rw-r--r--
📄
fib_notifier.h
1.29 KB
01/28/2018 09:20:33 PM
rw-r--r--
📄
fib_rules.h
4.18 KB
11/01/2022 04:52:05 PM
rw-r--r--
📄
firewire.h
636 bytes
01/28/2018 09:20:33 PM
rw-r--r--
📄
flow.h
6.16 KB
01/28/2018 09:20:33 PM
rw-r--r--
📄
flow_dissector.h
7.55 KB
11/01/2022 04:52:05 PM
rw-r--r--
📄
fou.h
549 bytes
01/28/2018 09:20:33 PM
rw-r--r--
📄
fq.h
2.67 KB
11/01/2022 04:52:05 PM
rw-r--r--
📄
fq_impl.h
6.9 KB
11/01/2022 04:52:05 PM
rw-r--r--
📄
garp.h
2.62 KB
01/28/2018 09:20:33 PM
rw-r--r--
📄
gen_stats.h
2.34 KB
01/28/2018 09:20:33 PM
rw-r--r--
📄
genetlink.h
11.3 KB
11/01/2022 04:52:05 PM
rw-r--r--
📄
geneve.h
1.67 KB
01/28/2018 09:20:33 PM
rw-r--r--
📄
gre.h
2.99 KB
01/28/2018 09:20:33 PM
rw-r--r--
📄
gro_cells.h
443 bytes
01/28/2018 09:20:33 PM
rw-r--r--
📄
gtp.h
633 bytes
01/28/2018 09:20:33 PM
rw-r--r--
📄
gue.h
3.23 KB
01/28/2018 09:20:33 PM
rw-r--r--
📄
hwbm.h
937 bytes
01/28/2018 09:20:33 PM
rw-r--r--
📄
icmp.h
2.01 KB
11/01/2022 04:52:05 PM
rw-r--r--
📄
ieee80211_radiotap.h
6.63 KB
01/28/2018 09:20:33 PM
rw-r--r--
📄
ieee802154_netdev.h
9.14 KB
01/28/2018 09:20:33 PM
rw-r--r--
📄
if_inet6.h
6.13 KB
01/28/2018 09:20:33 PM
rw-r--r--
📄
ife.h
1.06 KB
11/01/2022 04:52:05 PM
rw-r--r--
📄
ila.h
498 bytes
01/28/2018 09:20:33 PM
rw-r--r--
📄
inet6_connection_sock.h
976 bytes
01/28/2018 09:20:33 PM
rw-r--r--
📄
inet6_hashtables.h
3.7 KB
01/28/2018 09:20:33 PM
rw-r--r--
📄
inet_common.h
1.89 KB
01/28/2018 09:20:33 PM
rw-r--r--
📄
inet_connection_sock.h
10.48 KB
11/01/2022 04:52:05 PM
rw-r--r--
📄
inet_ecn.h
6.02 KB
11/01/2022 04:52:05 PM
rw-r--r--
📄
inet_frag.h
4.51 KB
11/01/2022 04:52:05 PM
rw-r--r--
📄
inet_hashtables.h
12.91 KB
11/01/2022 04:52:05 PM
rw-r--r--
📄
inet_sock.h
8.25 KB
11/01/2022 04:52:05 PM
rw-r--r--
📄
inet_timewait_sock.h
3.82 KB
11/01/2022 04:52:05 PM
rw-r--r--
📄
inetpeer.h
3.29 KB
11/01/2022 04:52:05 PM
rw-r--r--
📄
ip.h
18.51 KB
11/01/2022 04:52:05 PM
rw-r--r--
📄
ip6_checksum.h
2.89 KB
01/28/2018 09:20:33 PM
rw-r--r--
📄
ip6_fib.h
10.04 KB
11/01/2022 04:52:05 PM
rw-r--r--
📄
ip6_route.h
7.63 KB
11/01/2022 04:52:05 PM
rw-r--r--
📄
ip6_tunnel.h
4.72 KB
11/01/2022 04:52:05 PM
rw-r--r--
📄
ip_fib.h
10.72 KB
11/01/2022 04:52:05 PM
rw-r--r--
📄
ip_tunnels.h
13.61 KB
11/01/2022 04:52:05 PM
rw-r--r--
📄
ip_vs.h
46.78 KB
11/01/2022 04:52:05 PM
rw-r--r--
📄
ipcomp.h
659 bytes
01/28/2018 09:20:33 PM
rw-r--r--
📄
ipconfig.h
811 bytes
01/28/2018 09:20:33 PM
rw-r--r--
📄
ipv6.h
29.97 KB
11/01/2022 04:52:05 PM
rw-r--r--
📄
ipv6_frag.h
2.54 KB
11/01/2022 04:52:05 PM
rw-r--r--
📄
ipx.h
4.4 KB
01/28/2018 09:20:33 PM
rw-r--r--
📁
iucv
-
11/17/2022 06:42:23 AM
rwxr-xr-x
📄
iw_handler.h
20.91 KB
01/28/2018 09:20:33 PM
rw-r--r--
📄
kcm.h
4.96 KB
01/28/2018 09:20:33 PM
rw-r--r--
📄
l3mdev.h
5.86 KB
11/01/2022 04:52:05 PM
rw-r--r--
📄
lapb.h
4.75 KB
01/28/2018 09:20:33 PM
rw-r--r--
📄
lib80211.h
3.92 KB
01/28/2018 09:20:33 PM
rw-r--r--
📄
llc.h
4.41 KB
11/01/2022 04:52:05 PM
rw-r--r--
📄
llc_c_ac.h
9.31 KB
01/28/2018 09:20:33 PM
rw-r--r--
📄
llc_c_ev.h
10.68 KB
01/28/2018 09:20:33 PM
rw-r--r--
📄
llc_c_st.h
1.72 KB
01/28/2018 09:20:33 PM
rw-r--r--
📄
llc_conn.h
4.06 KB
11/01/2022 04:52:05 PM
rw-r--r--
📄
llc_if.h
2.16 KB
01/28/2018 09:20:33 PM
rw-r--r--
📄
llc_pdu.h
14.44 KB
11/01/2022 04:52:05 PM
rw-r--r--
📄
llc_s_ac.h
1.55 KB
01/28/2018 09:20:33 PM
rw-r--r--
📄
llc_s_ev.h
2.2 KB
01/28/2018 09:20:33 PM
rw-r--r--
📄
llc_s_st.h
947 bytes
01/28/2018 09:20:33 PM
rw-r--r--
📄
llc_sap.h
1.08 KB
01/28/2018 09:20:33 PM
rw-r--r--
📄
lwtunnel.h
5.84 KB
01/28/2018 09:20:33 PM
rw-r--r--
📄
mac80211.h
230.36 KB
11/01/2022 04:52:05 PM
rw-r--r--
📄
mac802154.h
15.27 KB
01/28/2018 09:20:33 PM
rw-r--r--
📄
mip6.h
1.58 KB
01/28/2018 09:20:33 PM
rw-r--r--
📄
mld.h
2.8 KB
01/28/2018 09:20:33 PM
rw-r--r--
📄
mpls.h
932 bytes
01/28/2018 09:20:33 PM
rw-r--r--
📄
mpls_iptunnel.h
827 bytes
01/28/2018 09:20:33 PM
rw-r--r--
📄
mrp.h
3.03 KB
01/28/2018 09:20:33 PM
rw-r--r--
📄
ncsi.h
1.92 KB
01/28/2018 09:20:33 PM
rw-r--r--
📄
ndisc.h
13.77 KB
01/28/2018 09:20:33 PM
rw-r--r--
📄
neighbour.h
15.06 KB
11/01/2022 04:52:05 PM
rw-r--r--
📄
net_namespace.h
10.08 KB
11/01/2022 04:52:05 PM
rw-r--r--
📄
net_ratelimit.h
220 bytes
01/28/2018 09:20:33 PM
rw-r--r--
📄
netevent.h
910 bytes
01/28/2018 09:20:33 PM
rw-r--r--
📁
netfilter
-
11/17/2022 06:42:23 AM
rwxr-xr-x
📄
netlabel.h
20.74 KB
01/28/2018 09:20:33 PM
rw-r--r--
📄
netlink.h
40.39 KB
01/28/2018 09:20:33 PM
rw-r--r--
📁
netns
-
11/17/2022 06:42:23 AM
rwxr-xr-x
📄
netprio_cgroup.h
1.24 KB
01/28/2018 09:20:33 PM
rw-r--r--
📄
netrom.h
7.68 KB
01/28/2018 09:20:33 PM
rw-r--r--
📄
nexthop.h
865 bytes
11/01/2022 04:52:05 PM
rw-r--r--
📁
nfc
-
11/17/2022 06:42:23 AM
rwxr-xr-x
📄
nl802154.h
12.09 KB
11/01/2022 04:52:05 PM
rw-r--r--
📄
nsh.h
12.31 KB
01/28/2018 09:20:33 PM
rw-r--r--
📄
p8022.h
447 bytes
01/28/2018 09:20:33 PM
rw-r--r--
📁
phonet
-
11/17/2022 06:42:23 AM
rwxr-xr-x
📄
ping.h
3.45 KB
01/28/2018 09:20:33 PM
rw-r--r--
📄
pkt_cls.h
17.34 KB
11/01/2022 04:52:05 PM
rw-r--r--
📄
pkt_sched.h
4.05 KB
01/28/2018 09:20:33 PM
rw-r--r--
📄
pptp.h
557 bytes
01/28/2018 09:20:33 PM
rw-r--r--
📄
protocol.h
4.08 KB
01/28/2018 09:20:33 PM
rw-r--r--
📄
psample.h
860 bytes
11/01/2022 04:52:05 PM
rw-r--r--
📄
psnap.h
351 bytes
01/28/2018 09:20:33 PM
rw-r--r--
📄
raw.h
2.07 KB
01/28/2018 09:20:33 PM
rw-r--r--
📄
rawv6.h
854 bytes
01/28/2018 09:20:33 PM
rw-r--r--
📄
red.h
10.45 KB
11/01/2022 04:52:05 PM
rw-r--r--
📄
regulatory.h
10.12 KB
11/01/2022 04:52:05 PM
rw-r--r--
📄
request_sock.h
6.46 KB
11/01/2022 04:52:05 PM
rw-r--r--
📄
rose.h
7.62 KB
01/28/2018 09:20:33 PM
rw-r--r--
📄
route.h
10.02 KB
11/01/2022 04:52:05 PM
rw-r--r--
📄
rtnetlink.h
6.13 KB
11/01/2022 04:52:05 PM
rw-r--r--
📄
sch_generic.h
23.3 KB
11/01/2022 04:52:05 PM
rw-r--r--
📄
scm.h
3.5 KB
01/28/2018 09:20:33 PM
rw-r--r--
📁
sctp
-
11/17/2022 06:42:23 AM
rwxr-xr-x
📄
secure_seq.h
855 bytes
11/01/2022 04:52:05 PM
rw-r--r--
📄
seg6.h
1.66 KB
01/28/2018 09:20:33 PM
rw-r--r--
📄
seg6_hmac.h
1.65 KB
01/28/2018 09:20:33 PM
rw-r--r--
📄
slhc_vj.h
6.67 KB
11/01/2022 04:52:05 PM
rw-r--r--
📄
smc.h
440 bytes
01/28/2018 09:20:33 PM
rw-r--r--
📄
snmp.h
5.23 KB
01/28/2018 09:20:33 PM
rw-r--r--
📄
sock.h
69.75 KB
11/01/2022 04:52:05 PM
rw-r--r--
📄
sock_reuseport.h
863 bytes
01/28/2018 09:20:33 PM
rw-r--r--
📄
stp.h
383 bytes
01/28/2018 09:20:33 PM
rw-r--r--
📄
strparser.h
3.75 KB
01/28/2018 09:20:33 PM
rw-r--r--
📄
switchdev.h
6.52 KB
01/28/2018 09:20:33 PM
rw-r--r--
📁
tc_act
-
11/17/2022 06:42:23 AM
rwxr-xr-x
📄
tcp.h
62.8 KB
11/01/2022 04:52:05 PM
rw-r--r--
📄
tcp_states.h
1.26 KB
01/28/2018 09:20:33 PM
rw-r--r--
📄
timewait_sock.h
1.11 KB
01/28/2018 09:20:33 PM
rw-r--r--
📄
tipc.h
2.34 KB
01/28/2018 09:20:33 PM
rw-r--r--
📄
tls.h
7.12 KB
11/01/2022 04:52:05 PM
rw-r--r--
📄
transp_v6.h
2.08 KB
11/01/2022 04:52:05 PM
rw-r--r--
📄
tso.h
515 bytes
01/28/2018 09:20:33 PM
rw-r--r--
📄
tun_proto.h
988 bytes
01/28/2018 09:20:33 PM
rw-r--r--
📄
udp.h
12.82 KB
11/01/2022 04:52:05 PM
rw-r--r--
📄
udp_tunnel.h
5.12 KB
01/28/2018 09:20:33 PM
rw-r--r--
📄
udplite.h
3.83 KB
11/01/2022 04:52:05 PM
rw-r--r--
📄
vsock_addr.h
1.05 KB
01/28/2018 09:20:33 PM
rw-r--r--
📄
vxlan.h
10.43 KB
11/01/2022 04:52:05 PM
rw-r--r--
📄
wext.h
1.51 KB
01/28/2018 09:20:33 PM
rw-r--r--
📄
wimax.h
19.97 KB
01/28/2018 09:20:33 PM
rw-r--r--
📄
x25.h
9.43 KB
01/28/2018 09:20:33 PM
rw-r--r--
📄
x25device.h
387 bytes
01/28/2018 09:20:33 PM
rw-r--r--
📄
xfrm.h
53.72 KB
11/01/2022 04:52:05 PM
rw-r--r--
Editing: fq_impl.h
Close
/* * Copyright (c) 2016 Qualcomm Atheros, Inc * * GPL v2 * * Based on net/sched/sch_fq_codel.c */ #ifndef __NET_SCHED_FQ_IMPL_H #define __NET_SCHED_FQ_IMPL_H #include <net/fq.h> /* functions that are embedded into includer */ static void fq_adjust_removal(struct fq *fq, struct fq_flow *flow, struct sk_buff *skb) { struct fq_tin *tin = flow->tin; tin->backlog_bytes -= skb->len; tin->backlog_packets--; flow->backlog -= skb->len; fq->backlog--; fq->memory_usage -= skb->truesize; } static void fq_rejigger_backlog(struct fq *fq, struct fq_flow *flow) { struct fq_flow *i; if (flow->backlog == 0) { list_del_init(&flow->backlogchain); } else { i = flow; list_for_each_entry_continue(i, &fq->backlogs, backlogchain) if (i->backlog < flow->backlog) break; list_move_tail(&flow->backlogchain, &i->backlogchain); } } static struct sk_buff *fq_flow_dequeue(struct fq *fq, struct fq_flow *flow) { struct sk_buff *skb; lockdep_assert_held(&fq->lock); skb = __skb_dequeue(&flow->queue); if (!skb) return NULL; fq_adjust_removal(fq, flow, skb); fq_rejigger_backlog(fq, flow); return skb; } static struct sk_buff *fq_tin_dequeue(struct fq *fq, struct fq_tin *tin, fq_tin_dequeue_t dequeue_func) { struct fq_flow *flow; struct list_head *head; struct sk_buff *skb; lockdep_assert_held(&fq->lock); begin: head = &tin->new_flows; if (list_empty(head)) { head = &tin->old_flows; if (list_empty(head)) return NULL; } flow = list_first_entry(head, struct fq_flow, flowchain); if (flow->deficit <= 0) { flow->deficit += fq->quantum; list_move_tail(&flow->flowchain, &tin->old_flows); goto begin; } skb = dequeue_func(fq, tin, flow); if (!skb) { /* force a pass through old_flows to prevent starvation */ if ((head == &tin->new_flows) && !list_empty(&tin->old_flows)) { list_move_tail(&flow->flowchain, &tin->old_flows); } else { list_del_init(&flow->flowchain); flow->tin = NULL; } goto begin; } flow->deficit -= skb->len; tin->tx_bytes += skb->len; tin->tx_packets++; return skb; } static struct fq_flow *fq_flow_classify(struct fq *fq, struct fq_tin *tin, struct sk_buff *skb, fq_flow_get_default_t get_default_func) { struct fq_flow *flow; u32 hash; u32 idx; lockdep_assert_held(&fq->lock); hash = skb_get_hash_perturb(skb, &fq->perturbation); idx = reciprocal_scale(hash, fq->flows_cnt); flow = &fq->flows[idx]; if (flow->tin && flow->tin != tin) { flow = get_default_func(fq, tin, idx, skb); tin->collisions++; fq->collisions++; } if (!flow->tin) tin->flows++; return flow; } static void fq_recalc_backlog(struct fq *fq, struct fq_tin *tin, struct fq_flow *flow) { struct fq_flow *i; if (list_empty(&flow->backlogchain)) list_add_tail(&flow->backlogchain, &fq->backlogs); i = flow; list_for_each_entry_continue_reverse(i, &fq->backlogs, backlogchain) if (i->backlog > flow->backlog) break; list_move(&flow->backlogchain, &i->backlogchain); } static void fq_tin_enqueue(struct fq *fq, struct fq_tin *tin, struct sk_buff *skb, fq_skb_free_t free_func, fq_flow_get_default_t get_default_func) { struct fq_flow *flow; bool oom; lockdep_assert_held(&fq->lock); flow = fq_flow_classify(fq, tin, skb, get_default_func); flow->tin = tin; flow->backlog += skb->len; tin->backlog_bytes += skb->len; tin->backlog_packets++; fq->memory_usage += skb->truesize; fq->backlog++; fq_recalc_backlog(fq, tin, flow); if (list_empty(&flow->flowchain)) { flow->deficit = fq->quantum; list_add_tail(&flow->flowchain, &tin->new_flows); } __skb_queue_tail(&flow->queue, skb); oom = (fq->memory_usage > fq->memory_limit); while (fq->backlog > fq->limit || oom) { flow = list_first_entry_or_null(&fq->backlogs, struct fq_flow, backlogchain); if (!flow) return; skb = fq_flow_dequeue(fq, flow); if (!skb) return; free_func(fq, flow->tin, flow, skb); flow->tin->overlimit++; fq->overlimit++; if (oom) { fq->overmemory++; oom = (fq->memory_usage > fq->memory_limit); } } } static void fq_flow_filter(struct fq *fq, struct fq_flow *flow, fq_skb_filter_t filter_func, void *filter_data, fq_skb_free_t free_func) { struct fq_tin *tin = flow->tin; struct sk_buff *skb, *tmp; lockdep_assert_held(&fq->lock); skb_queue_walk_safe(&flow->queue, skb, tmp) { if (!filter_func(fq, tin, flow, skb, filter_data)) continue; __skb_unlink(skb, &flow->queue); fq_adjust_removal(fq, flow, skb); free_func(fq, tin, flow, skb); } fq_rejigger_backlog(fq, flow); } static void fq_tin_filter(struct fq *fq, struct fq_tin *tin, fq_skb_filter_t filter_func, void *filter_data, fq_skb_free_t free_func) { struct fq_flow *flow; lockdep_assert_held(&fq->lock); list_for_each_entry(flow, &tin->new_flows, flowchain) fq_flow_filter(fq, flow, filter_func, filter_data, free_func); list_for_each_entry(flow, &tin->old_flows, flowchain) fq_flow_filter(fq, flow, filter_func, filter_data, free_func); } static void fq_flow_reset(struct fq *fq, struct fq_flow *flow, fq_skb_free_t free_func) { struct sk_buff *skb; while ((skb = fq_flow_dequeue(fq, flow))) free_func(fq, flow->tin, flow, skb); if (!list_empty(&flow->flowchain)) list_del_init(&flow->flowchain); if (!list_empty(&flow->backlogchain)) list_del_init(&flow->backlogchain); flow->tin = NULL; WARN_ON_ONCE(flow->backlog); } static void fq_tin_reset(struct fq *fq, struct fq_tin *tin, fq_skb_free_t free_func) { struct list_head *head; struct fq_flow *flow; for (;;) { head = &tin->new_flows; if (list_empty(head)) { head = &tin->old_flows; if (list_empty(head)) break; } flow = list_first_entry(head, struct fq_flow, flowchain); fq_flow_reset(fq, flow, free_func); } WARN_ON_ONCE(tin->backlog_bytes); WARN_ON_ONCE(tin->backlog_packets); } static void fq_flow_init(struct fq_flow *flow) { INIT_LIST_HEAD(&flow->flowchain); INIT_LIST_HEAD(&flow->backlogchain); __skb_queue_head_init(&flow->queue); } static void fq_tin_init(struct fq_tin *tin) { INIT_LIST_HEAD(&tin->new_flows); INIT_LIST_HEAD(&tin->old_flows); } static int fq_init(struct fq *fq, int flows_cnt) { int i; memset(fq, 0, sizeof(fq[0])); INIT_LIST_HEAD(&fq->backlogs); spin_lock_init(&fq->lock); fq->flows_cnt = max_t(u32, flows_cnt, 1); get_random_bytes(&fq->perturbation, sizeof(fq->perturbation)); fq->quantum = 300; fq->limit = 8192; fq->memory_limit = 16 << 20; /* 16 MBytes */ fq->flows = kcalloc(fq->flows_cnt, sizeof(fq->flows[0]), GFP_KERNEL); if (!fq->flows) return -ENOMEM; for (i = 0; i < fq->flows_cnt; i++) fq_flow_init(&fq->flows[i]); return 0; } static void fq_reset(struct fq *fq, fq_skb_free_t free_func) { int i; for (i = 0; i < fq->flows_cnt; i++) fq_flow_reset(fq, &fq->flows[i], free_func); kfree(fq->flows); fq->flows = NULL; } #endif