blob: fcb07915aaacc244bedc54f660b774c2550b85a5 [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
43/**
44 * struct tipc_dist_queue - queue holding deferred name table updates
45 */
46static struct list_head tipc_dist_queue = LIST_HEAD_INIT(tipc_dist_queue);
47
48struct distr_queue_item {
49 struct distr_item i;
50 u32 dtype;
51 u32 node;
52 unsigned long expires;
53 struct list_head next;
54};
55
Per Lidenb97bf3f2006-01-02 19:04:38 +010056/**
57 * publ_to_item - add publication info to a publication message
58 */
Per Lidenb97bf3f2006-01-02 19:04:38 +010059static void publ_to_item(struct distr_item *i, struct publication *p)
60{
61 i->type = htonl(p->type);
62 i->lower = htonl(p->lower);
63 i->upper = htonl(p->upper);
64 i->ref = htonl(p->ref);
65 i->key = htonl(p->key);
Per Lidenb97bf3f2006-01-02 19:04:38 +010066}
67
68/**
69 * named_prepare_buf - allocate & initialize a publication message
70 */
Ying Xue34747532015-01-09 15:27:10 +080071static struct sk_buff *named_prepare_buf(struct net *net, u32 type, u32 size,
72 u32 dest)
Per Lidenb97bf3f2006-01-02 19:04:38 +010073{
Jon Paul Maloyc5898632015-02-05 08:36:36 -050074 struct tipc_net *tn = net_generic(net, tipc_net_id);
Allan Stephens741d9eb2011-05-31 15:03:18 -040075 struct sk_buff *buf = tipc_buf_acquire(INT_H_SIZE + size);
Per Lidenb97bf3f2006-01-02 19:04:38 +010076 struct tipc_msg *msg;
77
78 if (buf != NULL) {
79 msg = buf_msg(buf);
Jon Paul Maloyc5898632015-02-05 08:36:36 -050080 tipc_msg_init(tn->own_addr, msg, NAME_DISTRIBUTOR, type,
81 INT_H_SIZE, dest);
Allan Stephens741d9eb2011-05-31 15:03:18 -040082 msg_set_size(msg, INT_H_SIZE + size);
Per Lidenb97bf3f2006-01-02 19:04:38 +010083 }
84 return buf;
85}
86
Ying Xuef2f98002015-01-09 15:27:05 +080087void named_cluster_distribute(struct net *net, struct sk_buff *skb)
Allan Stephens8f92df62010-12-31 18:59:19 +000088{
Ying Xuef2f98002015-01-09 15:27:05 +080089 struct tipc_net *tn = net_generic(net, tipc_net_id);
Ying Xuea6ca1092014-11-26 11:41:55 +080090 struct sk_buff *oskb;
Jon Paul Maloydbdf6d22014-07-16 20:40:58 -040091 struct tipc_node *node;
92 u32 dnode;
Allan Stephens8f92df62010-12-31 18:59:19 +000093
Ying Xue6c7a7622014-03-27 12:54:37 +080094 rcu_read_lock();
Ying Xuef2f98002015-01-09 15:27:05 +080095 list_for_each_entry_rcu(node, &tn->node_list, list) {
Jon Paul Maloydbdf6d22014-07-16 20:40:58 -040096 dnode = node->addr;
Ying Xue34747532015-01-09 15:27:10 +080097 if (in_own_node(net, dnode))
Jon Paul Maloydbdf6d22014-07-16 20:40:58 -040098 continue;
99 if (!tipc_node_active_links(node))
100 continue;
Ying Xuea6ca1092014-11-26 11:41:55 +0800101 oskb = skb_copy(skb, GFP_ATOMIC);
102 if (!oskb)
Jon Paul Maloydbdf6d22014-07-16 20:40:58 -0400103 break;
Ying Xuea6ca1092014-11-26 11:41:55 +0800104 msg_set_destnode(buf_msg(oskb), dnode);
Ying Xuef2f98002015-01-09 15:27:05 +0800105 tipc_link_xmit_skb(net, oskb, dnode, dnode);
Allan Stephens8f92df62010-12-31 18:59:19 +0000106 }
Ying Xue6c7a7622014-03-27 12:54:37 +0800107 rcu_read_unlock();
Allan Stephens8f92df62010-12-31 18:59:19 +0000108
Ying Xuea6ca1092014-11-26 11:41:55 +0800109 kfree_skb(skb);
Allan Stephens8f92df62010-12-31 18:59:19 +0000110}
111
Per Lidenb97bf3f2006-01-02 19:04:38 +0100112/**
Per Liden4323add2006-01-18 00:38:21 +0100113 * tipc_named_publish - tell other nodes about a new publication by this node
Per Lidenb97bf3f2006-01-02 19:04:38 +0100114 */
Ying Xue4ac1c8d2015-01-09 15:27:09 +0800115struct sk_buff *tipc_named_publish(struct net *net, struct publication *publ)
Per Lidenb97bf3f2006-01-02 19:04:38 +0100116{
Ying Xue4ac1c8d2015-01-09 15:27:09 +0800117 struct tipc_net *tn = net_generic(net, tipc_net_id);
Per Lidenb97bf3f2006-01-02 19:04:38 +0100118 struct sk_buff *buf;
119 struct distr_item *item;
120
Ying Xue97ede292014-12-02 15:00:30 +0800121 list_add_tail_rcu(&publ->local_list,
Ying Xue4ac1c8d2015-01-09 15:27:09 +0800122 &tn->nametbl->publ_list[publ->scope]);
Per Lidenb97bf3f2006-01-02 19:04:38 +0100123
Allan Stephens1110b8d2012-04-17 17:57:52 -0400124 if (publ->scope == TIPC_NODE_SCOPE)
Ying Xueeab8c0452014-04-28 18:00:10 +0800125 return NULL;
Allan Stephens1110b8d2012-04-17 17:57:52 -0400126
Ying Xue34747532015-01-09 15:27:10 +0800127 buf = named_prepare_buf(net, PUBLICATION, ITEM_SIZE, 0);
Per Lidenb97bf3f2006-01-02 19:04:38 +0100128 if (!buf) {
Erik Hugne2cf8aa12012-06-29 00:16:37 -0400129 pr_warn("Publication distribution failure\n");
Ying Xueeab8c0452014-04-28 18:00:10 +0800130 return NULL;
Per Lidenb97bf3f2006-01-02 19:04:38 +0100131 }
132
133 item = (struct distr_item *)msg_data(buf_msg(buf));
134 publ_to_item(item, publ);
Ying Xueeab8c0452014-04-28 18:00:10 +0800135 return buf;
Per Lidenb97bf3f2006-01-02 19:04:38 +0100136}
137
138/**
Per Liden4323add2006-01-18 00:38:21 +0100139 * tipc_named_withdraw - tell other nodes about a withdrawn publication by this node
Per Lidenb97bf3f2006-01-02 19:04:38 +0100140 */
Ying Xue34747532015-01-09 15:27:10 +0800141struct sk_buff *tipc_named_withdraw(struct net *net, struct publication *publ)
Per Lidenb97bf3f2006-01-02 19:04:38 +0100142{
143 struct sk_buff *buf;
144 struct distr_item *item;
145
146 list_del(&publ->local_list);
Per Lidenb97bf3f2006-01-02 19:04:38 +0100147
Allan Stephens1110b8d2012-04-17 17:57:52 -0400148 if (publ->scope == TIPC_NODE_SCOPE)
Ying Xueeab8c0452014-04-28 18:00:10 +0800149 return NULL;
Allan Stephens1110b8d2012-04-17 17:57:52 -0400150
Ying Xue34747532015-01-09 15:27:10 +0800151 buf = named_prepare_buf(net, WITHDRAWAL, ITEM_SIZE, 0);
Per Lidenb97bf3f2006-01-02 19:04:38 +0100152 if (!buf) {
Erik Hugne2cf8aa12012-06-29 00:16:37 -0400153 pr_warn("Withdrawal distribution failure\n");
Ying Xueeab8c0452014-04-28 18:00:10 +0800154 return NULL;
Per Lidenb97bf3f2006-01-02 19:04:38 +0100155 }
156
157 item = (struct distr_item *)msg_data(buf_msg(buf));
158 publ_to_item(item, publ);
Ying Xueeab8c0452014-04-28 18:00:10 +0800159 return buf;
Per Lidenb97bf3f2006-01-02 19:04:38 +0100160}
161
Jon Paul Maloydbdf6d22014-07-16 20:40:58 -0400162/**
Allan Stephense11aa052012-04-17 17:57:52 -0400163 * named_distribute - prepare name info for bulk distribution to another node
Ying Xuea6ca1092014-11-26 11:41:55 +0800164 * @list: list of messages (buffers) to be returned from this function
Jon Paul Maloydbdf6d22014-07-16 20:40:58 -0400165 * @dnode: node to be updated
166 * @pls: linked list of publication items to be packed into buffer chain
Allan Stephense11aa052012-04-17 17:57:52 -0400167 */
Ying Xuef2f98002015-01-09 15:27:05 +0800168static void named_distribute(struct net *net, struct sk_buff_head *list,
169 u32 dnode, struct list_head *pls)
Allan Stephense11aa052012-04-17 17:57:52 -0400170{
171 struct publication *publ;
Ying Xuea6ca1092014-11-26 11:41:55 +0800172 struct sk_buff *skb = NULL;
Allan Stephense11aa052012-04-17 17:57:52 -0400173 struct distr_item *item = NULL;
Ying Xuef2f98002015-01-09 15:27:05 +0800174 uint msg_dsz = (tipc_node_get_mtu(net, dnode, 0) / ITEM_SIZE) *
175 ITEM_SIZE;
Ying Xue1b61e702014-12-02 15:00:23 +0800176 uint msg_rem = msg_dsz;
Allan Stephense11aa052012-04-17 17:57:52 -0400177
Ying Xue993bfe52014-12-02 15:00:24 +0800178 list_for_each_entry(publ, pls, local_list) {
Jon Paul Maloydbdf6d22014-07-16 20:40:58 -0400179 /* Prepare next buffer: */
Ying Xuea6ca1092014-11-26 11:41:55 +0800180 if (!skb) {
Ying Xue34747532015-01-09 15:27:10 +0800181 skb = named_prepare_buf(net, PUBLICATION, msg_rem,
182 dnode);
Ying Xuea6ca1092014-11-26 11:41:55 +0800183 if (!skb) {
Erik Hugne2cf8aa12012-06-29 00:16:37 -0400184 pr_warn("Bulk publication failure\n");
Allan Stephense11aa052012-04-17 17:57:52 -0400185 return;
186 }
Ying Xuea6ca1092014-11-26 11:41:55 +0800187 item = (struct distr_item *)msg_data(buf_msg(skb));
Allan Stephense11aa052012-04-17 17:57:52 -0400188 }
Jon Paul Maloydbdf6d22014-07-16 20:40:58 -0400189
190 /* Pack publication into message: */
Allan Stephense11aa052012-04-17 17:57:52 -0400191 publ_to_item(item, publ);
192 item++;
Jon Paul Maloydbdf6d22014-07-16 20:40:58 -0400193 msg_rem -= ITEM_SIZE;
194
195 /* Append full buffer to list: */
196 if (!msg_rem) {
Ying Xuea6ca1092014-11-26 11:41:55 +0800197 __skb_queue_tail(list, skb);
198 skb = NULL;
Ying Xue1b61e702014-12-02 15:00:23 +0800199 msg_rem = msg_dsz;
Allan Stephense11aa052012-04-17 17:57:52 -0400200 }
201 }
Ying Xue1b61e702014-12-02 15:00:23 +0800202 if (skb) {
203 msg_set_size(buf_msg(skb), INT_H_SIZE + (msg_dsz - msg_rem));
204 skb_trim(skb, INT_H_SIZE + (msg_dsz - msg_rem));
205 __skb_queue_tail(list, skb);
206 }
Allan Stephense11aa052012-04-17 17:57:52 -0400207}
208
Per Lidenb97bf3f2006-01-02 19:04:38 +0100209/**
Per Liden4323add2006-01-18 00:38:21 +0100210 * tipc_named_node_up - tell specified node about all publications by this node
Per Lidenb97bf3f2006-01-02 19:04:38 +0100211 */
Ying Xuef2f98002015-01-09 15:27:05 +0800212void tipc_named_node_up(struct net *net, u32 dnode)
Per Lidenb97bf3f2006-01-02 19:04:38 +0100213{
Ying Xue4ac1c8d2015-01-09 15:27:09 +0800214 struct tipc_net *tn = net_generic(net, tipc_net_id);
Ying Xuea6ca1092014-11-26 11:41:55 +0800215 struct sk_buff_head head;
216
217 __skb_queue_head_init(&head);
Allan Stephens9aa88c22011-05-31 13:38:02 -0400218
Ying Xue97ede292014-12-02 15:00:30 +0800219 rcu_read_lock();
Ying Xuef2f98002015-01-09 15:27:05 +0800220 named_distribute(net, &head, dnode,
Ying Xue4ac1c8d2015-01-09 15:27:09 +0800221 &tn->nametbl->publ_list[TIPC_CLUSTER_SCOPE]);
Ying Xuef2f98002015-01-09 15:27:05 +0800222 named_distribute(net, &head, dnode,
Ying Xue4ac1c8d2015-01-09 15:27:09 +0800223 &tn->nametbl->publ_list[TIPC_ZONE_SCOPE]);
Ying Xue97ede292014-12-02 15:00:30 +0800224 rcu_read_unlock();
Allan Stephens9aa88c22011-05-31 13:38:02 -0400225
Ying Xuef2f98002015-01-09 15:27:05 +0800226 tipc_link_xmit(net, &head, dnode, dnode);
Per Lidenb97bf3f2006-01-02 19:04:38 +0100227}
228
Ying Xuef2f98002015-01-09 15:27:05 +0800229static void tipc_publ_subscribe(struct net *net, struct publication *publ,
230 u32 addr)
Ying Xuea8f48af2014-11-26 11:41:45 +0800231{
232 struct tipc_node *node;
233
Ying Xue34747532015-01-09 15:27:10 +0800234 if (in_own_node(net, addr))
Ying Xuea8f48af2014-11-26 11:41:45 +0800235 return;
236
Ying Xuef2f98002015-01-09 15:27:05 +0800237 node = tipc_node_find(net, addr);
Ying Xuea8f48af2014-11-26 11:41:45 +0800238 if (!node) {
239 pr_warn("Node subscription rejected, unknown node 0x%x\n",
240 addr);
241 return;
242 }
243
244 tipc_node_lock(node);
245 list_add_tail(&publ->nodesub_list, &node->publ_list);
246 tipc_node_unlock(node);
247}
248
Ying Xuef2f98002015-01-09 15:27:05 +0800249static void tipc_publ_unsubscribe(struct net *net, struct publication *publ,
250 u32 addr)
Ying Xuea8f48af2014-11-26 11:41:45 +0800251{
252 struct tipc_node *node;
253
Ying Xuef2f98002015-01-09 15:27:05 +0800254 node = tipc_node_find(net, addr);
Ying Xuea8f48af2014-11-26 11:41:45 +0800255 if (!node)
256 return;
257
258 tipc_node_lock(node);
259 list_del_init(&publ->nodesub_list);
260 tipc_node_unlock(node);
261}
262
Per Lidenb97bf3f2006-01-02 19:04:38 +0100263/**
Ying Xuea8f48af2014-11-26 11:41:45 +0800264 * tipc_publ_purge - remove publication associated with a failed node
YOSHIFUJI Hideakic4307282007-02-09 23:25:21 +0900265 *
266 * Invoked for each publication issued by a newly failed node.
Per Lidenb97bf3f2006-01-02 19:04:38 +0100267 * Removes publication structure from name table & deletes it.
Per Lidenb97bf3f2006-01-02 19:04:38 +0100268 */
Ying Xuef2f98002015-01-09 15:27:05 +0800269static void tipc_publ_purge(struct net *net, struct publication *publ, u32 addr)
Per Lidenb97bf3f2006-01-02 19:04:38 +0100270{
Ying Xue4ac1c8d2015-01-09 15:27:09 +0800271 struct tipc_net *tn = net_generic(net, tipc_net_id);
Per Lidenb97bf3f2006-01-02 19:04:38 +0100272 struct publication *p;
Allan Stephensf1310722006-06-25 23:51:37 -0700273
Ying Xue4ac1c8d2015-01-09 15:27:09 +0800274 spin_lock_bh(&tn->nametbl_lock);
275 p = tipc_nametbl_remove_publ(net, publ->type, publ->lower,
Per Liden4323add2006-01-18 00:38:21 +0100276 publ->node, publ->ref, publ->key);
Allan Stephens431697e2011-02-23 13:51:15 -0500277 if (p)
Ying Xuef2f98002015-01-09 15:27:05 +0800278 tipc_publ_unsubscribe(net, p, addr);
Ying Xue4ac1c8d2015-01-09 15:27:09 +0800279 spin_unlock_bh(&tn->nametbl_lock);
Allan Stephensf1310722006-06-25 23:51:37 -0700280
YOSHIFUJI Hideakic4307282007-02-09 23:25:21 +0900281 if (p != publ) {
Erik Hugne2cf8aa12012-06-29 00:16:37 -0400282 pr_err("Unable to remove publication from failed node\n"
283 " (type=%u, lower=%u, node=0x%x, ref=%u, key=%u)\n",
284 publ->type, publ->lower, publ->node, publ->ref,
285 publ->key);
Allan Stephensf1310722006-06-25 23:51:37 -0700286 }
287
Ying Xue97ede292014-12-02 15:00:30 +0800288 kfree_rcu(p, rcu);
Per Lidenb97bf3f2006-01-02 19:04:38 +0100289}
290
Ying Xuef2f98002015-01-09 15:27:05 +0800291void tipc_publ_notify(struct net *net, struct list_head *nsub_list, u32 addr)
Ying Xuea8f48af2014-11-26 11:41:45 +0800292{
293 struct publication *publ, *tmp;
294
295 list_for_each_entry_safe(publ, tmp, nsub_list, nodesub_list)
Ying Xuef2f98002015-01-09 15:27:05 +0800296 tipc_publ_purge(net, publ, addr);
Ying Xuea8f48af2014-11-26 11:41:45 +0800297}
298
Per Lidenb97bf3f2006-01-02 19:04:38 +0100299/**
Erik Hugnef4ad8a42014-08-28 09:08:46 +0200300 * tipc_update_nametbl - try to process a nametable update and notify
301 * subscribers
302 *
303 * tipc_nametbl_lock must be held.
304 * Returns the publication item if successful, otherwise NULL.
305 */
Ying Xuef2f98002015-01-09 15:27:05 +0800306static bool tipc_update_nametbl(struct net *net, struct distr_item *i,
307 u32 node, u32 dtype)
Erik Hugnef4ad8a42014-08-28 09:08:46 +0200308{
309 struct publication *publ = NULL;
310
311 if (dtype == PUBLICATION) {
Ying Xue4ac1c8d2015-01-09 15:27:09 +0800312 publ = tipc_nametbl_insert_publ(net, ntohl(i->type),
313 ntohl(i->lower),
Erik Hugnef4ad8a42014-08-28 09:08:46 +0200314 ntohl(i->upper),
315 TIPC_CLUSTER_SCOPE, node,
316 ntohl(i->ref), ntohl(i->key));
317 if (publ) {
Ying Xuef2f98002015-01-09 15:27:05 +0800318 tipc_publ_subscribe(net, publ, node);
Erik Hugne0fc4dff2014-09-10 14:02:50 +0200319 return true;
Erik Hugnef4ad8a42014-08-28 09:08:46 +0200320 }
321 } else if (dtype == WITHDRAWAL) {
Ying Xue4ac1c8d2015-01-09 15:27:09 +0800322 publ = tipc_nametbl_remove_publ(net, ntohl(i->type),
323 ntohl(i->lower),
Erik Hugnef4ad8a42014-08-28 09:08:46 +0200324 node, ntohl(i->ref),
325 ntohl(i->key));
326 if (publ) {
Ying Xuef2f98002015-01-09 15:27:05 +0800327 tipc_publ_unsubscribe(net, publ, node);
Ying Xue97ede292014-12-02 15:00:30 +0800328 kfree_rcu(publ, rcu);
Erik Hugne0fc4dff2014-09-10 14:02:50 +0200329 return true;
Erik Hugnef4ad8a42014-08-28 09:08:46 +0200330 }
331 } else {
332 pr_warn("Unrecognized name table message received\n");
333 }
Erik Hugne0fc4dff2014-09-10 14:02:50 +0200334 return false;
Erik Hugnef4ad8a42014-08-28 09:08:46 +0200335}
336
337/**
Erik Hugnea5325ae2014-08-28 09:08:47 +0200338 * tipc_named_add_backlog - add a failed name table update to the backlog
339 *
340 */
341static void tipc_named_add_backlog(struct distr_item *i, u32 type, u32 node)
342{
343 struct distr_queue_item *e;
344 unsigned long now = get_jiffies_64();
345
346 e = kzalloc(sizeof(*e), GFP_ATOMIC);
347 if (!e)
348 return;
349 e->dtype = type;
350 e->node = node;
351 e->expires = now + msecs_to_jiffies(sysctl_tipc_named_timeout);
352 memcpy(e, i, sizeof(*i));
353 list_add_tail(&e->next, &tipc_dist_queue);
354}
355
356/**
357 * tipc_named_process_backlog - try to process any pending name table updates
358 * from the network.
359 */
Ying Xuef2f98002015-01-09 15:27:05 +0800360void tipc_named_process_backlog(struct net *net)
Erik Hugnea5325ae2014-08-28 09:08:47 +0200361{
362 struct distr_queue_item *e, *tmp;
363 char addr[16];
364 unsigned long now = get_jiffies_64();
365
366 list_for_each_entry_safe(e, tmp, &tipc_dist_queue, next) {
367 if (time_after(e->expires, now)) {
Ying Xuef2f98002015-01-09 15:27:05 +0800368 if (!tipc_update_nametbl(net, &e->i, e->node, e->dtype))
Erik Hugnea5325ae2014-08-28 09:08:47 +0200369 continue;
370 } else {
371 tipc_addr_string_fill(addr, e->node);
372 pr_warn_ratelimited("Dropping name table update (%d) of {%u, %u, %u} from %s key=%u\n",
373 e->dtype, ntohl(e->i.type),
374 ntohl(e->i.lower),
375 ntohl(e->i.upper),
376 addr, ntohl(e->i.key));
377 }
378 list_del(&e->next);
379 kfree(e);
380 }
381}
382
383/**
Jon Paul Maloyc637c102015-02-05 08:36:41 -0500384 * tipc_named_rcv - process name table update messages sent by another node
Per Lidenb97bf3f2006-01-02 19:04:38 +0100385 */
Jon Paul Maloyc637c102015-02-05 08:36:41 -0500386void tipc_named_rcv(struct net *net, struct sk_buff_head *inputq)
Per Lidenb97bf3f2006-01-02 19:04:38 +0100387{
Ying Xue4ac1c8d2015-01-09 15:27:09 +0800388 struct tipc_net *tn = net_generic(net, tipc_net_id);
Jon Paul Maloyc637c102015-02-05 08:36:41 -0500389 struct tipc_msg *msg;
390 struct distr_item *item;
391 uint count;
392 u32 node;
393 struct sk_buff *skb;
394 int mtype;
Per Lidenb97bf3f2006-01-02 19:04:38 +0100395
Ying Xue4ac1c8d2015-01-09 15:27:09 +0800396 spin_lock_bh(&tn->nametbl_lock);
Jon Paul Maloyc637c102015-02-05 08:36:41 -0500397 for (skb = skb_dequeue(inputq); skb; skb = skb_dequeue(inputq)) {
398 msg = buf_msg(skb);
399 mtype = msg_type(msg);
400 item = (struct distr_item *)msg_data(msg);
401 count = msg_data_sz(msg) / ITEM_SIZE;
402 node = msg_orignode(msg);
403 while (count--) {
404 if (!tipc_update_nametbl(net, item, node, mtype))
405 tipc_named_add_backlog(item, mtype, node);
406 item++;
407 }
408 kfree_skb(skb);
409 tipc_named_process_backlog(net);
Per Lidenb97bf3f2006-01-02 19:04:38 +0100410 }
Ying Xue4ac1c8d2015-01-09 15:27:09 +0800411 spin_unlock_bh(&tn->nametbl_lock);
Per Lidenb97bf3f2006-01-02 19:04:38 +0100412}
413
414/**
Allan Stephens1110b8d2012-04-17 17:57:52 -0400415 * tipc_named_reinit - re-initialize local publications
YOSHIFUJI Hideakic4307282007-02-09 23:25:21 +0900416 *
Allan Stephens945af1c2011-10-14 14:42:25 -0400417 * This routine is called whenever TIPC networking is enabled.
Allan Stephens1110b8d2012-04-17 17:57:52 -0400418 * All name table entries published by this node are updated to reflect
419 * the node's new network address.
Per Lidenb97bf3f2006-01-02 19:04:38 +0100420 */
Ying Xue4ac1c8d2015-01-09 15:27:09 +0800421void tipc_named_reinit(struct net *net)
Per Lidenb97bf3f2006-01-02 19:04:38 +0100422{
Ying Xue4ac1c8d2015-01-09 15:27:09 +0800423 struct tipc_net *tn = net_generic(net, tipc_net_id);
Per Lidenb97bf3f2006-01-02 19:04:38 +0100424 struct publication *publ;
Allan Stephensa9098042012-04-17 17:57:52 -0400425 int scope;
Per Lidenb97bf3f2006-01-02 19:04:38 +0100426
Ying Xue4ac1c8d2015-01-09 15:27:09 +0800427 spin_lock_bh(&tn->nametbl_lock);
Allan Stephens945af1c2011-10-14 14:42:25 -0400428
Allan Stephens1110b8d2012-04-17 17:57:52 -0400429 for (scope = TIPC_ZONE_SCOPE; scope <= TIPC_NODE_SCOPE; scope++)
Ying Xue4ac1c8d2015-01-09 15:27:09 +0800430 list_for_each_entry_rcu(publ, &tn->nametbl->publ_list[scope],
Ying Xue97ede292014-12-02 15:00:30 +0800431 local_list)
Ying Xue34747532015-01-09 15:27:10 +0800432 publ->node = tn->own_addr;
Allan Stephens945af1c2011-10-14 14:42:25 -0400433
Ying Xue4ac1c8d2015-01-09 15:27:09 +0800434 spin_unlock_bh(&tn->nametbl_lock);
Per Lidenb97bf3f2006-01-02 19:04:38 +0100435}