4b22b9337f359bfd063322244f5336cc7c6ffcfars/* -*- Mode: C; tab-width: 4 -*-
cda73f64f20b8a0afc4909f5ea1f055ec7913856Toomas Soome * Copyright (c) 2002-2015 Apple Inc. All rights reserved.
4b22b9337f359bfd063322244f5336cc7c6ffcfars * Licensed under the Apache License, Version 2.0 (the "License");
4b22b9337f359bfd063322244f5336cc7c6ffcfars * you may not use this file except in compliance with the License.
4b22b9337f359bfd063322244f5336cc7c6ffcfars * You may obtain a copy of the License at
4b22b9337f359bfd063322244f5336cc7c6ffcfars * Unless required by applicable law or agreed to in writing, software
4b22b9337f359bfd063322244f5336cc7c6ffcfars * distributed under the License is distributed on an "AS IS" BASIS,
4b22b9337f359bfd063322244f5336cc7c6ffcfars * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
4b22b9337f359bfd063322244f5336cc7c6ffcfars * See the License for the specific language governing permissions and
4b22b9337f359bfd063322244f5336cc7c6ffcfars * limitations under the License.
4b22b9337f359bfd063322244f5336cc7c6ffcfars#include "mDNSEmbeddedAPI.h" // Defines the interface provided to the client layer above
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome#include "mDNSPosix.h" // Defines the specific types needed to run mDNS on this platform
4b22b9337f359bfd063322244f5336cc7c6ffcfars#else // USES_NETLINK
4b22b9337f359bfd063322244f5336cc7c6ffcfars#endif // USES_NETLINK
4b22b9337f359bfd063322244f5336cc7c6ffcfars// ***************************************************************************
4b22b9337f359bfd063322244f5336cc7c6ffcfars// Structures
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome// We keep a list of client-supplied event sources in PosixEventSource records
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soometypedef struct PosixEventSource PosixEventSource;
4b22b9337f359bfd063322244f5336cc7c6ffcfars// Context record for interface change callback
4b22b9337f359bfd063322244f5336cc7c6ffcfars// Note that static data is initialized to zero in (modern) C.
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soomestatic GenLinkedList gEventSources; // linked list of PosixEventSource's
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soomestatic sigset_t gEventSignalSet; // Signals which event loop listens for
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soomestatic sigset_t gEventSignals; // Signals which were received while inside loop
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soomestatic PosixNetworkInterface *gRecentInterfaces;
4b22b9337f359bfd063322244f5336cc7c6ffcfars// ***************************************************************************
4b22b9337f359bfd063322244f5336cc7c6ffcfars// Globals (for debugging)
4b22b9337f359bfd063322244f5336cc7c6ffcfars// ***************************************************************************
4b22b9337f359bfd063322244f5336cc7c6ffcfars// Functions
4b22b9337f359bfd063322244f5336cc7c6ffcfars#define PosixErrorToStatus(errNum) ((errNum) == 0 ? mStatus_NoError : mStatus_UnknownErr)
4b22b9337f359bfd063322244f5336cc7c6ffcfarsmDNSlocal void SockAddrTomDNSAddr(const struct sockaddr *const sa, mDNSAddr *ipAddr, mDNSIPPort *ipPort)
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome struct sockaddr_in *sin = (struct sockaddr_in*)sa;
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome ipAddr->ip.v4.NotAnInteger = sin->sin_addr.s_addr;
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome if (ipPort) ipPort->NotAnInteger = sin->sin_port;
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome struct sockaddr_in6 *sin6 = (struct sockaddr_in6*)sa;
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome ipAddr->ip.v6 = *(mDNSv6Addr*)&sin6->sin6_addr;
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome if (ipPort) ipPort->NotAnInteger = sin6->sin6_port;
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome verbosedebugf("SockAddrTomDNSAddr: Uknown address family %d\n", sa->sa_family);
4b22b9337f359bfd063322244f5336cc7c6ffcfars// mDNS core calls this routine when it needs to send a packet.
4b22b9337f359bfd063322244f5336cc7c6ffcfarsmDNSexport mStatus mDNSPlatformSendUDP(const mDNS *const m, const void *const msg, const mDNSu8 *const end,
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome mDNSInterfaceID InterfaceID, UDPSocket *src, const mDNSAddr *dst,
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome mDNSIPPort dstPort, mDNSBool useBackgroundTrafficClass)
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome PosixNetworkInterface * thisIntf = (PosixNetworkInterface *)(InterfaceID);
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome (void)src; // Will need to use this parameter once we implement mDNSPlatformUDPSocket/mDNSPlatformUDPClose
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome LogMsg("mDNSPlatformSendUDP: Invalid argument -dstPort is set to 0");
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome struct sockaddr_in *sin = (struct sockaddr_in*)&to;
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome sin->sin_addr.s_addr = dst->ip.v4.NotAnInteger;
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome sendingsocket = thisIntf ? thisIntf->multicastSocket4 : m->p->unicastSocket4;
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome struct sockaddr_in6 *sin6 = (struct sockaddr_in6*)&to;
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome sin6->sin6_addr = *(struct in6_addr*)&dst->ip.v6;
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome sendingsocket = thisIntf ? thisIntf->multicastSocket6 : m->p->unicastSocket6;
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome err = sendto(sendingsocket, msg, (char*)end - (char*)msg, 0, (struct sockaddr *)&to, GET_SA_LEN(to));
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome else if (err < 0)
4b22b9337f359bfd063322244f5336cc7c6ffcfars // Don't report EHOSTDOWN (i.e. ARP failure), ENETDOWN, or no route to host for unicast destinations
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome if (errno == EHOSTDOWN || errno == ENETDOWN || errno == EHOSTUNREACH || errno == ENETUNREACH) return(mStatus_TransientErr);
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome /* dont report ENETUNREACH */
cda73f64f20b8a0afc4909f5ea1f055ec7913856Toomas Soome if (errno == ENETUNREACH) return(mStatus_TransientErr);
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome LogMsg("mDNSPlatformSendUDP got error %d (%s) sending packet to %#a on interface %#a/%s/%d",
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome errno, strerror(errno), dst, &thisIntf->coreIntf.ip, thisIntf->intfName, thisIntf->index);
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome LogMsg("mDNSPlatformSendUDP got error %d (%s) sending packet to %#a", errno, strerror(errno), dst);
4b22b9337f359bfd063322244f5336cc7c6ffcfars// This routine is called when the main loop detects that data is available on a socket.
4b22b9337f359bfd063322244f5336cc7c6ffcfarsmDNSlocal void SocketDataReady(mDNS *const m, PosixNetworkInterface *intf, int skt)
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome const mDNSInterfaceID InterfaceID = intf ? intf->coreIntf.InterfaceID : NULL;
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome packetLen = recvfrom_flags(skt, &packet, sizeof(packet), &flags, (struct sockaddr *) &from, &fromLen, &packetInfo, &ttl);
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome SockAddrTomDNSAddr((struct sockaddr*)&from, &senderAddr, &senderPort);
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome SockAddrTomDNSAddr((struct sockaddr*)&packetInfo.ipi_addr, &destAddr, NULL);
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome // If we have broken IP_RECVDSTADDR functionality (so far
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome // I've only seen this on OpenBSD) then apply a hack to
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome // convince mDNS Core that this isn't a spoof packet.
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome // Basically what we do is check to see whether the
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome // packet arrived as a multicast and, if so, set its
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome // destAddr to the mDNS address.
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome // I must admit that I could just be doing something
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome // wrong on OpenBSD and hence triggering this problem
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome // but I'm at a loss as to how.
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome // If this platform doesn't have IP_PKTINFO or IP_RECVDSTADDR, then we have
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome // no way to tell the destination address or interface this packet arrived on,
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome // so all we can do is just assume it's a multicast
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome #if HAVE_BROKEN_RECVDSTADDR || (!defined(IP_PKTINFO) && !defined(IP_RECVDSTADDR))
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome if ((destAddr.NotAnInteger == 0) && (flags & MSG_MCAST))
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome if (senderAddr.type == mDNSAddrType_IPv4) destAddr.ip.v4 = AllDNSLinkGroup_v4.ip.v4;
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome else if (senderAddr.type == mDNSAddrType_IPv6) destAddr.ip.v6 = AllDNSLinkGroup_v6.ip.v6;
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome // We only accept the packet if the interface on which it came
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome // in matches the interface associated with this socket.
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome // We do this match by name or by index, depending on which
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome // information is available. recvfrom_flags sets the name
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome // to "" if the name isn't available, or the index to -1
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome // if the index is available. This accomodates the various
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome // different capabilities of our target platforms.
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome // Ignore multicasts accidentally delivered to our unicast receiving socket
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome if (mDNSAddrIsDNSMulticast(&destAddr)) packetLen = -1;
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome if (packetInfo.ipi_ifname[0] != 0) reject = (strcmp(packetInfo.ipi_ifname, intf->intfName) != 0);
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome else if (packetInfo.ipi_ifindex != -1) reject = (packetInfo.ipi_ifindex != intf->index);
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome verbosedebugf("SocketDataReady ignored a packet from %#a to %#a on interface %s/%d expecting %#a/%s/%d/%d",
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome &senderAddr, &destAddr, packetInfo.ipi_ifname, packetInfo.ipi_ifindex,
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome &intf->coreIntf.ip, intf->intfName, intf->index, skt);
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome if (num_pkts_rejected > (num_pkts_accepted + 1) * (num_registered_interfaces + 1) * 2)
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome "*** WARNING: Received %d packets; Accepted %d packets; Rejected %d packets because of interface mismatch\n",
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome num_pkts_accepted + num_pkts_rejected, num_pkts_accepted, num_pkts_rejected);
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome verbosedebugf("SocketDataReady got a packet from %#a to %#a on interface %#a/%s/%d/%d",
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome &senderAddr, &destAddr, &intf->coreIntf.ip, intf->intfName, intf->index, skt);
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome mDNSCoreReceive(m, &packet, (mDNSu8 *)&packet + packetLen,
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome &senderAddr, senderPort, &destAddr, MulticastDNSPort, InterfaceID);
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas SoomemDNSexport mDNSBool mDNSPlatformPeekUDP(mDNS *const m, UDPSocket *src)
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome (void)m; // unused
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas SoomemDNSexport TCPSocket *mDNSPlatformTCPSocket(mDNS * const m, TCPSocketFlags flags, mDNSIPPort * port, mDNSBool useBackgroundTrafficClass)
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome (void)m; // Unused
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas SoomemDNSexport TCPSocket *mDNSPlatformTCPAccept(TCPSocketFlags flags, int sd)
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas SoomemDNSexport int mDNSPlatformTCPGetFD(TCPSocket *sock)
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas SoomemDNSexport mStatus mDNSPlatformTCPConnect(TCPSocket *sock, const mDNSAddr *dst, mDNSOpaque16 dstport, domainname *hostname, mDNSInterfaceID InterfaceID,
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas SoomemDNSexport void mDNSPlatformTCPCloseConnection(TCPSocket *sock)
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas SoomemDNSexport long mDNSPlatformReadTCP(TCPSocket *sock, void *buf, unsigned long buflen, mDNSBool * closed)
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas SoomemDNSexport long mDNSPlatformWriteTCP(TCPSocket *sock, const char *msg, unsigned long len)
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas SoomemDNSexport UDPSocket *mDNSPlatformUDPSocket(mDNS * const m, mDNSIPPort port)
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome (void)m; // Unused
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas SoomemDNSexport void mDNSPlatformUDPClose(UDPSocket *sock)
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas SoomemDNSexport void mDNSPlatformUpdateProxyList(mDNS *const m, const mDNSInterfaceID InterfaceID)
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome (void)m; // Unused
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas SoomemDNSexport void mDNSPlatformSendRawPacket(const void *const msg, const mDNSu8 *const end, mDNSInterfaceID InterfaceID)
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas SoomemDNSexport void mDNSPlatformSetLocalAddressCacheEntry(mDNS *const m, const mDNSAddr *const tpa, const mDNSEthAddr *const tha, mDNSInterfaceID InterfaceID)
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome (void)m; // Unused
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas SoomemDNSexport mStatus mDNSPlatformTLSSetupCerts(void)
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas SoomemDNSexport void mDNSPlatformTLSTearDownCerts(void)
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas SoomemDNSexport void mDNSPlatformSetAllowSleep(mDNS *const m, mDNSBool allowSleep, const char *reason)
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas SoomemDNSexport void FreeEtcHosts(mDNS *const m, AuthRecord *const rr, mStatus result)
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome (void)m; // unused
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome#pragma mark ***** DDNS Config Platform Functions
cda73f64f20b8a0afc4909f5ea1f055ec7913856Toomas Soome * Stub to set or get DNS config. Even if it actually does not do anything, it has to
cda73f64f20b8a0afc4909f5ea1f055ec7913856Toomas Soome * make sure the data is zeroed properly.
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas SoomemDNSexport mDNSBool mDNSPlatformSetDNSConfig(mDNS *const m, mDNSBool setservers, mDNSBool setsearch, domainname *const fqdn, DNameListElem **RegDomains,
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome DNameListElem **BrowseDomains, mDNSBool ackConfig)
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas SoomemDNSexport mStatus mDNSPlatformGetPrimaryInterface(mDNS * const m, mDNSAddr * v4, mDNSAddr * v6, mDNSAddr * router)
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas SoomemDNSexport void mDNSPlatformDynDNSHostNameStatusChanged(const domainname *const dname, const mStatus status)
4b22b9337f359bfd063322244f5336cc7c6ffcfars// This gets the current hostname, truncating it at the first dot if necessary
4b22b9337f359bfd063322244f5336cc7c6ffcfarsmDNSlocal void GetUserSpecifiedRFC1034ComputerName(domainlabel *const namelabel)
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome gethostname((char *)(&namelabel->c[1]), MAX_DOMAIN_LABEL);
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome while (len < MAX_DOMAIN_LABEL && namelabel->c[len+1] && namelabel->c[len+1] != '.') len++;
4b22b9337f359bfd063322244f5336cc7c6ffcfars// On OS X this gets the text of the field labelled "Computer Name" in the Sharing Prefs Control Panel
4b22b9337f359bfd063322244f5336cc7c6ffcfars// Other platforms can either get the information from the appropriate place,
4b22b9337f359bfd063322244f5336cc7c6ffcfars// or they can alternatively just require all registering services to provide an explicit name
4b22b9337f359bfd063322244f5336cc7c6ffcfarsmDNSlocal void GetUserSpecifiedFriendlyComputerName(domainlabel *const namelabel)
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome // On Unix we have no better name than the host name, so we just use that.
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome GetUserSpecifiedRFC1034ComputerName(namelabel);
4b22b9337f359bfd063322244f5336cc7c6ffcfarsmDNSexport int ParseDNSServers(mDNS *m, const char *filePath)
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome if (sscanf(line,"%10s %15s", keyword, nameserver) != 2) continue; // it will skip whitespaces
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome if (strncasecmp(keyword,"nameserver",10)) continue;
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome if (inet_aton(nameserver, (struct in_addr *)&ina) != 0)
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome mDNS_AddDNSServer(m, NULL, mDNSInterface_Any, 0, &DNSAddr, UnicastDNSPort, kScopeNone, 0, mDNSfalse, 0, mDNStrue, mDNStrue, mDNSfalse);
4b22b9337f359bfd063322244f5336cc7c6ffcfars// Searches the interface list looking for the named interface.
4b22b9337f359bfd063322244f5336cc7c6ffcfars// Returns a pointer to if it found, or NULL otherwise.
4b22b9337f359bfd063322244f5336cc7c6ffcfarsmDNSlocal PosixNetworkInterface *SearchForInterfaceByName(mDNS *const m, const char *intfName)
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome intf = (PosixNetworkInterface*)(m->HostInterfaces);
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome while ((intf != NULL) && (strcmp(intf->intfName, intfName) != 0))
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome intf = (PosixNetworkInterface *)(intf->coreIntf.next);
4b22b9337f359bfd063322244f5336cc7c6ffcfarsmDNSexport mDNSInterfaceID mDNSPlatformInterfaceIDfromInterfaceIndex(mDNS *const m, mDNSu32 index)
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome if (index == kDNSServiceInterfaceIndexLocalOnly) return(mDNSInterface_LocalOnly);
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome if (index == kDNSServiceInterfaceIndexP2P ) return(mDNSInterface_P2P);
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome if (index == kDNSServiceInterfaceIndexAny ) return(mDNSInterface_Any);
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome intf = (PosixNetworkInterface*)(m->HostInterfaces);
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome while ((intf != NULL) && (mDNSu32) intf->index != index)
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome intf = (PosixNetworkInterface *)(intf->coreIntf.next);
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas SoomemDNSexport mDNSu32 mDNSPlatformInterfaceIndexfromInterfaceID(mDNS *const m, mDNSInterfaceID id, mDNSBool suppressNetworkChange)
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome if (id == mDNSInterface_LocalOnly) return(kDNSServiceInterfaceIndexLocalOnly);
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome if (id == mDNSInterface_P2P ) return(kDNSServiceInterfaceIndexP2P);
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome if (id == mDNSInterface_Any ) return(kDNSServiceInterfaceIndexAny);
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome intf = (PosixNetworkInterface*)(m->HostInterfaces);
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome while ((intf != NULL) && (mDNSInterfaceID) intf != id)
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome intf = (PosixNetworkInterface *)(intf->coreIntf.next);
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome // If we didn't find the interface, check the RecentInterfaces list as well
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome while ((intf != NULL) && (mDNSInterfaceID) intf != id)
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome intf = (PosixNetworkInterface *)(intf->coreIntf.next);
4b22b9337f359bfd063322244f5336cc7c6ffcfars// Frees the specified PosixNetworkInterface structure. The underlying
4b22b9337f359bfd063322244f5336cc7c6ffcfars// interface must have already been deregistered with the mDNS core.
4b22b9337f359bfd063322244f5336cc7c6ffcfarsmDNSlocal void FreePosixNetworkInterface(PosixNetworkInterface *intf)
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome if (intf->intfName != NULL) free((void *)intf->intfName);
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome if (intf->multicastSocket4 != -1) assert(close(intf->multicastSocket4) == 0);
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome if (intf->multicastSocket6 != -1) assert(close(intf->multicastSocket6) == 0);
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome // Move interface to the RecentInterfaces list for a minute
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome intf->coreIntf.next = &gRecentInterfaces->coreIntf;
4b22b9337f359bfd063322244f5336cc7c6ffcfars// Grab the first interface, deregister it, free it, and repeat until done.
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome PosixNetworkInterface *intf = (PosixNetworkInterface*)(m->HostInterfaces);
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome mDNS_DeregisterInterface(m, &intf->coreIntf, mDNSfalse);
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome if (gMDNSPlatformPosixVerboseLevel > 0) fprintf(stderr, "Deregistered interface %s\n", intf->intfName);
4b22b9337f359bfd063322244f5336cc7c6ffcfars// Sets up a send/receive socket.
4b22b9337f359bfd063322244f5336cc7c6ffcfars// If mDNSIPPort port is non-zero, then it's a multicast socket on the specified interface
4b22b9337f359bfd063322244f5336cc7c6ffcfars// If mDNSIPPort port is zero, then it's a randomly assigned port number, used for sending unicast queries
4b22b9337f359bfd063322244f5336cc7c6ffcfarsmDNSlocal int SetupSocket(struct sockaddr *intfAddr, mDNSIPPort port, int interfaceIndex, int *sktPtr)
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome static const unsigned char kByteTwoFiveFive = 255;
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome const mDNSBool JoinMulticastGroup = (port.NotAnInteger != 0);
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome (void) interfaceIndex; // This parameter unused on plaforms that don't have IPv6
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome // Open the socket...
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome if (intfAddr->sa_family == AF_INET) *sktPtr = socket(PF_INET, SOCK_DGRAM, IPPROTO_UDP);
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome else if (intfAddr->sa_family == AF_INET6) *sktPtr = socket(PF_INET6, SOCK_DGRAM, IPPROTO_UDP);
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome if (*sktPtr < 0) { err = errno; perror((intfAddr->sa_family == AF_INET) ? "socket AF_INET" : "socket AF_INET6"); }
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome // ... with a shared UDP port, if it's for multicast receiving
cda73f64f20b8a0afc4909f5ea1f055ec7913856Toomas Soome // <rdar://problem/20946253>
cda73f64f20b8a0afc4909f5ea1f055ec7913856Toomas Soome // We test for SO_REUSEADDR first, as suggested by Jonny Törnbom from Axis Communications
cda73f64f20b8a0afc4909f5ea1f055ec7913856Toomas Soome // Linux kernel versions 3.9 introduces support for socket option
cda73f64f20b8a0afc4909f5ea1f055ec7913856Toomas Soome // SO_REUSEPORT, however this is not implemented the same as on *BSD
cda73f64f20b8a0afc4909f5ea1f055ec7913856Toomas Soome // systems. Linux version implements a "port hijacking" prevention
cda73f64f20b8a0afc4909f5ea1f055ec7913856Toomas Soome // mechanism, limiting processes wanting to bind to an already existing
cda73f64f20b8a0afc4909f5ea1f055ec7913856Toomas Soome // addr:port to have the same effective UID as the first who bound it. What
cda73f64f20b8a0afc4909f5ea1f055ec7913856Toomas Soome // this meant for us was that the daemon ran as one user and when for
cda73f64f20b8a0afc4909f5ea1f055ec7913856Toomas Soome // instance mDNSClientPosix was executed by another user, it wasn't allowed
cda73f64f20b8a0afc4909f5ea1f055ec7913856Toomas Soome // to bind to the socket. Our suggestion was to switch the order in which
cda73f64f20b8a0afc4909f5ea1f055ec7913856Toomas Soome // SO_REUSEPORT and SO_REUSEADDR was tested so that SO_REUSEADDR stays on
cda73f64f20b8a0afc4909f5ea1f055ec7913856Toomas Soome // top and SO_REUSEPORT to be used only if SO_REUSEADDR doesn't exist.
cda73f64f20b8a0afc4909f5ea1f055ec7913856Toomas Soome #if defined(SO_REUSEADDR) && !defined(__MAC_OS_X_VERSION_MIN_REQUIRED)
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome err = setsockopt(*sktPtr, SOL_SOCKET, SO_REUSEADDR, &kOn, sizeof(kOn));
cda73f64f20b8a0afc4909f5ea1f055ec7913856Toomas Soome err = setsockopt(*sktPtr, SOL_SOCKET, SO_REUSEPORT, &kOn, sizeof(kOn));
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome #error This platform has no way to avoid address busy errors on multicast.
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome if (err < 0) { err = errno; perror("setsockopt - SO_REUSExxxx"); }
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome // Enable inbound packets on IFEF_AWDL interface.
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome // Only done for multicast sockets, since we don't expect unicast socket operations
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome // on the IFEF_AWDL interface. Operation is a no-op for other interface types.
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome if (setsockopt(*sktPtr, SOL_SOCKET, SO_RECV_ANYIF, &kOn, sizeof(kOn)) < 0) perror("setsockopt - SO_RECV_ANYIF");
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome // We want to receive destination addresses and interface identifiers.
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome err = setsockopt(*sktPtr, IPPROTO_IP, IP_PKTINFO, &kOn, sizeof(kOn));
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome if (err < 0) { err = errno; perror("setsockopt - IP_PKTINFO"); }
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome #elif defined(IP_RECVDSTADDR) || defined(IP_RECVIF) // BSD and Solaris
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome err = setsockopt(*sktPtr, IPPROTO_IP, IP_RECVDSTADDR, &kOn, sizeof(kOn));
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome if (err < 0) { err = errno; perror("setsockopt - IP_RECVDSTADDR"); }
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome err = setsockopt(*sktPtr, IPPROTO_IP, IP_RECVIF, &kOn, sizeof(kOn));
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome if (err < 0) { err = errno; perror("setsockopt - IP_RECVIF"); }
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome #warning This platform has no way to get the destination interface information -- will only work for single-homed hosts
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome setsockopt(*sktPtr, IPPROTO_IP, IP_RECVTTL, &kOn, sizeof(kOn));
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome // We no longer depend on being able to get the received TTL, so don't worry if the option fails
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome // Add multicast group membership on this interface
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome imr.imr_multiaddr.s_addr = AllDNSLinkGroup_v4.ip.v4.NotAnInteger;
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome imr.imr_interface = ((struct sockaddr_in*)intfAddr)->sin_addr;
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome err = setsockopt(*sktPtr, IPPROTO_IP, IP_ADD_MEMBERSHIP, &imr, sizeof(imr));
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome if (err < 0) { err = errno; perror("setsockopt - IP_ADD_MEMBERSHIP"); }
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome // Specify outgoing interface too
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome err = setsockopt(*sktPtr, IPPROTO_IP, IP_MULTICAST_IF, &((struct sockaddr_in*)intfAddr)->sin_addr, sizeof(struct in_addr));
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome if (err < 0) { err = errno; perror("setsockopt - IP_MULTICAST_IF"); }
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome // Per the mDNS spec, send unicast packets with TTL 255
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome err = setsockopt(*sktPtr, IPPROTO_IP, IP_TTL, &kIntTwoFiveFive, sizeof(kIntTwoFiveFive));
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome if (err < 0) { err = errno; perror("setsockopt - IP_TTL"); }
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome // and multicast packets with TTL 255 too
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome // There's some debate as to whether IP_MULTICAST_TTL is an int or a byte so we just try both.
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome err = setsockopt(*sktPtr, IPPROTO_IP, IP_MULTICAST_TTL, &kByteTwoFiveFive, sizeof(kByteTwoFiveFive));
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome err = setsockopt(*sktPtr, IPPROTO_IP, IP_MULTICAST_TTL, &kIntTwoFiveFive, sizeof(kIntTwoFiveFive));
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome if (err < 0) { err = errno; perror("setsockopt - IP_MULTICAST_TTL"); }
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome // And start listening for packets
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome bindAddr.sin_addr.s_addr = INADDR_ANY; // Want to receive multicasts AND unicasts on this socket
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome err = bind(*sktPtr, (struct sockaddr *) &bindAddr, sizeof(bindAddr));
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome if (err < 0) { err = errno; perror("bind"); fflush(stderr); }
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome } // endif (intfAddr->sa_family == AF_INET)
cda73f64f20b8a0afc4909f5ea1f055ec7913856Toomas Soome err = setsockopt(*sktPtr, IPPROTO_IPV6, IPV6_RECVPKTINFO, &kOn, sizeof(kOn));
cda73f64f20b8a0afc4909f5ea1f055ec7913856Toomas Soome if (err < 0) { err = errno; perror("setsockopt - IPV6_RECVPKTINFO"); }
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome err = setsockopt(*sktPtr, IPPROTO_IPV6, IPV6_2292_PKTINFO, &kOn, sizeof(kOn));
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome if (err < 0) { err = errno; perror("setsockopt - IPV6_PKTINFO"); }
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome #warning This platform has no way to get the destination interface information for IPv6 -- will only work for single-homed hosts
cda73f64f20b8a0afc4909f5ea1f055ec7913856Toomas Soome err = setsockopt(*sktPtr, IPPROTO_IPV6, IPV6_RECVHOPLIMIT, &kOn, sizeof(kOn));
cda73f64f20b8a0afc4909f5ea1f055ec7913856Toomas Soome if (err < 0) { err = errno; perror("setsockopt - IPV6_RECVHOPLIMIT"); }
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome err = setsockopt(*sktPtr, IPPROTO_IPV6, IPV6_2292_HOPLIMIT, &kOn, sizeof(kOn));
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome if (err < 0) { err = errno; perror("setsockopt - IPV6_HOPLIMIT"); }
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome // Add multicast group membership on this interface
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome imr6.ipv6mr_multiaddr = *(const struct in6_addr*)&AllDNSLinkGroup_v6.ip.v6;
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome //LogMsg("Joining %.16a on %d", &imr6.ipv6mr_multiaddr, imr6.ipv6mr_interface);
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome err = setsockopt(*sktPtr, IPPROTO_IPV6, IPV6_JOIN_GROUP, &imr6, sizeof(imr6));
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome verbosedebugf("IPV6_JOIN_GROUP %.16a on %d failed.\n", &imr6.ipv6mr_multiaddr, imr6.ipv6mr_interface);
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome // Specify outgoing interface too
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome err = setsockopt(*sktPtr, IPPROTO_IPV6, IPV6_MULTICAST_IF, &multicast_if, sizeof(multicast_if));
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome if (err < 0) { err = errno; perror("setsockopt - IPV6_MULTICAST_IF"); }
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome // We want to receive only IPv6 packets on this socket.
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome // Without this option, we may get IPv4 addresses as mapped addresses.
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome err = setsockopt(*sktPtr, IPPROTO_IPV6, IPV6_V6ONLY, &kOn, sizeof(kOn));
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome if (err < 0) { err = errno; perror("setsockopt - IPV6_V6ONLY"); }
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome // Per the mDNS spec, send unicast packets with TTL 255
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome err = setsockopt(*sktPtr, IPPROTO_IPV6, IPV6_UNICAST_HOPS, &kIntTwoFiveFive, sizeof(kIntTwoFiveFive));
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome if (err < 0) { err = errno; perror("setsockopt - IPV6_UNICAST_HOPS"); }
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome // and multicast packets with TTL 255 too
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome // There's some debate as to whether IPV6_MULTICAST_HOPS is an int or a byte so we just try both.
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome err = setsockopt(*sktPtr, IPPROTO_IPV6, IPV6_MULTICAST_HOPS, &kByteTwoFiveFive, sizeof(kByteTwoFiveFive));
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome err = setsockopt(*sktPtr, IPPROTO_IPV6, IPV6_MULTICAST_HOPS, &kIntTwoFiveFive, sizeof(kIntTwoFiveFive));
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome if (err < 0) { err = errno; perror("setsockopt - IPV6_MULTICAST_HOPS"); }
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome // And start listening for packets
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome mDNSPlatformMemZero(&bindAddr6, sizeof(bindAddr6));
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome bindAddr6.sin6_addr = in6addr_any; // Want to receive multicasts AND unicasts on this socket
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome err = bind(*sktPtr, (struct sockaddr *) &bindAddr6, sizeof(bindAddr6));
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome if (err < 0) { err = errno; perror("bind"); fflush(stderr); }
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome } // endif (intfAddr->sa_family == AF_INET6)
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome // Set the socket to non-blocking.
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome err = fcntl(*sktPtr, F_SETFL, err | O_NONBLOCK);
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome if (err != 0 && *sktPtr != -1) { assert(close(*sktPtr) == 0); *sktPtr = -1; }
4b22b9337f359bfd063322244f5336cc7c6ffcfars// Creates a PosixNetworkInterface for the interface whose IP address is
4b22b9337f359bfd063322244f5336cc7c6ffcfars// intfAddr and whose name is intfName and registers it with mDNS core.
4b22b9337f359bfd063322244f5336cc7c6ffcfarsmDNSlocal int SetupOneInterface(mDNS *const m, struct sockaddr *intfAddr, struct sockaddr *intfMask, const char *intfName, int intfIndex)
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome // Allocate the interface structure itself.
cda73f64f20b8a0afc4909f5ea1f055ec7913856Toomas Soome intf = (PosixNetworkInterface*)calloc(1, sizeof(*intf));
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome // And make a copy of the intfName.
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome if (intf->intfName == NULL) { assert(0); err = ENOMEM; }
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome // Set up the fields required by the mDNS core.
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome SockAddrTomDNSAddr(intfAddr, &intf->coreIntf.ip, NULL);
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome SockAddrTomDNSAddr(intfMask, &intf->coreIntf.mask, NULL);
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome //LogMsg("SetupOneInterface: %#a %#a", &intf->coreIntf.ip, &intf->coreIntf.mask);
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome strncpy(intf->coreIntf.ifname, intfName, sizeof(intf->coreIntf.ifname));
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome intf->coreIntf.ifname[sizeof(intf->coreIntf.ifname)-1] = 0;
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome intf->coreIntf.Advertise = m->AdvertiseLocalAddresses;
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome // Set up the extra fields in PosixNetworkInterface.
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome assert(intf->intfName != NULL); // intf->intfName already set up above
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome alias = SearchForInterfaceByName(m, intf->intfName);
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome intf->coreIntf.InterfaceID = (mDNSInterfaceID)alias;
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome debugf("SetupOneInterface: %s %#a is an alias of %#a", intfName, &intf->coreIntf.ip, &alias->coreIntf.ip);
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome // Set up the multicast socket
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome if (alias->multicastSocket4 == -1 && intfAddr->sa_family == AF_INET)
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome err = SetupSocket(intfAddr, MulticastDNSPort, intf->index, &alias->multicastSocket4);
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome else if (alias->multicastSocket6 == -1 && intfAddr->sa_family == AF_INET6)
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome err = SetupSocket(intfAddr, MulticastDNSPort, intf->index, &alias->multicastSocket6);
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome // If interface is a direct link, address record will be marked as kDNSRecordTypeKnownUnique
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome // and skip the probe phase of the probe/announce packet sequence.
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome if (strcmp(intfName, STRINGIFY(DIRECTLINK_INTERFACE_NAME)) == 0)
cda73f64f20b8a0afc4909f5ea1f055ec7913856Toomas Soome intf->coreIntf.SupportsUnicastMDNSResponse = mDNStrue;
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome // The interface is all ready to go, let's register it with the mDNS core.
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome err = mDNS_RegisterInterface(m, &intf->coreIntf, mDNSfalse);
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome // Clean up.
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome debugf("SetupOneInterface: %s %#a Registered", intf->intfName, &intf->coreIntf.ip);
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome fprintf(stderr, "Registered interface %s\n", intf->intfName);
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome // Use intfName instead of intf->intfName in the next line to avoid dereferencing NULL.
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome debugf("SetupOneInterface: %s %#a failed to register %d", intfName, &intf->coreIntf.ip, err);
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome if (intf) { FreePosixNetworkInterface(intf); intf = NULL; }
4b22b9337f359bfd063322244f5336cc7c6ffcfars// Call get_ifi_info() to obtain a list of active interfaces and call SetupOneInterface() on each one.
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome struct ifi_info *intfList = get_ifi_info(AF_INET, mDNStrue);
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome if (err == 0) /* Link the IPv6 list to the end of the IPv4 list */
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome while (*p) p = &(*p)->ifi_next;
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome ) && (i->ifi_flags & IFF_UP) && !(i->ifi_flags & IFF_POINTOPOINT))
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome if (SetupOneInterface(m, i->ifi_addr, i->ifi_netmask, i->ifi_name, i->ifi_index) == 0)
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome // If we found no normal interfaces but we did find a loopback interface, register the
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome // loopback interface. This allows self-discovery if no interfaces are configured.
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome // Temporary workaround: Multicast loopback on IPv6 interfaces appears not to work.
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome // In the interim, we skip loopback interface only if we found at least one v4 interface to use
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome // if ((m->HostInterfaces == NULL) && (firstLoopback != NULL))
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome (void) SetupOneInterface(m, firstLoopback->ifi_addr, firstLoopback->ifi_netmask, firstLoopback->ifi_name, firstLoopback->ifi_index);
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome // Clean up.
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome // Clean up any interfaces that have been hanging around on the RecentInterfaces list for more than a minute
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome PosixNetworkInterface **ri = &gRecentInterfaces;
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome if (utc - pi->LastSeen < 60) ri = (PosixNetworkInterface **)&pi->coreIntf.next;
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome else { *ri = (PosixNetworkInterface *)pi->coreIntf.next; free(pi); }
4b22b9337f359bfd063322244f5336cc7c6ffcfars// See <http://www.faqs.org/rfcs/rfc3549.html> for a description of NetLink
4b22b9337f359bfd063322244f5336cc7c6ffcfars// Open a socket that will receive interface change notifications
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome sock = socket(AF_NETLINK, SOCK_RAW, NETLINK_ROUTE);
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome // Configure read to be non-blocking because inbound msg size is not known in advance
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome /* Subscribe the socket to Link & IP addr notifications. */
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome snl.nl_groups = RTMGRP_LINK | RTMGRP_IPV4_IFADDR;
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome ret = bind(sock, (struct sockaddr *) &snl, sizeof snl);
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas SoomemDNSlocal void PrintNetLinkMsg(const struct nlmsghdr *pNLMsg)
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome const char *kNLMsgTypes[] = { "", "NLMSG_NOOP", "NLMSG_ERROR", "NLMSG_DONE", "NLMSG_OVERRUN" };
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome const char *kNLRtMsgTypes[] = { "RTM_NEWLINK", "RTM_DELLINK", "RTM_GETLINK", "RTM_NEWADDR", "RTM_DELADDR", "RTM_GETADDR" };
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome printf("nlmsghdr len=%d, type=%s, flags=0x%x\n", pNLMsg->nlmsg_len,
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome pNLMsg->nlmsg_type < RTM_BASE ? kNLMsgTypes[pNLMsg->nlmsg_type] : kNLRtMsgTypes[pNLMsg->nlmsg_type - RTM_BASE],
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome if (RTM_NEWLINK <= pNLMsg->nlmsg_type && pNLMsg->nlmsg_type <= RTM_GETLINK)
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome struct ifinfomsg *pIfInfo = (struct ifinfomsg*) NLMSG_DATA(pNLMsg);
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome printf("ifinfomsg family=%d, type=%d, index=%d, flags=0x%x, change=0x%x\n", pIfInfo->ifi_family,
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome pIfInfo->ifi_type, pIfInfo->ifi_index, pIfInfo->ifi_flags, pIfInfo->ifi_change);
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome else if (RTM_NEWADDR <= pNLMsg->nlmsg_type && pNLMsg->nlmsg_type <= RTM_GETADDR)
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome struct ifaddrmsg *pIfAddr = (struct ifaddrmsg*) NLMSG_DATA(pNLMsg);
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome printf("ifaddrmsg family=%d, index=%d, flags=0x%x\n", pIfAddr->ifa_family,
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas SoomemDNSlocal mDNSu32 ProcessRoutingNotification(int sd)
4b22b9337f359bfd063322244f5336cc7c6ffcfars// Read through the messages on sd and if any indicate that any interface records should
4b22b9337f359bfd063322244f5336cc7c6ffcfars// be torn down and rebuilt, return affected indices as a bitmask. Otherwise return 0.
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome struct nlmsghdr *pNLMsg = (struct nlmsghdr*) buff;
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome // The structure here is more complex than it really ought to be because,
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome // unfortunately, there's no good way to size a buffer in advance large
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome // enough to hold all pending data and so avoid message fragmentation.
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome // (Note that FIONREAD is not supported on AF_NETLINK.)
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome // Make sure we've got an entire nlmsghdr in the buffer, and payload, too.
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome // If not, discard already-processed messages in buffer and read more data.
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome if (((char*) &pNLMsg[1] > (buff + readCount)) || // i.e. *pNLMsg extends off end of buffer
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome ((char*) pNLMsg + pNLMsg->nlmsg_len > (buff + readCount)))
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome if (buff < (char*) pNLMsg) // we have space to shuffle
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome // discard processed data
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome // read more data
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome readCount += read(sd, buff + readCount, sizeof buff - readCount);
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome continue; // spin around and revalidate with new readCount
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome break; // Otherwise message does not fit in buffer
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome // Process the NetLink message
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome if (pNLMsg->nlmsg_type == RTM_GETLINK || pNLMsg->nlmsg_type == RTM_NEWLINK)
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome result |= 1 << ((struct ifinfomsg*) NLMSG_DATA(pNLMsg))->ifi_index;
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome else if (pNLMsg->nlmsg_type == RTM_DELADDR || pNLMsg->nlmsg_type == RTM_NEWADDR)
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome result |= 1 << ((struct ifaddrmsg*) NLMSG_DATA(pNLMsg))->ifa_index;
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome // Advance pNLMsg to the next message in the buffer
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome if ((pNLMsg->nlmsg_flags & NLM_F_MULTI) != 0 && pNLMsg->nlmsg_type != NLMSG_DONE)
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome ssize_t len = readCount - ((char*)pNLMsg - buff);
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome break; // all done!
4b22b9337f359bfd063322244f5336cc7c6ffcfars#else // USES_NETLINK
4b22b9337f359bfd063322244f5336cc7c6ffcfars// Open a socket that will receive interface change notifications
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome // Configure read to be non-blocking because inbound msg size is not known in advance
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas SoomemDNSlocal void PrintRoutingSocketMsg(const struct ifa_msghdr *pRSMsg)
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome const char *kRSMsgTypes[] = { "", "RTM_ADD", "RTM_DELETE", "RTM_CHANGE", "RTM_GET", "RTM_LOSING",
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome "RTM_REDIRECT", "RTM_MISS", "RTM_LOCK", "RTM_OLDADD", "RTM_OLDDEL", "RTM_RESOLVE",
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome "RTM_NEWADDR", "RTM_DELADDR", "RTM_IFINFO", "RTM_NEWMADDR", "RTM_DELMADDR" };
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome int index = pRSMsg->ifam_type == RTM_IFINFO ? ((struct if_msghdr*) pRSMsg)->ifm_index : pRSMsg->ifam_index;
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome printf("ifa_msghdr len=%d, type=%s, index=%d\n", pRSMsg->ifam_msglen, kRSMsgTypes[pRSMsg->ifam_type], index);
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas SoomemDNSlocal mDNSu32 ProcessRoutingNotification(int sd)
4b22b9337f359bfd063322244f5336cc7c6ffcfars// Read through the messages on sd and if any indicate that any interface records should
4b22b9337f359bfd063322244f5336cc7c6ffcfars// be torn down and rebuilt, return affected indices as a bitmask. Otherwise return 0.
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome struct ifa_msghdr *pRSMsg = (struct ifa_msghdr*) buff;
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome if (readCount < (ssize_t) sizeof(struct ifa_msghdr))
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome return mStatus_UnsupportedErr; // cannot decipher message
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome // Process the message
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome * ADD & DELETE are happening when IPv6 announces are changing,
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome * and for some reason it will stop mdnsd to announce IPv6
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome * addresses. So we force mdnsd to check interfaces.
cda73f64f20b8a0afc4909f5ea1f055ec7913856Toomas Soome result |= 1 << ((struct if_msghdr*) pRSMsg)->ifm_index;
4b22b9337f359bfd063322244f5336cc7c6ffcfars#endif // USES_NETLINK
4b22b9337f359bfd063322244f5336cc7c6ffcfars// Called when data appears on interface change notification socket
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas SoomemDNSlocal void InterfaceChangeCallback(int fd, short filter, void *context)
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome changedInterfaces |= ProcessRoutingNotification(pChgRec->NotifySD);
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome while (0 < select(pChgRec->NotifySD + 1, &readFDs, (fd_set*) NULL, (fd_set*) NULL, &zeroTimeout));
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome // Currently we rebuild the entire interface list whenever any interface change is
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome // detected. If this ever proves to be a performance issue in a multi-homed
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome // configuration, more care should be paid to changedInterfaces.
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome mDNSPlatformPosixRefreshInterfaceList(pChgRec->mDNS);
4b22b9337f359bfd063322244f5336cc7c6ffcfars// Register with either a Routing Socket or RtNetLink to listen for interface changes.
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome pChgRec = (IfChangeRec*) mDNSPlatformMemAllocate(sizeof *pChgRec);
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome err = mDNSPosixAddFDToEventLoop(pChgRec->NotifySD, InterfaceChangeCallback, pChgRec);
4b22b9337f359bfd063322244f5336cc7c6ffcfars// Test to see if we're the first client running on UDP port 5353, by trying to bind to 5353 without using SO_REUSEPORT.
4b22b9337f359bfd063322244f5336cc7c6ffcfars// If we fail, someone else got here first. That's not a big problem; we can share the port for multicast responses --
4b22b9337f359bfd063322244f5336cc7c6ffcfars// we just need to be aware that we shouldn't expect to successfully receive unicast UDP responses.
4b22b9337f359bfd063322244f5336cc7c6ffcfarsmDNSlocal mDNSBool mDNSPlatformInit_CanReceiveUnicast(void)
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome int s = socket(AF_INET, SOCK_DGRAM, IPPROTO_UDP);
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome s5353.sin_port = MulticastDNSPort.NotAnInteger;
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome err = bind(s, (struct sockaddr *)&s5353, sizeof(s5353));
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome return(err == 0);
4b22b9337f359bfd063322244f5336cc7c6ffcfars// mDNS core calls this routine to initialise the platform-specific data.
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome if (mDNSPlatformInit_CanReceiveUnicast()) m->CanReceiveUnicastOn5353 = mDNStrue;
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome // Tell mDNS core the names of this machine.
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome // Set up the nice label
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome GetUserSpecifiedFriendlyComputerName(&m->nicelabel);
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome if (m->nicelabel.c[0] == 0) MakeDomainLabelFromLiteralString(&m->nicelabel, "Computer");
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome // Set up the RFC 1034-compliant label
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome GetUserSpecifiedRFC1034ComputerName(&m->hostlabel);
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome if (m->hostlabel.c[0] == 0) MakeDomainLabelFromLiteralString(&m->hostlabel, "Computer");
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome if (err == mStatus_NoError) err = SetupSocket(&sa, zeroIPPort, 0, &m->p->unicastSocket4);
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome if (err == mStatus_NoError) err = SetupSocket(&sa, zeroIPPort, 0, &m->p->unicastSocket6);
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome // Tell mDNS core about the network interfaces on this machine.
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome if (err == mStatus_NoError) err = SetupInterfaceList(m);
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome // Tell mDNS core about DNS Servers
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome if (err == mStatus_NoError) ParseDNSServers(m, uDNS_SERVERS_FILE);
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome // Failure to observe interface changes is non-fatal.
cda73f64f20b8a0afc4909f5ea1f055ec7913856Toomas Soome fprintf(stderr, "mDNS(%d) WARNING: Unable to detect interface changes (%d).\n",
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome // We don't do asynchronous initialization on the Posix platform, so by the time
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome // we get here the setup will already have succeeded or failed. If it succeeded,
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome // we should just call mDNSCoreInitComplete() immediately.
4b22b9337f359bfd063322244f5336cc7c6ffcfars// mDNS core calls this routine to clean up the platform-specific data.
4b22b9337f359bfd063322244f5336cc7c6ffcfars// In our case all we need to do is to tear down every network interface.
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome if (m->p->unicastSocket4 != -1) assert(close(m->p->unicastSocket4) == 0);
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome if (m->p->unicastSocket6 != -1) assert(close(m->p->unicastSocket6) == 0);
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome// This is used internally by InterfaceChangeCallback.
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome// It's also exported so that the Standalone Responder (mDNSResponderPosix)
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome// can call it in response to a SIGHUP (mainly for debugging purposes).
4b22b9337f359bfd063322244f5336cc7c6ffcfarsmDNSexport mStatus mDNSPlatformPosixRefreshInterfaceList(mDNS *const m)
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome // This is a pretty heavyweight way to process interface changes --
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome // destroying the entire interface list and then making fresh one from scratch.
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome // We should make it like the OS X version, which leaves unchanged interfaces alone.
4b22b9337f359bfd063322244f5336cc7c6ffcfars// On the Posix platform, locking is a no-op because we only ever enter
4b22b9337f359bfd063322244f5336cc7c6ffcfars// mDNS core on the main thread.
4b22b9337f359bfd063322244f5336cc7c6ffcfars// mDNS core calls this routine when it wants to prevent
4b22b9337f359bfd063322244f5336cc7c6ffcfars// the platform from reentering mDNS core code.
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome (void) m; // Unused
4b22b9337f359bfd063322244f5336cc7c6ffcfars// mDNS core calls this routine when it release the lock taken by
4b22b9337f359bfd063322244f5336cc7c6ffcfars// mDNSPlatformLock and allow the platform to reenter mDNS core code.
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome (void) m; // Unused
4b22b9337f359bfd063322244f5336cc7c6ffcfars// mDNS core calls this routine to copy C strings.
4b22b9337f359bfd063322244f5336cc7c6ffcfars// On the Posix platform this maps directly to the ANSI C strcpy.
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas SoomemDNSexport void mDNSPlatformStrCopy(void *dst, const void *src)
4b22b9337f359bfd063322244f5336cc7c6ffcfars// mDNS core calls this routine to get the length of a C string.
4b22b9337f359bfd063322244f5336cc7c6ffcfars// On the Posix platform this maps directly to the ANSI C strlen.
4b22b9337f359bfd063322244f5336cc7c6ffcfars// mDNS core calls this routine to copy memory.
4b22b9337f359bfd063322244f5336cc7c6ffcfars// On the Posix platform this maps directly to the ANSI C memcpy.
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas SoomemDNSexport void mDNSPlatformMemCopy(void *dst, const void *src, mDNSu32 len)
4b22b9337f359bfd063322244f5336cc7c6ffcfars// mDNS core calls this routine to test whether blocks of memory are byte-for-byte
4b22b9337f359bfd063322244f5336cc7c6ffcfars// identical. On the Posix platform this is a simple wrapper around ANSI C memcmp.
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas SoomemDNSexport mDNSBool mDNSPlatformMemSame(const void *dst, const void *src, mDNSu32 len)
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome// If the caller wants to know the exact return of memcmp, then use this instead
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome// of mDNSPlatformMemSame
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas SoomemDNSexport int mDNSPlatformMemCmp(const void *dst, const void *src, mDNSu32 len)
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas SoomemDNSexport void mDNSPlatformQsort(void *base, int nel, int width, int (*compar)(const void *, const void *))
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome// DNSSEC stub functions
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas SoomemDNSexport void VerifySignature(mDNS *const m, DNSSECVerifier *dv, DNSQuestion *q)
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas SoomemDNSexport mDNSBool AddNSECSForCacheRecord(mDNS *const m, CacheRecord *crlist, CacheRecord *negcr, mDNSu8 rcode)
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas SoomemDNSexport void BumpDNSSECStats(mDNS *const m, DNSSECStatsAction action, DNSSECStatsType type, mDNSu32 value)
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome// Proxy stub functions
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas SoomemDNSexport mDNSu8 *DNSProxySetAttributes(DNSQuestion *q, DNSMessageHeader *h, DNSMessage *msg, mDNSu8 *ptr, mDNSu8 *limit)
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas SoomemDNSexport void DNSProxyInit(mDNS *const m, mDNSu32 IpIfArr[], mDNSu32 OpIf)
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas SoomemDNSexport void DNSProxyTerminate(mDNS *const m)
4b22b9337f359bfd063322244f5336cc7c6ffcfars// mDNS core calls this routine to clear blocks of memory.
4b22b9337f359bfd063322244f5336cc7c6ffcfars// On the Posix platform this is a simple wrapper around ANSI C memset.
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas SoomemDNSexport void mDNSPlatformMemZero(void *dst, mDNSu32 len)
4b22b9337f359bfd063322244f5336cc7c6ffcfarsmDNSexport void * mDNSPlatformMemAllocate(mDNSu32 len) { return(malloc(len)); }
4b22b9337f359bfd063322244f5336cc7c6ffcfarsmDNSexport void mDNSPlatformMemFree (void *mem) { free(mem); }
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas SoomemDNSexport mDNSs32 mDNSPlatformOneSecond = 1024;
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome // No special setup is required on Posix -- we just use gettimeofday();
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome // This is not really safe, because gettimeofday can go backwards if the user manually changes the date or time
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome // We should find a better way to do this
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome // tv.tv_sec is seconds since 1st January 1970 (GMT, with no adjustment for daylight savings time)
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome // tv.tv_usec is microseconds since the start of this second (i.e. values 0 to 999999)
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome // We use the lower 22 bits of tv.tv_sec for the top 22 bits of our result
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome // and we multiply tv.tv_usec by 16 / 15625 to get a value in the range 0-1023 to go in the bottom 10 bits.
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome // This gives us a proper modular (cyclic) counter that has a resolution of roughly 1ms (actually 1/1024 second)
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome // and correctly cycles every 2^22 seconds (4194304 seconds = approx 48 days).
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome return((tv.tv_sec << 10) | (tv.tv_usec * 16 / 15625));
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas SoomemDNSexport void mDNSPlatformSendWakeupPacket(mDNS *const m, mDNSInterfaceID InterfaceID, char *EthAddr, char *IPAddr, int iteration)
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas SoomemDNSexport mDNSBool mDNSPlatformValidRecordForInterface(AuthRecord *rr, const NetworkInterfaceInfo *intf)
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas SoomemDNSexport mDNSBool mDNSPlatformValidQuestionForInterface(DNSQuestion *q, const NetworkInterfaceInfo *intf)
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome// Used for debugging purposes. For now, just set the buffer to zero
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas SoomemDNSexport void mDNSPlatformFormatTime(unsigned long te, mDNSu8 *buf, int bufsize)
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas SoomemDNSexport void mDNSPlatformSendKeepalive(mDNSAddr *sadd, mDNSAddr *dadd, mDNSIPPort *lport, mDNSIPPort *rport, mDNSu32 seq, mDNSu32 ack, mDNSu16 win)
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas SoomemDNSexport mStatus mDNSPlatformRetrieveTCPInfo(mDNS *const m, mDNSAddr *laddr, mDNSIPPort *lport, mDNSAddr *raddr, mDNSIPPort *rport, mDNSTCPInfo *mti)
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome (void) m; // Unused
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas SoomemDNSexport mStatus mDNSPlatformGetRemoteMacAddr(mDNS *const m, mDNSAddr *raddr)
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome (void) m; // Unused
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas SoomemDNSexport mStatus mDNSPlatformStoreSPSMACAddr(mDNSAddr *spsaddr, char *ifname)
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas SoomemDNSexport mStatus mDNSPlatformClearSPSMACAddr(void)
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas SoomemDNSexport mDNSu16 mDNSPlatformGetUDPPort(UDPSocket *sock)
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas SoomemDNSexport mDNSBool mDNSPlatformInterfaceIsD2D(mDNSInterfaceID InterfaceID)
cda73f64f20b8a0afc4909f5ea1f055ec7913856Toomas SoomemDNSexport void mDNSPlatformGetDNSRoutePolicy(mDNS *const m, DNSQuestion *q, mDNSBool *isCellBlocked)
cda73f64f20b8a0afc4909f5ea1f055ec7913856Toomas SoomemDNSexport void mDNSPlatformSetuDNSSocktOpt(UDPSocket *src, const mDNSAddr *dst, DNSQuestion *q)
4b22b9337f359bfd063322244f5336cc7c6ffcfarsmDNSlocal void mDNSPosixAddToFDSet(int *nfds, fd_set *readfds, int s)
4b22b9337f359bfd063322244f5336cc7c6ffcfarsmDNSexport void mDNSPosixGetFDSet(mDNS *m, int *nfds, fd_set *readfds, struct timeval *timeout)
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome // 1. Call mDNS_Execute() to let mDNSCore do what it needs to do
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome // 2. Build our list of active file descriptors
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome PosixNetworkInterface *info = (PosixNetworkInterface *)(m->HostInterfaces);
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome if (m->p->unicastSocket4 != -1) mDNSPosixAddToFDSet(nfds, readfds, m->p->unicastSocket4);
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome if (m->p->unicastSocket6 != -1) mDNSPosixAddToFDSet(nfds, readfds, m->p->unicastSocket6);
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome if (info->multicastSocket4 != -1) mDNSPosixAddToFDSet(nfds, readfds, info->multicastSocket4);
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome if (info->multicastSocket6 != -1) mDNSPosixAddToFDSet(nfds, readfds, info->multicastSocket6);
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome info = (PosixNetworkInterface *)(info->coreIntf.next);
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome // 3. Calculate the time remaining to the next scheduled event (in struct timeval format)
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome interval.tv_sec = ticks >> 10; // The high 22 bits are seconds
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome interval.tv_usec = ((ticks & 0x3FF) * 15625) / 16; // The low 10 bits are 1024ths
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome // 4. If client's proposed timeout is more than what we want, then reduce it
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome (timeout->tv_sec == interval.tv_sec && timeout->tv_usec > interval.tv_usec))
4b22b9337f359bfd063322244f5336cc7c6ffcfarsmDNSexport void mDNSPosixProcessFDSet(mDNS *const m, fd_set *readfds)
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome info = (PosixNetworkInterface *)(m->HostInterfaces);
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome if (m->p->unicastSocket4 != -1 && FD_ISSET(m->p->unicastSocket4, readfds))
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome SocketDataReady(m, NULL, m->p->unicastSocket4);
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome if (m->p->unicastSocket6 != -1 && FD_ISSET(m->p->unicastSocket6, readfds))
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome SocketDataReady(m, NULL, m->p->unicastSocket6);
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome if (info->multicastSocket4 != -1 && FD_ISSET(info->multicastSocket4, readfds))
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome SocketDataReady(m, info, info->multicastSocket4);
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome if (info->multicastSocket6 != -1 && FD_ISSET(info->multicastSocket6, readfds))
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome SocketDataReady(m, info, info->multicastSocket6);
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome info = (PosixNetworkInterface *)(info->coreIntf.next);
4b22b9337f359bfd063322244f5336cc7c6ffcfars// update gMaxFD
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome for (iSource=(PosixEventSource*)gEventSources.Head; iSource; iSource = iSource->Next)
4b22b9337f359bfd063322244f5336cc7c6ffcfars// Add a file descriptor to the set that mDNSPosixRunEventLoopOnce() listens to.
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas SoomemStatus mDNSPosixAddFDToEventLoop(int fd, mDNSPosixEventCallback callback, void *context)
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome InitLinkedList(&gEventSources, offsetof(PosixEventSource, Next));
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome newSource = (PosixEventSource*) malloc(sizeof *newSource);
4b22b9337f359bfd063322244f5336cc7c6ffcfars// Remove a file descriptor from the set that mDNSPosixRunEventLoopOnce() listens to.
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome for (iSource=(PosixEventSource*)gEventSources.Head; iSource; iSource = iSource->Next)
4b22b9337f359bfd063322244f5336cc7c6ffcfars// Simply note the received signal in gEventSignals.
4b22b9337f359bfd063322244f5336cc7c6ffcfars// Tell the event package to listen for signal and report it in mDNSPosixRunEventLoopOnce().
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas SoomemStatus mDNSPosixListenForSignalInEventLoop(int signum)
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome mDNSPlatformMemZero(&action, sizeof action); // more portable than member-wise assignment
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome err = sigaction(signum, &action, (struct sigaction*) NULL);
4b22b9337f359bfd063322244f5336cc7c6ffcfars// Tell the event package to stop listening for signal in mDNSPosixRunEventLoopOnce().
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas SoomemStatus mDNSPosixIgnoreSignalInEventLoop(int signum)
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome mDNSPlatformMemZero(&action, sizeof action); // more portable than member-wise assignment
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome err = sigaction(signum, &action, (struct sigaction*) NULL);
4b22b9337f359bfd063322244f5336cc7c6ffcfars// Do a single pass through the attendent event sources and dispatch any found to their callbacks.
4b22b9337f359bfd063322244f5336cc7c6ffcfars// Return as soon as internal timeout expires, or a signal we're listening for is received.
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas SoomemStatus mDNSPosixRunEventLoopOnce(mDNS *m, const struct timeval *pTimeout,
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome sigset_t *pSignalsReceived, mDNSBool *pDataDispatched)
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome // Include the sockets that are listening to the wire in our select() set
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome mDNSPosixGetFDSet(m, &fdMax, &listenFDs, &timeout); // timeout may get modified
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome numReady = select(fdMax + 1, &listenFDs, (fd_set*) NULL, (fd_set*) NULL, &timeout);
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome // If any data appeared, invoke its callback
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome (void) mDNSPosixProcessFDSet(m, &listenFDs); // call this first to process wire data for clients
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome for (iSource=(PosixEventSource*)gEventSources.Head; iSource; iSource = iSource->Next)
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome iSource->Callback(iSource->fd, 0, iSource->Context);
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome break; // in case callback removed elements from gEventSources
5ffb0c9b03b5149ff4f5821a62be4a52408ada2aToomas Soome (void) sigprocmask(SIG_BLOCK, &gEventSignalSet, (sigset_t*) NULL);