2 * nmrpflash - Netgear Unbrick Utility
3 * Copyright (C) 2016 Joseph Lehner <joseph.c.lehner@gmail.com>
5 * nmrpflash is free software: you can redistribute it and/or modify
6 * it under the terms of the GNU General Public License as published by
7 * the Free Software Foundation, either version 3 of the License, or
8 * (at your option) any later version.
10 * nmrpflash is distributed in the hope that it will be useful,
11 * but WITHOUT ANY WARRANTY; without even the implied warranty of
12 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
13 * GNU General Public License for more details.
15 * You should have received a copy of the GNU General Public License
16 * along with nmrpflash. If not, see <http://www.gnu.org/licenses/>.
20 #include <sys/types.h>
28 #if defined(NMRPFLASH_WINDOWS)
29 #define NMRPFLASH_NETALIAS_PREFIX "net"
33 #include <sys/ioctl.h>
38 #if defined(NMRPFLASH_LINUX)
39 #define NMRPFLASH_AF_PACKET AF_PACKET
40 #include <linux/if_packet.h>
42 #define NMRPFLASH_AF_PACKET AF_LINK
43 #include <net/if_types.h>
44 #include <net/if_media.h>
52 #ifndef NMRPFLASH_WINDOWS
54 #ifdef NMRPFLASH_LINUX
65 struct ethsock_arp_undo
71 struct ethsock_ip_undo
73 #ifndef NMRPFLASH_WINDOWS
80 const char *mac_to_str(uint8_t *mac)
83 snprintf(buf, sizeof(buf), "%02x:%02x:%02x:%02x:%02x:%02x",
84 mac[0], mac[1], mac[2], mac[3], mac[4], mac[5]);
88 static int x_pcap_findalldevs(pcap_if_t **devs)
90 char errbuf[PCAP_ERRBUF_SIZE];
91 if (pcap_findalldevs(devs, errbuf) != 0) {
92 fprintf(stderr, "%s.\n", errbuf);
99 #ifndef NMRPFLASH_WINDOWS
100 static inline bool sockaddr_get_hwaddr(struct sockaddr *sa, uint8_t *hwaddr)
104 if (sa->sa_family != NMRPFLASH_AF_PACKET) {
108 #ifndef NMRPFLASH_LINUX
109 if (((struct sockaddr_dl*)sa)->sdl_type != IFT_ETHER) {
112 src = LLADDR((struct sockaddr_dl*)sa);
114 src = ((struct sockaddr_ll*)sa)->sll_addr;
117 memcpy(hwaddr, src, 6);
121 #ifdef NMRPFLASH_LINUX
122 static int open_stp_state(const char *intf)
125 snprintf(name, sizeof(name), "/sys/class/net/%s/bridge/stp_state", intf);
126 return open(name, O_RDWR, 0644);
129 static bool is_stp_enabled(const char *intf)
132 int fd = open_stp_state(intf);
137 if (read(fd, &c, 1) != 1) {
145 static bool set_stp_enabled(const char *intf, bool enabled)
148 const char *s = enabled ? "1\n" : "0\n";
149 int fd = open_stp_state(intf);
154 ret = (write(fd, s, 2) == 2);
161 static bool get_intf_info(const char *intf, uint8_t *hwaddr, bool *bridge)
163 struct ifaddrs *ifas, *ifa;
166 if (getifaddrs(&ifas) != 0) {
167 xperror("getifaddrs");
174 for (ifa = ifas; ifa; ifa = ifa->ifa_next) {
175 if (!strcmp(ifa->ifa_name, intf)) {
176 if (sockaddr_get_hwaddr(ifa->ifa_addr, hwaddr)) {
178 *bridge = ((struct if_data*) ifa->ifa_data)->ifi_type == IFT_BRIDGE;
192 void win_perror2(const char *msg, DWORD err)
195 FormatMessageA(FORMAT_MESSAGE_ALLOCATE_BUFFER |
196 FORMAT_MESSAGE_FROM_SYSTEM | FORMAT_MESSAGE_IGNORE_INSERTS,
197 NULL, err, MAKELANGID(LANG_NEUTRAL, SUBLANG_DEFAULT),
198 (LPTSTR)&buf, 0, NULL);
201 /* FormatMessageA terminates buf with CRLF! */
202 fprintf(stderr, "%s: %s", msg, buf);
205 fprintf(stderr, "%s: error %d\n", msg, (int)err);
209 static bool get_intf_info(const char *intf, uint8_t *hwaddr, DWORD *index)
211 PIP_ADAPTER_INFO adapters, adapter;
216 if ((ret = GetAdaptersInfo(NULL, &bufLen)) != ERROR_BUFFER_OVERFLOW) {
217 win_perror2("GetAdaptersInfo", ret);
221 adapters = malloc(bufLen);
227 if ((ret = GetAdaptersInfo(adapters, &bufLen) == NO_ERROR)) {
228 for (adapter = adapters; adapter; adapter = adapter->Next) {
229 if (adapter->Type != MIB_IF_TYPE_ETHERNET && adapter->Type != IF_TYPE_IEEE80211) {
233 /* Interface names from WinPcap are "\Device\NPF_{GUID}", while
234 * AdapterName from GetAdaptersInfo is just "{GUID}".*/
235 if (strstr(intf, adapter->AdapterName)) {
236 if (adapter->AddressLength == 6) {
237 memcpy(hwaddr, adapter->Address, 6);
239 *index = adapter->Index;
247 win_perror2("GetAdaptersInfo", ret);
254 static const char *intf_alias_to_wpcap(const char *intf)
256 static char buf[128];
257 pcap_if_t *devs, *dev;
258 unsigned i = 0, dev_num = 0;
260 if (intf[0] == '\\') {
262 } else if (sscanf(intf, NMRPFLASH_NETALIAS_PREFIX "%u", &dev_num) != 1) {
263 fprintf(stderr, "Invalid interface alias.\n");
267 if (x_pcap_findalldevs(&devs) != 0) {
271 for (dev = devs; dev; dev = dev->next, ++i) {
274 printf("%s%u: %s\n", NMRPFLASH_NETALIAS_PREFIX, i, dev->name);
276 strncpy(buf, dev->name, sizeof(buf) - 1);
277 buf[sizeof(buf) - 1] = '\0';
282 pcap_freealldevs(devs);
285 fprintf(stderr, "Interface alias not found.\n");
292 static const char *intf_get_pretty_name(const char *intf)
294 static char buf[512];
300 guid = strstr(intf, "NPF_{");
307 snprintf(buf, sizeof(buf),
308 "System\\CurrentControlSet\\Control\\Network\\"
309 "{4D36E972-E325-11CE-BFC1-08002BE10318}\\"
310 "%s\\Connection", guid);
311 err = RegOpenKeyExA(HKEY_LOCAL_MACHINE, buf, 0, KEY_READ, &hkey);
312 if (err != ERROR_SUCCESS) {
314 win_perror2("RegOpenKeyExA", err);
320 err = RegQueryValueExA(hkey, "Name", NULL, NULL, (LPBYTE)buf, &len);
321 if (err == ERROR_SUCCESS) {
325 win_perror2("RegQueryValueExA", err);
335 inline uint8_t *ethsock_get_hwaddr(struct ethsock *sock)
340 struct ethsock *ethsock_create(const char *intf, uint16_t protocol)
342 char buf[PCAP_ERRBUF_SIZE];
343 struct bpf_program fp;
344 struct ethsock *sock;
348 #ifdef NMRPFLASH_WINDOWS
349 intf = intf_alias_to_wpcap(intf);
355 sock = malloc(sizeof(struct ethsock));
364 sock->pcap = pcap_open_live(sock->intf, BUFSIZ, 1, 1, buf);
366 fprintf(stderr, "%s.\n", buf);
371 fprintf(stderr, "Warning: %s.\n", buf);
374 if (pcap_datalink(sock->pcap) != DLT_EN10MB) {
375 fprintf(stderr, "%s is not an ethernet interface.\n",
380 #ifndef NMRPFLASH_WINDOWS
381 err = !get_intf_info(intf, sock->hwaddr, &is_bridge);
383 err = !get_intf_info(intf, sock->hwaddr, &sock->index);
386 fprintf(stderr, "Failed to get interface info.\n");
390 #ifndef NMRPFLASH_WINDOWS
391 sock->fd = pcap_get_selectable_fd(sock->pcap);
392 if (sock->fd == -1) {
393 pcap_perror(sock->pcap, "pcap_get_selectable_fd");
397 sock->handle = pcap_getevent(sock->pcap);
399 pcap_perror(sock->pcap, "pcap_getevent");
403 err = pcap_setmintocopy(sock->pcap, 1);
405 pcap_perror(sock->pcap, "pcap_setmintocopy");
410 snprintf(buf, sizeof(buf), "ether proto 0x%04x and not ether src %s",
411 protocol, mac_to_str(sock->hwaddr));
413 err = pcap_compile(sock->pcap, &fp, buf, 0, 0);
415 pcap_perror(sock->pcap, "pcap_compile");
419 err = pcap_setfilter(sock->pcap, &fp);
423 pcap_perror(sock->pcap, "pcap_setfilter");
427 #ifdef NMRPFLASH_LINUX
428 // nmrpflash does not work on bridge interfaces with STP enabled
429 if ((sock->stp = is_stp_enabled(intf))) {
430 if (!set_stp_enabled(intf, false)) {
431 fprintf(stderr, "Warning: failed to disable STP on %s.\n", intf);
436 fprintf(stderr, "Warning: bridge interfaces are not fully "
437 "supported on this platform.\n");
448 int select_fd(int fd, unsigned timeout)
457 tv.tv_sec = timeout / 1000;
458 tv.tv_usec = 1000 * (timeout % 1000);
460 status = select(fd + 1, &fds, NULL, NULL, &tv);
462 sock_perror("select");
468 ssize_t ethsock_recv(struct ethsock *sock, void *buf, size_t len)
470 struct pcap_pkthdr* hdr;
471 const u_char *capbuf;
473 #ifdef NMRPFLASH_WINDOWS
477 ret = WaitForSingleObject(sock->handle, sock->timeout);
478 if (ret == WAIT_TIMEOUT) {
480 } else if (ret != WAIT_OBJECT_0) {
481 win_perror2("WaitForSingleObject", ret);
487 status = select_fd(sock->fd, sock->timeout);
490 } else if (status == 0) {
496 status = pcap_next_ex(sock->pcap, &hdr, &capbuf);
499 memcpy(buf, capbuf, MIN(len, hdr->caplen));
504 pcap_perror(sock->pcap, "pcap_next_ex");
507 fprintf(stderr, "pcap_next_ex: returned %d.\n", status);
512 int ethsock_send(struct ethsock *sock, void *buf, size_t len)
514 #ifdef NMRPFLASH_WINDOWS
515 if (pcap_sendpacket(sock->pcap, buf, len) == 0) {
518 pcap_perror(sock->pcap, "pcap_sendpacket");
522 if (pcap_inject(sock->pcap, buf, len) == len) {
525 pcap_perror(sock->pcap, "pcap_inject");
531 int ethsock_close(struct ethsock *sock)
537 #ifdef NMRPFLASH_LINUX
539 set_stp_enabled(sock->intf, true);
543 pcap_close(sock->pcap);
550 inline int ethsock_set_timeout(struct ethsock *sock, unsigned msec)
552 sock->timeout = msec;
556 #ifndef NMRPFLASH_WINDOWS
557 int ethsock_arp_add(struct ethsock *sock, uint8_t *hwaddr, uint32_t ipaddr, struct ethsock_arp_undo **undo)
562 int ethsock_arp_del(struct ethsock *sock, struct ethsock_arp_undo **undo)
567 static int ethsock_arp(struct ethsock *sock, uint8_t *hwaddr, uint32_t ipaddr, struct ethsock_arp_undo **undo)
571 .dwIndex = sock->index,
574 .dwType = MIB_IPNET_TYPE_STATIC
577 memcpy(arp.bPhysAddr, hwaddr, 6);
580 ret = CreateIpNetEntry(&arp);
581 if (ret != NO_ERROR) {
582 win_perror2("CreateIpNetEntry", ret);
586 *undo = malloc(sizeof(struct ethsock_arp_undo));
592 (*undo)->ipaddr = ipaddr;
593 memcpy((*undo)->hwaddr, hwaddr, 6);
595 DeleteIpNetEntry(&arp);
601 int ethsock_arp_add(struct ethsock *sock, uint8_t *hwaddr, uint32_t ipaddr, struct ethsock_arp_undo **undo)
603 ethsock_arp(sock, hwaddr, ipaddr, NULL);
604 return undo ? ethsock_arp(sock, hwaddr, ipaddr, undo) : -1;
607 int ethsock_arp_del(struct ethsock *sock, struct ethsock_arp_undo **undo)
613 int ret = ethsock_arp(sock, (*undo)->hwaddr, (*undo)->ipaddr, NULL);
620 static bool get_hwaddr_from_pcap(const pcap_if_t *dev, uint8_t *hwaddr)
623 #ifndef NMRPFLASH_WINDOWS
627 for (addr = dev->addresses; addr; addr = addr->next) {
629 printf("%s: sa_family=%d, sa_data={ ", dev->name,
630 addr->addr->sa_family);
631 for (i = 0; i != sizeof(addr->addr->sa_data); ++i) {
632 printf("%02x ", addr->addr->sa_data[i] & 0xff);
637 if (sockaddr_get_hwaddr(addr->addr, hwaddr)) {
643 return get_intf_info(dev->name, hwaddr, &is_bridge);
646 int ethsock_list_all(void)
648 pcap_if_t *devs, *dev;
651 unsigned dev_num = 0, dev_ok = 0;
652 #ifdef NMRPFLASH_WINDOWS
656 if (x_pcap_findalldevs(&devs) != 0) {
660 memset(hwaddr, 0, 6);
662 for (dev = devs; dev; dev = dev->next, ++dev_num) {
663 if (dev->flags & PCAP_IF_LOOPBACK) {
665 printf("%-15s (loopback device)\n", dev->name);
670 if (!get_hwaddr_from_pcap(dev, hwaddr)) {
672 printf("%-15s (not an ethernet device)\n",
678 #ifndef NMRPFLASH_WINDOWS
679 printf("%-15s", dev->name);
681 /* Call this here so *_perror() calls don't happen within a line */
682 pretty = intf_get_pretty_name(dev->name);
685 printf("%s%u", NMRPFLASH_NETALIAS_PREFIX, dev_num);
687 printf("%s", dev->name);
691 for (addr = dev->addresses; addr; addr = addr->next) {
692 if (addr->addr->sa_family == AF_INET) {
694 inet_ntoa(((struct sockaddr_in*)addr->addr)->sin_addr));
700 printf(" %-15s", "0.0.0.0");
703 printf(" %s", mac_to_str(hwaddr));
705 #ifdef NMRPFLASH_WINDOWS
707 printf(" (%s)", pretty);
708 } else if (dev->description) {
709 printf(" (%s)", dev->description);
718 printf("No suitable network interfaces found.\n");
724 int ethsock_for_each_ip(struct ethsock *sock, ethsock_ip_callback_t callback,
727 struct ethsock_ip_callback_args args;
728 pcap_if_t *devs, *dev;
732 if (x_pcap_findalldevs(&devs) != 0) {
738 for (dev = devs; dev; dev = dev->next) {
739 if (strcmp(sock->intf, dev->name)) {
743 for (addr = dev->addresses; addr; addr = addr->next) {
744 if (addr->addr->sa_family == AF_INET) {
745 args.ipaddr = &((struct sockaddr_in*)addr->addr)->sin_addr;
746 args.ipmask = &((struct sockaddr_in*)addr->netmask)->sin_addr;
748 status = callback(&args);
758 pcap_freealldevs(devs);
760 return status <= 0 ? status : 0;
763 static inline void set_addr(void *p, uint32_t addr)
765 struct sockaddr_in* sin = p;
766 sin->sin_family = AF_INET;
767 sin->sin_addr.s_addr = addr;
769 ((struct sockaddr*)p)->sa_len = sizeof(struct sockaddr_in);
773 #ifndef NMRPFLASH_WINDOWS
774 static bool set_interface_up(int fd, const char *intf, bool up)
777 strncpy(ifr.ifr_name, intf, IFNAMSIZ);
779 if (ioctl(fd, SIOCGIFFLAGS, &ifr) != 0) {
781 xperror("ioctl(SIOCGIFFLAGS)");
787 ifr.ifr_flags &= ~(IFF_UP | IFF_RUNNING);
789 ifr.ifr_flags |= IFF_UP | IFF_RUNNING;
792 if (ioctl(fd, SIOCSIFFLAGS, &ifr) != 0) {
794 xperror("ioctl(SIOCSIFFLAGS)");
804 int ethsock_ip_add(struct ethsock *sock, uint32_t ipaddr, uint32_t ipmask, struct ethsock_ip_undo **undo)
806 if (undo && !(*undo = malloc(sizeof(struct ethsock_ip_undo)))) {
812 int fd = socket(AF_INET, SOCK_DGRAM, 0);
814 sock_perror("socket");
818 #ifndef NMRPFLASH_WINDOWS
819 // XXX: undo is non-zero only if we're adding an IP
821 #ifdef NMRPFLASH_LINUX
823 strncpy(ifr.ifr_name, sock->intf, IFNAMSIZ);
824 // FIXME: automatically determine the next free alias
825 strcat(ifr.ifr_name, ":42");
828 set_addr(&ifr.ifr_addr, ipaddr);
829 if (ioctl(fd, SIOCSIFADDR, &ifr) != 0) {
830 xperror("ioctl(SIOSIFADDR)");
834 set_addr(&ifr.ifr_netmask, ipmask);
835 if (ioctl(fd, SIOCSIFNETMASK, &ifr) != 0) {
836 xperror("ioctl(SIOCSIFNETMASK)");
840 (*undo)->ip[0] = ipaddr;
841 (*undo)->ip[1] = ipmask;
844 if (!set_interface_up(fd, ifr.ifr_name, add)) {
847 #else // NMRPFLASH_OSX (or any other BSD)
848 struct ifaliasreq ifra;
849 memset(&ifra, 0, sizeof(ifra));
850 strncpy(ifra.ifra_name, sock->intf, IFNAMSIZ);
852 set_addr(&ifra.ifra_addr, ipaddr);
853 set_addr(&ifra.ifra_mask, ipmask);
854 //set_addr(&ifra.ifra_broadaddr, (ipaddr & ipmask) | ~ipmask);
856 if (ioctl(fd, add ? SIOCAIFADDR : SIOCDIFADDR, &ifra) != 0) {
858 xperror("ioctl(SIOCAIFADDR");
864 (*undo)->ip[0] = ipaddr;
865 (*undo)->ip[1] = ipmask;
866 set_interface_up(fd, ifra.ifra_name, true);
870 #else // NMRPFLASH_WINDOWS
871 struct sockaddr_in sin;
874 (*undo)->context = 0;
876 DWORD err = AddIPAddress(ipaddr, ipmask, sock->index, &(*undo)->context, &instance);
877 if (err != NO_ERROR && err != ERROR_DUP_DOMAINNAME && err != ERROR_OBJECT_ALREADY_EXISTS) {
878 win_perror2("AddIPAddress", err);
882 set_addr(&sin, ipaddr);
883 time_t beg = time_monotonic();
885 /* Wait until the new IP has actually been added */
887 while (bind(fd, (struct sockaddr*)&sin, sizeof(sin)) != 0) {
888 if ((time_monotonic() - beg) >= 5) {
889 fprintf(stderr, "Failed to bind after 5 seconds: ");
891 DeleteIPAddress((*undo)->context);
899 #ifndef NMRPFLASH_WINDOWS
904 if (ret != 0 && undo) {
912 int ethsock_ip_del(struct ethsock *sock, struct ethsock_ip_undo **undo)
920 #ifndef NMRPFLASH_WINDOWS
921 if ((*undo)->ip[0] != INADDR_NONE) {
922 ret = ethsock_ip_add(sock, (*undo)->ip[0], (*undo)->ip[1], NULL);
927 DeleteIPAddress((*undo)->context);