blob: 4c54fb37875a89f3e4e05aafd994fff4865ec668 [file] [log] [blame]
Per Lidenb97bf3f2006-01-02 19:04:38 +01001/*
2 * net/tipc/name_distr.c: TIPC name distribution code
YOSHIFUJI Hideakic4307282007-02-09 23:25:21 +09003 *
Erik Hugnea5325ae2014-08-28 09:08:47 +02004 * Copyright (c) 2000-2006, 2014, Ericsson AB
Allan Stephens431697e2011-02-23 13:51:15 -05005 * Copyright (c) 2005, 2010-2011, 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"
Per Lidenb97bf3f2006-01-02 19:04:38 +010038#include "link.h"
Per Lidenb97bf3f2006-01-02 19:04:38 +010039#include "name_distr.h"
40
Erik Hugnea5325ae2014-08-28 09:08:47 +020041int sysctl_tipc_named_timeout __read_mostly = 2000;
42
Erik Hugnea5325ae2014-08-28 09:08:47 +020043struct distr_queue_item {
44 struct distr_item i;
45 u32 dtype;
46 u32 node;
47 unsigned long expires;
48 struct list_head next;
49};
50
Per Lidenb97bf3f2006-01-02 19:04:38 +010051/**
52 * publ_to_item - add publication info to a publication message
53 */
Per Lidenb97bf3f2006-01-02 19:04:38 +010054static void publ_to_item(struct distr_item *i, struct publication *p)
55{
56 i->type = htonl(p->type);
57 i->lower = htonl(p->lower);
58 i->upper = htonl(p->upper);
59 i->ref = htonl(p->ref);
60 i->key = htonl(p->key);
Per Lidenb97bf3f2006-01-02 19:04:38 +010061}
62
63/**
64 * named_prepare_buf - allocate & initialize a publication message
Parthasarathy Bhuvaragand2f394d2016-09-01 16:22:16 +020065 *
66 * The buffer returned is of size INT_H_SIZE + payload size
Per Lidenb97bf3f2006-01-02 19:04:38 +010067 */
Ying Xue34747532015-01-09 15:27:10 +080068static struct sk_buff *named_prepare_buf(struct net *net, u32 type, u32 size,
69 u32 dest)
Per Lidenb97bf3f2006-01-02 19:04:38 +010070{
Jon Paul Maloyc5898632015-02-05 08:36:36 -050071 struct tipc_net *tn = net_generic(net, tipc_net_id);
Parthasarathy Bhuvaragan57d5f642017-01-13 15:46:25 +010072 struct sk_buff *buf = tipc_buf_acquire(INT_H_SIZE + size, GFP_ATOMIC);
Per Lidenb97bf3f2006-01-02 19:04:38 +010073 struct tipc_msg *msg;
74
75 if (buf != NULL) {
76 msg = buf_msg(buf);
Jon Paul Maloyc5898632015-02-05 08:36:36 -050077 tipc_msg_init(tn->own_addr, msg, NAME_DISTRIBUTOR, type,
78 INT_H_SIZE, dest);
Allan Stephens741d9eb2011-05-31 15:03:18 -040079 msg_set_size(msg, INT_H_SIZE + size);
Per Lidenb97bf3f2006-01-02 19:04:38 +010080 }
81 return buf;
82}
83
84/**
Per Liden4323add2006-01-18 00:38:21 +010085 * tipc_named_publish - tell other nodes about a new publication by this node
Per Lidenb97bf3f2006-01-02 19:04:38 +010086 */
Ying Xue4ac1c8d2015-01-09 15:27:09 +080087struct sk_buff *tipc_named_publish(struct net *net, struct publication *publ)
Per Lidenb97bf3f2006-01-02 19:04:38 +010088{
Jon Maloy64a52b26d52018-03-15 16:48:52 +010089 struct name_table *nt = tipc_name_table(net);
Per Lidenb97bf3f2006-01-02 19:04:38 +010090 struct distr_item *item;
Jon Maloy64a52b26d52018-03-15 16:48:52 +010091 struct sk_buff *skb;
Per Lidenb97bf3f2006-01-02 19:04:38 +010092
Jon Maloy64a52b26d52018-03-15 16:48:52 +010093 if (publ->scope == TIPC_NODE_SCOPE) {
Jon Maloy935439c2018-03-15 16:48:54 +010094 list_add_tail_rcu(&publ->binding_node, &nt->node_scope);
Ying Xueeab8c0452014-04-28 18:00:10 +080095 return NULL;
Jon Maloy64a52b26d52018-03-15 16:48:52 +010096 }
Jon Maloy935439c2018-03-15 16:48:54 +010097 list_add_tail_rcu(&publ->binding_node, &nt->cluster_scope);
Allan Stephens1110b8d2012-04-17 17:57:52 -040098
Jon Maloy64a52b26d52018-03-15 16:48:52 +010099 skb = named_prepare_buf(net, PUBLICATION, ITEM_SIZE, 0);
100 if (!skb) {
Erik Hugne2cf8aa12012-06-29 00:16:37 -0400101 pr_warn("Publication distribution failure\n");
Ying Xueeab8c0452014-04-28 18:00:10 +0800102 return NULL;
Per Lidenb97bf3f2006-01-02 19:04:38 +0100103 }
104
Jon Maloy64a52b26d52018-03-15 16:48:52 +0100105 item = (struct distr_item *)msg_data(buf_msg(skb));
Per Lidenb97bf3f2006-01-02 19:04:38 +0100106 publ_to_item(item, publ);
Jon Maloy64a52b26d52018-03-15 16:48:52 +0100107 return skb;
Per Lidenb97bf3f2006-01-02 19:04:38 +0100108}
109
110/**
Per Liden4323add2006-01-18 00:38:21 +0100111 * tipc_named_withdraw - tell other nodes about a withdrawn publication by this node
Per Lidenb97bf3f2006-01-02 19:04:38 +0100112 */
Ying Xue34747532015-01-09 15:27:10 +0800113struct sk_buff *tipc_named_withdraw(struct net *net, struct publication *publ)
Per Lidenb97bf3f2006-01-02 19:04:38 +0100114{
115 struct sk_buff *buf;
116 struct distr_item *item;
117
Jon Maloy935439c2018-03-15 16:48:54 +0100118 list_del(&publ->binding_node);
Per Lidenb97bf3f2006-01-02 19:04:38 +0100119
Allan Stephens1110b8d2012-04-17 17:57:52 -0400120 if (publ->scope == TIPC_NODE_SCOPE)
Ying Xueeab8c0452014-04-28 18:00:10 +0800121 return NULL;
Allan Stephens1110b8d2012-04-17 17:57:52 -0400122
Ying Xue34747532015-01-09 15:27:10 +0800123 buf = named_prepare_buf(net, WITHDRAWAL, ITEM_SIZE, 0);
Per Lidenb97bf3f2006-01-02 19:04:38 +0100124 if (!buf) {
Erik Hugne2cf8aa12012-06-29 00:16:37 -0400125 pr_warn("Withdrawal distribution failure\n");
Ying Xueeab8c0452014-04-28 18:00:10 +0800126 return NULL;
Per Lidenb97bf3f2006-01-02 19:04:38 +0100127 }
128
129 item = (struct distr_item *)msg_data(buf_msg(buf));
130 publ_to_item(item, publ);
Ying Xueeab8c0452014-04-28 18:00:10 +0800131 return buf;
Per Lidenb97bf3f2006-01-02 19:04:38 +0100132}
133
Jon Paul Maloydbdf6d22014-07-16 20:40:58 -0400134/**
Allan Stephense11aa052012-04-17 17:57:52 -0400135 * named_distribute - prepare name info for bulk distribution to another node
Ying Xuea6ca1092014-11-26 11:41:55 +0800136 * @list: list of messages (buffers) to be returned from this function
Jon Paul Maloydbdf6d22014-07-16 20:40:58 -0400137 * @dnode: node to be updated
138 * @pls: linked list of publication items to be packed into buffer chain
Allan Stephense11aa052012-04-17 17:57:52 -0400139 */
Ying Xuef2f98002015-01-09 15:27:05 +0800140static void named_distribute(struct net *net, struct sk_buff_head *list,
141 u32 dnode, struct list_head *pls)
Allan Stephense11aa052012-04-17 17:57:52 -0400142{
143 struct publication *publ;
Ying Xuea6ca1092014-11-26 11:41:55 +0800144 struct sk_buff *skb = NULL;
Allan Stephense11aa052012-04-17 17:57:52 -0400145 struct distr_item *item = NULL;
Parthasarathy Bhuvaragand2f394d2016-09-01 16:22:16 +0200146 u32 msg_dsz = ((tipc_node_get_mtu(net, dnode, 0) - INT_H_SIZE) /
147 ITEM_SIZE) * ITEM_SIZE;
148 u32 msg_rem = msg_dsz;
Allan Stephense11aa052012-04-17 17:57:52 -0400149
Jon Maloy935439c2018-03-15 16:48:54 +0100150 list_for_each_entry(publ, pls, binding_node) {
Jon Paul Maloydbdf6d22014-07-16 20:40:58 -0400151 /* Prepare next buffer: */
Ying Xuea6ca1092014-11-26 11:41:55 +0800152 if (!skb) {
Ying Xue34747532015-01-09 15:27:10 +0800153 skb = named_prepare_buf(net, PUBLICATION, msg_rem,
154 dnode);
Ying Xuea6ca1092014-11-26 11:41:55 +0800155 if (!skb) {
Erik Hugne2cf8aa12012-06-29 00:16:37 -0400156 pr_warn("Bulk publication failure\n");
Allan Stephense11aa052012-04-17 17:57:52 -0400157 return;
158 }
Jon Paul Maloy06bd2b12016-10-27 18:51:55 -0400159 msg_set_bc_ack_invalid(buf_msg(skb), true);
Ying Xuea6ca1092014-11-26 11:41:55 +0800160 item = (struct distr_item *)msg_data(buf_msg(skb));
Allan Stephense11aa052012-04-17 17:57:52 -0400161 }
Jon Paul Maloydbdf6d22014-07-16 20:40:58 -0400162
163 /* Pack publication into message: */
Allan Stephense11aa052012-04-17 17:57:52 -0400164 publ_to_item(item, publ);
165 item++;
Jon Paul Maloydbdf6d22014-07-16 20:40:58 -0400166 msg_rem -= ITEM_SIZE;
167
168 /* Append full buffer to list: */
169 if (!msg_rem) {
Ying Xuea6ca1092014-11-26 11:41:55 +0800170 __skb_queue_tail(list, skb);
171 skb = NULL;
Ying Xue1b61e702014-12-02 15:00:23 +0800172 msg_rem = msg_dsz;
Allan Stephense11aa052012-04-17 17:57:52 -0400173 }
174 }
Ying Xue1b61e702014-12-02 15:00:23 +0800175 if (skb) {
176 msg_set_size(buf_msg(skb), INT_H_SIZE + (msg_dsz - msg_rem));
177 skb_trim(skb, INT_H_SIZE + (msg_dsz - msg_rem));
178 __skb_queue_tail(list, skb);
179 }
Allan Stephense11aa052012-04-17 17:57:52 -0400180}
181
Per Lidenb97bf3f2006-01-02 19:04:38 +0100182/**
Per Liden4323add2006-01-18 00:38:21 +0100183 * tipc_named_node_up - tell specified node about all publications by this node
Per Lidenb97bf3f2006-01-02 19:04:38 +0100184 */
Ying Xuef2f98002015-01-09 15:27:05 +0800185void tipc_named_node_up(struct net *net, u32 dnode)
Per Lidenb97bf3f2006-01-02 19:04:38 +0100186{
Jon Maloy64a52b26d52018-03-15 16:48:52 +0100187 struct name_table *nt = tipc_name_table(net);
Ying Xuea6ca1092014-11-26 11:41:55 +0800188 struct sk_buff_head head;
189
190 __skb_queue_head_init(&head);
Allan Stephens9aa88c22011-05-31 13:38:02 -0400191
Ying Xue97ede292014-12-02 15:00:30 +0800192 rcu_read_lock();
Jon Maloy64a52b26d52018-03-15 16:48:52 +0100193 named_distribute(net, &head, dnode, &nt->cluster_scope);
Ying Xue97ede292014-12-02 15:00:30 +0800194 rcu_read_unlock();
Allan Stephens9aa88c22011-05-31 13:38:02 -0400195
Jon Paul Maloyc49a0a842015-10-22 08:51:47 -0400196 tipc_node_xmit(net, &head, dnode, 0);
Per Lidenb97bf3f2006-01-02 19:04:38 +0100197}
198
199/**
Ying Xuea8f48af2014-11-26 11:41:45 +0800200 * tipc_publ_purge - remove publication associated with a failed node
YOSHIFUJI Hideakic4307282007-02-09 23:25:21 +0900201 *
202 * Invoked for each publication issued by a newly failed node.
Per Lidenb97bf3f2006-01-02 19:04:38 +0100203 * Removes publication structure from name table & deletes it.
Per Lidenb97bf3f2006-01-02 19:04:38 +0100204 */
Ying Xuef2f98002015-01-09 15:27:05 +0800205static void tipc_publ_purge(struct net *net, struct publication *publ, u32 addr)
Per Lidenb97bf3f2006-01-02 19:04:38 +0100206{
Ying Xue4ac1c8d2015-01-09 15:27:09 +0800207 struct tipc_net *tn = net_generic(net, tipc_net_id);
Per Lidenb97bf3f2006-01-02 19:04:38 +0100208 struct publication *p;
Allan Stephensf131072c2006-06-25 23:51:37 -0700209
Ying Xue4ac1c8d2015-01-09 15:27:09 +0800210 spin_lock_bh(&tn->nametbl_lock);
211 p = tipc_nametbl_remove_publ(net, publ->type, publ->lower,
Per Liden4323add2006-01-18 00:38:21 +0100212 publ->node, publ->ref, publ->key);
Allan Stephens431697e2011-02-23 13:51:15 -0500213 if (p)
Jon Maloy935439c2018-03-15 16:48:54 +0100214 tipc_node_unsubscribe(net, &p->binding_node, addr);
Ying Xue4ac1c8d2015-01-09 15:27:09 +0800215 spin_unlock_bh(&tn->nametbl_lock);
Allan Stephensf131072c2006-06-25 23:51:37 -0700216
YOSHIFUJI Hideakic4307282007-02-09 23:25:21 +0900217 if (p != publ) {
Erik Hugne2cf8aa12012-06-29 00:16:37 -0400218 pr_err("Unable to remove publication from failed node\n"
219 " (type=%u, lower=%u, node=0x%x, ref=%u, key=%u)\n",
220 publ->type, publ->lower, publ->node, publ->ref,
221 publ->key);
Allan Stephensf131072c2006-06-25 23:51:37 -0700222 }
223
Ying Xue97ede292014-12-02 15:00:30 +0800224 kfree_rcu(p, rcu);
Per Lidenb97bf3f2006-01-02 19:04:38 +0100225}
226
Erik Hugneddb1d332016-04-07 10:40:44 -0400227/**
228 * tipc_dist_queue_purge - remove deferred updates from a node that went down
229 */
230static void tipc_dist_queue_purge(struct net *net, u32 addr)
231{
232 struct tipc_net *tn = net_generic(net, tipc_net_id);
233 struct distr_queue_item *e, *tmp;
234
235 spin_lock_bh(&tn->nametbl_lock);
236 list_for_each_entry_safe(e, tmp, &tn->dist_queue, next) {
237 if (e->node != addr)
238 continue;
239 list_del(&e->next);
240 kfree(e);
241 }
242 spin_unlock_bh(&tn->nametbl_lock);
243}
244
Ying Xuef2f98002015-01-09 15:27:05 +0800245void tipc_publ_notify(struct net *net, struct list_head *nsub_list, u32 addr)
Ying Xuea8f48af2014-11-26 11:41:45 +0800246{
247 struct publication *publ, *tmp;
248
Jon Maloy935439c2018-03-15 16:48:54 +0100249 list_for_each_entry_safe(publ, tmp, nsub_list, binding_node)
Ying Xuef2f98002015-01-09 15:27:05 +0800250 tipc_publ_purge(net, publ, addr);
Erik Hugneddb1d332016-04-07 10:40:44 -0400251 tipc_dist_queue_purge(net, addr);
Ying Xuea8f48af2014-11-26 11:41:45 +0800252}
253
Per Lidenb97bf3f2006-01-02 19:04:38 +0100254/**
Erik Hugnef4ad8a42014-08-28 09:08:46 +0200255 * tipc_update_nametbl - try to process a nametable update and notify
256 * subscribers
257 *
258 * tipc_nametbl_lock must be held.
259 * Returns the publication item if successful, otherwise NULL.
260 */
Ying Xuef2f98002015-01-09 15:27:05 +0800261static bool tipc_update_nametbl(struct net *net, struct distr_item *i,
262 u32 node, u32 dtype)
Erik Hugnef4ad8a42014-08-28 09:08:46 +0200263{
264 struct publication *publ = NULL;
265
266 if (dtype == PUBLICATION) {
Ying Xue4ac1c8d2015-01-09 15:27:09 +0800267 publ = tipc_nametbl_insert_publ(net, ntohl(i->type),
268 ntohl(i->lower),
Erik Hugnef4ad8a42014-08-28 09:08:46 +0200269 ntohl(i->upper),
270 TIPC_CLUSTER_SCOPE, node,
271 ntohl(i->ref), ntohl(i->key));
272 if (publ) {
Jon Maloy935439c2018-03-15 16:48:54 +0100273 tipc_node_subscribe(net, &publ->binding_node, node);
Erik Hugne0fc4dff2014-09-10 14:02:50 +0200274 return true;
Erik Hugnef4ad8a42014-08-28 09:08:46 +0200275 }
276 } else if (dtype == WITHDRAWAL) {
Ying Xue4ac1c8d2015-01-09 15:27:09 +0800277 publ = tipc_nametbl_remove_publ(net, ntohl(i->type),
278 ntohl(i->lower),
Erik Hugnef4ad8a42014-08-28 09:08:46 +0200279 node, ntohl(i->ref),
280 ntohl(i->key));
281 if (publ) {
Jon Maloy935439c2018-03-15 16:48:54 +0100282 tipc_node_unsubscribe(net, &publ->binding_node, node);
Ying Xue97ede292014-12-02 15:00:30 +0800283 kfree_rcu(publ, rcu);
Erik Hugne0fc4dff2014-09-10 14:02:50 +0200284 return true;
Erik Hugnef4ad8a42014-08-28 09:08:46 +0200285 }
286 } else {
287 pr_warn("Unrecognized name table message received\n");
288 }
Erik Hugne0fc4dff2014-09-10 14:02:50 +0200289 return false;
Erik Hugnef4ad8a42014-08-28 09:08:46 +0200290}
291
292/**
Erik Hugnea5325ae2014-08-28 09:08:47 +0200293 * tipc_named_add_backlog - add a failed name table update to the backlog
294 *
295 */
Erik Hugne541726a2016-04-07 10:40:43 -0400296static void tipc_named_add_backlog(struct net *net, struct distr_item *i,
297 u32 type, u32 node)
Erik Hugnea5325ae2014-08-28 09:08:47 +0200298{
299 struct distr_queue_item *e;
Erik Hugne541726a2016-04-07 10:40:43 -0400300 struct tipc_net *tn = net_generic(net, tipc_net_id);
Erik Hugnea5325ae2014-08-28 09:08:47 +0200301 unsigned long now = get_jiffies_64();
302
303 e = kzalloc(sizeof(*e), GFP_ATOMIC);
304 if (!e)
305 return;
306 e->dtype = type;
307 e->node = node;
308 e->expires = now + msecs_to_jiffies(sysctl_tipc_named_timeout);
309 memcpy(e, i, sizeof(*i));
Erik Hugne541726a2016-04-07 10:40:43 -0400310 list_add_tail(&e->next, &tn->dist_queue);
Erik Hugnea5325ae2014-08-28 09:08:47 +0200311}
312
313/**
314 * tipc_named_process_backlog - try to process any pending name table updates
315 * from the network.
316 */
Ying Xuef2f98002015-01-09 15:27:05 +0800317void tipc_named_process_backlog(struct net *net)
Erik Hugnea5325ae2014-08-28 09:08:47 +0200318{
319 struct distr_queue_item *e, *tmp;
Erik Hugne541726a2016-04-07 10:40:43 -0400320 struct tipc_net *tn = net_generic(net, tipc_net_id);
Erik Hugnea5325ae2014-08-28 09:08:47 +0200321 char addr[16];
322 unsigned long now = get_jiffies_64();
323
Erik Hugne541726a2016-04-07 10:40:43 -0400324 list_for_each_entry_safe(e, tmp, &tn->dist_queue, next) {
Erik Hugnea5325ae2014-08-28 09:08:47 +0200325 if (time_after(e->expires, now)) {
Ying Xuef2f98002015-01-09 15:27:05 +0800326 if (!tipc_update_nametbl(net, &e->i, e->node, e->dtype))
Erik Hugnea5325ae2014-08-28 09:08:47 +0200327 continue;
328 } else {
329 tipc_addr_string_fill(addr, e->node);
330 pr_warn_ratelimited("Dropping name table update (%d) of {%u, %u, %u} from %s key=%u\n",
331 e->dtype, ntohl(e->i.type),
332 ntohl(e->i.lower),
333 ntohl(e->i.upper),
334 addr, ntohl(e->i.key));
335 }
336 list_del(&e->next);
337 kfree(e);
338 }
339}
340
341/**
Jon Paul Maloyc637c102015-02-05 08:36:41 -0500342 * tipc_named_rcv - process name table update messages sent by another node
Per Lidenb97bf3f2006-01-02 19:04:38 +0100343 */
Jon Paul Maloyc637c102015-02-05 08:36:41 -0500344void tipc_named_rcv(struct net *net, struct sk_buff_head *inputq)
Per Lidenb97bf3f2006-01-02 19:04:38 +0100345{
Ying Xue4ac1c8d2015-01-09 15:27:09 +0800346 struct tipc_net *tn = net_generic(net, tipc_net_id);
Jon Paul Maloyc637c102015-02-05 08:36:41 -0500347 struct tipc_msg *msg;
348 struct distr_item *item;
349 uint count;
350 u32 node;
351 struct sk_buff *skb;
352 int mtype;
Per Lidenb97bf3f2006-01-02 19:04:38 +0100353
Ying Xue4ac1c8d2015-01-09 15:27:09 +0800354 spin_lock_bh(&tn->nametbl_lock);
Jon Paul Maloyc637c102015-02-05 08:36:41 -0500355 for (skb = skb_dequeue(inputq); skb; skb = skb_dequeue(inputq)) {
Jon Paul Maloyc7cad0d2015-11-19 14:30:40 -0500356 skb_linearize(skb);
Jon Paul Maloyc637c102015-02-05 08:36:41 -0500357 msg = buf_msg(skb);
358 mtype = msg_type(msg);
359 item = (struct distr_item *)msg_data(msg);
360 count = msg_data_sz(msg) / ITEM_SIZE;
361 node = msg_orignode(msg);
362 while (count--) {
363 if (!tipc_update_nametbl(net, item, node, mtype))
Erik Hugne541726a2016-04-07 10:40:43 -0400364 tipc_named_add_backlog(net, item, mtype, node);
Jon Paul Maloyc637c102015-02-05 08:36:41 -0500365 item++;
366 }
367 kfree_skb(skb);
368 tipc_named_process_backlog(net);
Per Lidenb97bf3f2006-01-02 19:04:38 +0100369 }
Ying Xue4ac1c8d2015-01-09 15:27:09 +0800370 spin_unlock_bh(&tn->nametbl_lock);
Per Lidenb97bf3f2006-01-02 19:04:38 +0100371}
372
373/**
Allan Stephens1110b8d2012-04-17 17:57:52 -0400374 * tipc_named_reinit - re-initialize local publications
YOSHIFUJI Hideakic4307282007-02-09 23:25:21 +0900375 *
Allan Stephens945af1c2011-10-14 14:42:25 -0400376 * This routine is called whenever TIPC networking is enabled.
Allan Stephens1110b8d2012-04-17 17:57:52 -0400377 * All name table entries published by this node are updated to reflect
378 * the node's new network address.
Per Lidenb97bf3f2006-01-02 19:04:38 +0100379 */
Ying Xue4ac1c8d2015-01-09 15:27:09 +0800380void tipc_named_reinit(struct net *net)
Per Lidenb97bf3f2006-01-02 19:04:38 +0100381{
Jon Maloy64a52b26d52018-03-15 16:48:52 +0100382 struct name_table *nt = tipc_name_table(net);
383 struct tipc_net *tn = tipc_net(net);
Per Lidenb97bf3f2006-01-02 19:04:38 +0100384 struct publication *publ;
385
Ying Xue4ac1c8d2015-01-09 15:27:09 +0800386 spin_lock_bh(&tn->nametbl_lock);
Allan Stephens945af1c2011-10-14 14:42:25 -0400387
Jon Maloy935439c2018-03-15 16:48:54 +0100388 list_for_each_entry_rcu(publ, &nt->node_scope, binding_node)
Jon Maloy64a52b26d52018-03-15 16:48:52 +0100389 publ->node = tn->own_addr;
Jon Maloy935439c2018-03-15 16:48:54 +0100390 list_for_each_entry_rcu(publ, &nt->cluster_scope, binding_node)
Jon Maloy64a52b26d52018-03-15 16:48:52 +0100391 publ->node = tn->own_addr;
Allan Stephens945af1c2011-10-14 14:42:25 -0400392
Ying Xue4ac1c8d2015-01-09 15:27:09 +0800393 spin_unlock_bh(&tn->nametbl_lock);
Per Lidenb97bf3f2006-01-02 19:04:38 +0100394}