Commit 93cfb6c1 authored by Toke Høiland-Jørgensen's avatar Toke Høiland-Jørgensen Committed by David S. Miller

sch_cake: Fix TC filter flow override and expand it to hosts as well

The TC filter flow mapping override completely skipped the call to
cake_hash(); however that meant that the internal state was not being
updated, which ultimately leads to deadlocks in some configurations. Fix
that by passing the overridden flow ID into cake_hash() instead so it can
react appropriately.

In addition, the major number of the class ID can now be set to override
the host mapping in host isolation mode. If both host and flow are
overridden (or if the respective modes are disabled), flow dissection and
hashing will be skipped entirely; otherwise, the hashing will be kept for
the portions that are not set by the filter.
Signed-off-by: default avatarToke Høiland-Jørgensen <toke@toke.dk>
Signed-off-by: default avatarDavid S. Miller <davem@davemloft.net>
parent 3d0371b3
...@@ -620,15 +620,20 @@ static bool cake_ddst(int flow_mode) ...@@ -620,15 +620,20 @@ static bool cake_ddst(int flow_mode)
} }
static u32 cake_hash(struct cake_tin_data *q, const struct sk_buff *skb, static u32 cake_hash(struct cake_tin_data *q, const struct sk_buff *skb,
int flow_mode) int flow_mode, u16 flow_override, u16 host_override)
{ {
u32 flow_hash = 0, srchost_hash, dsthost_hash; u32 flow_hash = 0, srchost_hash = 0, dsthost_hash = 0;
u16 reduced_hash, srchost_idx, dsthost_idx; u16 reduced_hash, srchost_idx, dsthost_idx;
struct flow_keys keys, host_keys; struct flow_keys keys, host_keys;
if (unlikely(flow_mode == CAKE_FLOW_NONE)) if (unlikely(flow_mode == CAKE_FLOW_NONE))
return 0; return 0;
/* If both overrides are set we can skip packet dissection entirely */
if ((flow_override || !(flow_mode & CAKE_FLOW_FLOWS)) &&
(host_override || !(flow_mode & CAKE_FLOW_HOSTS)))
goto skip_hash;
skb_flow_dissect_flow_keys(skb, &keys, skb_flow_dissect_flow_keys(skb, &keys,
FLOW_DISSECTOR_F_STOP_AT_FLOW_LABEL); FLOW_DISSECTOR_F_STOP_AT_FLOW_LABEL);
...@@ -675,6 +680,14 @@ static u32 cake_hash(struct cake_tin_data *q, const struct sk_buff *skb, ...@@ -675,6 +680,14 @@ static u32 cake_hash(struct cake_tin_data *q, const struct sk_buff *skb,
if (flow_mode & CAKE_FLOW_FLOWS) if (flow_mode & CAKE_FLOW_FLOWS)
flow_hash = flow_hash_from_keys(&keys); flow_hash = flow_hash_from_keys(&keys);
skip_hash:
if (flow_override)
flow_hash = flow_override - 1;
if (host_override) {
dsthost_hash = host_override - 1;
srchost_hash = host_override - 1;
}
if (!(flow_mode & CAKE_FLOW_FLOWS)) { if (!(flow_mode & CAKE_FLOW_FLOWS)) {
if (flow_mode & CAKE_FLOW_SRC_IP) if (flow_mode & CAKE_FLOW_SRC_IP)
flow_hash ^= srchost_hash; flow_hash ^= srchost_hash;
...@@ -1570,7 +1583,7 @@ static u32 cake_classify(struct Qdisc *sch, struct cake_tin_data **t, ...@@ -1570,7 +1583,7 @@ static u32 cake_classify(struct Qdisc *sch, struct cake_tin_data **t,
struct cake_sched_data *q = qdisc_priv(sch); struct cake_sched_data *q = qdisc_priv(sch);
struct tcf_proto *filter; struct tcf_proto *filter;
struct tcf_result res; struct tcf_result res;
u32 flow = 0; u16 flow = 0, host = 0;
int result; int result;
filter = rcu_dereference_bh(q->filter_list); filter = rcu_dereference_bh(q->filter_list);
...@@ -1594,10 +1607,12 @@ static u32 cake_classify(struct Qdisc *sch, struct cake_tin_data **t, ...@@ -1594,10 +1607,12 @@ static u32 cake_classify(struct Qdisc *sch, struct cake_tin_data **t,
#endif #endif
if (TC_H_MIN(res.classid) <= CAKE_QUEUES) if (TC_H_MIN(res.classid) <= CAKE_QUEUES)
flow = TC_H_MIN(res.classid); flow = TC_H_MIN(res.classid);
if (TC_H_MAJ(res.classid) <= (CAKE_QUEUES << 16))
host = TC_H_MAJ(res.classid) >> 16;
} }
hash: hash:
*t = cake_select_tin(sch, skb); *t = cake_select_tin(sch, skb);
return flow ?: cake_hash(*t, skb, flow_mode) + 1; return cake_hash(*t, skb, flow_mode, flow, host) + 1;
} }
static void cake_reconfigure(struct Qdisc *sch); static void cake_reconfigure(struct Qdisc *sch);
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment