1 /* 2 * Copyright (c) 2009, Microsoft Corporation. 3 * 4 * This program is free software; you can redistribute it and/or modify it 5 * under the terms and conditions of the GNU General Public License, 6 * version 2, as published by the Free Software Foundation. 7 * 8 * This program is distributed in the hope it will be useful, but WITHOUT 9 * ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or 10 * FITNESS FOR A PARTICULAR PURPOSE. See the GNU General Public License for 11 * more details. 12 * 13 * You should have received a copy of the GNU General Public License along with 14 * this program; if not, write to the Free Software Foundation, Inc., 59 Temple 15 * Place - Suite 330, Boston, MA 02111-1307 USA. 16 * 17 * Authors: 18 * Haiyang Zhang <haiyangz@microsoft.com> 19 * Hank Janssen <hjanssen@microsoft.com> 20 * K. Y. Srinivasan <kys@microsoft.com> 21 * 22 */ 23 #define pr_fmt(fmt) KBUILD_MODNAME ": " fmt 24 25 #include <linux/init.h> 26 #include <linux/module.h> 27 #include <linux/device.h> 28 #include <linux/interrupt.h> 29 #include <linux/sysctl.h> 30 #include <linux/slab.h> 31 #include <linux/acpi.h> 32 #include <linux/completion.h> 33 #include <linux/hyperv.h> 34 #include <linux/kernel_stat.h> 35 #include <linux/clockchips.h> 36 #include <linux/cpu.h> 37 #include <linux/sched/task_stack.h> 38 39 #include <asm/hyperv.h> 40 #include <asm/hypervisor.h> 41 #include <asm/mshyperv.h> 42 #include <linux/notifier.h> 43 #include <linux/ptrace.h> 44 #include <linux/screen_info.h> 45 #include <linux/kdebug.h> 46 #include <linux/efi.h> 47 #include <linux/random.h> 48 #include "hyperv_vmbus.h" 49 50 struct vmbus_dynid { 51 struct list_head node; 52 struct hv_vmbus_device_id id; 53 }; 54 55 static struct acpi_device *hv_acpi_dev; 56 57 static struct completion probe_event; 58 59 static int hyperv_cpuhp_online; 60 61 static int hyperv_panic_event(struct notifier_block *nb, unsigned long val, 62 void *args) 63 { 64 struct pt_regs *regs; 65 66 regs = current_pt_regs(); 67 68 hyperv_report_panic(regs); 69 return NOTIFY_DONE; 70 } 71 72 static int hyperv_die_event(struct notifier_block *nb, unsigned long val, 73 void *args) 74 { 75 struct die_args *die = (struct die_args *)args; 76 struct pt_regs *regs = die->regs; 77 78 hyperv_report_panic(regs); 79 return NOTIFY_DONE; 80 } 81 82 static struct notifier_block hyperv_die_block = { 83 .notifier_call = hyperv_die_event, 84 }; 85 static struct notifier_block hyperv_panic_block = { 86 .notifier_call = hyperv_panic_event, 87 }; 88 89 static const char *fb_mmio_name = "fb_range"; 90 static struct resource *fb_mmio; 91 static struct resource *hyperv_mmio; 92 static DEFINE_SEMAPHORE(hyperv_mmio_lock); 93 94 static int vmbus_exists(void) 95 { 96 if (hv_acpi_dev == NULL) 97 return -ENODEV; 98 99 return 0; 100 } 101 102 #define VMBUS_ALIAS_LEN ((sizeof((struct hv_vmbus_device_id *)0)->guid) * 2) 103 static void print_alias_name(struct hv_device *hv_dev, char *alias_name) 104 { 105 int i; 106 for (i = 0; i < VMBUS_ALIAS_LEN; i += 2) 107 sprintf(&alias_name[i], "%02x", hv_dev->dev_type.b[i/2]); 108 } 109 110 static u8 channel_monitor_group(struct vmbus_channel *channel) 111 { 112 return (u8)channel->offermsg.monitorid / 32; 113 } 114 115 static u8 channel_monitor_offset(struct vmbus_channel *channel) 116 { 117 return (u8)channel->offermsg.monitorid % 32; 118 } 119 120 static u32 channel_pending(struct vmbus_channel *channel, 121 struct hv_monitor_page *monitor_page) 122 { 123 u8 monitor_group = channel_monitor_group(channel); 124 return monitor_page->trigger_group[monitor_group].pending; 125 } 126 127 static u32 channel_latency(struct vmbus_channel *channel, 128 struct hv_monitor_page *monitor_page) 129 { 130 u8 monitor_group = channel_monitor_group(channel); 131 u8 monitor_offset = channel_monitor_offset(channel); 132 return monitor_page->latency[monitor_group][monitor_offset]; 133 } 134 135 static u32 channel_conn_id(struct vmbus_channel *channel, 136 struct hv_monitor_page *monitor_page) 137 { 138 u8 monitor_group = channel_monitor_group(channel); 139 u8 monitor_offset = channel_monitor_offset(channel); 140 return monitor_page->parameter[monitor_group][monitor_offset].connectionid.u.id; 141 } 142 143 static ssize_t id_show(struct device *dev, struct device_attribute *dev_attr, 144 char *buf) 145 { 146 struct hv_device *hv_dev = device_to_hv_device(dev); 147 148 if (!hv_dev->channel) 149 return -ENODEV; 150 return sprintf(buf, "%d\n", hv_dev->channel->offermsg.child_relid); 151 } 152 static DEVICE_ATTR_RO(id); 153 154 static ssize_t state_show(struct device *dev, struct device_attribute *dev_attr, 155 char *buf) 156 { 157 struct hv_device *hv_dev = device_to_hv_device(dev); 158 159 if (!hv_dev->channel) 160 return -ENODEV; 161 return sprintf(buf, "%d\n", hv_dev->channel->state); 162 } 163 static DEVICE_ATTR_RO(state); 164 165 static ssize_t monitor_id_show(struct device *dev, 166 struct device_attribute *dev_attr, char *buf) 167 { 168 struct hv_device *hv_dev = device_to_hv_device(dev); 169 170 if (!hv_dev->channel) 171 return -ENODEV; 172 return sprintf(buf, "%d\n", hv_dev->channel->offermsg.monitorid); 173 } 174 static DEVICE_ATTR_RO(monitor_id); 175 176 static ssize_t class_id_show(struct device *dev, 177 struct device_attribute *dev_attr, char *buf) 178 { 179 struct hv_device *hv_dev = device_to_hv_device(dev); 180 181 if (!hv_dev->channel) 182 return -ENODEV; 183 return sprintf(buf, "{%pUl}\n", 184 hv_dev->channel->offermsg.offer.if_type.b); 185 } 186 static DEVICE_ATTR_RO(class_id); 187 188 static ssize_t device_id_show(struct device *dev, 189 struct device_attribute *dev_attr, char *buf) 190 { 191 struct hv_device *hv_dev = device_to_hv_device(dev); 192 193 if (!hv_dev->channel) 194 return -ENODEV; 195 return sprintf(buf, "{%pUl}\n", 196 hv_dev->channel->offermsg.offer.if_instance.b); 197 } 198 static DEVICE_ATTR_RO(device_id); 199 200 static ssize_t modalias_show(struct device *dev, 201 struct device_attribute *dev_attr, char *buf) 202 { 203 struct hv_device *hv_dev = device_to_hv_device(dev); 204 char alias_name[VMBUS_ALIAS_LEN + 1]; 205 206 print_alias_name(hv_dev, alias_name); 207 return sprintf(buf, "vmbus:%s\n", alias_name); 208 } 209 static DEVICE_ATTR_RO(modalias); 210 211 static ssize_t server_monitor_pending_show(struct device *dev, 212 struct device_attribute *dev_attr, 213 char *buf) 214 { 215 struct hv_device *hv_dev = device_to_hv_device(dev); 216 217 if (!hv_dev->channel) 218 return -ENODEV; 219 return sprintf(buf, "%d\n", 220 channel_pending(hv_dev->channel, 221 vmbus_connection.monitor_pages[1])); 222 } 223 static DEVICE_ATTR_RO(server_monitor_pending); 224 225 static ssize_t client_monitor_pending_show(struct device *dev, 226 struct device_attribute *dev_attr, 227 char *buf) 228 { 229 struct hv_device *hv_dev = device_to_hv_device(dev); 230 231 if (!hv_dev->channel) 232 return -ENODEV; 233 return sprintf(buf, "%d\n", 234 channel_pending(hv_dev->channel, 235 vmbus_connection.monitor_pages[1])); 236 } 237 static DEVICE_ATTR_RO(client_monitor_pending); 238 239 static ssize_t server_monitor_latency_show(struct device *dev, 240 struct device_attribute *dev_attr, 241 char *buf) 242 { 243 struct hv_device *hv_dev = device_to_hv_device(dev); 244 245 if (!hv_dev->channel) 246 return -ENODEV; 247 return sprintf(buf, "%d\n", 248 channel_latency(hv_dev->channel, 249 vmbus_connection.monitor_pages[0])); 250 } 251 static DEVICE_ATTR_RO(server_monitor_latency); 252 253 static ssize_t client_monitor_latency_show(struct device *dev, 254 struct device_attribute *dev_attr, 255 char *buf) 256 { 257 struct hv_device *hv_dev = device_to_hv_device(dev); 258 259 if (!hv_dev->channel) 260 return -ENODEV; 261 return sprintf(buf, "%d\n", 262 channel_latency(hv_dev->channel, 263 vmbus_connection.monitor_pages[1])); 264 } 265 static DEVICE_ATTR_RO(client_monitor_latency); 266 267 static ssize_t server_monitor_conn_id_show(struct device *dev, 268 struct device_attribute *dev_attr, 269 char *buf) 270 { 271 struct hv_device *hv_dev = device_to_hv_device(dev); 272 273 if (!hv_dev->channel) 274 return -ENODEV; 275 return sprintf(buf, "%d\n", 276 channel_conn_id(hv_dev->channel, 277 vmbus_connection.monitor_pages[0])); 278 } 279 static DEVICE_ATTR_RO(server_monitor_conn_id); 280 281 static ssize_t client_monitor_conn_id_show(struct device *dev, 282 struct device_attribute *dev_attr, 283 char *buf) 284 { 285 struct hv_device *hv_dev = device_to_hv_device(dev); 286 287 if (!hv_dev->channel) 288 return -ENODEV; 289 return sprintf(buf, "%d\n", 290 channel_conn_id(hv_dev->channel, 291 vmbus_connection.monitor_pages[1])); 292 } 293 static DEVICE_ATTR_RO(client_monitor_conn_id); 294 295 static ssize_t out_intr_mask_show(struct device *dev, 296 struct device_attribute *dev_attr, char *buf) 297 { 298 struct hv_device *hv_dev = device_to_hv_device(dev); 299 struct hv_ring_buffer_debug_info outbound; 300 301 if (!hv_dev->channel) 302 return -ENODEV; 303 hv_ringbuffer_get_debuginfo(&hv_dev->channel->outbound, &outbound); 304 return sprintf(buf, "%d\n", outbound.current_interrupt_mask); 305 } 306 static DEVICE_ATTR_RO(out_intr_mask); 307 308 static ssize_t out_read_index_show(struct device *dev, 309 struct device_attribute *dev_attr, char *buf) 310 { 311 struct hv_device *hv_dev = device_to_hv_device(dev); 312 struct hv_ring_buffer_debug_info outbound; 313 314 if (!hv_dev->channel) 315 return -ENODEV; 316 hv_ringbuffer_get_debuginfo(&hv_dev->channel->outbound, &outbound); 317 return sprintf(buf, "%d\n", outbound.current_read_index); 318 } 319 static DEVICE_ATTR_RO(out_read_index); 320 321 static ssize_t out_write_index_show(struct device *dev, 322 struct device_attribute *dev_attr, 323 char *buf) 324 { 325 struct hv_device *hv_dev = device_to_hv_device(dev); 326 struct hv_ring_buffer_debug_info outbound; 327 328 if (!hv_dev->channel) 329 return -ENODEV; 330 hv_ringbuffer_get_debuginfo(&hv_dev->channel->outbound, &outbound); 331 return sprintf(buf, "%d\n", outbound.current_write_index); 332 } 333 static DEVICE_ATTR_RO(out_write_index); 334 335 static ssize_t out_read_bytes_avail_show(struct device *dev, 336 struct device_attribute *dev_attr, 337 char *buf) 338 { 339 struct hv_device *hv_dev = device_to_hv_device(dev); 340 struct hv_ring_buffer_debug_info outbound; 341 342 if (!hv_dev->channel) 343 return -ENODEV; 344 hv_ringbuffer_get_debuginfo(&hv_dev->channel->outbound, &outbound); 345 return sprintf(buf, "%d\n", outbound.bytes_avail_toread); 346 } 347 static DEVICE_ATTR_RO(out_read_bytes_avail); 348 349 static ssize_t out_write_bytes_avail_show(struct device *dev, 350 struct device_attribute *dev_attr, 351 char *buf) 352 { 353 struct hv_device *hv_dev = device_to_hv_device(dev); 354 struct hv_ring_buffer_debug_info outbound; 355 356 if (!hv_dev->channel) 357 return -ENODEV; 358 hv_ringbuffer_get_debuginfo(&hv_dev->channel->outbound, &outbound); 359 return sprintf(buf, "%d\n", outbound.bytes_avail_towrite); 360 } 361 static DEVICE_ATTR_RO(out_write_bytes_avail); 362 363 static ssize_t in_intr_mask_show(struct device *dev, 364 struct device_attribute *dev_attr, char *buf) 365 { 366 struct hv_device *hv_dev = device_to_hv_device(dev); 367 struct hv_ring_buffer_debug_info inbound; 368 369 if (!hv_dev->channel) 370 return -ENODEV; 371 hv_ringbuffer_get_debuginfo(&hv_dev->channel->inbound, &inbound); 372 return sprintf(buf, "%d\n", inbound.current_interrupt_mask); 373 } 374 static DEVICE_ATTR_RO(in_intr_mask); 375 376 static ssize_t in_read_index_show(struct device *dev, 377 struct device_attribute *dev_attr, char *buf) 378 { 379 struct hv_device *hv_dev = device_to_hv_device(dev); 380 struct hv_ring_buffer_debug_info inbound; 381 382 if (!hv_dev->channel) 383 return -ENODEV; 384 hv_ringbuffer_get_debuginfo(&hv_dev->channel->inbound, &inbound); 385 return sprintf(buf, "%d\n", inbound.current_read_index); 386 } 387 static DEVICE_ATTR_RO(in_read_index); 388 389 static ssize_t in_write_index_show(struct device *dev, 390 struct device_attribute *dev_attr, char *buf) 391 { 392 struct hv_device *hv_dev = device_to_hv_device(dev); 393 struct hv_ring_buffer_debug_info inbound; 394 395 if (!hv_dev->channel) 396 return -ENODEV; 397 hv_ringbuffer_get_debuginfo(&hv_dev->channel->inbound, &inbound); 398 return sprintf(buf, "%d\n", inbound.current_write_index); 399 } 400 static DEVICE_ATTR_RO(in_write_index); 401 402 static ssize_t in_read_bytes_avail_show(struct device *dev, 403 struct device_attribute *dev_attr, 404 char *buf) 405 { 406 struct hv_device *hv_dev = device_to_hv_device(dev); 407 struct hv_ring_buffer_debug_info inbound; 408 409 if (!hv_dev->channel) 410 return -ENODEV; 411 hv_ringbuffer_get_debuginfo(&hv_dev->channel->inbound, &inbound); 412 return sprintf(buf, "%d\n", inbound.bytes_avail_toread); 413 } 414 static DEVICE_ATTR_RO(in_read_bytes_avail); 415 416 static ssize_t in_write_bytes_avail_show(struct device *dev, 417 struct device_attribute *dev_attr, 418 char *buf) 419 { 420 struct hv_device *hv_dev = device_to_hv_device(dev); 421 struct hv_ring_buffer_debug_info inbound; 422 423 if (!hv_dev->channel) 424 return -ENODEV; 425 hv_ringbuffer_get_debuginfo(&hv_dev->channel->inbound, &inbound); 426 return sprintf(buf, "%d\n", inbound.bytes_avail_towrite); 427 } 428 static DEVICE_ATTR_RO(in_write_bytes_avail); 429 430 static ssize_t channel_vp_mapping_show(struct device *dev, 431 struct device_attribute *dev_attr, 432 char *buf) 433 { 434 struct hv_device *hv_dev = device_to_hv_device(dev); 435 struct vmbus_channel *channel = hv_dev->channel, *cur_sc; 436 unsigned long flags; 437 int buf_size = PAGE_SIZE, n_written, tot_written; 438 struct list_head *cur; 439 440 if (!channel) 441 return -ENODEV; 442 443 tot_written = snprintf(buf, buf_size, "%u:%u\n", 444 channel->offermsg.child_relid, channel->target_cpu); 445 446 spin_lock_irqsave(&channel->lock, flags); 447 448 list_for_each(cur, &channel->sc_list) { 449 if (tot_written >= buf_size - 1) 450 break; 451 452 cur_sc = list_entry(cur, struct vmbus_channel, sc_list); 453 n_written = scnprintf(buf + tot_written, 454 buf_size - tot_written, 455 "%u:%u\n", 456 cur_sc->offermsg.child_relid, 457 cur_sc->target_cpu); 458 tot_written += n_written; 459 } 460 461 spin_unlock_irqrestore(&channel->lock, flags); 462 463 return tot_written; 464 } 465 static DEVICE_ATTR_RO(channel_vp_mapping); 466 467 static ssize_t vendor_show(struct device *dev, 468 struct device_attribute *dev_attr, 469 char *buf) 470 { 471 struct hv_device *hv_dev = device_to_hv_device(dev); 472 return sprintf(buf, "0x%x\n", hv_dev->vendor_id); 473 } 474 static DEVICE_ATTR_RO(vendor); 475 476 static ssize_t device_show(struct device *dev, 477 struct device_attribute *dev_attr, 478 char *buf) 479 { 480 struct hv_device *hv_dev = device_to_hv_device(dev); 481 return sprintf(buf, "0x%x\n", hv_dev->device_id); 482 } 483 static DEVICE_ATTR_RO(device); 484 485 /* Set up per device attributes in /sys/bus/vmbus/devices/<bus device> */ 486 static struct attribute *vmbus_dev_attrs[] = { 487 &dev_attr_id.attr, 488 &dev_attr_state.attr, 489 &dev_attr_monitor_id.attr, 490 &dev_attr_class_id.attr, 491 &dev_attr_device_id.attr, 492 &dev_attr_modalias.attr, 493 &dev_attr_server_monitor_pending.attr, 494 &dev_attr_client_monitor_pending.attr, 495 &dev_attr_server_monitor_latency.attr, 496 &dev_attr_client_monitor_latency.attr, 497 &dev_attr_server_monitor_conn_id.attr, 498 &dev_attr_client_monitor_conn_id.attr, 499 &dev_attr_out_intr_mask.attr, 500 &dev_attr_out_read_index.attr, 501 &dev_attr_out_write_index.attr, 502 &dev_attr_out_read_bytes_avail.attr, 503 &dev_attr_out_write_bytes_avail.attr, 504 &dev_attr_in_intr_mask.attr, 505 &dev_attr_in_read_index.attr, 506 &dev_attr_in_write_index.attr, 507 &dev_attr_in_read_bytes_avail.attr, 508 &dev_attr_in_write_bytes_avail.attr, 509 &dev_attr_channel_vp_mapping.attr, 510 &dev_attr_vendor.attr, 511 &dev_attr_device.attr, 512 NULL, 513 }; 514 ATTRIBUTE_GROUPS(vmbus_dev); 515 516 /* 517 * vmbus_uevent - add uevent for our device 518 * 519 * This routine is invoked when a device is added or removed on the vmbus to 520 * generate a uevent to udev in the userspace. The udev will then look at its 521 * rule and the uevent generated here to load the appropriate driver 522 * 523 * The alias string will be of the form vmbus:guid where guid is the string 524 * representation of the device guid (each byte of the guid will be 525 * represented with two hex characters. 526 */ 527 static int vmbus_uevent(struct device *device, struct kobj_uevent_env *env) 528 { 529 struct hv_device *dev = device_to_hv_device(device); 530 int ret; 531 char alias_name[VMBUS_ALIAS_LEN + 1]; 532 533 print_alias_name(dev, alias_name); 534 ret = add_uevent_var(env, "MODALIAS=vmbus:%s", alias_name); 535 return ret; 536 } 537 538 static const uuid_le null_guid; 539 540 static inline bool is_null_guid(const uuid_le *guid) 541 { 542 if (uuid_le_cmp(*guid, null_guid)) 543 return false; 544 return true; 545 } 546 547 /* 548 * Return a matching hv_vmbus_device_id pointer. 549 * If there is no match, return NULL. 550 */ 551 static const struct hv_vmbus_device_id *hv_vmbus_get_id(struct hv_driver *drv, 552 const uuid_le *guid) 553 { 554 const struct hv_vmbus_device_id *id = NULL; 555 struct vmbus_dynid *dynid; 556 557 /* Look at the dynamic ids first, before the static ones */ 558 spin_lock(&drv->dynids.lock); 559 list_for_each_entry(dynid, &drv->dynids.list, node) { 560 if (!uuid_le_cmp(dynid->id.guid, *guid)) { 561 id = &dynid->id; 562 break; 563 } 564 } 565 spin_unlock(&drv->dynids.lock); 566 567 if (id) 568 return id; 569 570 id = drv->id_table; 571 if (id == NULL) 572 return NULL; /* empty device table */ 573 574 for (; !is_null_guid(&id->guid); id++) 575 if (!uuid_le_cmp(id->guid, *guid)) 576 return id; 577 578 return NULL; 579 } 580 581 /* vmbus_add_dynid - add a new device ID to this driver and re-probe devices */ 582 static int vmbus_add_dynid(struct hv_driver *drv, uuid_le *guid) 583 { 584 struct vmbus_dynid *dynid; 585 586 dynid = kzalloc(sizeof(*dynid), GFP_KERNEL); 587 if (!dynid) 588 return -ENOMEM; 589 590 dynid->id.guid = *guid; 591 592 spin_lock(&drv->dynids.lock); 593 list_add_tail(&dynid->node, &drv->dynids.list); 594 spin_unlock(&drv->dynids.lock); 595 596 return driver_attach(&drv->driver); 597 } 598 599 static void vmbus_free_dynids(struct hv_driver *drv) 600 { 601 struct vmbus_dynid *dynid, *n; 602 603 spin_lock(&drv->dynids.lock); 604 list_for_each_entry_safe(dynid, n, &drv->dynids.list, node) { 605 list_del(&dynid->node); 606 kfree(dynid); 607 } 608 spin_unlock(&drv->dynids.lock); 609 } 610 611 /* Parse string of form: 1b4e28ba-2fa1-11d2-883f-b9a761bde3f */ 612 static int get_uuid_le(const char *str, uuid_le *uu) 613 { 614 unsigned int b[16]; 615 int i; 616 617 if (strlen(str) < 37) 618 return -1; 619 620 for (i = 0; i < 36; i++) { 621 switch (i) { 622 case 8: case 13: case 18: case 23: 623 if (str[i] != '-') 624 return -1; 625 break; 626 default: 627 if (!isxdigit(str[i])) 628 return -1; 629 } 630 } 631 632 /* unparse little endian output byte order */ 633 if (sscanf(str, 634 "%2x%2x%2x%2x-%2x%2x-%2x%2x-%2x%2x-%2x%2x%2x%2x%2x%2x", 635 &b[3], &b[2], &b[1], &b[0], 636 &b[5], &b[4], &b[7], &b[6], &b[8], &b[9], 637 &b[10], &b[11], &b[12], &b[13], &b[14], &b[15]) != 16) 638 return -1; 639 640 for (i = 0; i < 16; i++) 641 uu->b[i] = b[i]; 642 return 0; 643 } 644 645 /* 646 * store_new_id - sysfs frontend to vmbus_add_dynid() 647 * 648 * Allow GUIDs to be added to an existing driver via sysfs. 649 */ 650 static ssize_t new_id_store(struct device_driver *driver, const char *buf, 651 size_t count) 652 { 653 struct hv_driver *drv = drv_to_hv_drv(driver); 654 uuid_le guid = NULL_UUID_LE; 655 ssize_t retval; 656 657 if (get_uuid_le(buf, &guid) != 0) 658 return -EINVAL; 659 660 if (hv_vmbus_get_id(drv, &guid)) 661 return -EEXIST; 662 663 retval = vmbus_add_dynid(drv, &guid); 664 if (retval) 665 return retval; 666 return count; 667 } 668 static DRIVER_ATTR_WO(new_id); 669 670 /* 671 * store_remove_id - remove a PCI device ID from this driver 672 * 673 * Removes a dynamic pci device ID to this driver. 674 */ 675 static ssize_t remove_id_store(struct device_driver *driver, const char *buf, 676 size_t count) 677 { 678 struct hv_driver *drv = drv_to_hv_drv(driver); 679 struct vmbus_dynid *dynid, *n; 680 uuid_le guid = NULL_UUID_LE; 681 size_t retval = -ENODEV; 682 683 if (get_uuid_le(buf, &guid)) 684 return -EINVAL; 685 686 spin_lock(&drv->dynids.lock); 687 list_for_each_entry_safe(dynid, n, &drv->dynids.list, node) { 688 struct hv_vmbus_device_id *id = &dynid->id; 689 690 if (!uuid_le_cmp(id->guid, guid)) { 691 list_del(&dynid->node); 692 kfree(dynid); 693 retval = count; 694 break; 695 } 696 } 697 spin_unlock(&drv->dynids.lock); 698 699 return retval; 700 } 701 static DRIVER_ATTR_WO(remove_id); 702 703 static struct attribute *vmbus_drv_attrs[] = { 704 &driver_attr_new_id.attr, 705 &driver_attr_remove_id.attr, 706 NULL, 707 }; 708 ATTRIBUTE_GROUPS(vmbus_drv); 709 710 711 /* 712 * vmbus_match - Attempt to match the specified device to the specified driver 713 */ 714 static int vmbus_match(struct device *device, struct device_driver *driver) 715 { 716 struct hv_driver *drv = drv_to_hv_drv(driver); 717 struct hv_device *hv_dev = device_to_hv_device(device); 718 719 /* The hv_sock driver handles all hv_sock offers. */ 720 if (is_hvsock_channel(hv_dev->channel)) 721 return drv->hvsock; 722 723 if (hv_vmbus_get_id(drv, &hv_dev->dev_type)) 724 return 1; 725 726 return 0; 727 } 728 729 /* 730 * vmbus_probe - Add the new vmbus's child device 731 */ 732 static int vmbus_probe(struct device *child_device) 733 { 734 int ret = 0; 735 struct hv_driver *drv = 736 drv_to_hv_drv(child_device->driver); 737 struct hv_device *dev = device_to_hv_device(child_device); 738 const struct hv_vmbus_device_id *dev_id; 739 740 dev_id = hv_vmbus_get_id(drv, &dev->dev_type); 741 if (drv->probe) { 742 ret = drv->probe(dev, dev_id); 743 if (ret != 0) 744 pr_err("probe failed for device %s (%d)\n", 745 dev_name(child_device), ret); 746 747 } else { 748 pr_err("probe not set for driver %s\n", 749 dev_name(child_device)); 750 ret = -ENODEV; 751 } 752 return ret; 753 } 754 755 /* 756 * vmbus_remove - Remove a vmbus device 757 */ 758 static int vmbus_remove(struct device *child_device) 759 { 760 struct hv_driver *drv; 761 struct hv_device *dev = device_to_hv_device(child_device); 762 763 if (child_device->driver) { 764 drv = drv_to_hv_drv(child_device->driver); 765 if (drv->remove) 766 drv->remove(dev); 767 } 768 769 return 0; 770 } 771 772 773 /* 774 * vmbus_shutdown - Shutdown a vmbus device 775 */ 776 static void vmbus_shutdown(struct device *child_device) 777 { 778 struct hv_driver *drv; 779 struct hv_device *dev = device_to_hv_device(child_device); 780 781 782 /* The device may not be attached yet */ 783 if (!child_device->driver) 784 return; 785 786 drv = drv_to_hv_drv(child_device->driver); 787 788 if (drv->shutdown) 789 drv->shutdown(dev); 790 791 return; 792 } 793 794 795 /* 796 * vmbus_device_release - Final callback release of the vmbus child device 797 */ 798 static void vmbus_device_release(struct device *device) 799 { 800 struct hv_device *hv_dev = device_to_hv_device(device); 801 struct vmbus_channel *channel = hv_dev->channel; 802 803 hv_process_channel_removal(channel, 804 channel->offermsg.child_relid); 805 kfree(hv_dev); 806 807 } 808 809 /* The one and only one */ 810 static struct bus_type hv_bus = { 811 .name = "vmbus", 812 .match = vmbus_match, 813 .shutdown = vmbus_shutdown, 814 .remove = vmbus_remove, 815 .probe = vmbus_probe, 816 .uevent = vmbus_uevent, 817 .dev_groups = vmbus_dev_groups, 818 .drv_groups = vmbus_drv_groups, 819 }; 820 821 struct onmessage_work_context { 822 struct work_struct work; 823 struct hv_message msg; 824 }; 825 826 static void vmbus_onmessage_work(struct work_struct *work) 827 { 828 struct onmessage_work_context *ctx; 829 830 /* Do not process messages if we're in DISCONNECTED state */ 831 if (vmbus_connection.conn_state == DISCONNECTED) 832 return; 833 834 ctx = container_of(work, struct onmessage_work_context, 835 work); 836 vmbus_onmessage(&ctx->msg); 837 kfree(ctx); 838 } 839 840 static void hv_process_timer_expiration(struct hv_message *msg, 841 struct hv_per_cpu_context *hv_cpu) 842 { 843 struct clock_event_device *dev = hv_cpu->clk_evt; 844 845 if (dev->event_handler) 846 dev->event_handler(dev); 847 848 vmbus_signal_eom(msg, HVMSG_TIMER_EXPIRED); 849 } 850 851 void vmbus_on_msg_dpc(unsigned long data) 852 { 853 struct hv_per_cpu_context *hv_cpu = (void *)data; 854 void *page_addr = hv_cpu->synic_message_page; 855 struct hv_message *msg = (struct hv_message *)page_addr + 856 VMBUS_MESSAGE_SINT; 857 struct vmbus_channel_message_header *hdr; 858 struct vmbus_channel_message_table_entry *entry; 859 struct onmessage_work_context *ctx; 860 u32 message_type = msg->header.message_type; 861 862 if (message_type == HVMSG_NONE) 863 /* no msg */ 864 return; 865 866 hdr = (struct vmbus_channel_message_header *)msg->u.payload; 867 868 if (hdr->msgtype >= CHANNELMSG_COUNT) { 869 WARN_ONCE(1, "unknown msgtype=%d\n", hdr->msgtype); 870 goto msg_handled; 871 } 872 873 entry = &channel_message_table[hdr->msgtype]; 874 if (entry->handler_type == VMHT_BLOCKING) { 875 ctx = kmalloc(sizeof(*ctx), GFP_ATOMIC); 876 if (ctx == NULL) 877 return; 878 879 INIT_WORK(&ctx->work, vmbus_onmessage_work); 880 memcpy(&ctx->msg, msg, sizeof(*msg)); 881 882 queue_work(vmbus_connection.work_queue, &ctx->work); 883 } else 884 entry->message_handler(hdr); 885 886 msg_handled: 887 vmbus_signal_eom(msg, message_type); 888 } 889 890 891 /* 892 * Direct callback for channels using other deferred processing 893 */ 894 static void vmbus_channel_isr(struct vmbus_channel *channel) 895 { 896 void (*callback_fn)(void *); 897 898 callback_fn = READ_ONCE(channel->onchannel_callback); 899 if (likely(callback_fn != NULL)) 900 (*callback_fn)(channel->channel_callback_context); 901 } 902 903 /* 904 * Schedule all channels with events pending 905 */ 906 static void vmbus_chan_sched(struct hv_per_cpu_context *hv_cpu) 907 { 908 unsigned long *recv_int_page; 909 u32 maxbits, relid; 910 911 if (vmbus_proto_version < VERSION_WIN8) { 912 maxbits = MAX_NUM_CHANNELS_SUPPORTED; 913 recv_int_page = vmbus_connection.recv_int_page; 914 } else { 915 /* 916 * When the host is win8 and beyond, the event page 917 * can be directly checked to get the id of the channel 918 * that has the interrupt pending. 919 */ 920 void *page_addr = hv_cpu->synic_event_page; 921 union hv_synic_event_flags *event 922 = (union hv_synic_event_flags *)page_addr + 923 VMBUS_MESSAGE_SINT; 924 925 maxbits = HV_EVENT_FLAGS_COUNT; 926 recv_int_page = event->flags; 927 } 928 929 if (unlikely(!recv_int_page)) 930 return; 931 932 for_each_set_bit(relid, recv_int_page, maxbits) { 933 struct vmbus_channel *channel; 934 935 if (!sync_test_and_clear_bit(relid, recv_int_page)) 936 continue; 937 938 /* Special case - vmbus channel protocol msg */ 939 if (relid == 0) 940 continue; 941 942 /* Find channel based on relid */ 943 list_for_each_entry(channel, &hv_cpu->chan_list, percpu_list) { 944 if (channel->offermsg.child_relid != relid) 945 continue; 946 947 switch (channel->callback_mode) { 948 case HV_CALL_ISR: 949 vmbus_channel_isr(channel); 950 break; 951 952 case HV_CALL_BATCHED: 953 hv_begin_read(&channel->inbound); 954 /* fallthrough */ 955 case HV_CALL_DIRECT: 956 tasklet_schedule(&channel->callback_event); 957 } 958 } 959 } 960 } 961 962 static void vmbus_isr(void) 963 { 964 struct hv_per_cpu_context *hv_cpu 965 = this_cpu_ptr(hv_context.cpu_context); 966 void *page_addr = hv_cpu->synic_event_page; 967 struct hv_message *msg; 968 union hv_synic_event_flags *event; 969 bool handled = false; 970 971 if (unlikely(page_addr == NULL)) 972 return; 973 974 event = (union hv_synic_event_flags *)page_addr + 975 VMBUS_MESSAGE_SINT; 976 /* 977 * Check for events before checking for messages. This is the order 978 * in which events and messages are checked in Windows guests on 979 * Hyper-V, and the Windows team suggested we do the same. 980 */ 981 982 if ((vmbus_proto_version == VERSION_WS2008) || 983 (vmbus_proto_version == VERSION_WIN7)) { 984 985 /* Since we are a child, we only need to check bit 0 */ 986 if (sync_test_and_clear_bit(0, event->flags)) 987 handled = true; 988 } else { 989 /* 990 * Our host is win8 or above. The signaling mechanism 991 * has changed and we can directly look at the event page. 992 * If bit n is set then we have an interrup on the channel 993 * whose id is n. 994 */ 995 handled = true; 996 } 997 998 if (handled) 999 vmbus_chan_sched(hv_cpu); 1000 1001 page_addr = hv_cpu->synic_message_page; 1002 msg = (struct hv_message *)page_addr + VMBUS_MESSAGE_SINT; 1003 1004 /* Check if there are actual msgs to be processed */ 1005 if (msg->header.message_type != HVMSG_NONE) { 1006 if (msg->header.message_type == HVMSG_TIMER_EXPIRED) 1007 hv_process_timer_expiration(msg, hv_cpu); 1008 else 1009 tasklet_schedule(&hv_cpu->msg_dpc); 1010 } 1011 1012 add_interrupt_randomness(HYPERVISOR_CALLBACK_VECTOR, 0); 1013 } 1014 1015 1016 /* 1017 * vmbus_bus_init -Main vmbus driver initialization routine. 1018 * 1019 * Here, we 1020 * - initialize the vmbus driver context 1021 * - invoke the vmbus hv main init routine 1022 * - retrieve the channel offers 1023 */ 1024 static int vmbus_bus_init(void) 1025 { 1026 int ret; 1027 1028 /* Hypervisor initialization...setup hypercall page..etc */ 1029 ret = hv_init(); 1030 if (ret != 0) { 1031 pr_err("Unable to initialize the hypervisor - 0x%x\n", ret); 1032 return ret; 1033 } 1034 1035 ret = bus_register(&hv_bus); 1036 if (ret) 1037 return ret; 1038 1039 hv_setup_vmbus_irq(vmbus_isr); 1040 1041 ret = hv_synic_alloc(); 1042 if (ret) 1043 goto err_alloc; 1044 /* 1045 * Initialize the per-cpu interrupt state and 1046 * connect to the host. 1047 */ 1048 ret = cpuhp_setup_state(CPUHP_AP_ONLINE_DYN, "x86/hyperv:online", 1049 hv_synic_init, hv_synic_cleanup); 1050 if (ret < 0) 1051 goto err_alloc; 1052 hyperv_cpuhp_online = ret; 1053 1054 ret = vmbus_connect(); 1055 if (ret) 1056 goto err_connect; 1057 1058 /* 1059 * Only register if the crash MSRs are available 1060 */ 1061 if (ms_hyperv.misc_features & HV_FEATURE_GUEST_CRASH_MSR_AVAILABLE) { 1062 register_die_notifier(&hyperv_die_block); 1063 atomic_notifier_chain_register(&panic_notifier_list, 1064 &hyperv_panic_block); 1065 } 1066 1067 vmbus_request_offers(); 1068 1069 return 0; 1070 1071 err_connect: 1072 cpuhp_remove_state(hyperv_cpuhp_online); 1073 err_alloc: 1074 hv_synic_free(); 1075 hv_remove_vmbus_irq(); 1076 1077 bus_unregister(&hv_bus); 1078 1079 return ret; 1080 } 1081 1082 /** 1083 * __vmbus_child_driver_register() - Register a vmbus's driver 1084 * @hv_driver: Pointer to driver structure you want to register 1085 * @owner: owner module of the drv 1086 * @mod_name: module name string 1087 * 1088 * Registers the given driver with Linux through the 'driver_register()' call 1089 * and sets up the hyper-v vmbus handling for this driver. 1090 * It will return the state of the 'driver_register()' call. 1091 * 1092 */ 1093 int __vmbus_driver_register(struct hv_driver *hv_driver, struct module *owner, const char *mod_name) 1094 { 1095 int ret; 1096 1097 pr_info("registering driver %s\n", hv_driver->name); 1098 1099 ret = vmbus_exists(); 1100 if (ret < 0) 1101 return ret; 1102 1103 hv_driver->driver.name = hv_driver->name; 1104 hv_driver->driver.owner = owner; 1105 hv_driver->driver.mod_name = mod_name; 1106 hv_driver->driver.bus = &hv_bus; 1107 1108 spin_lock_init(&hv_driver->dynids.lock); 1109 INIT_LIST_HEAD(&hv_driver->dynids.list); 1110 1111 ret = driver_register(&hv_driver->driver); 1112 1113 return ret; 1114 } 1115 EXPORT_SYMBOL_GPL(__vmbus_driver_register); 1116 1117 /** 1118 * vmbus_driver_unregister() - Unregister a vmbus's driver 1119 * @hv_driver: Pointer to driver structure you want to 1120 * un-register 1121 * 1122 * Un-register the given driver that was previous registered with a call to 1123 * vmbus_driver_register() 1124 */ 1125 void vmbus_driver_unregister(struct hv_driver *hv_driver) 1126 { 1127 pr_info("unregistering driver %s\n", hv_driver->name); 1128 1129 if (!vmbus_exists()) { 1130 driver_unregister(&hv_driver->driver); 1131 vmbus_free_dynids(hv_driver); 1132 } 1133 } 1134 EXPORT_SYMBOL_GPL(vmbus_driver_unregister); 1135 1136 /* 1137 * vmbus_device_create - Creates and registers a new child device 1138 * on the vmbus. 1139 */ 1140 struct hv_device *vmbus_device_create(const uuid_le *type, 1141 const uuid_le *instance, 1142 struct vmbus_channel *channel) 1143 { 1144 struct hv_device *child_device_obj; 1145 1146 child_device_obj = kzalloc(sizeof(struct hv_device), GFP_KERNEL); 1147 if (!child_device_obj) { 1148 pr_err("Unable to allocate device object for child device\n"); 1149 return NULL; 1150 } 1151 1152 child_device_obj->channel = channel; 1153 memcpy(&child_device_obj->dev_type, type, sizeof(uuid_le)); 1154 memcpy(&child_device_obj->dev_instance, instance, 1155 sizeof(uuid_le)); 1156 child_device_obj->vendor_id = 0x1414; /* MSFT vendor ID */ 1157 1158 1159 return child_device_obj; 1160 } 1161 1162 /* 1163 * vmbus_device_register - Register the child device 1164 */ 1165 int vmbus_device_register(struct hv_device *child_device_obj) 1166 { 1167 int ret = 0; 1168 1169 dev_set_name(&child_device_obj->device, "%pUl", 1170 child_device_obj->channel->offermsg.offer.if_instance.b); 1171 1172 child_device_obj->device.bus = &hv_bus; 1173 child_device_obj->device.parent = &hv_acpi_dev->dev; 1174 child_device_obj->device.release = vmbus_device_release; 1175 1176 /* 1177 * Register with the LDM. This will kick off the driver/device 1178 * binding...which will eventually call vmbus_match() and vmbus_probe() 1179 */ 1180 ret = device_register(&child_device_obj->device); 1181 1182 if (ret) 1183 pr_err("Unable to register child device\n"); 1184 else 1185 pr_debug("child device %s registered\n", 1186 dev_name(&child_device_obj->device)); 1187 1188 return ret; 1189 } 1190 1191 /* 1192 * vmbus_device_unregister - Remove the specified child device 1193 * from the vmbus. 1194 */ 1195 void vmbus_device_unregister(struct hv_device *device_obj) 1196 { 1197 pr_debug("child device %s unregistered\n", 1198 dev_name(&device_obj->device)); 1199 1200 /* 1201 * Kick off the process of unregistering the device. 1202 * This will call vmbus_remove() and eventually vmbus_device_release() 1203 */ 1204 device_unregister(&device_obj->device); 1205 } 1206 1207 1208 /* 1209 * VMBUS is an acpi enumerated device. Get the information we 1210 * need from DSDT. 1211 */ 1212 #define VTPM_BASE_ADDRESS 0xfed40000 1213 static acpi_status vmbus_walk_resources(struct acpi_resource *res, void *ctx) 1214 { 1215 resource_size_t start = 0; 1216 resource_size_t end = 0; 1217 struct resource *new_res; 1218 struct resource **old_res = &hyperv_mmio; 1219 struct resource **prev_res = NULL; 1220 1221 switch (res->type) { 1222 1223 /* 1224 * "Address" descriptors are for bus windows. Ignore 1225 * "memory" descriptors, which are for registers on 1226 * devices. 1227 */ 1228 case ACPI_RESOURCE_TYPE_ADDRESS32: 1229 start = res->data.address32.address.minimum; 1230 end = res->data.address32.address.maximum; 1231 break; 1232 1233 case ACPI_RESOURCE_TYPE_ADDRESS64: 1234 start = res->data.address64.address.minimum; 1235 end = res->data.address64.address.maximum; 1236 break; 1237 1238 default: 1239 /* Unused resource type */ 1240 return AE_OK; 1241 1242 } 1243 /* 1244 * Ignore ranges that are below 1MB, as they're not 1245 * necessary or useful here. 1246 */ 1247 if (end < 0x100000) 1248 return AE_OK; 1249 1250 new_res = kzalloc(sizeof(*new_res), GFP_ATOMIC); 1251 if (!new_res) 1252 return AE_NO_MEMORY; 1253 1254 /* If this range overlaps the virtual TPM, truncate it. */ 1255 if (end > VTPM_BASE_ADDRESS && start < VTPM_BASE_ADDRESS) 1256 end = VTPM_BASE_ADDRESS; 1257 1258 new_res->name = "hyperv mmio"; 1259 new_res->flags = IORESOURCE_MEM; 1260 new_res->start = start; 1261 new_res->end = end; 1262 1263 /* 1264 * If two ranges are adjacent, merge them. 1265 */ 1266 do { 1267 if (!*old_res) { 1268 *old_res = new_res; 1269 break; 1270 } 1271 1272 if (((*old_res)->end + 1) == new_res->start) { 1273 (*old_res)->end = new_res->end; 1274 kfree(new_res); 1275 break; 1276 } 1277 1278 if ((*old_res)->start == new_res->end + 1) { 1279 (*old_res)->start = new_res->start; 1280 kfree(new_res); 1281 break; 1282 } 1283 1284 if ((*old_res)->start > new_res->end) { 1285 new_res->sibling = *old_res; 1286 if (prev_res) 1287 (*prev_res)->sibling = new_res; 1288 *old_res = new_res; 1289 break; 1290 } 1291 1292 prev_res = old_res; 1293 old_res = &(*old_res)->sibling; 1294 1295 } while (1); 1296 1297 return AE_OK; 1298 } 1299 1300 static int vmbus_acpi_remove(struct acpi_device *device) 1301 { 1302 struct resource *cur_res; 1303 struct resource *next_res; 1304 1305 if (hyperv_mmio) { 1306 if (fb_mmio) { 1307 __release_region(hyperv_mmio, fb_mmio->start, 1308 resource_size(fb_mmio)); 1309 fb_mmio = NULL; 1310 } 1311 1312 for (cur_res = hyperv_mmio; cur_res; cur_res = next_res) { 1313 next_res = cur_res->sibling; 1314 kfree(cur_res); 1315 } 1316 } 1317 1318 return 0; 1319 } 1320 1321 static void vmbus_reserve_fb(void) 1322 { 1323 int size; 1324 /* 1325 * Make a claim for the frame buffer in the resource tree under the 1326 * first node, which will be the one below 4GB. The length seems to 1327 * be underreported, particularly in a Generation 1 VM. So start out 1328 * reserving a larger area and make it smaller until it succeeds. 1329 */ 1330 1331 if (screen_info.lfb_base) { 1332 if (efi_enabled(EFI_BOOT)) 1333 size = max_t(__u32, screen_info.lfb_size, 0x800000); 1334 else 1335 size = max_t(__u32, screen_info.lfb_size, 0x4000000); 1336 1337 for (; !fb_mmio && (size >= 0x100000); size >>= 1) { 1338 fb_mmio = __request_region(hyperv_mmio, 1339 screen_info.lfb_base, size, 1340 fb_mmio_name, 0); 1341 } 1342 } 1343 } 1344 1345 /** 1346 * vmbus_allocate_mmio() - Pick a memory-mapped I/O range. 1347 * @new: If successful, supplied a pointer to the 1348 * allocated MMIO space. 1349 * @device_obj: Identifies the caller 1350 * @min: Minimum guest physical address of the 1351 * allocation 1352 * @max: Maximum guest physical address 1353 * @size: Size of the range to be allocated 1354 * @align: Alignment of the range to be allocated 1355 * @fb_overlap_ok: Whether this allocation can be allowed 1356 * to overlap the video frame buffer. 1357 * 1358 * This function walks the resources granted to VMBus by the 1359 * _CRS object in the ACPI namespace underneath the parent 1360 * "bridge" whether that's a root PCI bus in the Generation 1 1361 * case or a Module Device in the Generation 2 case. It then 1362 * attempts to allocate from the global MMIO pool in a way that 1363 * matches the constraints supplied in these parameters and by 1364 * that _CRS. 1365 * 1366 * Return: 0 on success, -errno on failure 1367 */ 1368 int vmbus_allocate_mmio(struct resource **new, struct hv_device *device_obj, 1369 resource_size_t min, resource_size_t max, 1370 resource_size_t size, resource_size_t align, 1371 bool fb_overlap_ok) 1372 { 1373 struct resource *iter, *shadow; 1374 resource_size_t range_min, range_max, start; 1375 const char *dev_n = dev_name(&device_obj->device); 1376 int retval; 1377 1378 retval = -ENXIO; 1379 down(&hyperv_mmio_lock); 1380 1381 /* 1382 * If overlaps with frame buffers are allowed, then first attempt to 1383 * make the allocation from within the reserved region. Because it 1384 * is already reserved, no shadow allocation is necessary. 1385 */ 1386 if (fb_overlap_ok && fb_mmio && !(min > fb_mmio->end) && 1387 !(max < fb_mmio->start)) { 1388 1389 range_min = fb_mmio->start; 1390 range_max = fb_mmio->end; 1391 start = (range_min + align - 1) & ~(align - 1); 1392 for (; start + size - 1 <= range_max; start += align) { 1393 *new = request_mem_region_exclusive(start, size, dev_n); 1394 if (*new) { 1395 retval = 0; 1396 goto exit; 1397 } 1398 } 1399 } 1400 1401 for (iter = hyperv_mmio; iter; iter = iter->sibling) { 1402 if ((iter->start >= max) || (iter->end <= min)) 1403 continue; 1404 1405 range_min = iter->start; 1406 range_max = iter->end; 1407 start = (range_min + align - 1) & ~(align - 1); 1408 for (; start + size - 1 <= range_max; start += align) { 1409 shadow = __request_region(iter, start, size, NULL, 1410 IORESOURCE_BUSY); 1411 if (!shadow) 1412 continue; 1413 1414 *new = request_mem_region_exclusive(start, size, dev_n); 1415 if (*new) { 1416 shadow->name = (char *)*new; 1417 retval = 0; 1418 goto exit; 1419 } 1420 1421 __release_region(iter, start, size); 1422 } 1423 } 1424 1425 exit: 1426 up(&hyperv_mmio_lock); 1427 return retval; 1428 } 1429 EXPORT_SYMBOL_GPL(vmbus_allocate_mmio); 1430 1431 /** 1432 * vmbus_free_mmio() - Free a memory-mapped I/O range. 1433 * @start: Base address of region to release. 1434 * @size: Size of the range to be allocated 1435 * 1436 * This function releases anything requested by 1437 * vmbus_mmio_allocate(). 1438 */ 1439 void vmbus_free_mmio(resource_size_t start, resource_size_t size) 1440 { 1441 struct resource *iter; 1442 1443 down(&hyperv_mmio_lock); 1444 for (iter = hyperv_mmio; iter; iter = iter->sibling) { 1445 if ((iter->start >= start + size) || (iter->end <= start)) 1446 continue; 1447 1448 __release_region(iter, start, size); 1449 } 1450 release_mem_region(start, size); 1451 up(&hyperv_mmio_lock); 1452 1453 } 1454 EXPORT_SYMBOL_GPL(vmbus_free_mmio); 1455 1456 /** 1457 * vmbus_cpu_number_to_vp_number() - Map CPU to VP. 1458 * @cpu_number: CPU number in Linux terms 1459 * 1460 * This function returns the mapping between the Linux processor 1461 * number and the hypervisor's virtual processor number, useful 1462 * in making hypercalls and such that talk about specific 1463 * processors. 1464 * 1465 * Return: Virtual processor number in Hyper-V terms 1466 */ 1467 int vmbus_cpu_number_to_vp_number(int cpu_number) 1468 { 1469 return hv_context.vp_index[cpu_number]; 1470 } 1471 EXPORT_SYMBOL_GPL(vmbus_cpu_number_to_vp_number); 1472 1473 static int vmbus_acpi_add(struct acpi_device *device) 1474 { 1475 acpi_status result; 1476 int ret_val = -ENODEV; 1477 struct acpi_device *ancestor; 1478 1479 hv_acpi_dev = device; 1480 1481 result = acpi_walk_resources(device->handle, METHOD_NAME__CRS, 1482 vmbus_walk_resources, NULL); 1483 1484 if (ACPI_FAILURE(result)) 1485 goto acpi_walk_err; 1486 /* 1487 * Some ancestor of the vmbus acpi device (Gen1 or Gen2 1488 * firmware) is the VMOD that has the mmio ranges. Get that. 1489 */ 1490 for (ancestor = device->parent; ancestor; ancestor = ancestor->parent) { 1491 result = acpi_walk_resources(ancestor->handle, METHOD_NAME__CRS, 1492 vmbus_walk_resources, NULL); 1493 1494 if (ACPI_FAILURE(result)) 1495 continue; 1496 if (hyperv_mmio) { 1497 vmbus_reserve_fb(); 1498 break; 1499 } 1500 } 1501 ret_val = 0; 1502 1503 acpi_walk_err: 1504 complete(&probe_event); 1505 if (ret_val) 1506 vmbus_acpi_remove(device); 1507 return ret_val; 1508 } 1509 1510 static const struct acpi_device_id vmbus_acpi_device_ids[] = { 1511 {"VMBUS", 0}, 1512 {"VMBus", 0}, 1513 {"", 0}, 1514 }; 1515 MODULE_DEVICE_TABLE(acpi, vmbus_acpi_device_ids); 1516 1517 static struct acpi_driver vmbus_acpi_driver = { 1518 .name = "vmbus", 1519 .ids = vmbus_acpi_device_ids, 1520 .ops = { 1521 .add = vmbus_acpi_add, 1522 .remove = vmbus_acpi_remove, 1523 }, 1524 }; 1525 1526 static void hv_kexec_handler(void) 1527 { 1528 hv_synic_clockevents_cleanup(); 1529 vmbus_initiate_unload(false); 1530 vmbus_connection.conn_state = DISCONNECTED; 1531 /* Make sure conn_state is set as hv_synic_cleanup checks for it */ 1532 mb(); 1533 cpuhp_remove_state(hyperv_cpuhp_online); 1534 hyperv_cleanup(); 1535 }; 1536 1537 static void hv_crash_handler(struct pt_regs *regs) 1538 { 1539 vmbus_initiate_unload(true); 1540 /* 1541 * In crash handler we can't schedule synic cleanup for all CPUs, 1542 * doing the cleanup for current CPU only. This should be sufficient 1543 * for kdump. 1544 */ 1545 vmbus_connection.conn_state = DISCONNECTED; 1546 hv_synic_cleanup(smp_processor_id()); 1547 hyperv_cleanup(); 1548 }; 1549 1550 static int __init hv_acpi_init(void) 1551 { 1552 int ret, t; 1553 1554 if (x86_hyper != &x86_hyper_ms_hyperv) 1555 return -ENODEV; 1556 1557 init_completion(&probe_event); 1558 1559 /* 1560 * Get ACPI resources first. 1561 */ 1562 ret = acpi_bus_register_driver(&vmbus_acpi_driver); 1563 1564 if (ret) 1565 return ret; 1566 1567 t = wait_for_completion_timeout(&probe_event, 5*HZ); 1568 if (t == 0) { 1569 ret = -ETIMEDOUT; 1570 goto cleanup; 1571 } 1572 1573 ret = vmbus_bus_init(); 1574 if (ret) 1575 goto cleanup; 1576 1577 hv_setup_kexec_handler(hv_kexec_handler); 1578 hv_setup_crash_handler(hv_crash_handler); 1579 1580 return 0; 1581 1582 cleanup: 1583 acpi_bus_unregister_driver(&vmbus_acpi_driver); 1584 hv_acpi_dev = NULL; 1585 return ret; 1586 } 1587 1588 static void __exit vmbus_exit(void) 1589 { 1590 int cpu; 1591 1592 hv_remove_kexec_handler(); 1593 hv_remove_crash_handler(); 1594 vmbus_connection.conn_state = DISCONNECTED; 1595 hv_synic_clockevents_cleanup(); 1596 vmbus_disconnect(); 1597 hv_remove_vmbus_irq(); 1598 for_each_online_cpu(cpu) { 1599 struct hv_per_cpu_context *hv_cpu 1600 = per_cpu_ptr(hv_context.cpu_context, cpu); 1601 1602 tasklet_kill(&hv_cpu->msg_dpc); 1603 } 1604 vmbus_free_channels(); 1605 1606 if (ms_hyperv.misc_features & HV_FEATURE_GUEST_CRASH_MSR_AVAILABLE) { 1607 unregister_die_notifier(&hyperv_die_block); 1608 atomic_notifier_chain_unregister(&panic_notifier_list, 1609 &hyperv_panic_block); 1610 } 1611 bus_unregister(&hv_bus); 1612 1613 cpuhp_remove_state(hyperv_cpuhp_online); 1614 hv_synic_free(); 1615 acpi_bus_unregister_driver(&vmbus_acpi_driver); 1616 } 1617 1618 1619 MODULE_LICENSE("GPL"); 1620 1621 subsys_initcall(hv_acpi_init); 1622 module_exit(vmbus_exit); 1623