Commit 0d051bf9 authored by Jon Paul Maloy's avatar Jon Paul Maloy Committed by David S. Miller

tipc: make bearer packet filtering generic

In commit 5b7066c3 ("tipc: stricter filtering of packets in bearer
layer") we introduced a method of filtering out messages while a bearer
is being reset, to avoid that links may be re-created and come back in
working state while we are still in the process of shutting them down.

This solution works well, but is limited to only work with L2 media, which
is insufficient with the increasing use of UDP as carrier media.

We now replace this solution with a more generic one, by introducing a
new flag "up" in the generic struct tipc_bearer. This field will be set
and reset at the same locations as with the previous solution, while
the packet filtering is moved to the generic code for the sending side.
On the receiving side, the filtering is still done in media specific
code, but now including the UDP bearer.
Acked-by: default avatarYing Xue <ying.xue@windriver.com>
Signed-off-by: default avatarJon Maloy <jon.maloy@ericsson.com>
Signed-off-by: default avatarDavid S. Miller <davem@davemloft.net>
parent 37bd91d1
...@@ -56,6 +56,13 @@ static struct tipc_media * const media_info_array[] = { ...@@ -56,6 +56,13 @@ static struct tipc_media * const media_info_array[] = {
NULL NULL
}; };
static struct tipc_bearer *bearer_get(struct net *net, int bearer_id)
{
struct tipc_net *tn = tipc_net(net);
return rcu_dereference_rtnl(tn->bearer_list[bearer_id]);
}
static void bearer_disable(struct net *net, struct tipc_bearer *b); static void bearer_disable(struct net *net, struct tipc_bearer *b);
/** /**
...@@ -323,6 +330,7 @@ static int tipc_enable_bearer(struct net *net, const char *name, ...@@ -323,6 +330,7 @@ static int tipc_enable_bearer(struct net *net, const char *name,
b->domain = disc_domain; b->domain = disc_domain;
b->net_plane = bearer_id + 'A'; b->net_plane = bearer_id + 'A';
b->priority = priority; b->priority = priority;
test_and_set_bit_lock(0, &b->up);
res = tipc_disc_create(net, b, &b->bcast_addr, &skb); res = tipc_disc_create(net, b, &b->bcast_addr, &skb);
if (res) { if (res) {
...@@ -360,15 +368,24 @@ static int tipc_reset_bearer(struct net *net, struct tipc_bearer *b) ...@@ -360,15 +368,24 @@ static int tipc_reset_bearer(struct net *net, struct tipc_bearer *b)
*/ */
void tipc_bearer_reset_all(struct net *net) void tipc_bearer_reset_all(struct net *net)
{ {
struct tipc_net *tn = tipc_net(net);
struct tipc_bearer *b; struct tipc_bearer *b;
int i; int i;
for (i = 0; i < MAX_BEARERS; i++) { for (i = 0; i < MAX_BEARERS; i++) {
b = rcu_dereference_rtnl(tn->bearer_list[i]); b = bearer_get(net, i);
if (b)
clear_bit_unlock(0, &b->up);
}
for (i = 0; i < MAX_BEARERS; i++) {
b = bearer_get(net, i);
if (b) if (b)
tipc_reset_bearer(net, b); tipc_reset_bearer(net, b);
} }
for (i = 0; i < MAX_BEARERS; i++) {
b = bearer_get(net, i);
if (b)
test_and_set_bit_lock(0, &b->up);
}
} }
/** /**
...@@ -382,8 +399,9 @@ static void bearer_disable(struct net *net, struct tipc_bearer *b) ...@@ -382,8 +399,9 @@ static void bearer_disable(struct net *net, struct tipc_bearer *b)
int bearer_id = b->identity; int bearer_id = b->identity;
pr_info("Disabling bearer <%s>\n", b->name); pr_info("Disabling bearer <%s>\n", b->name);
b->media->disable_media(b); clear_bit_unlock(0, &b->up);
tipc_node_delete_links(net, bearer_id); tipc_node_delete_links(net, bearer_id);
b->media->disable_media(b);
RCU_INIT_POINTER(b->media_ptr, NULL); RCU_INIT_POINTER(b->media_ptr, NULL);
if (b->link_req) if (b->link_req)
tipc_disc_delete(b->link_req); tipc_disc_delete(b->link_req);
...@@ -440,22 +458,16 @@ int tipc_l2_send_msg(struct net *net, struct sk_buff *skb, ...@@ -440,22 +458,16 @@ int tipc_l2_send_msg(struct net *net, struct sk_buff *skb,
{ {
struct net_device *dev; struct net_device *dev;
int delta; int delta;
void *tipc_ptr;
dev = (struct net_device *)rcu_dereference_rtnl(b->media_ptr); dev = (struct net_device *)rcu_dereference_rtnl(b->media_ptr);
if (!dev) if (!dev)
return 0; return 0;
/* Send RESET message even if bearer is detached from device */ delta = SKB_DATA_ALIGN(dev->hard_header_len - skb_headroom(skb));
tipc_ptr = rcu_dereference_rtnl(dev->tipc_ptr); if ((delta > 0) && pskb_expand_head(skb, delta, 0, GFP_ATOMIC)) {
if (unlikely(!tipc_ptr && !msg_is_reset(buf_msg(skb)))) kfree_skb(skb);
goto drop; return 0;
}
delta = dev->hard_header_len - skb_headroom(skb);
if ((delta > 0) &&
pskb_expand_head(skb, SKB_DATA_ALIGN(delta), 0, GFP_ATOMIC))
goto drop;
skb_reset_network_header(skb); skb_reset_network_header(skb);
skb->dev = dev; skb->dev = dev;
skb->protocol = htons(ETH_P_TIPC); skb->protocol = htons(ETH_P_TIPC);
...@@ -463,9 +475,6 @@ int tipc_l2_send_msg(struct net *net, struct sk_buff *skb, ...@@ -463,9 +475,6 @@ int tipc_l2_send_msg(struct net *net, struct sk_buff *skb,
dev->dev_addr, skb->len); dev->dev_addr, skb->len);
dev_queue_xmit(skb); dev_queue_xmit(skb);
return 0; return 0;
drop:
kfree_skb(skb);
return 0;
} }
int tipc_bearer_mtu(struct net *net, u32 bearer_id) int tipc_bearer_mtu(struct net *net, u32 bearer_id)
...@@ -487,12 +496,12 @@ void tipc_bearer_xmit_skb(struct net *net, u32 bearer_id, ...@@ -487,12 +496,12 @@ void tipc_bearer_xmit_skb(struct net *net, u32 bearer_id,
struct sk_buff *skb, struct sk_buff *skb,
struct tipc_media_addr *dest) struct tipc_media_addr *dest)
{ {
struct tipc_net *tn = tipc_net(net); struct tipc_msg *hdr = buf_msg(skb);
struct tipc_bearer *b; struct tipc_bearer *b;
rcu_read_lock(); rcu_read_lock();
b = rcu_dereference_rtnl(tn->bearer_list[bearer_id]); b = bearer_get(net, bearer_id);
if (likely(b)) if (likely(b && (test_bit(0, &b->up) || msg_is_reset(hdr))))
b->media->send_msg(net, skb, b, dest); b->media->send_msg(net, skb, b, dest);
else else
kfree_skb(skb); kfree_skb(skb);
...@@ -505,7 +514,6 @@ void tipc_bearer_xmit(struct net *net, u32 bearer_id, ...@@ -505,7 +514,6 @@ void tipc_bearer_xmit(struct net *net, u32 bearer_id,
struct sk_buff_head *xmitq, struct sk_buff_head *xmitq,
struct tipc_media_addr *dst) struct tipc_media_addr *dst)
{ {
struct tipc_net *tn = net_generic(net, tipc_net_id);
struct tipc_bearer *b; struct tipc_bearer *b;
struct sk_buff *skb, *tmp; struct sk_buff *skb, *tmp;
...@@ -513,12 +521,15 @@ void tipc_bearer_xmit(struct net *net, u32 bearer_id, ...@@ -513,12 +521,15 @@ void tipc_bearer_xmit(struct net *net, u32 bearer_id,
return; return;
rcu_read_lock(); rcu_read_lock();
b = rcu_dereference_rtnl(tn->bearer_list[bearer_id]); b = bearer_get(net, bearer_id);
if (unlikely(!b)) if (unlikely(!b))
__skb_queue_purge(xmitq); __skb_queue_purge(xmitq);
skb_queue_walk_safe(xmitq, skb, tmp) { skb_queue_walk_safe(xmitq, skb, tmp) {
__skb_dequeue(xmitq); __skb_dequeue(xmitq);
b->media->send_msg(net, skb, b, dst); if (likely(test_bit(0, &b->up) || msg_is_reset(buf_msg(skb))))
b->media->send_msg(net, skb, b, dst);
else
kfree(skb);
} }
rcu_read_unlock(); rcu_read_unlock();
} }
...@@ -535,8 +546,8 @@ void tipc_bearer_bc_xmit(struct net *net, u32 bearer_id, ...@@ -535,8 +546,8 @@ void tipc_bearer_bc_xmit(struct net *net, u32 bearer_id,
struct tipc_msg *hdr; struct tipc_msg *hdr;
rcu_read_lock(); rcu_read_lock();
b = rcu_dereference_rtnl(tn->bearer_list[bearer_id]); b = bearer_get(net, bearer_id);
if (unlikely(!b)) if (unlikely(!b || !test_bit(0, &b->up)))
__skb_queue_purge(xmitq); __skb_queue_purge(xmitq);
skb_queue_walk_safe(xmitq, skb, tmp) { skb_queue_walk_safe(xmitq, skb, tmp) {
hdr = buf_msg(skb); hdr = buf_msg(skb);
...@@ -566,7 +577,8 @@ static int tipc_l2_rcv_msg(struct sk_buff *skb, struct net_device *dev, ...@@ -566,7 +577,8 @@ static int tipc_l2_rcv_msg(struct sk_buff *skb, struct net_device *dev,
rcu_read_lock(); rcu_read_lock();
b = rcu_dereference_rtnl(dev->tipc_ptr); b = rcu_dereference_rtnl(dev->tipc_ptr);
if (likely(b && (skb->pkt_type <= PACKET_BROADCAST))) { if (likely(b && test_bit(0, &b->up) &&
(skb->pkt_type <= PACKET_BROADCAST))) {
skb->next = NULL; skb->next = NULL;
tipc_rcv(dev_net(dev), skb, b); tipc_rcv(dev_net(dev), skb, b);
rcu_read_unlock(); rcu_read_unlock();
...@@ -591,18 +603,9 @@ static int tipc_l2_device_event(struct notifier_block *nb, unsigned long evt, ...@@ -591,18 +603,9 @@ static int tipc_l2_device_event(struct notifier_block *nb, unsigned long evt,
{ {
struct net_device *dev = netdev_notifier_info_to_dev(ptr); struct net_device *dev = netdev_notifier_info_to_dev(ptr);
struct net *net = dev_net(dev); struct net *net = dev_net(dev);
struct tipc_net *tn = tipc_net(net);
struct tipc_bearer *b; struct tipc_bearer *b;
int i;
b = rtnl_dereference(dev->tipc_ptr); b = rtnl_dereference(dev->tipc_ptr);
if (!b) {
for (i = 0; i < MAX_BEARERS; b = NULL, i++) {
b = rtnl_dereference(tn->bearer_list[i]);
if (b && (b->media_ptr == dev))
break;
}
}
if (!b) if (!b)
return NOTIFY_DONE; return NOTIFY_DONE;
...@@ -613,11 +616,10 @@ static int tipc_l2_device_event(struct notifier_block *nb, unsigned long evt, ...@@ -613,11 +616,10 @@ static int tipc_l2_device_event(struct notifier_block *nb, unsigned long evt,
if (netif_carrier_ok(dev)) if (netif_carrier_ok(dev))
break; break;
case NETDEV_UP: case NETDEV_UP:
rcu_assign_pointer(dev->tipc_ptr, b); test_and_set_bit_lock(0, &b->up);
break; break;
case NETDEV_GOING_DOWN: case NETDEV_GOING_DOWN:
RCU_INIT_POINTER(dev->tipc_ptr, NULL); clear_bit_unlock(0, &b->up);
synchronize_net();
tipc_reset_bearer(net, b); tipc_reset_bearer(net, b);
break; break;
case NETDEV_CHANGEMTU: case NETDEV_CHANGEMTU:
......
...@@ -150,6 +150,7 @@ struct tipc_bearer { ...@@ -150,6 +150,7 @@ struct tipc_bearer {
u32 identity; u32 identity;
struct tipc_link_req *link_req; struct tipc_link_req *link_req;
char net_plane; char net_plane;
unsigned long up;
}; };
struct tipc_bearer_names { struct tipc_bearer_names {
......
...@@ -224,7 +224,7 @@ static int tipc_udp_recv(struct sock *sk, struct sk_buff *skb) ...@@ -224,7 +224,7 @@ static int tipc_udp_recv(struct sock *sk, struct sk_buff *skb)
rcu_read_lock(); rcu_read_lock();
b = rcu_dereference_rtnl(ub->bearer); b = rcu_dereference_rtnl(ub->bearer);
if (b) { if (b && test_bit(0, &b->up)) {
tipc_rcv(sock_net(sk), skb, b); tipc_rcv(sock_net(sk), skb, b);
rcu_read_unlock(); rcu_read_unlock();
return 0; return 0;
......
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