+ send_packet(source, packet);
+}
+
+/* RFC 2710 */
+
+#ifdef ENABLE_MULTICAST
+static void route_membershipreport(node_t *source, vpn_packet_t *packet)
+{
+ struct ip6_hdr ip6;
+ struct icmp6_hdr icmp6;
+ subnet_t *subnet, search = {0};
+ uint16_t checksum;
+
+ struct {
+ struct in6_addr ip6_src; /* source address */
+ struct in6_addr ip6_dst; /* destination address */
+ uint32_t length;
+ uint32_t next;
+ } pseudo;
+
+ cp();
+
+ if(!checklength(source, packet, ether_size + ip6_size + icmp6_size + sizeof(ipv6_t)))
+ return;
+
+ if(source != myself) {
+ ifdebug(TRAFFIC) logger(LOG_WARNING, _("Got membership report from %s (%s) while in router mode!"), source->name, source->hostname);
+ return;
+ }
+
+ /* Copy headers from packet to structs on the stack */
+
+ memcpy(&ip6, packet->data + ether_size, ip6_size);
+ memcpy(&icmp6, packet->data + ether_size + ip6_size + 8, icmp6_size);
+
+ /* Create pseudo header */
+
+ pseudo.ip6_src = ip6.ip6_src;
+ pseudo.ip6_dst = ip6.ip6_dst;
+ pseudo.length = htonl(icmp6_size + sizeof(ipv6_t));
+ pseudo.next = htonl(IPPROTO_ICMPV6);
+
+ /* Generate checksum */
+
+ checksum = inet_checksum(&pseudo, sizeof(pseudo), ~0);
+ checksum = inet_checksum(&icmp6, icmp6_size, checksum);
+ checksum = inet_checksum(packet->data + ether_size + ip6_size + 8 + icmp6_size, sizeof(ipv6_t), checksum);
+
+ if(checksum) {
+ ifdebug(TRAFFIC) logger(LOG_WARNING, _("Cannot route packet: checksum error for membership report"));
+ return;
+ }
+
+ /* Check if the IPv6 address exists on the VPN */
+
+ search.type = SUBNET_IPV6;
+ search.net.ipv6.address = *(ipv6_t *)(packet->data + ether_size + ip6_size + 8 + icmp6_size);
+ search.net.ipv6.prefixlength = 128;
+ search.owner = myself;
+
+ subnet = avl_search(myself->subnet_tree, &search);
+
+ if(!subnet) {
+ avl_node_t *node;
+ connection_t *c;
+
+ ifdebug(TRAFFIC) logger(LOG_WARNING, _("Learned new IPv6 multicast address %hx:%hx:%hx:%hx:%hx:%hx:%hx:%hx"),
+ ntohs(*(uint16_t *) &packet->data[70]),
+ ntohs(*(uint16_t *) &packet->data[72]),
+ ntohs(*(uint16_t *) &packet->data[74]),
+ ntohs(*(uint16_t *) &packet->data[76]),
+ ntohs(*(uint16_t *) &packet->data[78]),
+ ntohs(*(uint16_t *) &packet->data[80]),
+ ntohs(*(uint16_t *) &packet->data[82]),
+ ntohs(*(uint16_t *) &packet->data[84]));
+
+ subnet = new_subnet();
+ subnet->type = SUBNET_IPV6;
+ subnet->net.ipv6.address = *(ipv6_t *)(packet->data + ether_size + ip6_size + 8 + icmp6_size);
+ subnet->net.ipv6.prefixlength = 128;
+ subnet->expires = now + multicastexpire;
+ subnet_add(myself, subnet);
+
+ /* And tell all other tinc daemons it's ours */
+
+ for(node = connection_tree->head; node; node = node->next) {
+ c = node->data;
+ if(c->status.active)
+ send_add_subnet(c, subnet);
+ }
+ }
+
+ if(subnet->expires)
+ subnet->expires = now + multicastexpire;
+}
+#endif
+
+static void route_ipv6(node_t *source, vpn_packet_t *packet)
+{
+ cp();
+
+ if(!checklength(source, packet, ether_size + ip6_size))
+ return;
+
+ if(packet->data[20] == IPPROTO_ICMPV6 && checklength(source, packet, ether_size + ip6_size + icmp6_size) && packet->data[54] == ND_NEIGHBOR_SOLICIT) {
+ route_neighborsol(source, packet);
+ return;
+ }
+
+#ifdef ENABLE_MULTICAST
+ if(packet->data[20] == IPPROTO_HOPOPTS && checklength(source, packet, ether_size + ip6_size + 8)
+ && packet->data[54] == IPPROTO_ICMPV6 && checklength(source, packet, ether_size + ip6_size + 8 + icmp6_size)
+ && packet->data[62] == ICMP6_MEMBERSHIP_REPORT) {
+ route_membershipreport(source, packet);
+ return;
+ }
+
+ if(packet->data[38] == 0xff && packet->data[39] & 0x0c) {
+ route_ipv6_multicast(source, packet);
+ return;
+ }
+#endif
+
+ route_ipv6_unicast(source, packet);
projects / tinc / commitdiff