device.c 37 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091929394959697989910010110210310410510610710810911011111211311411511611711811912012112212312412512612712812913013113213313413513613713813914014114214314414514614714814915015115215315415515615715815916016116216316416516616716816917017117217317417517617717817918018118218318418518618718818919019119219319419519619719819920020120220320420520620720820921021121221321421521621721821922022122222322422522622722822923023123223323423523623723823924024124224324424524624724824925025125225325425525625725825926026126226326426526626726826927027127227327427527627727827928028128228328428528628728828929029129229329429529629729829930030130230330430530630730830931031131231331431531631731831932032132232332432532632732832933033133233333433533633733833934034134234334434534634734834935035135235335435535635735835936036136236336436536636736836937037137237337437537637737837938038138238338438538638738838939039139239339439539639739839940040140240340440540640740840941041141241341441541641741841942042142242342442542642742842943043143243343443543643743843944044144244344444544644744844945045145245345445545645745845946046146246346446546646746846947047147247347447547647747847948048148248348448548648748848949049149249349449549649749849950050150250350450550650750850951051151251351451551651751851952052152252352452552652752852953053153253353453553653753853954054154254354454554654754854955055155255355455555655755855956056156256356456556656756856957057157257357457557657757857958058158258358458558658758858959059159259359459559659759859960060160260360460560660760860961061161261361461561661761861962062162262362462562662762862963063163263363463563663763863964064164264364464564664764864965065165265365465565665765865966066166266366466566666766866967067167267367467567667767867968068168268368468568668768868969069169269369469569669769869970070170270370470570670770870971071171271371471571671771871972072172272372472572672772872973073173273373473573673773873974074174274374474574674774874975075175275375475575675775875976076176276376476576676776876977077177277377477577677777877978078178278378478578678778878979079179279379479579679779879980080180280380480580680780880981081181281381481581681781881982082182282382482582682782882983083183283383483583683783883984084184284384484584684784884985085185285385485585685785885986086186286386486586686786886987087187287387487587687787887988088188288388488588688788888989089189289389489589689789889990090190290390490590690790890991091191291391491591691791891992092192292392492592692792892993093193293393493593693793893994094194294394494594694794894995095195295395495595695795895996096196296396496596696796896997097197297397497597697797897998098198298398498598698798898999099199299399499599699799899910001001100210031004100510061007100810091010101110121013101410151016101710181019102010211022102310241025102610271028102910301031103210331034103510361037103810391040104110421043104410451046104710481049105010511052105310541055105610571058105910601061106210631064106510661067106810691070107110721073107410751076107710781079108010811082108310841085108610871088108910901091109210931094109510961097109810991100110111021103110411051106110711081109111011111112111311141115111611171118111911201121112211231124112511261127112811291130113111321133113411351136113711381139114011411142114311441145114611471148114911501151115211531154115511561157115811591160116111621163116411651166116711681169117011711172117311741175117611771178117911801181118211831184118511861187118811891190119111921193119411951196119711981199120012011202120312041205120612071208120912101211121212131214121512161217121812191220122112221223122412251226122712281229123012311232123312341235123612371238123912401241124212431244124512461247124812491250125112521253125412551256125712581259126012611262126312641265126612671268126912701271127212731274127512761277127812791280128112821283128412851286128712881289129012911292129312941295129612971298129913001301130213031304130513061307130813091310131113121313131413151316131713181319132013211322132313241325132613271328132913301331133213331334133513361337133813391340134113421343134413451346134713481349135013511352135313541355135613571358135913601361136213631364136513661367136813691370137113721373137413751376137713781379138013811382138313841385138613871388138913901391139213931394139513961397139813991400140114021403140414051406140714081409141014111412141314141415141614171418141914201421142214231424142514261427142814291430143114321433143414351436143714381439144014411442144314441445
  1. /*
  2. * netifd - network interface daemon
  3. * Copyright (C) 2012 Felix Fietkau <nbd@openwrt.org>
  4. *
  5. * This program is free software; you can redistribute it and/or modify
  6. * it under the terms of the GNU General Public License version 2
  7. * as published by the Free Software Foundation
  8. *
  9. * This program is distributed in the hope that it will be useful,
  10. * but WITHOUT ANY WARRANTY; without even the implied warranty of
  11. * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
  12. * GNU General Public License for more details.
  13. */
  14. #include <string.h>
  15. #include <stdlib.h>
  16. #include <stdio.h>
  17. #include <assert.h>
  18. #include <sys/types.h>
  19. #include <sys/socket.h>
  20. #include <libubox/list.h>
  21. #include "netifd.h"
  22. #include "system.h"
  23. #include "config.h"
  24. #include "wireless.h"
  25. #include "ubus.h"
  26. static struct list_head devtypes = LIST_HEAD_INIT(devtypes);
  27. static struct avl_tree devices;
  28. static struct blob_buf b;
  29. static const struct blobmsg_policy dev_attrs[__DEV_ATTR_MAX] = {
  30. [DEV_ATTR_TYPE] = { .name = "type", .type = BLOBMSG_TYPE_STRING },
  31. [DEV_ATTR_MTU] = { .name = "mtu", .type = BLOBMSG_TYPE_INT32 },
  32. [DEV_ATTR_MTU6] = { .name = "mtu6", .type = BLOBMSG_TYPE_INT32 },
  33. [DEV_ATTR_MACADDR] = { .name = "macaddr", .type = BLOBMSG_TYPE_STRING },
  34. [DEV_ATTR_TXQUEUELEN] = { .name = "txqueuelen", .type = BLOBMSG_TYPE_INT32 },
  35. [DEV_ATTR_ENABLED] = { .name = "enabled", .type = BLOBMSG_TYPE_BOOL },
  36. [DEV_ATTR_IPV6] = { .name = "ipv6", .type = BLOBMSG_TYPE_BOOL },
  37. [DEV_ATTR_IP6SEGMENTROUTING] = { .name = "ip6segmentrouting", .type = BLOBMSG_TYPE_BOOL },
  38. [DEV_ATTR_PROMISC] = { .name = "promisc", .type = BLOBMSG_TYPE_BOOL },
  39. [DEV_ATTR_RPFILTER] = { .name = "rpfilter", .type = BLOBMSG_TYPE_STRING },
  40. [DEV_ATTR_ACCEPTLOCAL] = { .name = "acceptlocal", .type = BLOBMSG_TYPE_BOOL },
  41. [DEV_ATTR_IGMPVERSION] = { .name = "igmpversion", .type = BLOBMSG_TYPE_INT32 },
  42. [DEV_ATTR_MLDVERSION] = { .name = "mldversion", .type = BLOBMSG_TYPE_INT32 },
  43. [DEV_ATTR_NEIGHREACHABLETIME] = { .name = "neighreachabletime", .type = BLOBMSG_TYPE_INT32 },
  44. [DEV_ATTR_NEIGHGCSTALETIME] = { .name = "neighgcstaletime", .type = BLOBMSG_TYPE_INT32 },
  45. [DEV_ATTR_DADTRANSMITS] = { .name = "dadtransmits", .type = BLOBMSG_TYPE_INT32 },
  46. [DEV_ATTR_MULTICAST_TO_UNICAST] = { .name = "multicast_to_unicast", .type = BLOBMSG_TYPE_BOOL },
  47. [DEV_ATTR_MULTICAST_ROUTER] = { .name = "multicast_router", .type = BLOBMSG_TYPE_INT32 },
  48. [DEV_ATTR_MULTICAST_FAST_LEAVE] = { .name = "multicast_fast_leave", . type = BLOBMSG_TYPE_BOOL },
  49. [DEV_ATTR_MULTICAST] = { .name ="multicast", .type = BLOBMSG_TYPE_BOOL },
  50. [DEV_ATTR_LEARNING] = { .name ="learning", .type = BLOBMSG_TYPE_BOOL },
  51. [DEV_ATTR_UNICAST_FLOOD] = { .name ="unicast_flood", .type = BLOBMSG_TYPE_BOOL },
  52. [DEV_ATTR_SENDREDIRECTS] = { .name = "sendredirects", .type = BLOBMSG_TYPE_BOOL },
  53. [DEV_ATTR_NEIGHLOCKTIME] = { .name = "neighlocktime", .type = BLOBMSG_TYPE_INT32 },
  54. [DEV_ATTR_ISOLATE] = { .name = "isolate", .type = BLOBMSG_TYPE_BOOL },
  55. [DEV_ATTR_DROP_V4_UNICAST_IN_L2_MULTICAST] = { .name = "drop_v4_unicast_in_l2_multicast", .type = BLOBMSG_TYPE_BOOL },
  56. [DEV_ATTR_DROP_V6_UNICAST_IN_L2_MULTICAST] = { .name = "drop_v6_unicast_in_l2_multicast", .type = BLOBMSG_TYPE_BOOL },
  57. [DEV_ATTR_DROP_GRATUITOUS_ARP] = { .name = "drop_gratuitous_arp", .type = BLOBMSG_TYPE_BOOL },
  58. [DEV_ATTR_DROP_UNSOLICITED_NA] = { .name = "drop_unsolicited_na", .type = BLOBMSG_TYPE_BOOL },
  59. [DEV_ATTR_ARP_ACCEPT] = { .name = "arp_accept", .type = BLOBMSG_TYPE_BOOL },
  60. [DEV_ATTR_AUTH] = { .name = "auth", .type = BLOBMSG_TYPE_BOOL },
  61. [DEV_ATTR_AUTH_VLAN] = { .name = "auth_vlan", BLOBMSG_TYPE_ARRAY },
  62. [DEV_ATTR_SPEED] = { .name = "speed", .type = BLOBMSG_TYPE_INT32 },
  63. [DEV_ATTR_DUPLEX] = { .name = "duplex", .type = BLOBMSG_TYPE_BOOL },
  64. [DEV_ATTR_VLAN] = { .name = "vlan", .type = BLOBMSG_TYPE_ARRAY },
  65. [DEV_ATTR_PAUSE] = { .name = "pause", .type = BLOBMSG_TYPE_BOOL },
  66. [DEV_ATTR_ASYM_PAUSE] = { .name = "asym_pause", .type = BLOBMSG_TYPE_BOOL },
  67. [DEV_ATTR_RXPAUSE] = { .name = "rxpause", .type = BLOBMSG_TYPE_BOOL },
  68. [DEV_ATTR_TXPAUSE] = { .name = "txpause", .type = BLOBMSG_TYPE_BOOL },
  69. [DEV_ATTR_AUTONEG] = { .name = "autoneg", .type = BLOBMSG_TYPE_BOOL },
  70. [DEV_ATTR_GRO] = { .name = "gro", .type = BLOBMSG_TYPE_BOOL },
  71. [DEV_ATTR_MASTER] = { .name = "conduit", .type = BLOBMSG_TYPE_STRING },
  72. [DEV_ATTR_EEE] = { .name = "eee", .type = BLOBMSG_TYPE_BOOL },
  73. };
  74. const struct uci_blob_param_list device_attr_list = {
  75. .n_params = __DEV_ATTR_MAX,
  76. .params = dev_attrs,
  77. };
  78. static int __devlock = 0;
  79. int device_type_add(struct device_type *devtype)
  80. {
  81. if (device_type_get(devtype->name)) {
  82. netifd_log_message(L_WARNING, "Device handler '%s' already exists\n",
  83. devtype->name);
  84. return 1;
  85. }
  86. netifd_log_message(L_NOTICE, "Added device handler type: %s\n",
  87. devtype->name);
  88. list_add(&devtype->list, &devtypes);
  89. return 0;
  90. }
  91. struct device_type *
  92. device_type_get(const char *tname)
  93. {
  94. struct device_type *cur;
  95. list_for_each_entry(cur, &devtypes, list)
  96. if (!strcmp(cur->name, tname))
  97. return cur;
  98. return NULL;
  99. }
  100. static int device_vlan_len(struct kvlist *kv, const void *data)
  101. {
  102. return sizeof(unsigned int);
  103. }
  104. void device_vlan_update(bool done)
  105. {
  106. struct device *dev;
  107. avl_for_each_element(&devices, dev, avl) {
  108. if (!dev->vlans.update)
  109. continue;
  110. if (!done) {
  111. if (dev->vlan_aliases.get_len)
  112. kvlist_free(&dev->vlan_aliases);
  113. else
  114. kvlist_init(&dev->vlan_aliases, device_vlan_len);
  115. vlist_update(&dev->vlans);
  116. } else {
  117. vlist_flush(&dev->vlans);
  118. if (dev->type->vlan_update)
  119. dev->type->vlan_update(dev);
  120. }
  121. }
  122. }
  123. void device_stp_init(void)
  124. {
  125. struct device *dev;
  126. avl_for_each_element(&devices, dev, avl) {
  127. if (!dev->type->stp_init)
  128. continue;
  129. dev->type->stp_init(dev);
  130. }
  131. }
  132. static int set_device_state(struct device *dev, bool state)
  133. {
  134. if (state) {
  135. /* Get ifindex for all devices being enabled so a valid */
  136. /* ifindex is in place avoiding possible race conditions */
  137. device_set_ifindex(dev, system_if_resolve(dev));
  138. if (!dev->ifindex)
  139. return -1;
  140. system_if_get_settings(dev, &dev->orig_settings);
  141. /* Only keep orig settings based on what needs to be set */
  142. dev->orig_settings.valid_flags = dev->orig_settings.flags;
  143. dev->orig_settings.flags &= dev->settings.flags;
  144. system_if_apply_settings(dev, &dev->settings, dev->settings.flags);
  145. system_if_up(dev);
  146. system_if_apply_settings_after_up(dev, &dev->settings);
  147. } else {
  148. system_if_down(dev);
  149. system_if_apply_settings(dev, &dev->orig_settings, dev->orig_settings.flags);
  150. /* Restore any settings present in UCI which may have
  151. * failed to apply so that they will be re-attempted
  152. * the next time the device is brought up */
  153. dev->settings.flags |= dev->settings.valid_flags;
  154. }
  155. return 0;
  156. }
  157. static int
  158. simple_device_set_state(struct device *dev, bool state)
  159. {
  160. struct device *pdev;
  161. int ret = 0;
  162. pdev = dev->parent.dev;
  163. if (state && !pdev) {
  164. pdev = system_if_get_parent(dev);
  165. if (pdev)
  166. device_add_user(&dev->parent, pdev);
  167. }
  168. if (pdev) {
  169. if (state)
  170. ret = device_claim(&dev->parent);
  171. else
  172. device_release(&dev->parent);
  173. if (ret < 0)
  174. return ret;
  175. }
  176. return set_device_state(dev, state);
  177. }
  178. static struct device *
  179. simple_device_create(const char *name, struct device_type *devtype,
  180. struct blob_attr *attr)
  181. {
  182. struct blob_attr *tb[__DEV_ATTR_MAX];
  183. struct device *dev = NULL;
  184. /* device type is unused for simple devices */
  185. devtype = NULL;
  186. blobmsg_parse(dev_attrs, __DEV_ATTR_MAX, tb, blob_data(attr), blob_len(attr));
  187. dev = device_get(name, true);
  188. if (!dev)
  189. return NULL;
  190. dev->set_state = simple_device_set_state;
  191. device_init_settings(dev, tb);
  192. return dev;
  193. }
  194. static void simple_device_free(struct device *dev)
  195. {
  196. if (dev->parent.dev)
  197. device_remove_user(&dev->parent);
  198. free(dev);
  199. }
  200. struct device_type simple_device_type = {
  201. .name = "Network device",
  202. .config_params = &device_attr_list,
  203. .create = simple_device_create,
  204. .check_state = system_if_check,
  205. .free = simple_device_free,
  206. };
  207. void
  208. device_merge_settings(struct device *dev, struct device_settings *n)
  209. {
  210. struct device_settings *os = &dev->orig_settings;
  211. struct device_settings *s = &dev->settings;
  212. memset(n, 0, sizeof(*n));
  213. n->mtu = s->flags & DEV_OPT_MTU ? s->mtu : os->mtu;
  214. n->mtu6 = s->flags & DEV_OPT_MTU6 ? s->mtu6 : os->mtu6;
  215. n->txqueuelen = s->flags & DEV_OPT_TXQUEUELEN ?
  216. s->txqueuelen : os->txqueuelen;
  217. memcpy(n->macaddr,
  218. (s->flags & (DEV_OPT_MACADDR|DEV_OPT_DEFAULT_MACADDR) ? s->macaddr : os->macaddr),
  219. sizeof(n->macaddr));
  220. n->ipv6 = s->flags & DEV_OPT_IPV6 ? s->ipv6 : os->ipv6;
  221. n->ip6segmentrouting = s->flags & DEV_OPT_IP6SEGMENTROUTING ? s->ip6segmentrouting : os->ip6segmentrouting;
  222. n->promisc = s->flags & DEV_OPT_PROMISC ? s->promisc : os->promisc;
  223. n->rpfilter = s->flags & DEV_OPT_RPFILTER ? s->rpfilter : os->rpfilter;
  224. n->acceptlocal = s->flags & DEV_OPT_ACCEPTLOCAL ? s->acceptlocal : os->acceptlocal;
  225. n->igmpversion = s->flags & DEV_OPT_IGMPVERSION ? s->igmpversion : os->igmpversion;
  226. n->mldversion = s->flags & DEV_OPT_MLDVERSION ? s->mldversion : os->mldversion;
  227. n->neigh4reachabletime = s->flags & DEV_OPT_NEIGHREACHABLETIME ?
  228. s->neigh4reachabletime : os->neigh4reachabletime;
  229. n->neigh6reachabletime = s->flags & DEV_OPT_NEIGHREACHABLETIME ?
  230. s->neigh6reachabletime : os->neigh6reachabletime;
  231. n->neigh4gcstaletime = s->flags & DEV_OPT_NEIGHGCSTALETIME ?
  232. s->neigh4gcstaletime : os->neigh4gcstaletime;
  233. n->neigh6gcstaletime = s->flags & DEV_OPT_NEIGHGCSTALETIME ?
  234. s->neigh6gcstaletime : os->neigh6gcstaletime;
  235. n->neigh4locktime = s->flags & DEV_OPT_NEIGHLOCKTIME ?
  236. s->neigh4locktime : os->neigh4locktime;
  237. n->dadtransmits = s->flags & DEV_OPT_DADTRANSMITS ?
  238. s->dadtransmits : os->dadtransmits;
  239. n->multicast = s->flags & DEV_OPT_MULTICAST ?
  240. s->multicast : os->multicast;
  241. n->multicast_to_unicast = s->multicast_to_unicast;
  242. n->multicast_router = s->multicast_router;
  243. n->multicast_fast_leave = s->multicast_fast_leave;
  244. n->learning = s->learning;
  245. n->unicast_flood = s->unicast_flood;
  246. n->sendredirects = s->flags & DEV_OPT_SENDREDIRECTS ?
  247. s->sendredirects : os->sendredirects;
  248. n->drop_v4_unicast_in_l2_multicast = s->flags & DEV_OPT_DROP_V4_UNICAST_IN_L2_MULTICAST ?
  249. s->drop_v4_unicast_in_l2_multicast : os->drop_v4_unicast_in_l2_multicast;
  250. n->drop_v6_unicast_in_l2_multicast = s->flags & DEV_OPT_DROP_V6_UNICAST_IN_L2_MULTICAST ?
  251. s->drop_v6_unicast_in_l2_multicast : os->drop_v6_unicast_in_l2_multicast;
  252. n->drop_gratuitous_arp = s->flags & DEV_OPT_DROP_GRATUITOUS_ARP ?
  253. s->drop_gratuitous_arp : os->drop_gratuitous_arp;
  254. n->drop_unsolicited_na = s->flags & DEV_OPT_DROP_UNSOLICITED_NA ?
  255. s->drop_unsolicited_na : os->drop_unsolicited_na;
  256. n->arp_accept = s->flags & DEV_OPT_ARP_ACCEPT ?
  257. s->arp_accept : os->arp_accept;
  258. n->auth = s->flags & DEV_OPT_AUTH ? s->auth : os->auth;
  259. n->speed = s->flags & DEV_OPT_SPEED ? s->speed : os->speed;
  260. n->duplex = s->flags & DEV_OPT_DUPLEX ? s->duplex : os->duplex;
  261. n->pause = s->flags & DEV_OPT_PAUSE ? s->pause : os->pause;
  262. n->asym_pause = s->flags & DEV_OPT_ASYM_PAUSE ? s->asym_pause : os->asym_pause;
  263. n->rxpause = s->flags & DEV_OPT_RXPAUSE ? s->rxpause : os->rxpause;
  264. n->txpause = s->flags & DEV_OPT_TXPAUSE ? s->txpause : os->txpause;
  265. n->autoneg = s->flags & DEV_OPT_AUTONEG ? s->autoneg : os->autoneg;
  266. n->gro = s->flags & DEV_OPT_GRO ? s->gro : os->gro;
  267. n->eee = s->flags & DEV_OPT_EEE ? s->eee : os->eee;
  268. n->master_ifindex = s->flags & DEV_OPT_MASTER ? s->master_ifindex : os->master_ifindex;
  269. n->flags = s->flags | os->flags | os->valid_flags;
  270. }
  271. static bool device_fill_vlan_range(struct device_vlan_range *r, const char *val)
  272. {
  273. unsigned long cur_start, cur_end;
  274. char *sep;
  275. cur_start = strtoul(val, &sep, 0);
  276. cur_end = cur_start;
  277. if (*sep == '-')
  278. cur_end = strtoul(sep + 1, &sep, 0);
  279. if (*sep || cur_end < cur_start)
  280. return false;
  281. r->start = cur_start;
  282. r->end = cur_end;
  283. return true;
  284. }
  285. static void
  286. device_set_extra_vlans(struct device *dev, struct blob_attr *data)
  287. {
  288. struct blob_attr *cur;
  289. int n_vlans;
  290. size_t rem;
  291. dev->n_extra_vlan = 0;
  292. if (!data)
  293. return;
  294. n_vlans = blobmsg_check_array(data, BLOBMSG_TYPE_STRING);
  295. if (n_vlans < 1)
  296. return;
  297. dev->extra_vlan = realloc(dev->extra_vlan, n_vlans * sizeof(*dev->extra_vlan));
  298. blobmsg_for_each_attr(cur, data, rem)
  299. if (device_fill_vlan_range(&dev->extra_vlan[dev->n_extra_vlan],
  300. blobmsg_get_string(cur)))
  301. dev->n_extra_vlan++;
  302. }
  303. void
  304. device_init_settings(struct device *dev, struct blob_attr **tb)
  305. {
  306. struct device_settings *s = &dev->settings;
  307. struct blob_attr *cur;
  308. struct ether_addr *ea;
  309. bool disabled = false;
  310. if (dev->wireless)
  311. s->flags &= DEV_OPT_ISOLATE;
  312. else
  313. s->flags = 0;
  314. if ((cur = tb[DEV_ATTR_ENABLED]))
  315. disabled = !blobmsg_get_bool(cur);
  316. if ((cur = tb[DEV_ATTR_MTU]) && blobmsg_get_u32(cur) >= 68) {
  317. s->mtu = blobmsg_get_u32(cur);
  318. s->flags |= DEV_OPT_MTU;
  319. }
  320. if ((cur = tb[DEV_ATTR_MTU6]) && blobmsg_get_u32(cur) >= 1280) {
  321. s->mtu6 = blobmsg_get_u32(cur);
  322. s->flags |= DEV_OPT_MTU6;
  323. }
  324. if ((cur = tb[DEV_ATTR_TXQUEUELEN])) {
  325. s->txqueuelen = blobmsg_get_u32(cur);
  326. s->flags |= DEV_OPT_TXQUEUELEN;
  327. }
  328. if ((cur = tb[DEV_ATTR_MACADDR])) {
  329. ea = ether_aton(blobmsg_data(cur));
  330. if (ea) {
  331. memcpy(s->macaddr, ea, 6);
  332. s->flags |= DEV_OPT_MACADDR;
  333. }
  334. }
  335. if ((cur = tb[DEV_ATTR_IPV6])) {
  336. s->ipv6 = blobmsg_get_bool(cur);
  337. s->flags |= DEV_OPT_IPV6;
  338. }
  339. if ((cur = tb[DEV_ATTR_IP6SEGMENTROUTING])) {
  340. s->ip6segmentrouting = blobmsg_get_bool(cur);
  341. s->flags |= DEV_OPT_IP6SEGMENTROUTING;
  342. }
  343. if ((cur = tb[DEV_ATTR_PROMISC])) {
  344. s->promisc = blobmsg_get_bool(cur);
  345. s->flags |= DEV_OPT_PROMISC;
  346. }
  347. if ((cur = tb[DEV_ATTR_RPFILTER])) {
  348. if (system_resolve_rpfilter(blobmsg_data(cur), &s->rpfilter))
  349. s->flags |= DEV_OPT_RPFILTER;
  350. else
  351. D(DEVICE, "Failed to resolve rpfilter: %s", (char *) blobmsg_data(cur));
  352. }
  353. if ((cur = tb[DEV_ATTR_ACCEPTLOCAL])) {
  354. s->acceptlocal = blobmsg_get_bool(cur);
  355. s->flags |= DEV_OPT_ACCEPTLOCAL;
  356. }
  357. if ((cur = tb[DEV_ATTR_IGMPVERSION])) {
  358. s->igmpversion = blobmsg_get_u32(cur);
  359. if (s->igmpversion >= 1 && s->igmpversion <= 3)
  360. s->flags |= DEV_OPT_IGMPVERSION;
  361. else
  362. D(DEVICE, "Failed to resolve igmpversion: %d", blobmsg_get_u32(cur));
  363. }
  364. if ((cur = tb[DEV_ATTR_MLDVERSION])) {
  365. s->mldversion = blobmsg_get_u32(cur);
  366. if (s->mldversion >= 1 && s->mldversion <= 2)
  367. s->flags |= DEV_OPT_MLDVERSION;
  368. else
  369. D(DEVICE, "Failed to resolve mldversion: %d", blobmsg_get_u32(cur));
  370. }
  371. if ((cur = tb[DEV_ATTR_NEIGHREACHABLETIME])) {
  372. s->neigh6reachabletime = s->neigh4reachabletime = blobmsg_get_u32(cur);
  373. s->flags |= DEV_OPT_NEIGHREACHABLETIME;
  374. }
  375. if ((cur = tb[DEV_ATTR_NEIGHGCSTALETIME])) {
  376. s->neigh6gcstaletime = s->neigh4gcstaletime = blobmsg_get_u32(cur);
  377. s->flags |= DEV_OPT_NEIGHGCSTALETIME;
  378. }
  379. if ((cur = tb[DEV_ATTR_NEIGHLOCKTIME])) {
  380. s->neigh4locktime = blobmsg_get_u32(cur);
  381. s->flags |= DEV_OPT_NEIGHLOCKTIME;
  382. }
  383. if ((cur = tb[DEV_ATTR_DADTRANSMITS])) {
  384. s->dadtransmits = blobmsg_get_u32(cur);
  385. s->flags |= DEV_OPT_DADTRANSMITS;
  386. }
  387. if ((cur = tb[DEV_ATTR_MULTICAST_TO_UNICAST])) {
  388. s->multicast_to_unicast = blobmsg_get_bool(cur);
  389. s->flags |= DEV_OPT_MULTICAST_TO_UNICAST;
  390. }
  391. if ((cur = tb[DEV_ATTR_MULTICAST_ROUTER])) {
  392. s->multicast_router = blobmsg_get_u32(cur);
  393. if (s->multicast_router <= 2)
  394. s->flags |= DEV_OPT_MULTICAST_ROUTER;
  395. else
  396. D(DEVICE, "Invalid value: %d - (Use 0: never, 1: learn, 2: always)", blobmsg_get_u32(cur));
  397. }
  398. if ((cur = tb[DEV_ATTR_MULTICAST_FAST_LEAVE])) {
  399. s->multicast_fast_leave = blobmsg_get_bool(cur);
  400. s->flags |= DEV_OPT_MULTICAST_FAST_LEAVE;
  401. }
  402. if ((cur = tb[DEV_ATTR_MULTICAST])) {
  403. s->multicast = blobmsg_get_bool(cur);
  404. s->flags |= DEV_OPT_MULTICAST;
  405. }
  406. if ((cur = tb[DEV_ATTR_LEARNING])) {
  407. s->learning = blobmsg_get_bool(cur);
  408. s->flags |= DEV_OPT_LEARNING;
  409. }
  410. if ((cur = tb[DEV_ATTR_UNICAST_FLOOD])) {
  411. s->unicast_flood = blobmsg_get_bool(cur);
  412. s->flags |= DEV_OPT_UNICAST_FLOOD;
  413. }
  414. if ((cur = tb[DEV_ATTR_SENDREDIRECTS])) {
  415. s->sendredirects = blobmsg_get_bool(cur);
  416. s->flags |= DEV_OPT_SENDREDIRECTS;
  417. }
  418. if ((cur = tb[DEV_ATTR_ISOLATE])) {
  419. s->isolate = blobmsg_get_bool(cur);
  420. s->flags |= DEV_OPT_ISOLATE;
  421. }
  422. if ((cur = tb[DEV_ATTR_DROP_V4_UNICAST_IN_L2_MULTICAST])) {
  423. s->drop_v4_unicast_in_l2_multicast = blobmsg_get_bool(cur);
  424. s->flags |= DEV_OPT_DROP_V4_UNICAST_IN_L2_MULTICAST;
  425. }
  426. if ((cur = tb[DEV_ATTR_DROP_V6_UNICAST_IN_L2_MULTICAST])) {
  427. s->drop_v6_unicast_in_l2_multicast = blobmsg_get_bool(cur);
  428. s->flags |= DEV_OPT_DROP_V6_UNICAST_IN_L2_MULTICAST;
  429. }
  430. if ((cur = tb[DEV_ATTR_DROP_GRATUITOUS_ARP])) {
  431. s->drop_gratuitous_arp = blobmsg_get_bool(cur);
  432. s->flags |= DEV_OPT_DROP_GRATUITOUS_ARP;
  433. }
  434. if ((cur = tb[DEV_ATTR_DROP_UNSOLICITED_NA])) {
  435. s->drop_unsolicited_na = blobmsg_get_bool(cur);
  436. s->flags |= DEV_OPT_DROP_UNSOLICITED_NA;
  437. }
  438. if ((cur = tb[DEV_ATTR_ARP_ACCEPT])) {
  439. s->arp_accept = blobmsg_get_bool(cur);
  440. s->flags |= DEV_OPT_ARP_ACCEPT;
  441. }
  442. if ((cur = tb[DEV_ATTR_AUTH])) {
  443. s->auth = blobmsg_get_bool(cur);
  444. s->flags |= DEV_OPT_AUTH;
  445. }
  446. if ((cur = tb[DEV_ATTR_SPEED])) {
  447. s->speed = blobmsg_get_u32(cur);
  448. s->flags |= DEV_OPT_SPEED;
  449. }
  450. if ((cur = tb[DEV_ATTR_DUPLEX])) {
  451. s->duplex = blobmsg_get_bool(cur);
  452. s->flags |= DEV_OPT_DUPLEX;
  453. }
  454. if ((cur = tb[DEV_ATTR_PAUSE])) {
  455. s->pause = blobmsg_get_bool(cur);
  456. s->flags |= DEV_OPT_PAUSE;
  457. }
  458. if ((cur = tb[DEV_ATTR_ASYM_PAUSE])) {
  459. s->asym_pause = blobmsg_get_bool(cur);
  460. s->flags |= DEV_OPT_ASYM_PAUSE;
  461. }
  462. if ((cur = tb[DEV_ATTR_RXPAUSE])) {
  463. s->rxpause = blobmsg_get_bool(cur);
  464. s->flags |= DEV_OPT_RXPAUSE;
  465. }
  466. if ((cur = tb[DEV_ATTR_TXPAUSE])) {
  467. s->txpause = blobmsg_get_bool(cur);
  468. s->flags |= DEV_OPT_TXPAUSE;
  469. }
  470. if ((cur = tb[DEV_ATTR_AUTONEG])) {
  471. s->autoneg = blobmsg_get_bool(cur);
  472. s->flags |= DEV_OPT_AUTONEG;
  473. }
  474. if ((cur = tb[DEV_ATTR_GRO])) {
  475. s->gro = blobmsg_get_bool(cur);
  476. s->flags |= DEV_OPT_GRO;
  477. }
  478. if ((cur = tb[DEV_ATTR_MASTER])) {
  479. char *ifname = blobmsg_get_string(cur);
  480. s->master_ifindex = if_nametoindex(ifname);
  481. s->flags |= DEV_OPT_MASTER;
  482. }
  483. if ((cur = tb[DEV_ATTR_EEE])) {
  484. s->eee = blobmsg_get_bool(cur);
  485. s->flags |= DEV_OPT_EEE;
  486. }
  487. /* Remember the settings present in UCI */
  488. s->valid_flags = s->flags;
  489. cur = tb[DEV_ATTR_AUTH_VLAN];
  490. free(dev->config_auth_vlans);
  491. dev->config_auth_vlans = cur ? blob_memdup(cur) : NULL;
  492. device_set_extra_vlans(dev, tb[DEV_ATTR_VLAN]);
  493. device_set_disabled(dev, disabled);
  494. }
  495. static void __init dev_init(void)
  496. {
  497. avl_init(&devices, avl_strcmp, true, NULL);
  498. }
  499. static int device_release_cb(void *ctx, struct safe_list *list)
  500. {
  501. struct device_user *dep = container_of(list, struct device_user, list);
  502. if (!dep->dev || !dep->claimed)
  503. return 0;
  504. device_release(dep);
  505. return 0;
  506. }
  507. static int device_broadcast_cb(void *ctx, struct safe_list *list)
  508. {
  509. struct device_user *dep = container_of(list, struct device_user, list);
  510. int *ev = ctx;
  511. /* device might have been removed by an earlier callback */
  512. if (!dep->dev)
  513. return 0;
  514. if (dep->cb)
  515. dep->cb(dep, *ev);
  516. return 0;
  517. }
  518. void device_broadcast_event(struct device *dev, enum device_event ev)
  519. {
  520. static const char * const event_names[] = {
  521. [DEV_EVENT_ADD] = "add",
  522. [DEV_EVENT_REMOVE] = "remove",
  523. [DEV_EVENT_UP] = "up",
  524. [DEV_EVENT_DOWN] = "down",
  525. [DEV_EVENT_AUTH_UP] = "auth_up",
  526. [DEV_EVENT_LINK_UP] = "link_up",
  527. [DEV_EVENT_LINK_DOWN] = "link_down",
  528. [DEV_EVENT_TOPO_CHANGE] = "topo_change",
  529. };
  530. int dev_ev = ev;
  531. safe_list_for_each(&dev->aliases, device_broadcast_cb, &dev_ev);
  532. safe_list_for_each(&dev->users, device_broadcast_cb, &dev_ev);
  533. if (ev >= ARRAY_SIZE(event_names) || !event_names[ev] || !dev->ifname[0])
  534. return;
  535. blob_buf_init(&b, 0);
  536. blobmsg_add_string(&b, "name", dev->ifname);
  537. blobmsg_add_u8(&b, "auth_status", dev->auth_status);
  538. blobmsg_add_u8(&b, "present", dev->present);
  539. blobmsg_add_u8(&b, "active", dev->active);
  540. blobmsg_add_u8(&b, "link_active", dev->link_active);
  541. netifd_ubus_device_notify(event_names[ev], b.head, -1);
  542. }
  543. static void
  544. device_fill_default_settings(struct device *dev)
  545. {
  546. struct device_settings *s = &dev->settings;
  547. struct ether_addr *ea;
  548. const char *master;
  549. int ret;
  550. if (!(s->flags & DEV_OPT_MACADDR)) {
  551. ea = config_get_default_macaddr(dev->ifname);
  552. if (ea) {
  553. memcpy(s->macaddr, ea, 6);
  554. s->flags |= DEV_OPT_DEFAULT_MACADDR;
  555. }
  556. }
  557. if (!(s->flags & DEV_OPT_GRO)) {
  558. ret = config_get_default_gro(dev->ifname);
  559. if (ret >= 0) {
  560. s->gro = ret;
  561. s->flags |= DEV_OPT_GRO;
  562. }
  563. }
  564. if (!(s->flags & DEV_OPT_MASTER)) {
  565. master = config_get_default_conduit(dev->ifname);
  566. if (master) {
  567. s->master_ifindex = if_nametoindex(master);
  568. s->flags |= DEV_OPT_MASTER;
  569. }
  570. }
  571. }
  572. int device_claim(struct device_user *dep)
  573. {
  574. struct device *dev = dep->dev;
  575. int ret = 0;
  576. if (dep->claimed)
  577. return 0;
  578. if (!dev)
  579. return -1;
  580. dep->claimed = true;
  581. D(DEVICE, "Claim %s %s, new active count: %d", dev->type->name, dev->ifname, dev->active + 1);
  582. if (++dev->active != 1)
  583. return 0;
  584. device_broadcast_event(dev, DEV_EVENT_SETUP);
  585. device_fill_default_settings(dev);
  586. if (dev->external) {
  587. /* Get ifindex for external claimed devices so a valid */
  588. /* ifindex is in place avoiding possible race conditions */
  589. device_set_ifindex(dev, system_if_resolve(dev));
  590. if (!dev->ifindex)
  591. ret = -1;
  592. system_if_get_settings(dev, &dev->orig_settings);
  593. } else
  594. ret = dev->set_state(dev, true);
  595. if (ret == 0)
  596. device_broadcast_event(dev, DEV_EVENT_UP);
  597. else {
  598. D(DEVICE, "claim %s %s failed: %d", dev->type->name, dev->ifname, ret);
  599. dev->active = 0;
  600. dep->claimed = false;
  601. }
  602. return ret;
  603. }
  604. void device_release(struct device_user *dep)
  605. {
  606. struct device *dev = dep->dev;
  607. if (!dep->claimed)
  608. return;
  609. dep->claimed = false;
  610. dev->active--;
  611. D(DEVICE, "Release %s %s, new active count: %d", dev->type->name, dev->ifname, dev->active);
  612. assert(dev->active >= 0);
  613. if (dev->active)
  614. return;
  615. device_broadcast_event(dev, DEV_EVENT_TEARDOWN);
  616. if (!dev->external)
  617. dev->set_state(dev, false);
  618. if (dev->active)
  619. return;
  620. device_broadcast_event(dev, DEV_EVENT_DOWN);
  621. }
  622. int device_check_state(struct device *dev)
  623. {
  624. if (!dev->type->check_state)
  625. return simple_device_type.check_state(dev);
  626. return dev->type->check_state(dev);
  627. }
  628. int device_init_virtual(struct device *dev, struct device_type *type, const char *name)
  629. {
  630. assert(dev);
  631. assert(type);
  632. D(DEVICE, "Initialize device '%s'", name ? name : "");
  633. INIT_SAFE_LIST(&dev->users);
  634. INIT_SAFE_LIST(&dev->aliases);
  635. dev->type = type;
  636. if (name) {
  637. int ret;
  638. ret = device_set_ifname(dev, name);
  639. if (ret < 0) {
  640. netifd_log_message(L_WARNING, "Failed to initalize device '%s'\n", name);
  641. return ret;
  642. }
  643. }
  644. if (!dev->set_state)
  645. dev->set_state = set_device_state;
  646. return 0;
  647. }
  648. int device_init(struct device *dev, struct device_type *type, const char *ifname)
  649. {
  650. int ret;
  651. ret = device_init_virtual(dev, type, ifname);
  652. if (ret < 0)
  653. return ret;
  654. dev->avl.key = dev->ifname;
  655. ret = avl_insert(&devices, &dev->avl);
  656. if (ret < 0)
  657. return ret;
  658. system_if_clear_state(dev);
  659. return 0;
  660. }
  661. static struct device *
  662. device_create_default(const char *name, bool external)
  663. {
  664. struct device *dev;
  665. if (!external && system_if_force_external(name))
  666. return NULL;
  667. D(DEVICE, "Create simple device '%s'", name);
  668. dev = calloc(1, sizeof(*dev));
  669. if (!dev)
  670. return NULL;
  671. dev->external = external;
  672. dev->set_state = simple_device_set_state;
  673. if (device_init(dev, &simple_device_type, name) < 0) {
  674. device_cleanup(dev);
  675. free(dev);
  676. return NULL;
  677. }
  678. dev->default_config = true;
  679. if (external)
  680. system_if_apply_settings(dev, &dev->settings, dev->settings.flags);
  681. device_check_state(dev);
  682. return dev;
  683. }
  684. struct device *
  685. device_find(const char *name)
  686. {
  687. struct device *dev;
  688. return avl_find_element(&devices, name, dev, avl);
  689. }
  690. struct device *
  691. __device_get(const char *name, int create, bool check_vlan)
  692. {
  693. struct device *dev;
  694. dev = avl_find_element(&devices, name, dev, avl);
  695. if (!dev && check_vlan && strchr(name, '.'))
  696. return get_vlan_device_chain(name, create);
  697. if (name[0] == '@')
  698. return device_alias_get(name + 1);
  699. if (dev) {
  700. if (create > 1 && !dev->external) {
  701. system_if_apply_settings(dev, &dev->settings, dev->settings.flags);
  702. dev->external = true;
  703. device_set_present(dev, true);
  704. }
  705. return dev;
  706. }
  707. if (!create)
  708. return NULL;
  709. return device_create_default(name, create > 1);
  710. }
  711. static void
  712. device_delete(struct device *dev)
  713. {
  714. if (!dev->avl.key)
  715. return;
  716. D(DEVICE, "Delete device '%s' from list", dev->ifname);
  717. avl_delete(&devices, &dev->avl);
  718. dev->avl.key = NULL;
  719. }
  720. static int device_cleanup_cb(void *ctx, struct safe_list *list)
  721. {
  722. struct device_user *dep = container_of(list, struct device_user, list);
  723. if (dep->cb)
  724. dep->cb(dep, DEV_EVENT_REMOVE);
  725. device_release(dep);
  726. return 0;
  727. }
  728. void device_cleanup(struct device *dev)
  729. {
  730. D(DEVICE, "Clean up device '%s'", dev->ifname);
  731. safe_list_for_each(&dev->users, device_cleanup_cb, NULL);
  732. safe_list_for_each(&dev->aliases, device_cleanup_cb, NULL);
  733. device_delete(dev);
  734. }
  735. static void __device_set_present(struct device *dev, bool state, bool force)
  736. {
  737. if (dev->present == state && !force)
  738. return;
  739. dev->present = state;
  740. device_broadcast_event(dev, state ? DEV_EVENT_ADD : DEV_EVENT_REMOVE);
  741. }
  742. void
  743. device_refresh_present(struct device *dev)
  744. {
  745. bool state = dev->sys_present;
  746. if (dev->disabled || dev->deferred)
  747. state = false;
  748. __device_set_present(dev, state, false);
  749. }
  750. void
  751. device_set_auth_status(struct device *dev, bool value, struct blob_attr *vlans)
  752. {
  753. if (!value)
  754. vlans = NULL;
  755. else if (!blob_attr_equal(vlans, dev->auth_vlans))
  756. device_set_auth_status(dev, false, NULL);
  757. free(dev->auth_vlans);
  758. dev->auth_vlans = vlans ? blob_memdup(vlans) : NULL;
  759. if (dev->auth_status == value)
  760. return;
  761. dev->auth_status = value;
  762. if (!dev->present)
  763. return;
  764. if (dev->auth_status) {
  765. device_broadcast_event(dev, DEV_EVENT_AUTH_UP);
  766. return;
  767. }
  768. device_broadcast_event(dev, DEV_EVENT_LINK_DOWN);
  769. if (!dev->link_active)
  770. return;
  771. device_broadcast_event(dev, DEV_EVENT_LINK_UP);
  772. }
  773. void device_set_present(struct device *dev, bool state)
  774. {
  775. if (dev->sys_present == state)
  776. return;
  777. D(DEVICE, "%s '%s' %s present", dev->type->name, dev->ifname, state ? "is now" : "is no longer" );
  778. dev->sys_present = state;
  779. if (!state)
  780. __device_set_present(dev, state, true);
  781. else
  782. device_refresh_present(dev);
  783. if (!state)
  784. safe_list_for_each(&dev->users, device_release_cb, NULL);
  785. }
  786. void device_set_link(struct device *dev, bool state)
  787. {
  788. if (dev->link_active == state)
  789. return;
  790. netifd_log_message(L_NOTICE, "%s '%s' link is %s\n", dev->type->name, dev->ifname, state ? "up" : "down" );
  791. dev->link_active = state;
  792. if (!state)
  793. dev->auth_status = false;
  794. device_broadcast_event(dev, state ? DEV_EVENT_LINK_UP : DEV_EVENT_LINK_DOWN);
  795. }
  796. void device_set_ifindex(struct device *dev, int ifindex)
  797. {
  798. if (dev->ifindex == ifindex)
  799. return;
  800. dev->ifindex = ifindex;
  801. device_broadcast_event(dev, DEV_EVENT_UPDATE_IFINDEX);
  802. }
  803. int device_set_ifname(struct device *dev, const char *name)
  804. {
  805. int ret = 0;
  806. if (!strcmp(dev->ifname, name))
  807. return 0;
  808. if (strlen(name) > sizeof(dev->ifname) - 1) {
  809. netifd_log_message(L_WARNING, "Cannot set device name: '%s' is longer than max size %zd\n",
  810. name, sizeof(dev->ifname) - 1);
  811. return -1;
  812. }
  813. if (dev->avl.key)
  814. avl_delete(&devices, &dev->avl);
  815. strcpy(dev->ifname, name);
  816. if (dev->avl.key)
  817. ret = avl_insert(&devices, &dev->avl);
  818. if (ret == 0)
  819. device_broadcast_event(dev, DEV_EVENT_UPDATE_IFNAME);
  820. return ret;
  821. }
  822. static int device_refcount(struct device *dev)
  823. {
  824. struct list_head *list;
  825. int count = 0;
  826. list_for_each(list, &dev->users.list)
  827. count++;
  828. list_for_each(list, &dev->aliases.list)
  829. count++;
  830. return count;
  831. }
  832. static void
  833. __device_add_user(struct device_user *dep, struct device *dev)
  834. {
  835. struct safe_list *head;
  836. dep->dev = dev;
  837. if (dep->alias)
  838. head = &dev->aliases;
  839. else
  840. head = &dev->users;
  841. safe_list_add(&dep->list, head);
  842. D(DEVICE, "Add user for device '%s', refcount=%d", dev->ifname, device_refcount(dev));
  843. if (dep->cb && dev->present) {
  844. dep->cb(dep, DEV_EVENT_ADD);
  845. if (dev->active)
  846. dep->cb(dep, DEV_EVENT_UP);
  847. if (dev->link_active)
  848. dep->cb(dep, DEV_EVENT_LINK_UP);
  849. }
  850. }
  851. void device_add_user(struct device_user *dep, struct device *dev)
  852. {
  853. if (dep->dev == dev)
  854. return;
  855. if (dep->dev)
  856. device_remove_user(dep);
  857. if (!dev)
  858. return;
  859. __device_add_user(dep, dev);
  860. }
  861. static void
  862. device_free(struct device *dev)
  863. {
  864. __devlock++;
  865. free(dev->auth_vlans);
  866. free(dev->config);
  867. device_cleanup(dev);
  868. free(dev->config_auth_vlans);
  869. free(dev->extra_vlan);
  870. dev->type->free(dev);
  871. __devlock--;
  872. }
  873. static void
  874. __device_free_unused(struct uloop_timeout *timeout)
  875. {
  876. struct device *dev, *tmp;
  877. avl_for_each_element_safe(&devices, dev, avl, tmp) {
  878. if (!safe_list_empty(&dev->users) ||
  879. !safe_list_empty(&dev->aliases) ||
  880. dev->current_config)
  881. continue;
  882. device_free(dev);
  883. }
  884. }
  885. void device_free_unused(void)
  886. {
  887. static struct uloop_timeout free_timer = {
  888. .cb = __device_free_unused,
  889. };
  890. uloop_timeout_set(&free_timer, 1);
  891. }
  892. void device_remove_user(struct device_user *dep)
  893. {
  894. struct device *dev = dep->dev;
  895. if (!dep->dev)
  896. return;
  897. dep->hotplug = false;
  898. if (dep->claimed)
  899. device_release(dep);
  900. safe_list_del(&dep->list);
  901. dep->dev = NULL;
  902. D(DEVICE, "Remove user for device '%s', refcount=%d", dev->ifname, device_refcount(dev));
  903. device_free_unused();
  904. }
  905. void
  906. device_init_pending(void)
  907. {
  908. struct device *dev, *tmp;
  909. avl_for_each_element_safe(&devices, dev, avl, tmp) {
  910. if (!dev->config_pending)
  911. continue;
  912. dev->type->config_init(dev);
  913. dev->config_pending = false;
  914. device_check_state(dev);
  915. }
  916. }
  917. bool
  918. device_check_ip6segmentrouting(void)
  919. {
  920. struct device *dev;
  921. bool ip6segmentrouting = false;
  922. avl_for_each_element(&devices, dev, avl)
  923. ip6segmentrouting |= dev->settings.ip6segmentrouting;
  924. return ip6segmentrouting;
  925. }
  926. static enum dev_change_type
  927. device_set_config(struct device *dev, struct device_type *type,
  928. struct blob_attr *attr)
  929. {
  930. struct blob_attr *tb[__DEV_ATTR_MAX];
  931. const struct uci_blob_param_list *cfg = type->config_params;
  932. if (type != dev->type)
  933. return DEV_CONFIG_RECREATE;
  934. if (dev->type->reload)
  935. return dev->type->reload(dev, attr);
  936. if (uci_blob_check_equal(dev->config, attr, cfg))
  937. return DEV_CONFIG_NO_CHANGE;
  938. if (cfg == &device_attr_list) {
  939. memset(tb, 0, sizeof(tb));
  940. if (attr)
  941. blobmsg_parse(dev_attrs, __DEV_ATTR_MAX, tb,
  942. blob_data(attr), blob_len(attr));
  943. device_init_settings(dev, tb);
  944. return DEV_CONFIG_RESTART;
  945. } else
  946. return DEV_CONFIG_RECREATE;
  947. }
  948. enum dev_change_type
  949. device_apply_config(struct device *dev, struct device_type *type,
  950. struct blob_attr *config)
  951. {
  952. enum dev_change_type change;
  953. change = device_set_config(dev, type, config);
  954. if (dev->external) {
  955. system_if_apply_settings(dev, &dev->settings, dev->settings.flags);
  956. change = DEV_CONFIG_APPLIED;
  957. }
  958. switch (change) {
  959. case DEV_CONFIG_RESTART:
  960. case DEV_CONFIG_APPLIED:
  961. D(DEVICE, "Device '%s': config applied", dev->ifname);
  962. config = blob_memdup(config);
  963. free(dev->config);
  964. dev->config = config;
  965. if (change == DEV_CONFIG_RESTART && dev->present) {
  966. int ret = 0;
  967. device_set_present(dev, false);
  968. if (dev->active && !dev->external) {
  969. ret = dev->set_state(dev, false);
  970. if (!ret)
  971. ret = dev->set_state(dev, true);
  972. }
  973. if (!ret)
  974. device_set_present(dev, true);
  975. }
  976. break;
  977. case DEV_CONFIG_NO_CHANGE:
  978. D(DEVICE, "Device '%s': no configuration change", dev->ifname);
  979. break;
  980. case DEV_CONFIG_RECREATE:
  981. break;
  982. }
  983. return change;
  984. }
  985. static void
  986. device_replace(struct device *dev, struct device *odev)
  987. {
  988. struct device_user *dep;
  989. __devlock++;
  990. if (odev->present)
  991. device_set_present(odev, false);
  992. while (!list_empty(&odev->users.list)) {
  993. dep = list_first_entry(&odev->users.list, struct device_user, list.list);
  994. device_release(dep);
  995. if (!dep->dev)
  996. continue;
  997. safe_list_del(&dep->list);
  998. __device_add_user(dep, dev);
  999. }
  1000. __devlock--;
  1001. device_free(odev);
  1002. }
  1003. void
  1004. device_reset_config(void)
  1005. {
  1006. struct device *dev;
  1007. avl_for_each_element(&devices, dev, avl)
  1008. dev->current_config = false;
  1009. }
  1010. void
  1011. device_reset_old(void)
  1012. {
  1013. struct device *dev, *tmp, *ndev;
  1014. avl_for_each_element_safe(&devices, dev, avl, tmp) {
  1015. if (dev->current_config || dev->default_config)
  1016. continue;
  1017. if (dev->type != &simple_device_type)
  1018. continue;
  1019. ndev = device_create_default(dev->ifname, dev->external);
  1020. if (!ndev)
  1021. continue;
  1022. device_replace(ndev, dev);
  1023. }
  1024. }
  1025. struct device *
  1026. device_create(const char *name, struct device_type *type,
  1027. struct blob_attr *config)
  1028. {
  1029. struct device *odev = NULL, *dev;
  1030. enum dev_change_type change;
  1031. odev = device_find(name);
  1032. if (odev) {
  1033. odev->current_config = true;
  1034. change = device_apply_config(odev, type, config);
  1035. switch (change) {
  1036. case DEV_CONFIG_RECREATE:
  1037. D(DEVICE, "Device '%s': recreate device", odev->ifname);
  1038. device_delete(odev);
  1039. break;
  1040. default:
  1041. return odev;
  1042. }
  1043. } else
  1044. D(DEVICE, "Create new device '%s' (%s)", name, type->name);
  1045. config = blob_memdup(config);
  1046. if (!config)
  1047. return NULL;
  1048. dev = type->create(name, type, config);
  1049. if (!dev)
  1050. return NULL;
  1051. dev->current_config = true;
  1052. dev->config = config;
  1053. if (odev)
  1054. device_replace(dev, odev);
  1055. if (!config_init && dev->config_pending) {
  1056. type->config_init(dev);
  1057. dev->config_pending = false;
  1058. }
  1059. device_check_state(dev);
  1060. return dev;
  1061. }
  1062. void
  1063. device_dump_status(struct blob_buf *b, struct device *dev)
  1064. {
  1065. struct device_settings st;
  1066. void *c, *s;
  1067. if (!dev) {
  1068. avl_for_each_element(&devices, dev, avl) {
  1069. if (!dev->present)
  1070. continue;
  1071. c = blobmsg_open_table(b, dev->ifname);
  1072. device_dump_status(b, dev);
  1073. blobmsg_close_table(b, c);
  1074. }
  1075. return;
  1076. }
  1077. blobmsg_add_u8(b, "external", dev->external);
  1078. blobmsg_add_u8(b, "present", dev->present);
  1079. blobmsg_add_string(b, "type", dev->type->name);
  1080. if (!dev->present)
  1081. return;
  1082. blobmsg_add_u8(b, "up", !!dev->active);
  1083. blobmsg_add_u8(b, "carrier", !!dev->link_active);
  1084. blobmsg_add_u8(b, "auth_status", !!dev->auth_status);
  1085. if (dev->type->dump_info)
  1086. dev->type->dump_info(dev, b);
  1087. else
  1088. system_if_dump_info(dev, b);
  1089. if (dev->active) {
  1090. device_merge_settings(dev, &st);
  1091. if (st.flags & DEV_OPT_MASTER) {
  1092. char buf[64], *devname;
  1093. devname = if_indextoname(st.master_ifindex, buf);
  1094. if (devname)
  1095. blobmsg_add_string(b, "conduit", devname);
  1096. }
  1097. if (st.flags & DEV_OPT_MTU)
  1098. blobmsg_add_u32(b, "mtu", st.mtu);
  1099. if (st.flags & DEV_OPT_MTU6)
  1100. blobmsg_add_u32(b, "mtu6", st.mtu6);
  1101. if (st.flags & DEV_OPT_MACADDR)
  1102. blobmsg_add_string(b, "macaddr", format_macaddr(st.macaddr));
  1103. if (st.flags & DEV_OPT_TXQUEUELEN)
  1104. blobmsg_add_u32(b, "txqueuelen", st.txqueuelen);
  1105. if (st.flags & DEV_OPT_IPV6)
  1106. blobmsg_add_u8(b, "ipv6", st.ipv6);
  1107. if (st.flags & DEV_OPT_IP6SEGMENTROUTING)
  1108. blobmsg_add_u8(b, "ip6segmentrouting", st.ip6segmentrouting);
  1109. if (st.flags & DEV_OPT_PROMISC)
  1110. blobmsg_add_u8(b, "promisc", st.promisc);
  1111. if (st.flags & DEV_OPT_RPFILTER)
  1112. blobmsg_add_u32(b, "rpfilter", st.rpfilter);
  1113. if (st.flags & DEV_OPT_ACCEPTLOCAL)
  1114. blobmsg_add_u8(b, "acceptlocal", st.acceptlocal);
  1115. if (st.flags & DEV_OPT_IGMPVERSION)
  1116. blobmsg_add_u32(b, "igmpversion", st.igmpversion);
  1117. if (st.flags & DEV_OPT_MLDVERSION)
  1118. blobmsg_add_u32(b, "mldversion", st.mldversion);
  1119. if (st.flags & DEV_OPT_NEIGHREACHABLETIME) {
  1120. blobmsg_add_u32(b, "neigh4reachabletime", st.neigh4reachabletime);
  1121. blobmsg_add_u32(b, "neigh6reachabletime", st.neigh6reachabletime);
  1122. }
  1123. if (st.flags & DEV_OPT_NEIGHGCSTALETIME) {
  1124. blobmsg_add_u32(b, "neigh4gcstaletime", st.neigh4gcstaletime);
  1125. blobmsg_add_u32(b, "neigh6gcstaletime", st.neigh6gcstaletime);
  1126. }
  1127. if (st.flags & DEV_OPT_NEIGHLOCKTIME)
  1128. blobmsg_add_u32(b, "neigh4locktime", st.neigh4locktime);
  1129. if (st.flags & DEV_OPT_DADTRANSMITS)
  1130. blobmsg_add_u32(b, "dadtransmits", st.dadtransmits);
  1131. if (st.flags & DEV_OPT_MULTICAST_TO_UNICAST)
  1132. blobmsg_add_u8(b, "multicast_to_unicast", st.multicast_to_unicast);
  1133. if (st.flags & DEV_OPT_MULTICAST_ROUTER)
  1134. blobmsg_add_u32(b, "multicast_router", st.multicast_router);
  1135. if (st.flags & DEV_OPT_MULTICAST_FAST_LEAVE)
  1136. blobmsg_add_u8(b, "multicast_fast_leave", st.multicast_fast_leave);
  1137. if (st.flags & DEV_OPT_MULTICAST)
  1138. blobmsg_add_u8(b, "multicast", st.multicast);
  1139. if (st.flags & DEV_OPT_LEARNING)
  1140. blobmsg_add_u8(b, "learning", st.learning);
  1141. if (st.flags & DEV_OPT_UNICAST_FLOOD)
  1142. blobmsg_add_u8(b, "unicast_flood", st.unicast_flood);
  1143. if (st.flags & DEV_OPT_SENDREDIRECTS)
  1144. blobmsg_add_u8(b, "sendredirects", st.sendredirects);
  1145. if (st.flags & DEV_OPT_DROP_V4_UNICAST_IN_L2_MULTICAST)
  1146. blobmsg_add_u8(b, "drop_v4_unicast_in_l2_multicast", st.drop_v4_unicast_in_l2_multicast);
  1147. if (st.flags & DEV_OPT_DROP_V6_UNICAST_IN_L2_MULTICAST)
  1148. blobmsg_add_u8(b, "drop_v6_unicast_in_l2_multicast", st.drop_v6_unicast_in_l2_multicast);
  1149. if (st.flags & DEV_OPT_DROP_GRATUITOUS_ARP)
  1150. blobmsg_add_u8(b, "drop_gratuitous_arp", st.drop_gratuitous_arp);
  1151. if (st.flags & DEV_OPT_DROP_UNSOLICITED_NA)
  1152. blobmsg_add_u8(b, "drop_unsolicited_na", st.drop_unsolicited_na);
  1153. if (st.flags & DEV_OPT_ARP_ACCEPT)
  1154. blobmsg_add_u8(b, "arp_accept", st.arp_accept);
  1155. if (st.flags & DEV_OPT_AUTH)
  1156. blobmsg_add_u8(b, "auth", st.auth);
  1157. if (st.flags & DEV_OPT_GRO)
  1158. blobmsg_add_u8(b, "gro", st.gro);
  1159. if (st.flags & DEV_OPT_EEE)
  1160. blobmsg_add_u8(b, "eee", st.eee);
  1161. }
  1162. s = blobmsg_open_table(b, "statistics");
  1163. if (dev->type->dump_stats)
  1164. dev->type->dump_stats(dev, b);
  1165. else
  1166. system_if_dump_stats(dev, b);
  1167. blobmsg_close_table(b, s);
  1168. }
  1169. static void __init simple_device_type_init(void)
  1170. {
  1171. device_type_add(&simple_device_type);
  1172. }
  1173. void device_hotplug_event(const char *name, bool add)
  1174. {
  1175. struct device *dev;
  1176. wireless_device_hotplug_event(name, add);
  1177. dev = device_find(name);
  1178. if (!dev || dev->type != &simple_device_type)
  1179. return;
  1180. device_set_present(dev, add);
  1181. }