Commit 01e28b92 authored by Guillaume Nault's avatar Guillaume Nault Committed by David S. Miller

l2tp: split l2tp_session_get()

l2tp_session_get() is used for two different purposes. If 'tunnel' is
NULL, the session is searched globally in the supplied network
namespace. Otherwise it is searched exclusively in the tunnel context.

Callers always know the context in which they need to search the
session. But some of them do provide both a namespace and a tunnel,
making the semantic of the call unclear.

This patch defines l2tp_tunnel_get_session() for lookups done in a
tunnel and restricts l2tp_session_get() to namespace searches.
Signed-off-by: default avatarGuillaume Nault <g.nault@alphalink.fr>
Signed-off-by: default avatarDavid S. Miller <davem@davemloft.net>
parent d6a61ec9
...@@ -203,44 +203,44 @@ struct l2tp_tunnel *l2tp_tunnel_get_nth(const struct net *net, int nth) ...@@ -203,44 +203,44 @@ struct l2tp_tunnel *l2tp_tunnel_get_nth(const struct net *net, int nth)
} }
EXPORT_SYMBOL_GPL(l2tp_tunnel_get_nth); EXPORT_SYMBOL_GPL(l2tp_tunnel_get_nth);
/* Lookup a session. A new reference is held on the returned session. */ struct l2tp_session *l2tp_tunnel_get_session(struct l2tp_tunnel *tunnel,
struct l2tp_session *l2tp_session_get(const struct net *net, u32 session_id)
struct l2tp_tunnel *tunnel,
u32 session_id)
{ {
struct hlist_head *session_list; struct hlist_head *session_list;
struct l2tp_session *session; struct l2tp_session *session;
if (!tunnel) { session_list = l2tp_session_id_hash(tunnel, session_id);
struct l2tp_net *pn = l2tp_pernet(net);
session_list = l2tp_session_id_hash_2(pn, session_id);
rcu_read_lock_bh(); read_lock_bh(&tunnel->hlist_lock);
hlist_for_each_entry_rcu(session, session_list, global_hlist) { hlist_for_each_entry(session, session_list, hlist)
if (session->session_id == session_id) { if (session->session_id == session_id) {
l2tp_session_inc_refcount(session); l2tp_session_inc_refcount(session);
rcu_read_unlock_bh(); read_unlock_bh(&tunnel->hlist_lock);
return session; return session;
}
} }
rcu_read_unlock_bh(); read_unlock_bh(&tunnel->hlist_lock);
return NULL; return NULL;
} }
EXPORT_SYMBOL_GPL(l2tp_tunnel_get_session);
session_list = l2tp_session_id_hash(tunnel, session_id); struct l2tp_session *l2tp_session_get(const struct net *net, u32 session_id)
read_lock_bh(&tunnel->hlist_lock); {
hlist_for_each_entry(session, session_list, hlist) { struct hlist_head *session_list;
struct l2tp_session *session;
session_list = l2tp_session_id_hash_2(l2tp_pernet(net), session_id);
rcu_read_lock_bh();
hlist_for_each_entry_rcu(session, session_list, global_hlist)
if (session->session_id == session_id) { if (session->session_id == session_id) {
l2tp_session_inc_refcount(session); l2tp_session_inc_refcount(session);
read_unlock_bh(&tunnel->hlist_lock); rcu_read_unlock_bh();
return session; return session;
} }
} rcu_read_unlock_bh();
read_unlock_bh(&tunnel->hlist_lock);
return NULL; return NULL;
} }
...@@ -872,7 +872,7 @@ static int l2tp_udp_recv_core(struct l2tp_tunnel *tunnel, struct sk_buff *skb) ...@@ -872,7 +872,7 @@ static int l2tp_udp_recv_core(struct l2tp_tunnel *tunnel, struct sk_buff *skb)
} }
/* Find the session context */ /* Find the session context */
session = l2tp_session_get(tunnel->l2tp_net, tunnel, session_id); session = l2tp_tunnel_get_session(tunnel, session_id);
if (!session || !session->recv_skb) { if (!session || !session->recv_skb) {
if (session) if (session)
l2tp_session_dec_refcount(session); l2tp_session_dec_refcount(session);
......
...@@ -196,12 +196,12 @@ static inline void *l2tp_session_priv(struct l2tp_session *session) ...@@ -196,12 +196,12 @@ static inline void *l2tp_session_priv(struct l2tp_session *session)
struct l2tp_tunnel *l2tp_tunnel_get(const struct net *net, u32 tunnel_id); struct l2tp_tunnel *l2tp_tunnel_get(const struct net *net, u32 tunnel_id);
struct l2tp_tunnel *l2tp_tunnel_get_nth(const struct net *net, int nth); struct l2tp_tunnel *l2tp_tunnel_get_nth(const struct net *net, int nth);
struct l2tp_session *l2tp_tunnel_get_session(struct l2tp_tunnel *tunnel,
u32 session_id);
void l2tp_tunnel_free(struct l2tp_tunnel *tunnel); void l2tp_tunnel_free(struct l2tp_tunnel *tunnel);
struct l2tp_session *l2tp_session_get(const struct net *net, struct l2tp_session *l2tp_session_get(const struct net *net, u32 session_id);
struct l2tp_tunnel *tunnel,
u32 session_id);
struct l2tp_session *l2tp_session_get_nth(struct l2tp_tunnel *tunnel, int nth); struct l2tp_session *l2tp_session_get_nth(struct l2tp_tunnel *tunnel, int nth);
struct l2tp_session *l2tp_session_get_by_ifname(const struct net *net, struct l2tp_session *l2tp_session_get_by_ifname(const struct net *net,
const char *ifname); const char *ifname);
......
...@@ -144,7 +144,7 @@ static int l2tp_ip_recv(struct sk_buff *skb) ...@@ -144,7 +144,7 @@ static int l2tp_ip_recv(struct sk_buff *skb)
} }
/* Ok, this is a data packet. Lookup the session. */ /* Ok, this is a data packet. Lookup the session. */
session = l2tp_session_get(net, NULL, session_id); session = l2tp_session_get(net, session_id);
if (!session) if (!session)
goto discard; goto discard;
......
...@@ -157,7 +157,7 @@ static int l2tp_ip6_recv(struct sk_buff *skb) ...@@ -157,7 +157,7 @@ static int l2tp_ip6_recv(struct sk_buff *skb)
} }
/* Ok, this is a data packet. Lookup the session. */ /* Ok, this is a data packet. Lookup the session. */
session = l2tp_session_get(net, NULL, session_id); session = l2tp_session_get(net, session_id);
if (!session) if (!session)
goto discard; goto discard;
......
...@@ -66,7 +66,7 @@ static struct l2tp_session *l2tp_nl_session_get(struct genl_info *info) ...@@ -66,7 +66,7 @@ static struct l2tp_session *l2tp_nl_session_get(struct genl_info *info)
session_id = nla_get_u32(info->attrs[L2TP_ATTR_SESSION_ID]); session_id = nla_get_u32(info->attrs[L2TP_ATTR_SESSION_ID]);
tunnel = l2tp_tunnel_get(net, tunnel_id); tunnel = l2tp_tunnel_get(net, tunnel_id);
if (tunnel) { if (tunnel) {
session = l2tp_session_get(net, tunnel, session_id); session = l2tp_tunnel_get_session(tunnel, session_id);
l2tp_tunnel_dec_refcount(tunnel); l2tp_tunnel_dec_refcount(tunnel);
} }
} }
...@@ -627,7 +627,7 @@ static int l2tp_nl_cmd_session_create(struct sk_buff *skb, struct genl_info *inf ...@@ -627,7 +627,7 @@ static int l2tp_nl_cmd_session_create(struct sk_buff *skb, struct genl_info *inf
&cfg); &cfg);
if (ret >= 0) { if (ret >= 0) {
session = l2tp_session_get(net, tunnel, session_id); session = l2tp_tunnel_get_session(tunnel, session_id);
if (session) { if (session) {
ret = l2tp_session_notify(&l2tp_nl_family, info, session, ret = l2tp_session_notify(&l2tp_nl_family, info, session,
L2TP_CMD_SESSION_CREATE); L2TP_CMD_SESSION_CREATE);
......
...@@ -757,7 +757,7 @@ static int pppol2tp_connect(struct socket *sock, struct sockaddr *uservaddr, ...@@ -757,7 +757,7 @@ static int pppol2tp_connect(struct socket *sock, struct sockaddr *uservaddr,
if (tunnel->peer_tunnel_id == 0) if (tunnel->peer_tunnel_id == 0)
tunnel->peer_tunnel_id = info.peer_tunnel_id; tunnel->peer_tunnel_id = info.peer_tunnel_id;
session = l2tp_session_get(sock_net(sk), tunnel, info.session_id); session = l2tp_tunnel_get_session(tunnel, info.session_id);
if (session) { if (session) {
drop_refcnt = true; drop_refcnt = true;
...@@ -1134,10 +1134,10 @@ static int pppol2tp_tunnel_ioctl(struct l2tp_tunnel *tunnel, ...@@ -1134,10 +1134,10 @@ static int pppol2tp_tunnel_ioctl(struct l2tp_tunnel *tunnel,
} }
if (stats.session_id != 0) { if (stats.session_id != 0) {
/* resend to session ioctl handler */ /* resend to session ioctl handler */
struct l2tp_session *session = struct l2tp_session *session;
l2tp_session_get(sock_net(sk), tunnel,
stats.session_id);
session = l2tp_tunnel_get_session(tunnel,
stats.session_id);
if (!session) { if (!session) {
err = -EBADR; err = -EBADR;
break; break;
......
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