evie/android_kernel_oneplus_msm8998
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

net: Allow setting sock flow hash without a sock

Browse source 
This patch adds sock_rps_record_flow_hash and sock_rps_reset_flow_hash
which take a hash value as an argument and sets the sock_flow_table
accordingly.  This allows the table to be populated in cases where flow
is being tracked outside of a sock structure.

sock_rps_record_flow and sock_rps_reset_flow call this function
where the hash is taken from sk_rxhash.

Signed-off-by: Tom Herbert <therbert@google.com>
Signed-off-by: Zhi Yong Wu <wuzhy@linux.vnet.ibm.com>
Signed-off-by: David S. Miller <davem@davemloft.net>
This commit is contained in:
Tom Herbert 2013-12-22 18:54:31 +08:00 • committed by David S. Miller
parent 84a6a0acad
commit fe47755852
1 changed files with 14 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

18
include/net/sock.h
View file

@ -820,30 +820,40 @@ static inline int sk_backlog_rcv(struct sock *sk, struct sk_buff *skb)
return sk->sk_backlog_rcv(sk, skb); return sk->sk_backlog_rcv(sk, skb);
} }
static inline void sock_rps_record_flow(const struct sock *sk) static inline void sock_rps_record_flow_hash(__u32 hash)
{ {
#ifdef CONFIG_RPS #ifdef CONFIG_RPS
struct rps_sock_flow_table *sock_flow_table; struct rps_sock_flow_table *sock_flow_table;
rcu_read_lock(); rcu_read_lock();
sock_flow_table = rcu_dereference(rps_sock_flow_table); sock_flow_table = rcu_dereference(rps_sock_flow_table);
rps_record_sock_flow(sock_flow_table, sk->sk_rxhash); rps_record_sock_flow(sock_flow_table, hash);
rcu_read_unlock(); rcu_read_unlock();
#endif #endif
} }
static inline void sock_rps_reset_flow(const struct sock *sk) static inline void sock_rps_reset_flow_hash(__u32 hash)
{ {
#ifdef CONFIG_RPS #ifdef CONFIG_RPS
struct rps_sock_flow_table *sock_flow_table; struct rps_sock_flow_table *sock_flow_table;
rcu_read_lock(); rcu_read_lock();
sock_flow_table = rcu_dereference(rps_sock_flow_table); sock_flow_table = rcu_dereference(rps_sock_flow_table);
rps_reset_sock_flow(sock_flow_table, sk->sk_rxhash); rps_reset_sock_flow(sock_flow_table, hash);
rcu_read_unlock(); rcu_read_unlock();
#endif #endif
} }
static inline void sock_rps_record_flow(const struct sock *sk)
{
sock_rps_record_flow_hash(sk->sk_rxhash);
}
static inline void sock_rps_reset_flow(const struct sock *sk)
{
sock_rps_reset_flow_hash(sk->sk_rxhash);
}
static inline void sock_rps_save_rxhash(struct sock *sk, static inline void sock_rps_save_rxhash(struct sock *sk,
const struct sk_buff *skb) const struct sk_buff *skb)
{ {