blob: eb3856bb8c5a3d81bb37b217a0c52b40baeaf3e3 [file] [log] [blame]
Per Lidenb97bf3f2006-01-02 19:04:38 +01001/*
2 * net/tipc/node.c: TIPC node management routines
YOSHIFUJI Hideakic4307282007-02-09 23:25:21 +09003 *
Jon Paul Maloy16e166b2014-06-25 20:41:33 -05004 * Copyright (c) 2000-2006, 2012-2014, Ericsson AB
Ying Xue46651c52014-03-27 12:54:36 +08005 * Copyright (c) 2005-2006, 2010-2014, Wind River Systems
Per Lidenb97bf3f2006-01-02 19:04:38 +01006 * All rights reserved.
7 *
Per Liden9ea1fd32006-01-11 13:30:43 +01008 * Redistribution and use in source and binary forms, with or without
Per Lidenb97bf3f2006-01-02 19:04:38 +01009 * modification, are permitted provided that the following conditions are met:
10 *
Per Liden9ea1fd32006-01-11 13:30:43 +010011 * 1. Redistributions of source code must retain the above copyright
12 * notice, this list of conditions and the following disclaimer.
13 * 2. Redistributions in binary form must reproduce the above copyright
14 * notice, this list of conditions and the following disclaimer in the
15 * documentation and/or other materials provided with the distribution.
16 * 3. Neither the names of the copyright holders nor the names of its
17 * contributors may be used to endorse or promote products derived from
18 * this software without specific prior written permission.
Per Lidenb97bf3f2006-01-02 19:04:38 +010019 *
Per Liden9ea1fd32006-01-11 13:30:43 +010020 * Alternatively, this software may be distributed under the terms of the
21 * GNU General Public License ("GPL") version 2 as published by the Free
22 * Software Foundation.
23 *
24 * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS IS"
25 * AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
26 * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
27 * ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT OWNER OR CONTRIBUTORS BE
28 * LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR
29 * CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF
30 * SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS
31 * INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN
32 * CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE)
33 * ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE
Per Lidenb97bf3f2006-01-02 19:04:38 +010034 * POSSIBILITY OF SUCH DAMAGE.
35 */
36
37#include "core.h"
Richard Alpe22ae7cf2015-02-09 09:50:18 +010038#include "link.h"
Per Lidenb97bf3f2006-01-02 19:04:38 +010039#include "node.h"
Per Lidenb97bf3f2006-01-02 19:04:38 +010040#include "name_distr.h"
Jon Paul Maloy50100a52014-08-22 18:09:07 -040041#include "socket.h"
Jon Paul Maloya6bf70f2015-05-14 10:46:13 -040042#include "bcast.h"
Per Lidenb97bf3f2006-01-02 19:04:38 +010043
David S. Miller6c000552008-09-02 23:38:32 -070044static void node_lost_contact(struct tipc_node *n_ptr);
45static void node_established_contact(struct tipc_node *n_ptr);
Ying Xue8a0f6eb2015-03-26 18:10:24 +080046static void tipc_node_delete(struct tipc_node *node);
Per Lidenb97bf3f2006-01-02 19:04:38 +010047
Jon Paul Maloy02be61a2014-08-22 18:09:08 -040048struct tipc_sock_conn {
49 u32 port;
50 u32 peer_port;
51 u32 peer_node;
52 struct list_head list;
53};
54
Richard Alpe3e4b6ab2014-11-20 10:29:17 +010055static const struct nla_policy tipc_nl_node_policy[TIPC_NLA_NODE_MAX + 1] = {
56 [TIPC_NLA_NODE_UNSPEC] = { .type = NLA_UNSPEC },
57 [TIPC_NLA_NODE_ADDR] = { .type = NLA_U32 },
58 [TIPC_NLA_NODE_UP] = { .type = NLA_FLAG }
59};
60
Allan Stephens1ec2bb02011-10-27 15:03:24 -040061/*
Allan Stephensa635b462011-11-04 11:54:43 -040062 * A trivial power-of-two bitmask technique is used for speed, since this
63 * operation is done for every incoming TIPC packet. The number of hash table
64 * entries has been chosen so that no hash chain exceeds 8 nodes and will
65 * usually be much smaller (typically only a single node).
66 */
Paul Gortmaker872f24d2012-04-23 04:49:13 +000067static unsigned int tipc_hashfn(u32 addr)
Allan Stephensa635b462011-11-04 11:54:43 -040068{
69 return addr & (NODE_HTABLE_SIZE - 1);
70}
71
Ying Xue8a0f6eb2015-03-26 18:10:24 +080072static void tipc_node_kref_release(struct kref *kref)
73{
74 struct tipc_node *node = container_of(kref, struct tipc_node, kref);
75
76 tipc_node_delete(node);
77}
78
79void tipc_node_put(struct tipc_node *node)
80{
81 kref_put(&node->kref, tipc_node_kref_release);
82}
83
84static void tipc_node_get(struct tipc_node *node)
85{
86 kref_get(&node->kref);
87}
88
Allan Stephensa635b462011-11-04 11:54:43 -040089/*
Allan Stephens672d99e2011-02-25 18:42:52 -050090 * tipc_node_find - locate specified node object, if it exists
91 */
Ying Xuef2f98002015-01-09 15:27:05 +080092struct tipc_node *tipc_node_find(struct net *net, u32 addr)
Allan Stephens672d99e2011-02-25 18:42:52 -050093{
Ying Xuef2f98002015-01-09 15:27:05 +080094 struct tipc_net *tn = net_generic(net, tipc_net_id);
Allan Stephens672d99e2011-02-25 18:42:52 -050095 struct tipc_node *node;
Allan Stephens672d99e2011-02-25 18:42:52 -050096
Ying Xue34747532015-01-09 15:27:10 +080097 if (unlikely(!in_own_cluster_exact(net, addr)))
Allan Stephens672d99e2011-02-25 18:42:52 -050098 return NULL;
99
Ying Xue6c7a7622014-03-27 12:54:37 +0800100 rcu_read_lock();
Ying Xuef2f98002015-01-09 15:27:05 +0800101 hlist_for_each_entry_rcu(node, &tn->node_htable[tipc_hashfn(addr)],
102 hash) {
Ying Xue46651c52014-03-27 12:54:36 +0800103 if (node->addr == addr) {
Ying Xue8a0f6eb2015-03-26 18:10:24 +0800104 tipc_node_get(node);
Ying Xue6c7a7622014-03-27 12:54:37 +0800105 rcu_read_unlock();
Allan Stephens672d99e2011-02-25 18:42:52 -0500106 return node;
Ying Xue46651c52014-03-27 12:54:36 +0800107 }
Allan Stephens672d99e2011-02-25 18:42:52 -0500108 }
Ying Xue6c7a7622014-03-27 12:54:37 +0800109 rcu_read_unlock();
Allan Stephens672d99e2011-02-25 18:42:52 -0500110 return NULL;
111}
112
Ying Xuef2f98002015-01-09 15:27:05 +0800113struct tipc_node *tipc_node_create(struct net *net, u32 addr)
Per Lidenb97bf3f2006-01-02 19:04:38 +0100114{
Ying Xuef2f98002015-01-09 15:27:05 +0800115 struct tipc_net *tn = net_generic(net, tipc_net_id);
Allan Stephens672d99e2011-02-25 18:42:52 -0500116 struct tipc_node *n_ptr, *temp_node;
Per Lidenb97bf3f2006-01-02 19:04:38 +0100117
Ying Xuef2f98002015-01-09 15:27:05 +0800118 spin_lock_bh(&tn->node_list_lock);
Jon Paul Maloyb45db712015-02-03 08:59:19 -0500119 n_ptr = tipc_node_find(net, addr);
120 if (n_ptr)
121 goto exit;
Allan Stephens5af54792010-12-31 18:59:23 +0000122 n_ptr = kzalloc(sizeof(*n_ptr), GFP_ATOMIC);
Allan Stephensa10bd922006-06-25 23:52:17 -0700123 if (!n_ptr) {
Erik Hugne2cf8aa12012-06-29 00:16:37 -0400124 pr_warn("Node creation failed, no memory\n");
Jon Paul Maloyb45db712015-02-03 08:59:19 -0500125 goto exit;
Allan Stephensa10bd922006-06-25 23:52:17 -0700126 }
Allan Stephensa10bd922006-06-25 23:52:17 -0700127 n_ptr->addr = addr;
Ying Xuef2f98002015-01-09 15:27:05 +0800128 n_ptr->net = net;
Ying Xue8a0f6eb2015-03-26 18:10:24 +0800129 kref_init(&n_ptr->kref);
Allan Stephens51a8e4d2010-12-31 18:59:18 +0000130 spin_lock_init(&n_ptr->lock);
Allan Stephens672d99e2011-02-25 18:42:52 -0500131 INIT_HLIST_NODE(&n_ptr->hash);
132 INIT_LIST_HEAD(&n_ptr->list);
Ying Xuea8f48af2014-11-26 11:41:45 +0800133 INIT_LIST_HEAD(&n_ptr->publ_list);
Jon Paul Maloy02be61a2014-08-22 18:09:08 -0400134 INIT_LIST_HEAD(&n_ptr->conn_sks);
Jon Paul Maloy05dcc5a2015-03-13 16:08:10 -0400135 __skb_queue_head_init(&n_ptr->bclink.deferdq);
Ying Xuef2f98002015-01-09 15:27:05 +0800136 hlist_add_head_rcu(&n_ptr->hash, &tn->node_htable[tipc_hashfn(addr)]);
Ying Xuef2f98002015-01-09 15:27:05 +0800137 list_for_each_entry_rcu(temp_node, &tn->node_list, list) {
Allan Stephens672d99e2011-02-25 18:42:52 -0500138 if (n_ptr->addr < temp_node->addr)
139 break;
140 }
Ying Xue6c7a7622014-03-27 12:54:37 +0800141 list_add_tail_rcu(&n_ptr->list, &temp_node->list);
Ying Xueaecb9bb2014-05-08 08:54:39 +0800142 n_ptr->action_flags = TIPC_WAIT_PEER_LINKS_DOWN;
Allan Stephensfc0eea62011-10-28 16:26:41 -0400143 n_ptr->signature = INVALID_NODE_SIG;
Ying Xue8a0f6eb2015-03-26 18:10:24 +0800144 tipc_node_get(n_ptr);
Jon Paul Maloyb45db712015-02-03 08:59:19 -0500145exit:
Ying Xuef2f98002015-01-09 15:27:05 +0800146 spin_unlock_bh(&tn->node_list_lock);
Per Lidenb97bf3f2006-01-02 19:04:38 +0100147 return n_ptr;
148}
149
Ying Xue8a0f6eb2015-03-26 18:10:24 +0800150static void tipc_node_delete(struct tipc_node *node)
Per Lidenb97bf3f2006-01-02 19:04:38 +0100151{
Ying Xue8a0f6eb2015-03-26 18:10:24 +0800152 list_del_rcu(&node->list);
153 hlist_del_rcu(&node->hash);
154 kfree_rcu(node, rcu);
Per Lidenb97bf3f2006-01-02 19:04:38 +0100155}
156
Ying Xuef2f98002015-01-09 15:27:05 +0800157void tipc_node_stop(struct net *net)
Ying Xue46651c52014-03-27 12:54:36 +0800158{
Ying Xuef2f98002015-01-09 15:27:05 +0800159 struct tipc_net *tn = net_generic(net, tipc_net_id);
Ying Xue46651c52014-03-27 12:54:36 +0800160 struct tipc_node *node, *t_node;
161
Ying Xuef2f98002015-01-09 15:27:05 +0800162 spin_lock_bh(&tn->node_list_lock);
163 list_for_each_entry_safe(node, t_node, &tn->node_list, list)
Ying Xue8a0f6eb2015-03-26 18:10:24 +0800164 tipc_node_put(node);
Ying Xuef2f98002015-01-09 15:27:05 +0800165 spin_unlock_bh(&tn->node_list_lock);
Ying Xue46651c52014-03-27 12:54:36 +0800166}
167
Ying Xuef2f98002015-01-09 15:27:05 +0800168int tipc_node_add_conn(struct net *net, u32 dnode, u32 port, u32 peer_port)
Jon Paul Maloy02be61a2014-08-22 18:09:08 -0400169{
170 struct tipc_node *node;
171 struct tipc_sock_conn *conn;
Ying Xue8a0f6eb2015-03-26 18:10:24 +0800172 int err = 0;
Jon Paul Maloy02be61a2014-08-22 18:09:08 -0400173
Ying Xue34747532015-01-09 15:27:10 +0800174 if (in_own_node(net, dnode))
Jon Paul Maloy02be61a2014-08-22 18:09:08 -0400175 return 0;
176
Ying Xuef2f98002015-01-09 15:27:05 +0800177 node = tipc_node_find(net, dnode);
Jon Paul Maloy02be61a2014-08-22 18:09:08 -0400178 if (!node) {
179 pr_warn("Connecting sock to node 0x%x failed\n", dnode);
180 return -EHOSTUNREACH;
181 }
182 conn = kmalloc(sizeof(*conn), GFP_ATOMIC);
Ying Xue8a0f6eb2015-03-26 18:10:24 +0800183 if (!conn) {
184 err = -EHOSTUNREACH;
185 goto exit;
186 }
Jon Paul Maloy02be61a2014-08-22 18:09:08 -0400187 conn->peer_node = dnode;
188 conn->port = port;
189 conn->peer_port = peer_port;
190
191 tipc_node_lock(node);
192 list_add_tail(&conn->list, &node->conn_sks);
193 tipc_node_unlock(node);
Ying Xue8a0f6eb2015-03-26 18:10:24 +0800194exit:
195 tipc_node_put(node);
196 return err;
Jon Paul Maloy02be61a2014-08-22 18:09:08 -0400197}
198
Ying Xuef2f98002015-01-09 15:27:05 +0800199void tipc_node_remove_conn(struct net *net, u32 dnode, u32 port)
Jon Paul Maloy02be61a2014-08-22 18:09:08 -0400200{
201 struct tipc_node *node;
202 struct tipc_sock_conn *conn, *safe;
203
Ying Xue34747532015-01-09 15:27:10 +0800204 if (in_own_node(net, dnode))
Jon Paul Maloy02be61a2014-08-22 18:09:08 -0400205 return;
206
Ying Xuef2f98002015-01-09 15:27:05 +0800207 node = tipc_node_find(net, dnode);
Jon Paul Maloy02be61a2014-08-22 18:09:08 -0400208 if (!node)
209 return;
210
211 tipc_node_lock(node);
212 list_for_each_entry_safe(conn, safe, &node->conn_sks, list) {
213 if (port != conn->port)
214 continue;
215 list_del(&conn->list);
216 kfree(conn);
217 }
218 tipc_node_unlock(node);
Ying Xue8a0f6eb2015-03-26 18:10:24 +0800219 tipc_node_put(node);
Jon Paul Maloy02be61a2014-08-22 18:09:08 -0400220}
221
Per Lidenb97bf3f2006-01-02 19:04:38 +0100222/**
Per Liden4323add2006-01-18 00:38:21 +0100223 * tipc_node_link_up - handle addition of link
YOSHIFUJI Hideakic4307282007-02-09 23:25:21 +0900224 *
Per Lidenb97bf3f2006-01-02 19:04:38 +0100225 * Link becomes active (alone or shared) or standby, depending on its priority.
226 */
Paul Gortmakera18c4bc2011-12-29 20:58:42 -0500227void tipc_node_link_up(struct tipc_node *n_ptr, struct tipc_link *l_ptr)
Per Lidenb97bf3f2006-01-02 19:04:38 +0100228{
Paul Gortmakera18c4bc2011-12-29 20:58:42 -0500229 struct tipc_link **active = &n_ptr->active_links[0];
Per Lidenb97bf3f2006-01-02 19:04:38 +0100230
Allan Stephens5392d642006-06-25 23:52:50 -0700231 n_ptr->working_links++;
Ying Xue7b8613e2014-10-20 14:44:25 +0800232 n_ptr->action_flags |= TIPC_NOTIFY_LINK_UP;
233 n_ptr->link_id = l_ptr->peer_bearer_id << 16 | l_ptr->bearer_id;
234
Erik Hugne3fa9cac2015-01-22 17:10:31 +0100235 pr_debug("Established link <%s> on network plane %c\n",
236 l_ptr->name, l_ptr->net_plane);
YOSHIFUJI Hideakic4307282007-02-09 23:25:21 +0900237
Per Lidenb97bf3f2006-01-02 19:04:38 +0100238 if (!active[0]) {
Per Lidenb97bf3f2006-01-02 19:04:38 +0100239 active[0] = active[1] = l_ptr;
240 node_established_contact(n_ptr);
Jon Paul Maloy16e166b2014-06-25 20:41:33 -0500241 goto exit;
Per Lidenb97bf3f2006-01-02 19:04:38 +0100242 }
YOSHIFUJI Hideakic4307282007-02-09 23:25:21 +0900243 if (l_ptr->priority < active[0]->priority) {
Erik Hugne3fa9cac2015-01-22 17:10:31 +0100244 pr_debug("New link <%s> becomes standby\n", l_ptr->name);
Jon Paul Maloy16e166b2014-06-25 20:41:33 -0500245 goto exit;
Per Lidenb97bf3f2006-01-02 19:04:38 +0100246 }
Ying Xue247f0f32014-02-18 16:06:46 +0800247 tipc_link_dup_queue_xmit(active[0], l_ptr);
YOSHIFUJI Hideakic4307282007-02-09 23:25:21 +0900248 if (l_ptr->priority == active[0]->priority) {
Per Lidenb97bf3f2006-01-02 19:04:38 +0100249 active[0] = l_ptr;
Jon Paul Maloy16e166b2014-06-25 20:41:33 -0500250 goto exit;
Per Lidenb97bf3f2006-01-02 19:04:38 +0100251 }
Erik Hugne3fa9cac2015-01-22 17:10:31 +0100252 pr_debug("Old link <%s> becomes standby\n", active[0]->name);
Allan Stephensa10bd922006-06-25 23:52:17 -0700253 if (active[1] != active[0])
Erik Hugne3fa9cac2015-01-22 17:10:31 +0100254 pr_debug("Old link <%s> becomes standby\n", active[1]->name);
Per Lidenb97bf3f2006-01-02 19:04:38 +0100255 active[0] = active[1] = l_ptr;
Jon Paul Maloy16e166b2014-06-25 20:41:33 -0500256exit:
257 /* Leave room for changeover header when returning 'mtu' to users: */
Jon Paul Maloyed193ec2015-04-02 09:33:02 -0400258 n_ptr->act_mtus[0] = active[0]->mtu - INT_H_SIZE;
259 n_ptr->act_mtus[1] = active[1]->mtu - INT_H_SIZE;
Per Lidenb97bf3f2006-01-02 19:04:38 +0100260}
261
262/**
263 * node_select_active_links - select active link
264 */
David S. Miller6c000552008-09-02 23:38:32 -0700265static void node_select_active_links(struct tipc_node *n_ptr)
Per Lidenb97bf3f2006-01-02 19:04:38 +0100266{
Paul Gortmakera18c4bc2011-12-29 20:58:42 -0500267 struct tipc_link **active = &n_ptr->active_links[0];
Per Lidenb97bf3f2006-01-02 19:04:38 +0100268 u32 i;
269 u32 highest_prio = 0;
270
YOSHIFUJI Hideakic4307282007-02-09 23:25:21 +0900271 active[0] = active[1] = NULL;
Per Lidenb97bf3f2006-01-02 19:04:38 +0100272
273 for (i = 0; i < MAX_BEARERS; i++) {
Paul Gortmakera18c4bc2011-12-29 20:58:42 -0500274 struct tipc_link *l_ptr = n_ptr->links[i];
Per Lidenb97bf3f2006-01-02 19:04:38 +0100275
Per Liden4323add2006-01-18 00:38:21 +0100276 if (!l_ptr || !tipc_link_is_up(l_ptr) ||
Per Lidenb97bf3f2006-01-02 19:04:38 +0100277 (l_ptr->priority < highest_prio))
278 continue;
279
280 if (l_ptr->priority > highest_prio) {
YOSHIFUJI Hideakic4307282007-02-09 23:25:21 +0900281 highest_prio = l_ptr->priority;
Per Lidenb97bf3f2006-01-02 19:04:38 +0100282 active[0] = active[1] = l_ptr;
283 } else {
284 active[1] = l_ptr;
285 }
286 }
287}
288
289/**
Per Liden4323add2006-01-18 00:38:21 +0100290 * tipc_node_link_down - handle loss of link
Per Lidenb97bf3f2006-01-02 19:04:38 +0100291 */
Paul Gortmakera18c4bc2011-12-29 20:58:42 -0500292void tipc_node_link_down(struct tipc_node *n_ptr, struct tipc_link *l_ptr)
Per Lidenb97bf3f2006-01-02 19:04:38 +0100293{
Ying Xue34747532015-01-09 15:27:10 +0800294 struct tipc_net *tn = net_generic(n_ptr->net, tipc_net_id);
Paul Gortmakera18c4bc2011-12-29 20:58:42 -0500295 struct tipc_link **active;
Per Lidenb97bf3f2006-01-02 19:04:38 +0100296
Allan Stephens5392d642006-06-25 23:52:50 -0700297 n_ptr->working_links--;
Ying Xue7b8613e2014-10-20 14:44:25 +0800298 n_ptr->action_flags |= TIPC_NOTIFY_LINK_DOWN;
299 n_ptr->link_id = l_ptr->peer_bearer_id << 16 | l_ptr->bearer_id;
Allan Stephens5392d642006-06-25 23:52:50 -0700300
Per Liden4323add2006-01-18 00:38:21 +0100301 if (!tipc_link_is_active(l_ptr)) {
Erik Hugne3fa9cac2015-01-22 17:10:31 +0100302 pr_debug("Lost standby link <%s> on network plane %c\n",
303 l_ptr->name, l_ptr->net_plane);
Per Lidenb97bf3f2006-01-02 19:04:38 +0100304 return;
305 }
Erik Hugne3fa9cac2015-01-22 17:10:31 +0100306 pr_debug("Lost link <%s> on network plane %c\n",
307 l_ptr->name, l_ptr->net_plane);
Per Lidenb97bf3f2006-01-02 19:04:38 +0100308
309 active = &n_ptr->active_links[0];
310 if (active[0] == l_ptr)
311 active[0] = active[1];
312 if (active[1] == l_ptr)
313 active[1] = active[0];
314 if (active[0] == l_ptr)
315 node_select_active_links(n_ptr);
YOSHIFUJI Hideakic4307282007-02-09 23:25:21 +0900316 if (tipc_node_is_up(n_ptr))
Jon Paul Maloy170b3922014-01-07 17:02:41 -0500317 tipc_link_failover_send_queue(l_ptr);
YOSHIFUJI Hideakic4307282007-02-09 23:25:21 +0900318 else
Per Lidenb97bf3f2006-01-02 19:04:38 +0100319 node_lost_contact(n_ptr);
Jon Paul Maloy16e166b2014-06-25 20:41:33 -0500320
321 /* Leave room for changeover header when returning 'mtu' to users: */
322 if (active[0]) {
Jon Paul Maloyed193ec2015-04-02 09:33:02 -0400323 n_ptr->act_mtus[0] = active[0]->mtu - INT_H_SIZE;
324 n_ptr->act_mtus[1] = active[1]->mtu - INT_H_SIZE;
Jon Paul Maloy16e166b2014-06-25 20:41:33 -0500325 return;
326 }
Jon Paul Maloy16e166b2014-06-25 20:41:33 -0500327 /* Loopback link went down? No fragmentation needed from now on. */
Ying Xue34747532015-01-09 15:27:10 +0800328 if (n_ptr->addr == tn->own_addr) {
Jon Paul Maloy16e166b2014-06-25 20:41:33 -0500329 n_ptr->act_mtus[0] = MAX_MSG_SIZE;
330 n_ptr->act_mtus[1] = MAX_MSG_SIZE;
331 }
Per Lidenb97bf3f2006-01-02 19:04:38 +0100332}
333
Paul Gortmaker8f19afb2011-02-28 11:36:21 -0400334int tipc_node_active_links(struct tipc_node *n_ptr)
Per Lidenb97bf3f2006-01-02 19:04:38 +0100335{
Allan Stephens76ae0d72010-08-17 11:00:12 +0000336 return n_ptr->active_links[0] != NULL;
Per Lidenb97bf3f2006-01-02 19:04:38 +0100337}
338
David S. Miller6c000552008-09-02 23:38:32 -0700339int tipc_node_is_up(struct tipc_node *n_ptr)
Per Lidenb97bf3f2006-01-02 19:04:38 +0100340{
Paul Gortmaker8f19afb2011-02-28 11:36:21 -0400341 return tipc_node_active_links(n_ptr);
Per Lidenb97bf3f2006-01-02 19:04:38 +0100342}
343
Paul Gortmakera18c4bc2011-12-29 20:58:42 -0500344void tipc_node_attach_link(struct tipc_node *n_ptr, struct tipc_link *l_ptr)
Per Lidenb97bf3f2006-01-02 19:04:38 +0100345{
Ying Xue7a2f7d12014-04-21 10:55:46 +0800346 n_ptr->links[l_ptr->bearer_id] = l_ptr;
Allan Stephens37b9c082011-02-28 11:32:27 -0500347 n_ptr->link_cnt++;
Per Lidenb97bf3f2006-01-02 19:04:38 +0100348}
349
Paul Gortmakera18c4bc2011-12-29 20:58:42 -0500350void tipc_node_detach_link(struct tipc_node *n_ptr, struct tipc_link *l_ptr)
Per Lidenb97bf3f2006-01-02 19:04:38 +0100351{
Jon Paul Maloy7d339392014-02-13 17:29:16 -0500352 int i;
353
354 for (i = 0; i < MAX_BEARERS; i++) {
Jon Paul Maloy074bb432014-02-14 16:40:43 -0500355 if (l_ptr != n_ptr->links[i])
356 continue;
357 n_ptr->links[i] = NULL;
Jon Paul Maloy074bb432014-02-14 16:40:43 -0500358 n_ptr->link_cnt--;
Jon Paul Maloy7d339392014-02-13 17:29:16 -0500359 }
Per Lidenb97bf3f2006-01-02 19:04:38 +0100360}
361
David S. Miller6c000552008-09-02 23:38:32 -0700362static void node_established_contact(struct tipc_node *n_ptr)
Per Lidenb97bf3f2006-01-02 19:04:38 +0100363{
Ying Xueaecb9bb2014-05-08 08:54:39 +0800364 n_ptr->action_flags |= TIPC_NOTIFY_NODE_UP;
Jon Maloyc64f7a62012-11-16 13:51:31 +0800365 n_ptr->bclink.oos_state = 0;
Ying Xue1da46562015-01-09 15:27:07 +0800366 n_ptr->bclink.acked = tipc_bclink_get_last_sent(n_ptr->net);
367 tipc_bclink_add_node(n_ptr->net, n_ptr->addr);
Per Lidenb97bf3f2006-01-02 19:04:38 +0100368}
369
David S. Miller6c000552008-09-02 23:38:32 -0700370static void node_lost_contact(struct tipc_node *n_ptr)
Per Lidenb97bf3f2006-01-02 19:04:38 +0100371{
Per Lidenb97bf3f2006-01-02 19:04:38 +0100372 char addr_string[16];
Jon Paul Maloy708ac322015-02-05 08:36:42 -0500373 struct tipc_sock_conn *conn, *safe;
374 struct list_head *conns = &n_ptr->conn_sks;
375 struct sk_buff *skb;
376 struct tipc_net *tn = net_generic(n_ptr->net, tipc_net_id);
377 uint i;
Per Lidenb97bf3f2006-01-02 19:04:38 +0100378
Erik Hugne3fa9cac2015-01-22 17:10:31 +0100379 pr_debug("Lost contact with %s\n",
380 tipc_addr_string_fill(addr_string, n_ptr->addr));
Allan Stephensc5bd4d82011-04-07 11:58:08 -0400381
382 /* Flush broadcast link info associated with lost node */
Ying Xue389dd9b2012-11-16 13:51:30 +0800383 if (n_ptr->bclink.recv_permitted) {
Jon Paul Maloy05dcc5a2015-03-13 16:08:10 -0400384 __skb_queue_purge(&n_ptr->bclink.deferdq);
Allan Stephensc5bd4d82011-04-07 11:58:08 -0400385
Jon Paul Maloy37e22162014-05-14 05:39:12 -0400386 if (n_ptr->bclink.reasm_buf) {
387 kfree_skb(n_ptr->bclink.reasm_buf);
388 n_ptr->bclink.reasm_buf = NULL;
Allan Stephensc5bd4d82011-04-07 11:58:08 -0400389 }
390
Ying Xue1da46562015-01-09 15:27:07 +0800391 tipc_bclink_remove_node(n_ptr->net, n_ptr->addr);
Allan Stephens365595912011-10-24 15:26:24 -0400392 tipc_bclink_acknowledge(n_ptr, INVALID_LINK_SEQ);
Per Lidenb97bf3f2006-01-02 19:04:38 +0100393
Ying Xue389dd9b2012-11-16 13:51:30 +0800394 n_ptr->bclink.recv_permitted = false;
Allan Stephensc5bd4d82011-04-07 11:58:08 -0400395 }
Per Lidenb97bf3f2006-01-02 19:04:38 +0100396
Jon Paul Maloydff29b12015-04-02 09:33:01 -0400397 /* Abort any ongoing link failover */
Per Lidenb97bf3f2006-01-02 19:04:38 +0100398 for (i = 0; i < MAX_BEARERS; i++) {
Paul Gortmakera18c4bc2011-12-29 20:58:42 -0500399 struct tipc_link *l_ptr = n_ptr->links[i];
YOSHIFUJI Hideakic4307282007-02-09 23:25:21 +0900400 if (!l_ptr)
Per Lidenb97bf3f2006-01-02 19:04:38 +0100401 continue;
Jon Paul Maloydff29b12015-04-02 09:33:01 -0400402 l_ptr->flags &= ~LINK_FAILINGOVER;
403 l_ptr->failover_checkpt = 0;
404 l_ptr->failover_pkts = 0;
405 kfree_skb(l_ptr->failover_skb);
406 l_ptr->failover_skb = NULL;
Per Liden4323add2006-01-18 00:38:21 +0100407 tipc_link_reset_fragments(l_ptr);
Per Lidenb97bf3f2006-01-02 19:04:38 +0100408 }
409
Ying Xueca9cf062014-05-08 08:54:40 +0800410 n_ptr->action_flags &= ~TIPC_WAIT_OWN_LINKS_DOWN;
411
Jon Paul Maloy708ac322015-02-05 08:36:42 -0500412 /* Prevent re-contact with node until cleanup is done */
413 n_ptr->action_flags |= TIPC_WAIT_PEER_LINKS_DOWN;
414
415 /* Notify publications from this node */
416 n_ptr->action_flags |= TIPC_NOTIFY_NODE_DOWN;
417
418 /* Notify sockets connected to node */
419 list_for_each_entry_safe(conn, safe, conns, list) {
420 skb = tipc_msg_create(TIPC_CRITICAL_IMPORTANCE, TIPC_CONN_MSG,
421 SHORT_H_SIZE, 0, tn->own_addr,
422 conn->peer_node, conn->port,
423 conn->peer_port, TIPC_ERR_NO_NODE);
424 if (likely(skb)) {
425 skb_queue_tail(n_ptr->inputq, skb);
426 n_ptr->action_flags |= TIPC_MSG_EVT;
427 }
428 list_del(&conn->list);
429 kfree(conn);
430 }
Per Lidenb97bf3f2006-01-02 19:04:38 +0100431}
432
Erik Hugne78acb1f2014-04-24 16:26:47 +0200433/**
434 * tipc_node_get_linkname - get the name of a link
435 *
436 * @bearer_id: id of the bearer
437 * @node: peer node address
438 * @linkname: link name output buffer
439 *
440 * Returns 0 on success
441 */
Ying Xuef2f98002015-01-09 15:27:05 +0800442int tipc_node_get_linkname(struct net *net, u32 bearer_id, u32 addr,
443 char *linkname, size_t len)
Erik Hugne78acb1f2014-04-24 16:26:47 +0200444{
445 struct tipc_link *link;
Ying Xue8a0f6eb2015-03-26 18:10:24 +0800446 int err = -EINVAL;
Ying Xuef2f98002015-01-09 15:27:05 +0800447 struct tipc_node *node = tipc_node_find(net, addr);
Erik Hugne78acb1f2014-04-24 16:26:47 +0200448
Ying Xue8a0f6eb2015-03-26 18:10:24 +0800449 if (!node)
450 return err;
451
452 if (bearer_id >= MAX_BEARERS)
453 goto exit;
454
Erik Hugne78acb1f2014-04-24 16:26:47 +0200455 tipc_node_lock(node);
456 link = node->links[bearer_id];
457 if (link) {
458 strncpy(linkname, link->name, len);
Ying Xue8a0f6eb2015-03-26 18:10:24 +0800459 err = 0;
Erik Hugne78acb1f2014-04-24 16:26:47 +0200460 }
Ying Xue8a0f6eb2015-03-26 18:10:24 +0800461exit:
Erik Hugne78acb1f2014-04-24 16:26:47 +0200462 tipc_node_unlock(node);
Ying Xue8a0f6eb2015-03-26 18:10:24 +0800463 tipc_node_put(node);
464 return err;
Erik Hugne78acb1f2014-04-24 16:26:47 +0200465}
Ying Xue9db9fdd2014-05-05 08:56:12 +0800466
467void tipc_node_unlock(struct tipc_node *node)
468{
Ying Xuef2f98002015-01-09 15:27:05 +0800469 struct net *net = node->net;
Ying Xueca0c4272014-05-05 08:56:14 +0800470 u32 addr = 0;
Jon Paul Maloyc637c102015-02-05 08:36:41 -0500471 u32 flags = node->action_flags;
Ying Xue7b8613e2014-10-20 14:44:25 +0800472 u32 link_id = 0;
Jon Paul Maloy708ac322015-02-05 08:36:42 -0500473 struct list_head *publ_list;
Jon Paul Maloyc637c102015-02-05 08:36:41 -0500474 struct sk_buff_head *inputq = node->inputq;
Jon Paul Maloy708ac322015-02-05 08:36:42 -0500475 struct sk_buff_head *namedq;
Ying Xue9db9fdd2014-05-05 08:56:12 +0800476
Jon Paul Maloyc637c102015-02-05 08:36:41 -0500477 if (likely(!flags || (flags == TIPC_MSG_EVT))) {
478 node->action_flags = 0;
Ying Xue9db9fdd2014-05-05 08:56:12 +0800479 spin_unlock_bh(&node->lock);
Jon Paul Maloyc637c102015-02-05 08:36:41 -0500480 if (flags == TIPC_MSG_EVT)
481 tipc_sk_rcv(net, inputq);
Ying Xue9db9fdd2014-05-05 08:56:12 +0800482 return;
483 }
484
Ying Xue7b8613e2014-10-20 14:44:25 +0800485 addr = node->addr;
486 link_id = node->link_id;
Jon Paul Maloyc637c102015-02-05 08:36:41 -0500487 namedq = node->namedq;
Jon Paul Maloy708ac322015-02-05 08:36:42 -0500488 publ_list = &node->publ_list;
Ying Xue7b8613e2014-10-20 14:44:25 +0800489
Jon Paul Maloycb1b7282015-02-05 08:36:44 -0500490 node->action_flags &= ~(TIPC_MSG_EVT |
491 TIPC_NOTIFY_NODE_DOWN | TIPC_NOTIFY_NODE_UP |
492 TIPC_NOTIFY_LINK_DOWN | TIPC_NOTIFY_LINK_UP |
493 TIPC_WAKEUP_BCAST_USERS | TIPC_BCAST_MSG_EVT |
Ying Xueb952b2b2015-03-26 18:10:23 +0800494 TIPC_NAMED_MSG_EVT | TIPC_BCAST_RESET);
Ying Xue7b8613e2014-10-20 14:44:25 +0800495
Ying Xue9db9fdd2014-05-05 08:56:12 +0800496 spin_unlock_bh(&node->lock);
497
Jon Paul Maloy708ac322015-02-05 08:36:42 -0500498 if (flags & TIPC_NOTIFY_NODE_DOWN)
499 tipc_publ_notify(net, publ_list, addr);
Jon Paul Maloy50100a52014-08-22 18:09:07 -0400500
Jon Maloy908344c2014-10-07 14:12:34 -0400501 if (flags & TIPC_WAKEUP_BCAST_USERS)
Ying Xuef2f98002015-01-09 15:27:05 +0800502 tipc_bclink_wakeup_users(net);
Jon Maloy908344c2014-10-07 14:12:34 -0400503
Ying Xue7b8613e2014-10-20 14:44:25 +0800504 if (flags & TIPC_NOTIFY_NODE_UP)
Ying Xuef2f98002015-01-09 15:27:05 +0800505 tipc_named_node_up(net, addr);
Ying Xue7b8613e2014-10-20 14:44:25 +0800506
507 if (flags & TIPC_NOTIFY_LINK_UP)
Ying Xuef2f98002015-01-09 15:27:05 +0800508 tipc_nametbl_publish(net, TIPC_LINK_STATE, addr, addr,
Ying Xue7b8613e2014-10-20 14:44:25 +0800509 TIPC_NODE_SCOPE, link_id, addr);
510
511 if (flags & TIPC_NOTIFY_LINK_DOWN)
Ying Xuef2f98002015-01-09 15:27:05 +0800512 tipc_nametbl_withdraw(net, TIPC_LINK_STATE, addr,
Ying Xue7b8613e2014-10-20 14:44:25 +0800513 link_id, addr);
Jon Paul Maloyc637c102015-02-05 08:36:41 -0500514
515 if (flags & TIPC_MSG_EVT)
516 tipc_sk_rcv(net, inputq);
517
518 if (flags & TIPC_NAMED_MSG_EVT)
519 tipc_named_rcv(net, namedq);
Jon Paul Maloycb1b7282015-02-05 08:36:44 -0500520
521 if (flags & TIPC_BCAST_MSG_EVT)
522 tipc_bclink_input(net);
Ying Xueb952b2b2015-03-26 18:10:23 +0800523
524 if (flags & TIPC_BCAST_RESET)
525 tipc_link_reset_all(node);
Ying Xue9db9fdd2014-05-05 08:56:12 +0800526}
Richard Alpe3e4b6ab2014-11-20 10:29:17 +0100527
528/* Caller should hold node lock for the passed node */
Richard Alped8182802014-11-24 11:10:29 +0100529static int __tipc_nl_add_node(struct tipc_nl_msg *msg, struct tipc_node *node)
Richard Alpe3e4b6ab2014-11-20 10:29:17 +0100530{
531 void *hdr;
532 struct nlattr *attrs;
533
Richard Alpebfb3e5d2015-02-09 09:50:03 +0100534 hdr = genlmsg_put(msg->skb, msg->portid, msg->seq, &tipc_genl_family,
Richard Alpe3e4b6ab2014-11-20 10:29:17 +0100535 NLM_F_MULTI, TIPC_NL_NODE_GET);
536 if (!hdr)
537 return -EMSGSIZE;
538
539 attrs = nla_nest_start(msg->skb, TIPC_NLA_NODE);
540 if (!attrs)
541 goto msg_full;
542
543 if (nla_put_u32(msg->skb, TIPC_NLA_NODE_ADDR, node->addr))
544 goto attr_msg_full;
545 if (tipc_node_is_up(node))
546 if (nla_put_flag(msg->skb, TIPC_NLA_NODE_UP))
547 goto attr_msg_full;
548
549 nla_nest_end(msg->skb, attrs);
550 genlmsg_end(msg->skb, hdr);
551
552 return 0;
553
554attr_msg_full:
555 nla_nest_cancel(msg->skb, attrs);
556msg_full:
557 genlmsg_cancel(msg->skb, hdr);
558
559 return -EMSGSIZE;
560}
561
562int tipc_nl_node_dump(struct sk_buff *skb, struct netlink_callback *cb)
563{
564 int err;
Ying Xuef2f98002015-01-09 15:27:05 +0800565 struct net *net = sock_net(skb->sk);
566 struct tipc_net *tn = net_generic(net, tipc_net_id);
Richard Alpe3e4b6ab2014-11-20 10:29:17 +0100567 int done = cb->args[0];
568 int last_addr = cb->args[1];
569 struct tipc_node *node;
570 struct tipc_nl_msg msg;
571
572 if (done)
573 return 0;
574
575 msg.skb = skb;
576 msg.portid = NETLINK_CB(cb->skb).portid;
577 msg.seq = cb->nlh->nlmsg_seq;
578
579 rcu_read_lock();
Ying Xue8a0f6eb2015-03-26 18:10:24 +0800580 if (last_addr) {
581 node = tipc_node_find(net, last_addr);
582 if (!node) {
583 rcu_read_unlock();
584 /* We never set seq or call nl_dump_check_consistent()
585 * this means that setting prev_seq here will cause the
586 * consistence check to fail in the netlink callback
587 * handler. Resulting in the NLMSG_DONE message having
588 * the NLM_F_DUMP_INTR flag set if the node state
589 * changed while we released the lock.
590 */
591 cb->prev_seq = 1;
592 return -EPIPE;
593 }
594 tipc_node_put(node);
Richard Alpe3e4b6ab2014-11-20 10:29:17 +0100595 }
596
Ying Xuef2f98002015-01-09 15:27:05 +0800597 list_for_each_entry_rcu(node, &tn->node_list, list) {
Richard Alpe3e4b6ab2014-11-20 10:29:17 +0100598 if (last_addr) {
599 if (node->addr == last_addr)
600 last_addr = 0;
601 else
602 continue;
603 }
604
605 tipc_node_lock(node);
606 err = __tipc_nl_add_node(&msg, node);
607 if (err) {
608 last_addr = node->addr;
609 tipc_node_unlock(node);
610 goto out;
611 }
612
613 tipc_node_unlock(node);
614 }
615 done = 1;
616out:
617 cb->args[0] = done;
618 cb->args[1] = last_addr;
619 rcu_read_unlock();
620
621 return skb->len;
622}