tools/hv/hv_kvp_daemon.c

   1 /*
   2  * An implementation of key value pair (KVP) functionality for Linux.
   3  *
   4  *
   5  * Copyright (C) 2010, Novell, Inc.
   6  * Author : K. Y. Srinivasan <ksrinivasan@novell.com>
   7  *
   8  * This program is free software; you can redistribute it and/or modify it
   9  * under the terms of the GNU General Public License version 2 as published
  10  * by the Free Software Foundation.
  11  *
  12  * This program is distributed in the hope that it will be useful, but
  13  * WITHOUT ANY WARRANTY; without even the implied warranty of
  14  * MERCHANTABILITY OR FITNESS FOR A PARTICULAR PURPOSE, GOOD TITLE or
  15  * NON INFRINGEMENT.  See the GNU General Public License for more
  16  * details.
  17  *
  18  * You should have received a copy of the GNU General Public License
  19  * along with this program; if not, write to the Free Software
  20  * Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA.
  21  *
  22  */
  23
  24
  25 #include <sys/types.h>
  26 #include <sys/socket.h>
  27 #include <sys/poll.h>
  28 #include <sys/utsname.h>
  29 #include <linux/types.h>
  30 #include <stdio.h>
  31 #include <stdlib.h>
  32 #include <unistd.h>
  33 #include <string.h>
  34 #include <errno.h>
  35 #include <arpa/inet.h>
  36 #include <linux/connector.h>
  37 #include <linux/hyperv.h>
  38 #include <linux/netlink.h>
  39 #include <ifaddrs.h>
  40 #include <netdb.h>
  41 #include <syslog.h>
  42 #include <sys/stat.h>
  43 #include <fcntl.h>
  44
  45 /*
  46  * KVP protocol: The user mode component first registers with the
  47  * the kernel component. Subsequently, the kernel component requests, data
  48  * for the specified keys. In response to this message the user mode component
  49  * fills in the value corresponding to the specified key. We overload the
  50  * sequence field in the cn_msg header to define our KVP message types.
  51  *
  52  * We use this infrastructure for also supporting queries from user mode
  53  * application for state that may be maintained in the KVP kernel component.
  54  *
  55  */
  56
  57
  58 enum key_index {
  59         FullyQualifiedDomainName = 0,
  60         IntegrationServicesVersion, /*This key is serviced in the kernel*/
  61         NetworkAddressIPv4,
  62         NetworkAddressIPv6,
  63         OSBuildNumber,
  64         OSName,
  65         OSMajorVersion,
  66         OSMinorVersion,
  67         OSVersion,
  68         ProcessorArchitecture
  69 };
  70
  71 static char kvp_send_buffer[4096];
  72 static char kvp_recv_buffer[4096 * 2];
  73 static struct sockaddr_nl addr;
  74 static int in_hand_shake = 1;
  75
  76 static char *os_name = "";
  77 static char *os_major = "";
  78 static char *os_minor = "";
  79 static char *processor_arch;
  80 static char *os_build;
  81 static char *lic_version = "Unknown version";
  82 static struct utsname uts_buf;
  83
  84
  85 #define MAX_FILE_NAME 100
  86 #define ENTRIES_PER_BLOCK 50
  87
  88 struct kvp_record {
  89         char key[HV_KVP_EXCHANGE_MAX_KEY_SIZE];
  90         char value[HV_KVP_EXCHANGE_MAX_VALUE_SIZE];
  91 };
  92
  93 struct kvp_file_state {
  94         int fd;
  95         int num_blocks;
  96         struct kvp_record *records;
  97         int num_records;
  98         char fname[MAX_FILE_NAME];
  99 };
 100
 101 static struct kvp_file_state kvp_file_info[KVP_POOL_COUNT];
 102
 103 static void kvp_acquire_lock(int pool)
 104 {
 105         struct flock fl = {F_WRLCK, SEEK_SET, 0, 0, 0};
 106         fl.l_pid = getpid();
 107
 108         if (fcntl(kvp_file_info[pool].fd, F_SETLKW, &fl) == -1) {
 109                 syslog(LOG_ERR, "Failed to acquire the lock pool: %d", pool);
 110                 exit(-1);
 111         }
 112 }
 113
 114 static void kvp_release_lock(int pool)
 115 {
 116         struct flock fl = {F_UNLCK, SEEK_SET, 0, 0, 0};
 117         fl.l_pid = getpid();
 118
 119         if (fcntl(kvp_file_info[pool].fd, F_SETLK, &fl) == -1) {
 120                 perror("fcntl");
 121                 syslog(LOG_ERR, "Failed to release the lock pool: %d", pool);
 122                 exit(-1);
 123         }
 124 }
 125
 126 static void kvp_update_file(int pool)
 127 {
 128         FILE *filep;
 129         size_t bytes_written;
 130
 131         /*
 132          * We are going to write our in-memory registry out to
 133          * disk; acquire the lock first.
 134          */
 135         kvp_acquire_lock(pool);
 136
 137         filep = fopen(kvp_file_info[pool].fname, "w");
 138         if (!filep) {
 139                 kvp_release_lock(pool);
 140                 syslog(LOG_ERR, "Failed to open file, pool: %d", pool);
 141                 exit(-1);
 142         }
 143
 144         bytes_written = fwrite(kvp_file_info[pool].records,
 145                                 sizeof(struct kvp_record),
 146                                 kvp_file_info[pool].num_records, filep);
 147
 148         fflush(filep);
 149         kvp_release_lock(pool);
 150 }
 151
 152 static void kvp_update_mem_state(int pool)
 153 {
 154         FILE *filep;
 155         size_t records_read = 0;
 156         struct kvp_record *record = kvp_file_info[pool].records;
 157         struct kvp_record *readp;
 158         int num_blocks = kvp_file_info[pool].num_blocks;
 159         int alloc_unit = sizeof(struct kvp_record) * ENTRIES_PER_BLOCK;
 160
 161         kvp_acquire_lock(pool);
 162
 163         filep = fopen(kvp_file_info[pool].fname, "r");
 164         if (!filep) {
 165                 kvp_release_lock(pool);
 166                 syslog(LOG_ERR, "Failed to open file, pool: %d", pool);
 167                 exit(-1);
 168         }
 169         while (!feof(filep)) {
 170                 readp = &record[records_read];
 171                 records_read += fread(readp, sizeof(struct kvp_record),
 172                                         ENTRIES_PER_BLOCK * num_blocks,
 173                                         filep);
 174
 175                 if (!feof(filep)) {
 176                         /*
 177                          * We have more data to read.
 178                          */
 179                         num_blocks++;
 180                         record = realloc(record, alloc_unit * num_blocks);
 181
 182                         if (record == NULL) {
 183                                 syslog(LOG_ERR, "malloc failed");
 184                                 exit(-1);
 185                         }
 186                         continue;
 187                 }
 188                 break;
 189         }
 190
 191         kvp_file_info[pool].num_blocks = num_blocks;
 192         kvp_file_info[pool].records = record;
 193         kvp_file_info[pool].num_records = records_read;
 194
 195         kvp_release_lock(pool);
 196 }
 197 static int kvp_file_init(void)
 198 {
 199         int  fd;
 200         FILE *filep;
 201         size_t records_read;
 202         char *fname;
 203         struct kvp_record *record;
 204         struct kvp_record *readp;
 205         int num_blocks;
 206         int i;
 207         int alloc_unit = sizeof(struct kvp_record) * ENTRIES_PER_BLOCK;
 208
 209         if (access("/var/opt/hyperv", F_OK)) {
 210                 if (mkdir("/var/opt/hyperv", S_IRUSR | S_IWUSR | S_IROTH)) {
 211                         syslog(LOG_ERR, " Failed to create /var/opt/hyperv");
 212                         exit(-1);
 213                 }
 214         }
 215
 216         for (i = 0; i < KVP_POOL_COUNT; i++) {
 217                 fname = kvp_file_info[i].fname;
 218                 records_read = 0;
 219                 num_blocks = 1;
 220                 sprintf(fname, "/var/opt/hyperv/.kvp_pool_%d", i);
 221                 fd = open(fname, O_RDWR | O_CREAT, S_IRUSR | S_IWUSR | S_IROTH);
 222
 223                 if (fd == -1)
 224                         return 1;
 225
 226
 227                 filep = fopen(fname, "r");
 228                 if (!filep)
 229                         return 1;
 230
 231                 record = malloc(alloc_unit * num_blocks);
 232                 if (record == NULL) {
 233                         fclose(filep);
 234                         return 1;
 235                 }
 236                 while (!feof(filep)) {
 237                         readp = &record[records_read];
 238                         records_read += fread(readp, sizeof(struct kvp_record),
 239                                         ENTRIES_PER_BLOCK,
 240                                         filep);
 241
 242                         if (!feof(filep)) {
 243                                 /*
 244                                  * We have more data to read.
 245                                  */
 246                                 num_blocks++;
 247                                 record = realloc(record, alloc_unit *
 248                                                 num_blocks);
 249                                 if (record == NULL) {
 250                                         fclose(filep);
 251                                         return 1;
 252                                 }
 253                                 continue;
 254                         }
 255                         break;
 256                 }
 257                 kvp_file_info[i].fd = fd;
 258                 kvp_file_info[i].num_blocks = num_blocks;
 259                 kvp_file_info[i].records = record;
 260                 kvp_file_info[i].num_records = records_read;
 261                 fclose(filep);
 262
 263         }
 264
 265         return 0;
 266 }
 267
 268 static int kvp_key_delete(int pool, __u8 *key, int key_size)
 269 {
 270         int i;
 271         int j, k;
 272         int num_records;
 273         struct kvp_record *record;
 274
 275         /*
 276          * First update the in-memory state.
 277          */
 278         kvp_update_mem_state(pool);
 279
 280         num_records = kvp_file_info[pool].num_records;
 281         record = kvp_file_info[pool].records;
 282
 283         for (i = 0; i < num_records; i++) {
 284                 if (memcmp(key, record[i].key, key_size))
 285                         continue;
 286                 /*
 287                  * Found a match; just move the remaining
 288                  * entries up.
 289                  */
 290                 if (i == num_records) {
 291                         kvp_file_info[pool].num_records--;
 292                         kvp_update_file(pool);
 293                         return 0;
 294                 }
 295
 296                 j = i;
 297                 k = j + 1;
 298                 for (; k < num_records; k++) {
 299                         strcpy(record[j].key, record[k].key);
 300                         strcpy(record[j].value, record[k].value);
 301                         j++;
 302                 }
 303
 304                 kvp_file_info[pool].num_records--;
 305                 kvp_update_file(pool);
 306                 return 0;
 307         }
 308         return 1;
 309 }
 310
 311 static int kvp_key_add_or_modify(int pool, __u8 *key, int key_size, __u8 *value,
 312                         int value_size)
 313 {
 314         int i;
 315         int num_records;
 316         struct kvp_record *record;
 317         int num_blocks;
 318
 319         if ((key_size > HV_KVP_EXCHANGE_MAX_KEY_SIZE) ||
 320                 (value_size > HV_KVP_EXCHANGE_MAX_VALUE_SIZE))
 321                 return 1;
 322
 323         /*
 324          * First update the in-memory state.
 325          */
 326         kvp_update_mem_state(pool);
 327
 328         num_records = kvp_file_info[pool].num_records;
 329         record = kvp_file_info[pool].records;
 330         num_blocks = kvp_file_info[pool].num_blocks;
 331
 332         for (i = 0; i < num_records; i++) {
 333                 if (memcmp(key, record[i].key, key_size))
 334                         continue;
 335                 /*
 336                  * Found a match; just update the value -
 337                  * this is the modify case.
 338                  */
 339                 memcpy(record[i].value, value, value_size);
 340                 kvp_update_file(pool);
 341                 return 0;
 342         }
 343
 344         /*
 345          * Need to add a new entry;
 346          */
 347         if (num_records == (ENTRIES_PER_BLOCK * num_blocks)) {
 348                 /* Need to allocate a larger array for reg entries. */
 349                 record = realloc(record, sizeof(struct kvp_record) *
 350                          ENTRIES_PER_BLOCK * (num_blocks + 1));
 351
 352                 if (record == NULL)
 353                         return 1;
 354                 kvp_file_info[pool].num_blocks++;
 355
 356         }
 357         memcpy(record[i].value, value, value_size);
 358         memcpy(record[i].key, key, key_size);
 359         kvp_file_info[pool].records = record;
 360         kvp_file_info[pool].num_records++;
 361         kvp_update_file(pool);
 362         return 0;
 363 }
 364
 365 static int kvp_get_value(int pool, __u8 *key, int key_size, __u8 *value,
 366                         int value_size)
 367 {
 368         int i;
 369         int num_records;
 370         struct kvp_record *record;
 371
 372         if ((key_size > HV_KVP_EXCHANGE_MAX_KEY_SIZE) ||
 373                 (value_size > HV_KVP_EXCHANGE_MAX_VALUE_SIZE))
 374                 return 1;
 375
 376         /*
 377          * First update the in-memory state.
 378          */
 379         kvp_update_mem_state(pool);
 380
 381         num_records = kvp_file_info[pool].num_records;
 382         record = kvp_file_info[pool].records;
 383
 384         for (i = 0; i < num_records; i++) {
 385                 if (memcmp(key, record[i].key, key_size))
 386                         continue;
 387                 /*
 388                  * Found a match; just copy the value out.
 389                  */
 390                 memcpy(value, record[i].value, value_size);
 391                 return 0;
 392         }
 393
 394         return 1;
 395 }
 396
 397 static int kvp_pool_enumerate(int pool, int index, __u8 *key, int key_size,
 398                                 __u8 *value, int value_size)
 399 {
 400         struct kvp_record *record;
 401
 402         /*
 403          * First update our in-memory database.
 404          */
 405         kvp_update_mem_state(pool);
 406         record = kvp_file_info[pool].records;
 407
 408         if (index >= kvp_file_info[pool].num_records) {
 409                 return 1;
 410         }
 411
 412         memcpy(key, record[index].key, key_size);
 413         memcpy(value, record[index].value, value_size);
 414         return 0;
 415 }
 416
 417
 418 void kvp_get_os_info(void)
 419 {
 420         FILE    *file;
 421         char    *p, buf[512];
 422
 423         uname(&uts_buf);
 424         os_build = uts_buf.release;
 425         processor_arch = uts_buf.machine;
 426
 427         /*
 428          * The current windows host (win7) expects the build
 429          * string to be of the form: x.y.z
 430          * Strip additional information we may have.
 431          */
 432         p = strchr(os_build, '-');
 433         if (p)
 434                 *p = '\0';
 435
 436         file = fopen("/etc/SuSE-release", "r");
 437         if (file != NULL)
 438                 goto kvp_osinfo_found;
 439         file  = fopen("/etc/redhat-release", "r");
 440         if (file != NULL)
 441                 goto kvp_osinfo_found;
 442         /*
 443          * Add code for other supported platforms.
 444          */
 445
 446         /*
 447          * We don't have information about the os.
 448          */
 449         os_name = uts_buf.sysname;
 450         return;
 451
 452 kvp_osinfo_found:
 453         /* up to three lines */
 454         p = fgets(buf, sizeof(buf), file);
 455         if (p) {
 456                 p = strchr(buf, '\n');
 457                 if (p)
 458                         *p = '\0';
 459                 p = strdup(buf);
 460                 if (!p)
 461                         goto done;
 462                 os_name = p;
 463
 464                 /* second line */
 465                 p = fgets(buf, sizeof(buf), file);
 466                 if (p) {
 467                         p = strchr(buf, '\n');
 468                         if (p)
 469                                 *p = '\0';
 470                         p = strdup(buf);
 471                         if (!p)
 472                                 goto done;
 473                         os_major = p;
 474
 475                         /* third line */
 476                         p = fgets(buf, sizeof(buf), file);
 477                         if (p)  {
 478                                 p = strchr(buf, '\n');
 479                                 if (p)
 480                                         *p = '\0';
 481                                 p = strdup(buf);
 482                                 if (p)
 483                                         os_minor = p;
 484                         }
 485                 }
 486         }
 487
 488 done:
 489         fclose(file);
 490         return;
 491 }
 492
 493 static void kvp_process_ipconfig_file(char *cmd,
 494                                         char *config_buf, int len,
 495                                         int element_size, int offset)
 496 {
 497         char buf[256];
 498         char *p;
 499         char *x;
 500         FILE *file;
 501
 502         /*
 503          * First execute the command.
 504          */
 505         file = popen(cmd, "r");
 506         if (file == NULL)
 507                 return;
 508
 509         if (offset == 0)
 510                 memset(config_buf, 0, len);
 511         while ((p = fgets(buf, sizeof(buf), file)) != NULL) {
 512                 if ((len - strlen(config_buf)) < (element_size + 1))
 513                         break;
 514
 515                 x = strchr(p, '\n');
 516                 *x = '\0';
 517                 strcat(config_buf, p);
 518                 strcat(config_buf, ";");
 519         }
 520         pclose(file);
 521 }
 522
 523 static void kvp_get_ipconfig_info(char *if_name,
 524                                  struct hv_kvp_ipaddr_value *buffer)
 525 {
 526         char cmd[512];
 527         char dhcp_info[128];
 528         char *p;
 529         FILE *file;
 530
 531         /*
 532          * Get the address of default gateway (ipv4).
 533          */
 534         sprintf(cmd, "%s %s", "ip route show dev", if_name);
 535         strcat(cmd, " | awk '/default/ {print $3 }'");
 536
 537         /*
 538          * Execute the command to gather gateway info.
 539          */
 540         kvp_process_ipconfig_file(cmd, (char *)buffer->gate_way,
 541                                 (MAX_GATEWAY_SIZE * 2), INET_ADDRSTRLEN, 0);
 542
 543         /*
 544          * Get the address of default gateway (ipv6).
 545          */
 546         sprintf(cmd, "%s %s", "ip -f inet6  route show dev", if_name);
 547         strcat(cmd, " | awk '/default/ {print $3 }'");
 548
 549         /*
 550          * Execute the command to gather gateway info (ipv6).
 551          */
 552         kvp_process_ipconfig_file(cmd, (char *)buffer->gate_way,
 553                                 (MAX_GATEWAY_SIZE * 2), INET6_ADDRSTRLEN, 1);
 554
 555
 556         /*
 557          * Gather the DNS  state.
 558          * Since there is no standard way to get this information
 559          * across various distributions of interest; we just invoke
 560          * an external script that needs to be ported across distros
 561          * of interest.
 562          *
 563          * Following is the expected format of the information from the script:
 564          *
 565          * ipaddr1 (nameserver1)
 566          * ipaddr2 (nameserver2)
 567          * .
 568          * .
 569          */
 570
 571         sprintf(cmd, "%s",  "hv_get_dns_info");
 572
 573         /*
 574          * Execute the command to gather DNS info.
 575          */
 576         kvp_process_ipconfig_file(cmd, (char *)buffer->dns_addr,
 577                                 (MAX_IP_ADDR_SIZE * 2), INET_ADDRSTRLEN, 0);
 578
 579         /*
 580          * Gather the DHCP state.
 581          * We will gather this state by invoking an external script.
 582          * The parameter to the script is the interface name.
 583          * Here is the expected output:
 584          *
 585          * Enabled: DHCP enabled.
 586          */
 587
 588         sprintf(cmd, "%s %s", "hv_get_dhcp_info", if_name);
 589
 590         file = popen(cmd, "r");
 591         if (file == NULL)
 592                 return;
 593
 594         p = fgets(dhcp_info, sizeof(dhcp_info), file);
 595         if (p == NULL) {
 596                 pclose(file);
 597                 return;
 598         }
 599
 600         if (!strncmp(p, "Enabled", 7))
 601                 buffer->dhcp_enabled = 1;
 602         else
 603                 buffer->dhcp_enabled = 0;
 604
 605         pclose(file);
 606 }
 607
 608
 609 static unsigned int hweight32(unsigned int *w)
 610 {
 611         unsigned int res = *w - ((*w >> 1) & 0x55555555);
 612         res = (res & 0x33333333) + ((res >> 2) & 0x33333333);
 613         res = (res + (res >> 4)) & 0x0F0F0F0F;
 614         res = res + (res >> 8);
 615         return (res + (res >> 16)) & 0x000000FF;
 616 }
 617
 618 static int kvp_process_ip_address(void *addrp,
 619                                 int family, char *buffer,
 620                                 int length,  int *offset)
 621 {
 622         struct sockaddr_in *addr;
 623         struct sockaddr_in6 *addr6;
 624         int addr_length;
 625         char tmp[50];
 626         const char *str;
 627
 628         if (family == AF_INET) {
 629                 addr = (struct sockaddr_in *)addrp;
 630                 str = inet_ntop(family, &addr->sin_addr, tmp, 50);
 631                 addr_length = INET_ADDRSTRLEN;
 632         } else {
 633                 addr6 = (struct sockaddr_in6 *)addrp;
 634                 str = inet_ntop(family, &addr6->sin6_addr.s6_addr, tmp, 50);
 635                 addr_length = INET6_ADDRSTRLEN;
 636         }
 637
 638         if ((length - *offset) < addr_length + 1)
 639                 return 1;
 640         if (str == NULL) {
 641                 strcpy(buffer, "inet_ntop failed\n");
 642                 return 1;
 643         }
 644         if (*offset == 0)
 645                 strcpy(buffer, tmp);
 646         else
 647                 strcat(buffer, tmp);
 648         strcat(buffer, ";");
 649
 650         *offset += strlen(str) + 1;
 651         return 0;
 652 }
 653
 654 static int
 655 kvp_get_ip_address(int family, char *if_name, int op,
 656                  void  *out_buffer, int length)
 657 {
 658         struct ifaddrs *ifap;
 659         struct ifaddrs *curp;
 660         int offset = 0;
 661         int sn_offset = 0;
 662         int error = 0;
 663         char *buffer;
 664         struct hv_kvp_ipaddr_value *ip_buffer;
 665         char cidr_mask[5]; /* /xyz */
 666         int weight;
 667         int i;
 668         unsigned int *w;
 669         char *sn_str;
 670         struct sockaddr_in6 *addr6;
 671
 672         if (op == KVP_OP_ENUMERATE) {
 673                 buffer = out_buffer;
 674         } else {
 675                 ip_buffer = out_buffer;
 676                 buffer = (char *)ip_buffer->ip_addr;
 677                 ip_buffer->addr_family = 0;
 678         }
 679         /*
 680          * On entry into this function, the buffer is capable of holding the
 681          * maximum key value.
 682          */
 683
 684         if (getifaddrs(&ifap)) {
 685                 strcpy(buffer, "getifaddrs failed\n");
 686                 return 1;
 687         }
 688
 689         curp = ifap;
 690         while (curp != NULL) {
 691                 if (curp->ifa_addr == NULL) {
 692                         curp = curp->ifa_next;
 693                         continue;
 694                 }
 695
 696                 if ((if_name != NULL) &&
 697                         (strncmp(curp->ifa_name, if_name, strlen(if_name)))) {
 698                         /*
 699                          * We want info about a specific interface;
 700                          * just continue.
 701                          */
 702                         curp = curp->ifa_next;
 703                         continue;
 704                 }
 705
 706                 /*
 707                  * We only support two address families: AF_INET and AF_INET6.
 708                  * If a family value of 0 is specified, we collect both
 709                  * supported address families; if not we gather info on
 710                  * the specified address family.
 711                  */
 712                 if ((family != 0) && (curp->ifa_addr->sa_family != family)) {
 713                         curp = curp->ifa_next;
 714                         continue;
 715                 }
 716                 if ((curp->ifa_addr->sa_family != AF_INET) &&
 717                         (curp->ifa_addr->sa_family != AF_INET6)) {
 718                         curp = curp->ifa_next;
 719                         continue;
 720                 }
 721
 722                 if (op == KVP_OP_GET_IP_INFO) {
 723                         /*
 724                          * Gather info other than the IP address.
 725                          * IP address info will be gathered later.
 726                          */
 727                         if (curp->ifa_addr->sa_family == AF_INET) {
 728                                 ip_buffer->addr_family |= ADDR_FAMILY_IPV4;
 729                                 /*
 730                                  * Get subnet info.
 731                                  */
 732                                 error = kvp_process_ip_address(
 733                                                              curp->ifa_netmask,
 734                                                              AF_INET,
 735                                                              (char *)
 736                                                              ip_buffer->sub_net,
 737                                                              length,
 738                                                              &sn_offset);
 739                                 if (error)
 740                                         goto gather_ipaddr;
 741                         } else {
 742                                 ip_buffer->addr_family |= ADDR_FAMILY_IPV6;
 743
 744                                 /*
 745                                  * Get subnet info in CIDR format.
 746                                  */
 747                                 weight = 0;
 748                                 sn_str = (char *)ip_buffer->sub_net;
 749                                 addr6 = (struct sockaddr_in6 *)
 750                                         curp->ifa_netmask;
 751                                 w = addr6->sin6_addr.s6_addr32;
 752
 753                                 for (i = 0; i < 4; i++)
 754                                         weight += hweight32(&w[i]);
 755
 756                                 sprintf(cidr_mask, "/%d", weight);
 757                                 if ((length - sn_offset) <
 758                                         (strlen(cidr_mask) + 1))
 759                                         goto gather_ipaddr;
 760
 761                                 if (sn_offset == 0)
 762                                         strcpy(sn_str, cidr_mask);
 763                                 else
 764                                         strcat(sn_str, cidr_mask);
 765                                 strcat((char *)ip_buffer->sub_net, ";");
 766                                 sn_offset += strlen(sn_str) + 1;
 767                         }
 768
 769                         /*
 770                          * Collect other ip related configuration info.
 771                          */
 772
 773                         kvp_get_ipconfig_info(if_name, ip_buffer);
 774                 }
 775
 776 gather_ipaddr:
 777                 error = kvp_process_ip_address(curp->ifa_addr,
 778                                                 curp->ifa_addr->sa_family,
 779                                                 buffer,
 780                                                 length, &offset);
 781                 if (error)
 782                         goto getaddr_done;
 783
 784                 curp = curp->ifa_next;
 785         }
 786
 787 getaddr_done:
 788         freeifaddrs(ifap);
 789         return error;
 790 }
 791
 792
 793 static int
 794 kvp_get_domain_name(char *buffer, int length)
 795 {
 796         struct addrinfo hints, *info ;
 797         int error = 0;
 798
 799         gethostname(buffer, length);
 800         memset(&hints, 0, sizeof(hints));
 801         hints.ai_family = AF_INET; /*Get only ipv4 addrinfo. */
 802         hints.ai_socktype = SOCK_STREAM;
 803         hints.ai_flags = AI_CANONNAME;
 804
 805         error = getaddrinfo(buffer, NULL, &hints, &info);
 806         if (error != 0) {
 807                 strcpy(buffer, "getaddrinfo failed\n");
 808                 return error;
 809         }
 810         strcpy(buffer, info->ai_canonname);
 811         freeaddrinfo(info);
 812         return error;
 813 }
 814
 815 static int
 816 netlink_send(int fd, struct cn_msg *msg)
 817 {
 818         struct nlmsghdr *nlh;
 819         unsigned int size;
 820         struct msghdr message;
 821         char buffer[64];
 822         struct iovec iov[2];
 823
 824         size = NLMSG_SPACE(sizeof(struct cn_msg) + msg->len);
 825
 826         nlh = (struct nlmsghdr *)buffer;
 827         nlh->nlmsg_seq = 0;
 828         nlh->nlmsg_pid = getpid();
 829         nlh->nlmsg_type = NLMSG_DONE;
 830         nlh->nlmsg_len = NLMSG_LENGTH(size - sizeof(*nlh));
 831         nlh->nlmsg_flags = 0;
 832
 833         iov[0].iov_base = nlh;
 834         iov[0].iov_len = sizeof(*nlh);
 835
 836         iov[1].iov_base = msg;
 837         iov[1].iov_len = size;
 838
 839         memset(&message, 0, sizeof(message));
 840         message.msg_name = &addr;
 841         message.msg_namelen = sizeof(addr);
 842         message.msg_iov = iov;
 843         message.msg_iovlen = 2;
 844
 845         return sendmsg(fd, &message, 0);
 846 }
 847
 848 int main(void)
 849 {
 850         int fd, len, sock_opt;
 851         int error;
 852         struct cn_msg *message;
 853         struct pollfd pfd;
 854         struct nlmsghdr *incoming_msg;
 855         struct cn_msg   *incoming_cn_msg;
 856         struct hv_kvp_msg *hv_msg;
 857         char    *p;
 858         char    *key_value;
 859         char    *key_name;
 860         int     op;
 861         int     pool;
 862
 863         daemon(1, 0);
 864         openlog("KVP", 0, LOG_USER);
 865         syslog(LOG_INFO, "KVP starting; pid is:%d", getpid());
 866         /*
 867          * Retrieve OS release information.
 868          */
 869         kvp_get_os_info();
 870
 871         if (kvp_file_init()) {
 872                 syslog(LOG_ERR, "Failed to initialize the pools");
 873                 exit(-1);
 874         }
 875
 876         fd = socket(AF_NETLINK, SOCK_DGRAM, NETLINK_CONNECTOR);
 877         if (fd < 0) {
 878                 syslog(LOG_ERR, "netlink socket creation failed; error:%d", fd);
 879                 exit(-1);
 880         }
 881         addr.nl_family = AF_NETLINK;
 882         addr.nl_pad = 0;
 883         addr.nl_pid = 0;
 884         addr.nl_groups = CN_KVP_IDX;
 885
 886
 887         error = bind(fd, (struct sockaddr *)&addr, sizeof(addr));
 888         if (error < 0) {
 889                 syslog(LOG_ERR, "bind failed; error:%d", error);
 890                 close(fd);
 891                 exit(-1);
 892         }
 893         sock_opt = addr.nl_groups;
 894         setsockopt(fd, 270, 1, &sock_opt, sizeof(sock_opt));
 895         /*
 896          * Register ourselves with the kernel.
 897          */
 898         message = (struct cn_msg *)kvp_send_buffer;
 899         message->id.idx = CN_KVP_IDX;
 900         message->id.val = CN_KVP_VAL;
 901
 902         hv_msg = (struct hv_kvp_msg *)message->data;
 903         hv_msg->kvp_hdr.operation = KVP_OP_REGISTER1;
 904         message->ack = 0;
 905         message->len = sizeof(struct hv_kvp_msg);
 906
 907         len = netlink_send(fd, message);
 908         if (len < 0) {
 909                 syslog(LOG_ERR, "netlink_send failed; error:%d", len);
 910                 close(fd);
 911                 exit(-1);
 912         }
 913
 914         pfd.fd = fd;
 915
 916         while (1) {
 917                 struct sockaddr *addr_p = (struct sockaddr *) &addr;
 918                 socklen_t addr_l = sizeof(addr);
 919                 pfd.events = POLLIN;
 920                 pfd.revents = 0;
 921                 poll(&pfd, 1, -1);
 922
 923                 len = recvfrom(fd, kvp_recv_buffer, sizeof(kvp_recv_buffer), 0,
 924                                 addr_p, &addr_l);
 925
 926                 if (len < 0 || addr.nl_pid) {
 927                         syslog(LOG_ERR, "recvfrom failed; pid:%u error:%d %s",
 928                                         addr.nl_pid, errno, strerror(errno));
 929                         close(fd);
 930                         return -1;
 931                 }
 932
 933                 incoming_msg = (struct nlmsghdr *)kvp_recv_buffer;
 934                 incoming_cn_msg = (struct cn_msg *)NLMSG_DATA(incoming_msg);
 935                 hv_msg = (struct hv_kvp_msg *)incoming_cn_msg->data;
 936
 937                 /*
 938                  * We will use the KVP header information to pass back
 939                  * the error from this daemon. So, first copy the state
 940                  * and set the error code to success.
 941                  */
 942                 op = hv_msg->kvp_hdr.operation;
 943                 pool = hv_msg->kvp_hdr.pool;
 944                 hv_msg->error = HV_S_OK;
 945
 946                 if ((in_hand_shake) && (op == KVP_OP_REGISTER1)) {
 947                         /*
 948                          * Driver is registering with us; stash away the version
 949                          * information.
 950                          */
 951                         in_hand_shake = 0;
 952                         p = (char *)hv_msg->body.kvp_register.version;
 953                         lic_version = malloc(strlen(p) + 1);
 954                         if (lic_version) {
 955                                 strcpy(lic_version, p);
 956                                 syslog(LOG_INFO, "KVP LIC Version: %s",
 957                                         lic_version);
 958                         } else {
 959                                 syslog(LOG_ERR, "malloc failed");
 960                         }
 961                         continue;
 962                 }
 963
 964                 switch (op) {
 965                 case KVP_OP_SET:
 966                         if (kvp_key_add_or_modify(pool,
 967                                         hv_msg->body.kvp_set.data.key,
 968                                         hv_msg->body.kvp_set.data.key_size,
 969                                         hv_msg->body.kvp_set.data.value,
 970                                         hv_msg->body.kvp_set.data.value_size))
 971                                         hv_msg->error = HV_S_CONT;
 972                         break;
 973
 974                 case KVP_OP_GET:
 975                         if (kvp_get_value(pool,
 976                                         hv_msg->body.kvp_set.data.key,
 977                                         hv_msg->body.kvp_set.data.key_size,
 978                                         hv_msg->body.kvp_set.data.value,
 979                                         hv_msg->body.kvp_set.data.value_size))
 980                                         hv_msg->error = HV_S_CONT;
 981                         break;
 982
 983                 case KVP_OP_DELETE:
 984                         if (kvp_key_delete(pool,
 985                                         hv_msg->body.kvp_delete.key,
 986                                         hv_msg->body.kvp_delete.key_size))
 987                                         hv_msg->error = HV_S_CONT;
 988                         break;
 989
 990                 default:
 991                         break;
 992                 }
 993
 994                 if (op != KVP_OP_ENUMERATE)
 995                         goto kvp_done;
 996
 997                 /*
 998                  * If the pool is KVP_POOL_AUTO, dynamically generate
 999                  * both the key and the value; if not read from the
1000                  * appropriate pool.
1001                  */
1002                 if (pool != KVP_POOL_AUTO) {
1003                         if (kvp_pool_enumerate(pool,
1004                                         hv_msg->body.kvp_enum_data.index,
1005                                         hv_msg->body.kvp_enum_data.data.key,
1006                                         HV_KVP_EXCHANGE_MAX_KEY_SIZE,
1007                                         hv_msg->body.kvp_enum_data.data.value,
1008                                         HV_KVP_EXCHANGE_MAX_VALUE_SIZE))
1009                                         hv_msg->error = HV_S_CONT;
1010                         goto kvp_done;
1011                 }
1012
1013                 hv_msg = (struct hv_kvp_msg *)incoming_cn_msg->data;
1014                 key_name = (char *)hv_msg->body.kvp_enum_data.data.key;
1015                 key_value = (char *)hv_msg->body.kvp_enum_data.data.value;
1016
1017                 switch (hv_msg->body.kvp_enum_data.index) {
1018                 case FullyQualifiedDomainName:
1019                         kvp_get_domain_name(key_value,
1020                                         HV_KVP_EXCHANGE_MAX_VALUE_SIZE);
1021                         strcpy(key_name, "FullyQualifiedDomainName");
1022                         break;
1023                 case IntegrationServicesVersion:
1024                         strcpy(key_name, "IntegrationServicesVersion");
1025                         strcpy(key_value, lic_version);
1026                         break;
1027                 case NetworkAddressIPv4:
1028                         kvp_get_ip_address(AF_INET, NULL, KVP_OP_ENUMERATE,
1029                                 key_value, HV_KVP_EXCHANGE_MAX_VALUE_SIZE);
1030                         strcpy(key_name, "NetworkAddressIPv4");
1031                         break;
1032                 case NetworkAddressIPv6:
1033                         kvp_get_ip_address(AF_INET6, NULL, KVP_OP_ENUMERATE,
1034                                 key_value, HV_KVP_EXCHANGE_MAX_VALUE_SIZE);
1035                         strcpy(key_name, "NetworkAddressIPv6");
1036                         break;
1037                 case OSBuildNumber:
1038                         strcpy(key_value, os_build);
1039                         strcpy(key_name, "OSBuildNumber");
1040                         break;
1041                 case OSName:
1042                         strcpy(key_value, os_name);
1043                         strcpy(key_name, "OSName");
1044                         break;
1045                 case OSMajorVersion:
1046                         strcpy(key_value, os_major);
1047                         strcpy(key_name, "OSMajorVersion");
1048                         break;
1049                 case OSMinorVersion:
1050                         strcpy(key_value, os_minor);
1051                         strcpy(key_name, "OSMinorVersion");
1052                         break;
1053                 case OSVersion:
1054                         strcpy(key_value, os_build);
1055                         strcpy(key_name, "OSVersion");
1056                         break;
1057                 case ProcessorArchitecture:
1058                         strcpy(key_value, processor_arch);
1059                         strcpy(key_name, "ProcessorArchitecture");
1060                         break;
1061                 default:
1062                         hv_msg->error = HV_S_CONT;
1063                         break;
1064                 }
1065                 /*
1066                  * Send the value back to the kernel. The response is
1067                  * already in the receive buffer. Update the cn_msg header to
1068                  * reflect the key value that has been added to the message
1069                  */
1070 kvp_done:
1071
1072                 incoming_cn_msg->id.idx = CN_KVP_IDX;
1073                 incoming_cn_msg->id.val = CN_KVP_VAL;
1074                 incoming_cn_msg->ack = 0;
1075                 incoming_cn_msg->len = sizeof(struct hv_kvp_msg);
1076
1077                 len = netlink_send(fd, incoming_cn_msg);
1078                 if (len < 0) {
1079                         syslog(LOG_ERR, "net_link send failed; error:%d", len);
1080                         exit(-1);
1081                 }
1082         }
1083
1084 }