* cleanup: const'ified parameters and reduced duplicated code
[olsrd.git] / src / interfaces.c
1 /*
2  * The olsr.org Optimized Link-State Routing daemon(olsrd)
3  * Copyright (c) 2004, Andreas T√łnnesen(andreto@olsr.org)
4  * All rights reserved.
5  *
6  * Redistribution and use in source and binary forms, with or without 
7  * modification, are permitted provided that the following conditions 
8  * are met:
9  *
10  * * Redistributions of source code must retain the above copyright 
11  *   notice, this list of conditions and the following disclaimer.
12  * * Redistributions in binary form must reproduce the above copyright 
13  *   notice, this list of conditions and the following disclaimer in 
14  *   the documentation and/or other materials provided with the 
15  *   distribution.
16  * * Neither the name of olsr.org, olsrd nor the names of its 
17  *   contributors may be used to endorse or promote products derived 
18  *   from this software without specific prior written permission.
19  *
20  * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS 
21  * "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT 
22  * LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS 
23  * FOR A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE 
24  * COPYRIGHT OWNER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, 
25  * INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, 
26  * BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; 
27  * LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER 
28  * CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT 
29  * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN 
30  * ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE 
31  * POSSIBILITY OF SUCH DAMAGE.
32  *
33  * Visit http://www.olsr.org for more information.
34  *
35  * If you find this software useful feel free to make a donation
36  * to the project. For more information see the website or contact
37  * the copyright holders.
38  *
39  * $Id: interfaces.c,v 1.35 2007/10/13 12:09:11 bernd67 Exp $
40  */
41
42 #include "defs.h"
43 #include "interfaces.h"
44 #include "ifnet.h"
45 #include "scheduler.h"
46 #include "olsr.h"
47
48 static olsr_u32_t if_property_id;
49
50 /* The interface linked-list */
51 struct interface *ifnet;
52
53 /* Datastructures to use when creating new sockets */
54 struct sockaddr_in addrsock;
55 struct sockaddr_in6 addrsock6;
56
57
58 /* Ifchange functions */
59 struct ifchgf
60 {
61   int (*function)(struct interface *, int);
62   struct ifchgf *next;
63 };
64
65 static struct ifchgf *ifchgf_list;
66
67 /**
68  *Do initialization of various data needed for
69  *network interface management.
70  *This function also tries to set up the given interfaces.
71  *
72  *@return the number of interfaces configured
73  */
74 int
75 ifinit(void)
76 {
77   struct olsr_if *tmp_if;
78
79
80   /* Initial values */
81   ifnet = NULL;
82
83   /*
84    *Initializing addrsock struct to be
85    *used on all the sockets
86    */
87   if(olsr_cnf->ip_version == AF_INET)
88     {
89       /* IP version 4 */
90       memset(&addrsock, 0, sizeof (addrsock));
91       addrsock.sin_family = AF_INET;
92       addrsock.sin_port = htons(OLSRPORT);
93       (addrsock.sin_addr).s_addr = INADDR_ANY;
94     }
95   else
96     {
97       /* IP version 6 */
98       memset(&addrsock6, 0, sizeof (addrsock6));
99       addrsock6.sin6_family = AF_INET6;
100       addrsock6.sin6_port = htons(OLSRPORT);
101       //(addrsock6.sin6_addr).s_addr = IN6ADDR_ANY_INIT;
102     }
103
104   OLSR_PRINTF(1, "\n ---- Interface configuration ---- \n\n");
105     /* Run trough all interfaces immedeatly */
106     for(tmp_if = olsr_cnf->interfaces; tmp_if != NULL; tmp_if = tmp_if->next)
107       {
108         if(!tmp_if->host_emul)
109           {
110             if(!olsr_cnf->host_emul) /* XXX: TEMPORARY! */
111               chk_if_up(tmp_if, 1);     
112           }
113         else
114           add_hemu_if(tmp_if);
115       }
116   
117   /* register network interface update function with scheduler */
118   olsr_register_scheduler_event(&check_interface_updates, NULL, 
119                                 olsr_cnf->nic_chgs_pollrate, 0, NULL);
120
121   return (ifnet == NULL) ? 0 : 1;
122 }
123
124
125 olsr_u32_t
126 get_if_property_id(void)
127 {
128   return if_property_id++;
129 }
130
131 olsr_bool
132 add_if_geninfo(struct interface *ifp, void *data, olsr_u32_t owner_id)
133 {
134   struct if_gen_property *igp;
135
136   if(get_if_geninfo(ifp, owner_id) != NULL)
137     return OLSR_FALSE;
138
139   igp = olsr_malloc(sizeof(struct if_gen_property), __func__);
140
141   igp->owner_id = owner_id;
142   igp->data = data;
143
144   /* queue */
145   igp->next = ifp->gen_properties;
146   ifp->gen_properties = igp;
147
148   return OLSR_TRUE;
149 }
150
151 void *
152 get_if_geninfo(struct interface *ifp, olsr_u32_t owner_id)
153 {
154   struct if_gen_property *igp_list = ifp->gen_properties;
155
156
157   while(igp_list)
158     {
159       if(igp_list->owner_id == owner_id)
160         return igp_list->data;
161
162       igp_list = igp_list->next;
163     }
164
165   return NULL;
166 }
167
168 void *
169 del_if_geninfo(struct interface *ifp, olsr_u32_t owner_id)
170 {
171   void *data = NULL;
172   struct if_gen_property *igp_list = ifp->gen_properties;
173   struct if_gen_property *igp_prev = NULL;
174
175
176   while(igp_list)
177     {
178       if(igp_list->owner_id == owner_id)
179         break;
180
181       igp_prev = igp_list;
182       igp_list = igp_list->next;
183     }
184
185   /* Not found */
186   if(igp_list == NULL)
187     return NULL;
188
189   /* Dequeue */
190   if(igp_prev == NULL)
191     {
192       /* First elem */
193       ifp->gen_properties = igp_list->next;
194     }
195   else
196     {
197       igp_prev->next = igp_list->next;
198     }
199   data = igp_list->data;
200   free(igp_list);
201
202   return data;
203 }
204
205
206 void
207 run_ifchg_cbs(struct interface *ifp, int flag)
208 {
209   struct ifchgf *tmp_ifchgf_list = ifchgf_list;
210
211   while(tmp_ifchgf_list != NULL)
212     {
213       tmp_ifchgf_list->function(ifp, flag);
214       tmp_ifchgf_list = tmp_ifchgf_list->next;
215     }
216 }
217
218
219 /**
220  *Find the local interface with a given address.
221  *
222  *@param addr the address to check.
223  *
224  *@return the interface struct representing the interface
225  *that matched the address.
226  */
227
228 struct interface *
229 if_ifwithaddr(const union olsr_ip_addr * const addr)
230 {
231   struct interface *ifp;
232
233   if(!addr)
234     return NULL;
235
236   for (ifp = ifnet; ifp; ifp = ifp->int_next)
237     {
238       if(olsr_cnf->ip_version == AF_INET)
239         {
240           /* IPv4 */
241           //printf("Checking: %s == ", inet_ntoa(((struct sockaddr_in *)&ifp->int_addr)->sin_addr));
242           //printf("%s\n", olsr_ip_to_string(addr));
243
244           if (COMP_IP(&((struct sockaddr_in *)&ifp->int_addr)->sin_addr, addr))
245               return ifp;
246         }
247       else
248         {
249           /* IPv6 */
250           //printf("Checking %s ", olsr_ip_to_string((union olsr_ip_addr *)&ifp->int6_addr.sin6_addr));
251           //printf("== %s\n", olsr_ip_to_string((union olsr_ip_addr *)&((struct sockaddr_in6 *)addr)->sin6_addr));
252           if (COMP_IP(&ifp->int6_addr.sin6_addr, addr))
253             return ifp;
254         }
255     }
256   return NULL;
257 }
258
259
260
261 /**
262  *Find the interface with a given number.
263  *
264  *@param nr the number of the interface to find.
265  *
266  *@return return the interface struct representing the interface
267  *that matched the number.
268  */
269 struct interface *
270 if_ifwithsock(int fd)
271 {
272   struct interface *ifp;
273   ifp = ifnet;
274
275   while (ifp) 
276     {
277       if (ifp->olsr_socket == fd)
278         return ifp;
279       ifp = ifp->int_next;
280     }
281   
282   return NULL;
283 }
284
285
286 /**
287  *Find the interface with a given label.
288  *
289  *@param if_name the label of the interface to find.
290  *
291  *@return return the interface struct representing the interface
292  *that matched the label.
293  */
294 struct interface *
295 if_ifwithname(const char *if_name)
296 {
297   struct interface *ifp;
298   ifp = ifnet;
299
300   while (ifp) 
301     {
302       /* good ol' strcmp should be sufficcient here */
303       if (!strcmp(ifp->int_name, if_name))
304         return ifp;
305       ifp = ifp->int_next;
306     }
307   
308   return NULL;
309 }
310
311
312 /**
313  *Find the interface with a given interface index.
314  *
315  *@param iif_index of the interface to find.
316  *
317  *@return return the interface struct representing the interface
318  *that matched the iif_index.
319  */
320 struct interface *
321 if_ifwithindex(const int if_index)
322 {
323   struct interface *ifp = ifnet;
324   while (ifp) 
325     {
326       if (ifp->if_index == if_index)
327         return ifp;
328       ifp = ifp->int_next;
329     }
330   return NULL;
331 }
332
333
334 /**
335  *Get an interface name for a given interface index
336  *
337  *@param iif_index of the interface to find.
338  *
339  *@return "" or interface name.
340  */
341 const char *
342 if_ifwithindex_name(const int if_index)
343 {
344   const struct interface * const ifp = if_ifwithindex(if_index);
345   return ifp == NULL ? "void" : ifp->int_name;
346 }
347
348
349 /**
350  *Create a new interf_name struct using a given
351  *name and insert it into the interface list.
352  *
353  *@param name the name of the interface.
354  *
355  *@return nada
356  */
357 struct olsr_if *
358 queue_if(char *name, int hemu)
359 {
360   struct olsr_if *interf_n = olsr_cnf->interfaces;
361
362   //printf("Adding interface %s\n", name);
363
364   /* check if the inerfaces already exists */
365   while(interf_n != NULL)
366     {
367       if(memcmp(interf_n->name, name, strlen(name)) == 0)
368         {
369           fprintf(stderr, "Duplicate interfaces defined... not adding %s\n", name);
370           return NULL;
371         }
372       interf_n = interf_n->next;
373     }
374
375   interf_n = olsr_malloc(sizeof(struct olsr_if), "queue interface");
376
377   /* strlen () does not return length including terminating /0 */
378   interf_n->name = olsr_malloc(strlen(name) + 1, "queue interface name");
379   interf_n->cnf = NULL;
380   interf_n->interf = NULL;
381   interf_n->configured = 0;
382
383   interf_n->host_emul = hemu ? OLSR_TRUE : OLSR_FALSE;
384
385   strncpy(interf_n->name, name, strlen(name) + 1);
386   interf_n->next = olsr_cnf->interfaces;
387   olsr_cnf->interfaces = interf_n;
388
389   return interf_n;
390 }
391
392
393
394 /**
395  *Add an ifchange function. These functions are called on all (non-initial)
396  *changes in the interface set.
397  *
398  *@param
399  *
400  *@return
401  */
402 int
403 add_ifchgf(int (*f)(struct interface *, int))
404 {
405
406   struct ifchgf *new_ifchgf;
407
408   new_ifchgf = olsr_malloc(sizeof(struct ifchgf), "Add ifchgfunction");
409
410   new_ifchgf->next = ifchgf_list;
411   new_ifchgf->function = f;
412
413   ifchgf_list = new_ifchgf;
414
415   return 1;
416 }
417
418
419
420 /*
421  * Remove an ifchange function
422  */
423 int
424 del_ifchgf(int (*f)(struct interface *, int))
425 {
426   struct ifchgf *tmp_ifchgf, *prev;
427
428   tmp_ifchgf = ifchgf_list;
429   prev = NULL;
430
431   while(tmp_ifchgf)
432     {
433       if(tmp_ifchgf->function == f)
434         {
435           /* Remove entry */
436           if(prev == NULL)
437             {
438               ifchgf_list = tmp_ifchgf->next;
439               free(tmp_ifchgf);
440             }
441           else
442             {
443               prev->next = tmp_ifchgf->next;
444               free(tmp_ifchgf);
445             }
446           return 1;
447         }
448       prev = tmp_ifchgf;
449       tmp_ifchgf = tmp_ifchgf->next;
450     }
451
452   return 0;
453 }