~ [ source navigation ] ~ [ diff markup ] ~ [ identifier search ] ~

TOMOYO Linux Cross Reference
Linux/net/tipc/eth_media.c

Version: ~ [ linux-5.1-rc1 ] ~ [ linux-5.0.3 ] ~ [ linux-4.20.17 ] ~ [ linux-4.19.30 ] ~ [ linux-4.18.20 ] ~ [ linux-4.17.19 ] ~ [ linux-4.16.18 ] ~ [ linux-4.15.18 ] ~ [ linux-4.14.107 ] ~ [ linux-4.13.16 ] ~ [ linux-4.12.14 ] ~ [ linux-4.11.12 ] ~ [ linux-4.10.17 ] ~ [ linux-4.9.164 ] ~ [ linux-4.8.17 ] ~ [ linux-4.7.10 ] ~ [ linux-4.6.7 ] ~ [ linux-4.5.7 ] ~ [ linux-4.4.176 ] ~ [ linux-4.3.6 ] ~ [ linux-4.2.8 ] ~ [ linux-4.1.52 ] ~ [ linux-4.0.9 ] ~ [ linux-3.19.8 ] ~ [ linux-3.18.136 ] ~ [ linux-3.17.8 ] ~ [ linux-3.16.63 ] ~ [ linux-3.15.10 ] ~ [ linux-3.14.79 ] ~ [ linux-3.13.11 ] ~ [ linux-3.12.74 ] ~ [ linux-3.11.10 ] ~ [ linux-3.10.108 ] ~ [ linux-3.9.11 ] ~ [ linux-3.8.13 ] ~ [ linux-3.7.10 ] ~ [ linux-3.6.11 ] ~ [ linux-3.5.7 ] ~ [ linux-3.4.113 ] ~ [ linux-3.3.8 ] ~ [ linux-3.2.102 ] ~ [ linux-3.1.10 ] ~ [ linux-3.0.101 ] ~ [ linux-2.6.39.4 ] ~ [ linux-2.6.38.8 ] ~ [ linux-2.6.37.6 ] ~ [ linux-2.6.36.4 ] ~ [ linux-2.6.35.14 ] ~ [ linux-2.6.34.15 ] ~ [ linux-2.6.33.20 ] ~ [ linux-2.6.32.71 ] ~ [ linux-2.6.0 ] ~ [ linux-2.4.37.11 ] ~ [ unix-v6-master ] ~ [ ccs-tools-1.8.5 ] ~ [ policy-sample ] ~
Architecture: ~ [ i386 ] ~ [ alpha ] ~ [ m68k ] ~ [ mips ] ~ [ ppc ] ~ [ sparc ] ~ [ sparc64 ] ~

  1 /*
  2  * net/tipc/eth_media.c: Ethernet bearer support for TIPC
  3  *
  4  * Copyright (c) 2001-2007, Ericsson AB
  5  * Copyright (c) 2005-2007, Wind River Systems
  6  * All rights reserved.
  7  *
  8  * Redistribution and use in source and binary forms, with or without
  9  * modification, are permitted provided that the following conditions are met:
 10  *
 11  * 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.
 19  *
 20  * 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
 34  * POSSIBILITY OF SUCH DAMAGE.
 35  */
 36 
 37 #include "core.h"
 38 #include "bearer.h"
 39 
 40 #define MAX_ETH_BEARERS         2
 41 #define ETH_LINK_PRIORITY       TIPC_DEF_LINK_PRI
 42 #define ETH_LINK_TOLERANCE      TIPC_DEF_LINK_TOL
 43 #define ETH_LINK_WINDOW         TIPC_DEF_LINK_WIN
 44 
 45 /**
 46  * struct eth_bearer - Ethernet bearer data structure
 47  * @bearer: ptr to associated "generic" bearer structure
 48  * @dev: ptr to associated Ethernet network device
 49  * @tipc_packet_type: used in binding TIPC to Ethernet driver
 50  */
 51 
 52 struct eth_bearer {
 53         struct tipc_bearer *bearer;
 54         struct net_device *dev;
 55         struct packet_type tipc_packet_type;
 56         struct work_struct setup;
 57 };
 58 
 59 static struct eth_bearer eth_bearers[MAX_ETH_BEARERS];
 60 static int eth_started;
 61 static struct notifier_block notifier;
 62 
 63 /**
 64  * send_msg - send a TIPC message out over an Ethernet interface
 65  */
 66 
 67 static int send_msg(struct sk_buff *buf, struct tipc_bearer *tb_ptr,
 68                     struct tipc_media_addr *dest)
 69 {
 70         struct sk_buff *clone;
 71         struct net_device *dev;
 72         int delta;
 73 
 74         clone = skb_clone(buf, GFP_ATOMIC);
 75         if (!clone)
 76                 return 0;
 77 
 78         dev = ((struct eth_bearer *)(tb_ptr->usr_handle))->dev;
 79         delta = dev->hard_header_len - skb_headroom(buf);
 80 
 81         if ((delta > 0) &&
 82             pskb_expand_head(clone, SKB_DATA_ALIGN(delta), 0, GFP_ATOMIC)) {
 83                 kfree_skb(clone);
 84                 return 0;
 85         }
 86 
 87         skb_reset_network_header(clone);
 88         clone->dev = dev;
 89         dev_hard_header(clone, dev, ETH_P_TIPC, &dest->dev_addr.eth_addr,
 90                         dev->dev_addr, clone->len);
 91         dev_queue_xmit(clone);
 92         return 0;
 93 }
 94 
 95 /**
 96  * recv_msg - handle incoming TIPC message from an Ethernet interface
 97  *
 98  * Accept only packets explicitly sent to this node, or broadcast packets;
 99  * ignores packets sent using Ethernet multicast, and traffic sent to other
100  * nodes (which can happen if interface is running in promiscuous mode).
101  */
102 
103 static int recv_msg(struct sk_buff *buf, struct net_device *dev,
104                     struct packet_type *pt, struct net_device *orig_dev)
105 {
106         struct eth_bearer *eb_ptr = (struct eth_bearer *)pt->af_packet_priv;
107 
108         if (!net_eq(dev_net(dev), &init_net)) {
109                 kfree_skb(buf);
110                 return 0;
111         }
112 
113         if (likely(eb_ptr->bearer)) {
114                 if (likely(buf->pkt_type <= PACKET_BROADCAST)) {
115                         buf->next = NULL;
116                         tipc_recv_msg(buf, eb_ptr->bearer);
117                         return 0;
118                 }
119         }
120         kfree_skb(buf);
121         return 0;
122 }
123 
124 /**
125  * setup_bearer - setup association between Ethernet bearer and interface
126  */
127 static void setup_bearer(struct work_struct *work)
128 {
129         struct eth_bearer *eb_ptr =
130                 container_of(work, struct eth_bearer, setup);
131 
132         dev_add_pack(&eb_ptr->tipc_packet_type);
133 }
134 
135 /**
136  * enable_bearer - attach TIPC bearer to an Ethernet interface
137  */
138 
139 static int enable_bearer(struct tipc_bearer *tb_ptr)
140 {
141         struct net_device *dev = NULL;
142         struct net_device *pdev = NULL;
143         struct eth_bearer *eb_ptr = &eth_bearers[0];
144         struct eth_bearer *stop = &eth_bearers[MAX_ETH_BEARERS];
145         char *driver_name = strchr((const char *)tb_ptr->name, ':') + 1;
146         int pending_dev = 0;
147 
148         /* Find unused Ethernet bearer structure */
149 
150         while (eb_ptr->dev) {
151                 if (!eb_ptr->bearer)
152                         pending_dev++;
153                 if (++eb_ptr == stop)
154                         return pending_dev ? -EAGAIN : -EDQUOT;
155         }
156 
157         /* Find device with specified name */
158 
159         for_each_netdev(&init_net, pdev) {
160                 if (!strncmp(pdev->name, driver_name, IFNAMSIZ)) {
161                         dev = pdev;
162                         break;
163                 }
164         }
165         if (!dev)
166                 return -ENODEV;
167 
168         /* Find Ethernet bearer for device (or create one) */
169 
170         while ((eb_ptr != stop) && eb_ptr->dev && (eb_ptr->dev != dev))
171                 eb_ptr++;
172         if (eb_ptr == stop)
173                 return -EDQUOT;
174         if (!eb_ptr->dev) {
175                 eb_ptr->dev = dev;
176                 eb_ptr->tipc_packet_type.type = htons(ETH_P_TIPC);
177                 eb_ptr->tipc_packet_type.dev = dev;
178                 eb_ptr->tipc_packet_type.func = recv_msg;
179                 eb_ptr->tipc_packet_type.af_packet_priv = eb_ptr;
180                 INIT_LIST_HEAD(&(eb_ptr->tipc_packet_type.list));
181                 dev_hold(dev);
182                 INIT_WORK(&eb_ptr->setup, setup_bearer);
183                 schedule_work(&eb_ptr->setup);
184         }
185 
186         /* Associate TIPC bearer with Ethernet bearer */
187 
188         eb_ptr->bearer = tb_ptr;
189         tb_ptr->usr_handle = (void *)eb_ptr;
190         tb_ptr->mtu = dev->mtu;
191         tb_ptr->blocked = 0;
192         tb_ptr->addr.type = htonl(TIPC_MEDIA_TYPE_ETH);
193         memcpy(&tb_ptr->addr.dev_addr, dev->dev_addr, ETH_ALEN);
194         return 0;
195 }
196 
197 /**
198  * disable_bearer - detach TIPC bearer from an Ethernet interface
199  *
200  * We really should do dev_remove_pack() here, but this function can not be
201  * called at tasklet level. => Use eth_bearer->bearer as a flag to throw away
202  * incoming buffers, & postpone dev_remove_pack() to eth_media_stop() on exit.
203  */
204 
205 static void disable_bearer(struct tipc_bearer *tb_ptr)
206 {
207         ((struct eth_bearer *)tb_ptr->usr_handle)->bearer = NULL;
208 }
209 
210 /**
211  * recv_notification - handle device updates from OS
212  *
213  * Change the state of the Ethernet bearer (if any) associated with the
214  * specified device.
215  */
216 
217 static int recv_notification(struct notifier_block *nb, unsigned long evt,
218                              void *dv)
219 {
220         struct net_device *dev = (struct net_device *)dv;
221         struct eth_bearer *eb_ptr = &eth_bearers[0];
222         struct eth_bearer *stop = &eth_bearers[MAX_ETH_BEARERS];
223 
224         if (!net_eq(dev_net(dev), &init_net))
225                 return NOTIFY_DONE;
226 
227         while ((eb_ptr->dev != dev)) {
228                 if (++eb_ptr == stop)
229                         return NOTIFY_DONE;     /* couldn't find device */
230         }
231         if (!eb_ptr->bearer)
232                 return NOTIFY_DONE;             /* bearer had been disabled */
233 
234         eb_ptr->bearer->mtu = dev->mtu;
235 
236         switch (evt) {
237         case NETDEV_CHANGE:
238                 if (netif_carrier_ok(dev))
239                         tipc_continue(eb_ptr->bearer);
240                 else
241                         tipc_block_bearer(eb_ptr->bearer->name);
242                 break;
243         case NETDEV_UP:
244                 tipc_continue(eb_ptr->bearer);
245                 break;
246         case NETDEV_DOWN:
247                 tipc_block_bearer(eb_ptr->bearer->name);
248                 break;
249         case NETDEV_CHANGEMTU:
250         case NETDEV_CHANGEADDR:
251                 tipc_block_bearer(eb_ptr->bearer->name);
252                 tipc_continue(eb_ptr->bearer);
253                 break;
254         case NETDEV_UNREGISTER:
255         case NETDEV_CHANGENAME:
256                 tipc_disable_bearer(eb_ptr->bearer->name);
257                 break;
258         }
259         return NOTIFY_OK;
260 }
261 
262 /**
263  * eth_addr2str - convert Ethernet address to string
264  */
265 
266 static char *eth_addr2str(struct tipc_media_addr *a, char *str_buf, int str_size)
267 {
268         unchar *addr = (unchar *)&a->dev_addr;
269 
270         if (str_size < 18)
271                 *str_buf = '\0';
272         else
273                 sprintf(str_buf, "%pM", addr);
274         return str_buf;
275 }
276 
277 /**
278  * tipc_eth_media_start - activate Ethernet bearer support
279  *
280  * Register Ethernet media type with TIPC bearer code.  Also register
281  * with OS for notifications about device state changes.
282  */
283 
284 int tipc_eth_media_start(void)
285 {
286         struct tipc_media_addr bcast_addr;
287         int res;
288 
289         if (eth_started)
290                 return -EINVAL;
291 
292         bcast_addr.type = htonl(TIPC_MEDIA_TYPE_ETH);
293         memset(&bcast_addr.dev_addr, 0xff, ETH_ALEN);
294 
295         memset(eth_bearers, 0, sizeof(eth_bearers));
296 
297         res = tipc_register_media(TIPC_MEDIA_TYPE_ETH, "eth",
298                                   enable_bearer, disable_bearer, send_msg,
299                                   eth_addr2str, &bcast_addr, ETH_LINK_PRIORITY,
300                                   ETH_LINK_TOLERANCE, ETH_LINK_WINDOW);
301         if (res)
302                 return res;
303 
304         notifier.notifier_call = &recv_notification;
305         notifier.priority = 0;
306         res = register_netdevice_notifier(&notifier);
307         if (!res)
308                 eth_started = 1;
309         return res;
310 }
311 
312 /**
313  * tipc_eth_media_stop - deactivate Ethernet bearer support
314  */
315 
316 void tipc_eth_media_stop(void)
317 {
318         int i;
319 
320         if (!eth_started)
321                 return;
322 
323         unregister_netdevice_notifier(&notifier);
324         for (i = 0; i < MAX_ETH_BEARERS ; i++) {
325                 if (eth_bearers[i].bearer) {
326                         eth_bearers[i].bearer->blocked = 1;
327                         eth_bearers[i].bearer = NULL;
328                 }
329                 if (eth_bearers[i].dev) {
330                         dev_remove_pack(&eth_bearers[i].tipc_packet_type);
331                         dev_put(eth_bearers[i].dev);
332                 }
333         }
334         memset(&eth_bearers, 0, sizeof(eth_bearers));
335         eth_started = 0;
336 }
337 

~ [ source navigation ] ~ [ diff markup ] ~ [ identifier search ] ~

kernel.org | git.kernel.org | LWN.net | Project Home | Wiki (Japanese) | Wiki (English) | SVN repository | Mail admin

Linux® is a registered trademark of Linus Torvalds in the United States and other countries.
TOMOYO® is a registered trademark of NTT DATA CORPORATION.

osdn.jp