Plugins/KernelEventMonitor/ev_ipv4.c

   1 /*
   2  * Copyright (c) 2002-2015 Apple Inc. All rights reserved.
   3  *
   4  * @APPLE_LICENSE_HEADER_START@
   5  *
   6  * This file contains Original Code and/or Modifications of Original Code
   7  * as defined in and that are subject to the Apple Public Source License
   8  * Version 2.0 (the 'License'). You may not use this file except in
   9  * compliance with the License. Please obtain a copy of the License at
  10  * http://www.opensource.apple.com/apsl/ and read it before using this
  11  * file.
  12  *
  13  * The Original Code and all software distributed under the License are
  14  * distributed on an 'AS IS' basis, WITHOUT WARRANTY OF ANY KIND, EITHER
  15  * EXPRESS OR IMPLIED, AND APPLE HEREBY DISCLAIMS ALL SUCH WARRANTIES,
  16  * INCLUDING WITHOUT LIMITATION, ANY WARRANTIES OF MERCHANTABILITY,
  17  * FITNESS FOR A PARTICULAR PURPOSE, QUIET ENJOYMENT OR NON-INFRINGEMENT.
  18  * Please see the License for the specific language governing rights and
  19  * limitations under the License.
  20  *
  21  * @APPLE_LICENSE_HEADER_END@
  22  */
  23
  24 /*
  25  * Modification History
  26  *
  27  * August 5, 2002       Allan Nathanson <ajn@apple.com>
  28  * - split code out from eventmon.c
  29  */
  30
  31 #include "eventmon.h"
  32 #include "cache.h"
  33 #include "ev_ipv4.h"
  34
  35 #ifndef kSCEntNetIPv4ARPCollision
  36 #define kSCEntNetIPv4ARPCollision       CFSTR("IPv4ARPCollision")
  37 #endif  /* kSCEntNetIPv4ARPCollision */
  38
  39 #if     !TARGET_OS_IPHONE
  40 #ifndef kSCEntNetIPv4PortInUse
  41 #define kSCEntNetIPv4PortInUse          CFSTR("PortInUse")
  42 #endif  /* kSCEntNetIPv4PortInUse */
  43 #endif  /* !TARGET_OS_IPHONE */
  44
  45 #define IP_FORMAT       "%d.%d.%d.%d"
  46 #define IP_CH(ip, i)    (((u_char *)(ip))[i])
  47 #define IP_LIST(ip)     IP_CH(ip,0),IP_CH(ip,1),IP_CH(ip,2),IP_CH(ip,3)
  48
  49
  50 static void
  51 appendAddress(CFMutableDictionaryRef dict, CFStringRef key, struct in_addr *address)
  52 {
  53         CFStringRef             addr;
  54         CFArrayRef              addrs;
  55         CFMutableArrayRef       newAddrs;
  56
  57         addrs = CFDictionaryGetValue(dict, key);
  58         if (addrs) {
  59                 newAddrs = CFArrayCreateMutableCopy(NULL, 0, addrs);
  60         } else {
  61                 newAddrs = CFArrayCreateMutable(NULL, 0, &kCFTypeArrayCallBacks);
  62         }
  63
  64         addr = CFStringCreateWithFormat(NULL, NULL, CFSTR(IP_FORMAT), IP_LIST(address));
  65         CFArrayAppendValue(newAddrs, addr);
  66         CFRelease(addr);
  67
  68         CFDictionarySetValue(dict, key, newAddrs);
  69         CFRelease(newAddrs);
  70         return;
  71 }
  72
  73
  74 static CFMutableDictionaryRef
  75 copyIF(CFStringRef key, CFMutableDictionaryRef oldIFs, CFMutableDictionaryRef newIFs)
  76 {
  77         CFDictionaryRef         dict            = NULL;
  78         CFMutableDictionaryRef  newDict         = NULL;
  79
  80         if (CFDictionaryGetValueIfPresent(newIFs, key, (const void **)&dict)) {
  81                 newDict = CFDictionaryCreateMutableCopy(NULL, 0, dict);
  82         } else {
  83                 dict = cache_SCDynamicStoreCopyValue(store, key);
  84                 if (dict) {
  85                         CFDictionarySetValue(oldIFs, key, dict);
  86                         if (isA_CFDictionary(dict)) {
  87                                 newDict = CFDictionaryCreateMutableCopy(NULL, 0, dict);
  88                                 CFDictionaryRemoveValue(newDict, kSCPropNetIPv4Addresses);
  89                                 CFDictionaryRemoveValue(newDict, kSCPropNetIPv4SubnetMasks);
  90                                 CFDictionaryRemoveValue(newDict, kSCPropNetIPv4DestAddresses);
  91                                 CFDictionaryRemoveValue(newDict, kSCPropNetIPv4BroadcastAddresses);
  92                         }
  93                         CFRelease(dict);
  94                 }
  95         }
  96
  97         if (!newDict) {
  98                 newDict = CFDictionaryCreateMutable(NULL,
  99                                                     0,
 100                                                     &kCFTypeDictionaryKeyCallBacks,
 101                                                     &kCFTypeDictionaryValueCallBacks);
 102         }
 103
 104         return newDict;
 105 }
 106
 107
 108 static void
 109 updateStore(const void *key, const void *value, void *context)
 110 {
 111         CFDictionaryRef dict;
 112         CFDictionaryRef newDict = (CFDictionaryRef)value;
 113         CFDictionaryRef oldIFs  = (CFDictionaryRef)context;
 114
 115         dict = CFDictionaryGetValue(oldIFs, key);
 116
 117         if (!dict || !CFEqual(dict, newDict)) {
 118                 if (CFDictionaryGetCount(newDict) > 0) {
 119                         SC_log(LOG_DEBUG, "Update interface configuration: %@: %@", key, newDict);
 120                         cache_SCDynamicStoreSetValue(store, key, newDict);
 121                 } else if (dict) {
 122                         SC_log(LOG_DEBUG, "Update interface configuration: %@: <removed>", key);
 123                         cache_SCDynamicStoreRemoveValue(store, key);
 124                 }
 125                 network_changed = TRUE;
 126         }
 127
 128         return;
 129 }
 130
 131
 132 __private_extern__
 133 void
 134 ipv4_interface_update(struct ifaddrs *ifap, const char *if_name)
 135 {
 136         struct ifaddrs          *ifa;
 137         struct ifaddrs          *ifap_temp      = NULL;
 138         CFStringRef             interface;
 139         boolean_t               interfaceFound  = FALSE;
 140         CFStringRef             key             = NULL;
 141         CFMutableDictionaryRef  oldIFs;
 142         CFMutableDictionaryRef  newDict         = NULL;
 143         CFMutableDictionaryRef  newIFs;
 144
 145         oldIFs = CFDictionaryCreateMutable(NULL,
 146                                            0,
 147                                            &kCFTypeDictionaryKeyCallBacks,
 148                                            &kCFTypeDictionaryValueCallBacks);
 149         newIFs = CFDictionaryCreateMutable(NULL,
 150                                            0,
 151                                            &kCFTypeDictionaryKeyCallBacks,
 152                                            &kCFTypeDictionaryValueCallBacks);
 153
 154         if (!ifap) {
 155                 if (getifaddrs(&ifap_temp) == -1) {
 156                         SC_log(LOG_NOTICE, "getifaddrs() failed: %s", strerror(errno));
 157                         goto error;
 158                 }
 159                 ifap = ifap_temp;
 160         }
 161
 162         for (ifa = ifap; ifa; ifa = ifa->ifa_next) {
 163                 struct sockaddr_in      *sin;
 164
 165                 if (ifa->ifa_addr->sa_family != AF_INET) {
 166                         continue;                       /* sorry, not interested */
 167                 }
 168
 169                 /* check if this is the requested interface */
 170                 if (if_name) {
 171                         if (strncmp(if_name, ifa->ifa_name, IFNAMSIZ) == 0) {
 172                                 interfaceFound = TRUE;  /* yes, this is the one I want */
 173                         } else {
 174                                 continue;               /* sorry, not interested */
 175                         }
 176                 }
 177
 178                 interface = CFStringCreateWithCString(NULL, ifa->ifa_name, kCFStringEncodingMacRoman);
 179                 key       = SCDynamicStoreKeyCreateNetworkInterfaceEntity(NULL,
 180                                                                           kSCDynamicStoreDomainState,
 181                                                                           interface,
 182                                                                           kSCEntNetIPv4);
 183                 CFRelease(interface);
 184
 185                 newDict = copyIF(key, oldIFs, newIFs);
 186
 187                 /* ALIGN: cast ok, this should be aligned (getifaddrs). */
 188                 sin = (struct sockaddr_in *)(void *)ifa->ifa_addr;
 189                 appendAddress(newDict, kSCPropNetIPv4Addresses, &sin->sin_addr);
 190
 191                 if (ifa->ifa_flags & IFF_POINTOPOINT) {
 192                         struct sockaddr_in      *dst;
 193
 194                         /* ALIGN: cast ok, this should be aligned (getifaddrs). */
 195                         dst = (struct sockaddr_in *)(void *)ifa->ifa_dstaddr;
 196                         appendAddress(newDict, kSCPropNetIPv4DestAddresses, &dst->sin_addr);
 197                 } else {
 198                         struct sockaddr_in      *brd;
 199                         struct sockaddr_in      *msk;
 200
 201                         /* ALIGN: cast ok, this should be aligned (getifaddrs). */
 202                         brd = (struct sockaddr_in *)(void *)ifa->ifa_broadaddr;
 203                         appendAddress(newDict, kSCPropNetIPv4BroadcastAddresses,&brd->sin_addr);
 204
 205                         /* ALIGN: cast ok, this should be aligned (getifaddrs). */
 206                         msk = (struct sockaddr_in *)(void *)ifa->ifa_netmask;
 207                         appendAddress(newDict, kSCPropNetIPv4SubnetMasks, &msk->sin_addr);
 208                 }
 209
 210                 CFDictionarySetValue(newIFs, key, newDict);
 211                 CFRelease(newDict);
 212                 CFRelease(key);
 213         }
 214
 215         /* if the last address[es] were removed from the target interface */
 216         if (if_name && !interfaceFound) {
 217                 interface = CFStringCreateWithCString(NULL, if_name, kCFStringEncodingMacRoman);
 218                 key       = SCDynamicStoreKeyCreateNetworkInterfaceEntity(NULL,
 219                                                                           kSCDynamicStoreDomainState,
 220                                                                           interface,
 221                                                                           kSCEntNetIPv4);
 222                 CFRelease(interface);
 223
 224                 newDict = copyIF(key, oldIFs, newIFs);
 225
 226                 CFDictionarySetValue(newIFs, key, newDict);
 227                 CFRelease(newDict);
 228                 CFRelease(key);
 229         }
 230
 231         CFDictionaryApplyFunction(newIFs, updateStore, oldIFs);
 232
 233     error :
 234
 235         if (ifap_temp)  freeifaddrs(ifap_temp);
 236         CFRelease(oldIFs);
 237         CFRelease(newIFs);
 238
 239         return;
 240 }
 241
 242 __private_extern__
 243 void
 244 ipv4_arp_collision(const char *if_name, struct in_addr ip_addr, int hw_len, const void * hw_addr)
 245 {
 246         uint8_t *               hw_addr_bytes = (uint8_t *)hw_addr;
 247         int                     i;
 248         CFStringRef             if_name_cf;
 249         CFMutableStringRef      key;
 250         CFStringRef             prefix;
 251
 252         if_name_cf = CFStringCreateWithCString(NULL, if_name,
 253                                                kCFStringEncodingASCII);
 254         prefix = SCDynamicStoreKeyCreateNetworkInterfaceEntity(NULL,
 255                                                                kSCDynamicStoreDomainState,
 256                                                                if_name_cf,
 257                                                                kSCEntNetIPv4ARPCollision);
 258         key = CFStringCreateMutableCopy(NULL, 0, prefix);
 259         CFStringAppendFormat(key, NULL, CFSTR("/" IP_FORMAT),
 260                              IP_LIST(&ip_addr));
 261         for (i = 0; i < hw_len; i++) {
 262             CFStringAppendFormat(key, NULL, CFSTR("%s%02x"),
 263                                  (i == 0) ? "/" : ":", hw_addr_bytes[i]);
 264         }
 265         SC_log(LOG_DEBUG, "Post ARP collision: %@", key);
 266         cache_SCDynamicStoreNotifyValue(store, key);
 267         CFRelease(key);
 268         CFRelease(prefix);
 269         CFRelease(if_name_cf);
 270         return;
 271 }
 272
 273 #if     !TARGET_OS_IPHONE
 274 __private_extern__
 275 void
 276 ipv4_port_in_use(uint16_t port, pid_t req_pid)
 277 {
 278         CFStringRef             key;
 279
 280         key = SCDynamicStoreKeyCreate(NULL,
 281                                       CFSTR("%@/%@/Protocol/%@/%@/%d/%d"),
 282                                       kSCDynamicStoreDomainState,
 283                                       kSCCompNetwork,
 284                                       kSCEntNetIPv4,
 285                                       kSCEntNetIPv4PortInUse,
 286                                       port, req_pid);
 287         SC_log(LOG_DEBUG, "Post port-in-use: %@", key);
 288         cache_SCDynamicStoreNotifyValue(store, key);
 289         CFRelease(key);
 290         return;
 291 }
 292 #endif  /* !TARGET_OS_IPHONE */
 293
 294 static void
 295 interface_notify_entity(const char * if_name, const char * type, CFStringRef entity)
 296 {
 297         CFStringRef             if_name_cf;
 298         CFStringRef             key;
 299
 300         if_name_cf = CFStringCreateWithCString(NULL, if_name,
 301                                                kCFStringEncodingASCII);
 302         key = SCDynamicStoreKeyCreateNetworkInterfaceEntity(NULL,
 303                                                             kSCDynamicStoreDomainState,
 304                                                             if_name_cf,
 305                                                             entity);
 306         CFRelease(if_name_cf);
 307         SC_log(LOG_DEBUG, "Post %s: %@", type, key);
 308         cache_SCDynamicStoreNotifyValue(store, key);
 309         CFRelease(key);
 310         return;
 311 }
 312
 313 __private_extern__ void
 314 ipv4_router_arp_failure(const char * if_name)
 315 {
 316         interface_notify_entity(if_name, "Router ARP failure", kSCEntNetIPv4RouterARPFailure);
 317         return;
 318 }
 319
 320 __private_extern__ void
 321 ipv4_router_arp_alive(const char * if_name)
 322 {
 323         interface_notify_entity(if_name, "Router ARP alive", kSCEntNetIPv4RouterARPAlive);
 324         return;
 325 }