2009-07-14 07:02:34 +08:00
|
|
|
/*
|
|
|
|
* Copyright (c) 2009, Microsoft Corporation.
|
|
|
|
*
|
|
|
|
* This program is free software; you can redistribute it and/or modify it
|
|
|
|
* under the terms and conditions of the GNU General Public License,
|
|
|
|
* version 2, as published by the Free Software Foundation.
|
|
|
|
*
|
|
|
|
* This program is distributed in the hope it will be useful, but WITHOUT
|
|
|
|
* ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or
|
|
|
|
* FITNESS FOR A PARTICULAR PURPOSE. See the GNU General Public License for
|
|
|
|
* more details.
|
|
|
|
*
|
|
|
|
* You should have received a copy of the GNU General Public License along with
|
|
|
|
* this program; if not, write to the Free Software Foundation, Inc., 59 Temple
|
|
|
|
* Place - Suite 330, Boston, MA 02111-1307 USA.
|
|
|
|
*
|
|
|
|
* Authors:
|
|
|
|
* Haiyang Zhang <haiyangz@microsoft.com>
|
|
|
|
* Hank Janssen <hjanssen@microsoft.com>
|
2011-04-30 04:45:15 +08:00
|
|
|
* K. Y. Srinivasan <kys@microsoft.com>
|
2011-03-16 06:03:34 +08:00
|
|
|
*
|
2009-07-14 07:02:34 +08:00
|
|
|
*/
|
2011-03-30 04:58:47 +08:00
|
|
|
#define pr_fmt(fmt) KBUILD_MODNAME ": " fmt
|
|
|
|
|
2009-07-14 07:02:34 +08:00
|
|
|
#include <linux/init.h>
|
|
|
|
#include <linux/module.h>
|
|
|
|
#include <linux/device.h>
|
|
|
|
#include <linux/interrupt.h>
|
|
|
|
#include <linux/sysctl.h>
|
include cleanup: Update gfp.h and slab.h includes to prepare for breaking implicit slab.h inclusion from percpu.h
percpu.h is included by sched.h and module.h and thus ends up being
included when building most .c files. percpu.h includes slab.h which
in turn includes gfp.h making everything defined by the two files
universally available and complicating inclusion dependencies.
percpu.h -> slab.h dependency is about to be removed. Prepare for
this change by updating users of gfp and slab facilities include those
headers directly instead of assuming availability. As this conversion
needs to touch large number of source files, the following script is
used as the basis of conversion.
http://userweb.kernel.org/~tj/misc/slabh-sweep.py
The script does the followings.
* Scan files for gfp and slab usages and update includes such that
only the necessary includes are there. ie. if only gfp is used,
gfp.h, if slab is used, slab.h.
* When the script inserts a new include, it looks at the include
blocks and try to put the new include such that its order conforms
to its surrounding. It's put in the include block which contains
core kernel includes, in the same order that the rest are ordered -
alphabetical, Christmas tree, rev-Xmas-tree or at the end if there
doesn't seem to be any matching order.
* If the script can't find a place to put a new include (mostly
because the file doesn't have fitting include block), it prints out
an error message indicating which .h file needs to be added to the
file.
The conversion was done in the following steps.
1. The initial automatic conversion of all .c files updated slightly
over 4000 files, deleting around 700 includes and adding ~480 gfp.h
and ~3000 slab.h inclusions. The script emitted errors for ~400
files.
2. Each error was manually checked. Some didn't need the inclusion,
some needed manual addition while adding it to implementation .h or
embedding .c file was more appropriate for others. This step added
inclusions to around 150 files.
3. The script was run again and the output was compared to the edits
from #2 to make sure no file was left behind.
4. Several build tests were done and a couple of problems were fixed.
e.g. lib/decompress_*.c used malloc/free() wrappers around slab
APIs requiring slab.h to be added manually.
5. The script was run on all .h files but without automatically
editing them as sprinkling gfp.h and slab.h inclusions around .h
files could easily lead to inclusion dependency hell. Most gfp.h
inclusion directives were ignored as stuff from gfp.h was usually
wildly available and often used in preprocessor macros. Each
slab.h inclusion directive was examined and added manually as
necessary.
6. percpu.h was updated not to include slab.h.
7. Build test were done on the following configurations and failures
were fixed. CONFIG_GCOV_KERNEL was turned off for all tests (as my
distributed build env didn't work with gcov compiles) and a few
more options had to be turned off depending on archs to make things
build (like ipr on powerpc/64 which failed due to missing writeq).
* x86 and x86_64 UP and SMP allmodconfig and a custom test config.
* powerpc and powerpc64 SMP allmodconfig
* sparc and sparc64 SMP allmodconfig
* ia64 SMP allmodconfig
* s390 SMP allmodconfig
* alpha SMP allmodconfig
* um on x86_64 SMP allmodconfig
8. percpu.h modifications were reverted so that it could be applied as
a separate patch and serve as bisection point.
Given the fact that I had only a couple of failures from tests on step
6, I'm fairly confident about the coverage of this conversion patch.
If there is a breakage, it's likely to be something in one of the arch
headers which should be easily discoverable easily on most builds of
the specific arch.
Signed-off-by: Tejun Heo <tj@kernel.org>
Guess-its-ok-by: Christoph Lameter <cl@linux-foundation.org>
Cc: Ingo Molnar <mingo@redhat.com>
Cc: Lee Schermerhorn <Lee.Schermerhorn@hp.com>
2010-03-24 16:04:11 +08:00
|
|
|
#include <linux/slab.h>
|
2011-04-30 04:45:15 +08:00
|
|
|
#include <linux/acpi.h>
|
2010-05-29 07:22:44 +08:00
|
|
|
#include <linux/completion.h>
|
2011-10-05 03:29:52 +08:00
|
|
|
#include <linux/hyperv.h>
|
2012-12-01 22:46:54 +08:00
|
|
|
#include <linux/kernel_stat.h>
|
2015-01-10 15:54:32 +08:00
|
|
|
#include <linux/clockchips.h>
|
2015-02-28 03:25:51 +08:00
|
|
|
#include <linux/cpu.h>
|
2011-10-11 22:36:44 +08:00
|
|
|
#include <asm/hyperv.h>
|
2012-08-31 13:32:44 +08:00
|
|
|
#include <asm/hypervisor.h>
|
2013-02-18 03:30:44 +08:00
|
|
|
#include <asm/mshyperv.h>
|
2011-05-13 10:34:28 +08:00
|
|
|
#include "hyperv_vmbus.h"
|
2009-07-14 07:02:34 +08:00
|
|
|
|
2011-06-07 06:49:39 +08:00
|
|
|
static struct acpi_device *hv_acpi_dev;
|
2011-03-16 06:03:32 +08:00
|
|
|
|
2011-04-30 04:45:06 +08:00
|
|
|
static struct tasklet_struct msg_dpc;
|
2011-04-30 04:45:04 +08:00
|
|
|
static struct completion probe_event;
|
2011-04-30 04:45:15 +08:00
|
|
|
static int irq;
|
2011-03-16 06:03:44 +08:00
|
|
|
|
2014-02-24 21:17:09 +08:00
|
|
|
struct resource hyperv_mmio = {
|
|
|
|
.name = "hyperv mmio",
|
|
|
|
.flags = IORESOURCE_MEM,
|
|
|
|
};
|
|
|
|
EXPORT_SYMBOL_GPL(hyperv_mmio);
|
2011-03-16 06:03:44 +08:00
|
|
|
|
2011-12-02 01:59:34 +08:00
|
|
|
static int vmbus_exists(void)
|
|
|
|
{
|
|
|
|
if (hv_acpi_dev == NULL)
|
|
|
|
return -ENODEV;
|
|
|
|
|
|
|
|
return 0;
|
|
|
|
}
|
|
|
|
|
2011-09-03 00:25:56 +08:00
|
|
|
#define VMBUS_ALIAS_LEN ((sizeof((struct hv_vmbus_device_id *)0)->guid) * 2)
|
|
|
|
static void print_alias_name(struct hv_device *hv_dev, char *alias_name)
|
|
|
|
{
|
|
|
|
int i;
|
|
|
|
for (i = 0; i < VMBUS_ALIAS_LEN; i += 2)
|
|
|
|
sprintf(&alias_name[i], "%02x", hv_dev->dev_type.b[i/2]);
|
|
|
|
}
|
|
|
|
|
2013-09-14 02:32:56 +08:00
|
|
|
static u8 channel_monitor_group(struct vmbus_channel *channel)
|
|
|
|
{
|
|
|
|
return (u8)channel->offermsg.monitorid / 32;
|
|
|
|
}
|
|
|
|
|
|
|
|
static u8 channel_monitor_offset(struct vmbus_channel *channel)
|
|
|
|
{
|
|
|
|
return (u8)channel->offermsg.monitorid % 32;
|
|
|
|
}
|
|
|
|
|
|
|
|
static u32 channel_pending(struct vmbus_channel *channel,
|
|
|
|
struct hv_monitor_page *monitor_page)
|
|
|
|
{
|
|
|
|
u8 monitor_group = channel_monitor_group(channel);
|
|
|
|
return monitor_page->trigger_group[monitor_group].pending;
|
|
|
|
}
|
|
|
|
|
2013-09-14 02:32:57 +08:00
|
|
|
static u32 channel_latency(struct vmbus_channel *channel,
|
|
|
|
struct hv_monitor_page *monitor_page)
|
|
|
|
{
|
|
|
|
u8 monitor_group = channel_monitor_group(channel);
|
|
|
|
u8 monitor_offset = channel_monitor_offset(channel);
|
|
|
|
return monitor_page->latency[monitor_group][monitor_offset];
|
|
|
|
}
|
|
|
|
|
2013-09-14 02:32:58 +08:00
|
|
|
static u32 channel_conn_id(struct vmbus_channel *channel,
|
|
|
|
struct hv_monitor_page *monitor_page)
|
|
|
|
{
|
|
|
|
u8 monitor_group = channel_monitor_group(channel);
|
|
|
|
u8 monitor_offset = channel_monitor_offset(channel);
|
|
|
|
return monitor_page->parameter[monitor_group][monitor_offset].connectionid.u.id;
|
|
|
|
}
|
|
|
|
|
2013-09-14 02:32:49 +08:00
|
|
|
static ssize_t id_show(struct device *dev, struct device_attribute *dev_attr,
|
|
|
|
char *buf)
|
|
|
|
{
|
|
|
|
struct hv_device *hv_dev = device_to_hv_device(dev);
|
|
|
|
|
|
|
|
if (!hv_dev->channel)
|
|
|
|
return -ENODEV;
|
|
|
|
return sprintf(buf, "%d\n", hv_dev->channel->offermsg.child_relid);
|
|
|
|
}
|
|
|
|
static DEVICE_ATTR_RO(id);
|
|
|
|
|
2013-09-14 02:32:50 +08:00
|
|
|
static ssize_t state_show(struct device *dev, struct device_attribute *dev_attr,
|
|
|
|
char *buf)
|
|
|
|
{
|
|
|
|
struct hv_device *hv_dev = device_to_hv_device(dev);
|
|
|
|
|
|
|
|
if (!hv_dev->channel)
|
|
|
|
return -ENODEV;
|
|
|
|
return sprintf(buf, "%d\n", hv_dev->channel->state);
|
|
|
|
}
|
|
|
|
static DEVICE_ATTR_RO(state);
|
|
|
|
|
2013-09-14 02:32:51 +08:00
|
|
|
static ssize_t monitor_id_show(struct device *dev,
|
|
|
|
struct device_attribute *dev_attr, char *buf)
|
|
|
|
{
|
|
|
|
struct hv_device *hv_dev = device_to_hv_device(dev);
|
|
|
|
|
|
|
|
if (!hv_dev->channel)
|
|
|
|
return -ENODEV;
|
|
|
|
return sprintf(buf, "%d\n", hv_dev->channel->offermsg.monitorid);
|
|
|
|
}
|
|
|
|
static DEVICE_ATTR_RO(monitor_id);
|
|
|
|
|
2013-09-14 02:32:53 +08:00
|
|
|
static ssize_t class_id_show(struct device *dev,
|
|
|
|
struct device_attribute *dev_attr, char *buf)
|
|
|
|
{
|
|
|
|
struct hv_device *hv_dev = device_to_hv_device(dev);
|
|
|
|
|
|
|
|
if (!hv_dev->channel)
|
|
|
|
return -ENODEV;
|
|
|
|
return sprintf(buf, "{%pUl}\n",
|
|
|
|
hv_dev->channel->offermsg.offer.if_type.b);
|
|
|
|
}
|
|
|
|
static DEVICE_ATTR_RO(class_id);
|
|
|
|
|
2013-09-14 02:32:54 +08:00
|
|
|
static ssize_t device_id_show(struct device *dev,
|
|
|
|
struct device_attribute *dev_attr, char *buf)
|
|
|
|
{
|
|
|
|
struct hv_device *hv_dev = device_to_hv_device(dev);
|
|
|
|
|
|
|
|
if (!hv_dev->channel)
|
|
|
|
return -ENODEV;
|
|
|
|
return sprintf(buf, "{%pUl}\n",
|
|
|
|
hv_dev->channel->offermsg.offer.if_instance.b);
|
|
|
|
}
|
|
|
|
static DEVICE_ATTR_RO(device_id);
|
|
|
|
|
2013-09-14 02:32:52 +08:00
|
|
|
static ssize_t modalias_show(struct device *dev,
|
|
|
|
struct device_attribute *dev_attr, char *buf)
|
|
|
|
{
|
|
|
|
struct hv_device *hv_dev = device_to_hv_device(dev);
|
|
|
|
char alias_name[VMBUS_ALIAS_LEN + 1];
|
|
|
|
|
|
|
|
print_alias_name(hv_dev, alias_name);
|
|
|
|
return sprintf(buf, "vmbus:%s\n", alias_name);
|
|
|
|
}
|
|
|
|
static DEVICE_ATTR_RO(modalias);
|
|
|
|
|
2013-09-14 02:32:56 +08:00
|
|
|
static ssize_t server_monitor_pending_show(struct device *dev,
|
|
|
|
struct device_attribute *dev_attr,
|
|
|
|
char *buf)
|
|
|
|
{
|
|
|
|
struct hv_device *hv_dev = device_to_hv_device(dev);
|
|
|
|
|
|
|
|
if (!hv_dev->channel)
|
|
|
|
return -ENODEV;
|
|
|
|
return sprintf(buf, "%d\n",
|
|
|
|
channel_pending(hv_dev->channel,
|
|
|
|
vmbus_connection.monitor_pages[1]));
|
|
|
|
}
|
|
|
|
static DEVICE_ATTR_RO(server_monitor_pending);
|
|
|
|
|
|
|
|
static ssize_t client_monitor_pending_show(struct device *dev,
|
|
|
|
struct device_attribute *dev_attr,
|
|
|
|
char *buf)
|
|
|
|
{
|
|
|
|
struct hv_device *hv_dev = device_to_hv_device(dev);
|
|
|
|
|
|
|
|
if (!hv_dev->channel)
|
|
|
|
return -ENODEV;
|
|
|
|
return sprintf(buf, "%d\n",
|
|
|
|
channel_pending(hv_dev->channel,
|
|
|
|
vmbus_connection.monitor_pages[1]));
|
|
|
|
}
|
|
|
|
static DEVICE_ATTR_RO(client_monitor_pending);
|
2013-09-14 02:32:53 +08:00
|
|
|
|
2013-09-14 02:32:57 +08:00
|
|
|
static ssize_t server_monitor_latency_show(struct device *dev,
|
|
|
|
struct device_attribute *dev_attr,
|
|
|
|
char *buf)
|
|
|
|
{
|
|
|
|
struct hv_device *hv_dev = device_to_hv_device(dev);
|
|
|
|
|
|
|
|
if (!hv_dev->channel)
|
|
|
|
return -ENODEV;
|
|
|
|
return sprintf(buf, "%d\n",
|
|
|
|
channel_latency(hv_dev->channel,
|
|
|
|
vmbus_connection.monitor_pages[0]));
|
|
|
|
}
|
|
|
|
static DEVICE_ATTR_RO(server_monitor_latency);
|
|
|
|
|
|
|
|
static ssize_t client_monitor_latency_show(struct device *dev,
|
|
|
|
struct device_attribute *dev_attr,
|
|
|
|
char *buf)
|
|
|
|
{
|
|
|
|
struct hv_device *hv_dev = device_to_hv_device(dev);
|
|
|
|
|
|
|
|
if (!hv_dev->channel)
|
|
|
|
return -ENODEV;
|
|
|
|
return sprintf(buf, "%d\n",
|
|
|
|
channel_latency(hv_dev->channel,
|
|
|
|
vmbus_connection.monitor_pages[1]));
|
|
|
|
}
|
|
|
|
static DEVICE_ATTR_RO(client_monitor_latency);
|
|
|
|
|
2013-09-14 02:32:58 +08:00
|
|
|
static ssize_t server_monitor_conn_id_show(struct device *dev,
|
|
|
|
struct device_attribute *dev_attr,
|
|
|
|
char *buf)
|
|
|
|
{
|
|
|
|
struct hv_device *hv_dev = device_to_hv_device(dev);
|
|
|
|
|
|
|
|
if (!hv_dev->channel)
|
|
|
|
return -ENODEV;
|
|
|
|
return sprintf(buf, "%d\n",
|
|
|
|
channel_conn_id(hv_dev->channel,
|
|
|
|
vmbus_connection.monitor_pages[0]));
|
|
|
|
}
|
|
|
|
static DEVICE_ATTR_RO(server_monitor_conn_id);
|
|
|
|
|
|
|
|
static ssize_t client_monitor_conn_id_show(struct device *dev,
|
|
|
|
struct device_attribute *dev_attr,
|
|
|
|
char *buf)
|
|
|
|
{
|
|
|
|
struct hv_device *hv_dev = device_to_hv_device(dev);
|
|
|
|
|
|
|
|
if (!hv_dev->channel)
|
|
|
|
return -ENODEV;
|
|
|
|
return sprintf(buf, "%d\n",
|
|
|
|
channel_conn_id(hv_dev->channel,
|
|
|
|
vmbus_connection.monitor_pages[1]));
|
|
|
|
}
|
|
|
|
static DEVICE_ATTR_RO(client_monitor_conn_id);
|
|
|
|
|
2013-09-14 02:33:01 +08:00
|
|
|
static ssize_t out_intr_mask_show(struct device *dev,
|
|
|
|
struct device_attribute *dev_attr, char *buf)
|
|
|
|
{
|
|
|
|
struct hv_device *hv_dev = device_to_hv_device(dev);
|
|
|
|
struct hv_ring_buffer_debug_info outbound;
|
|
|
|
|
|
|
|
if (!hv_dev->channel)
|
|
|
|
return -ENODEV;
|
|
|
|
hv_ringbuffer_get_debuginfo(&hv_dev->channel->outbound, &outbound);
|
|
|
|
return sprintf(buf, "%d\n", outbound.current_interrupt_mask);
|
|
|
|
}
|
|
|
|
static DEVICE_ATTR_RO(out_intr_mask);
|
|
|
|
|
|
|
|
static ssize_t out_read_index_show(struct device *dev,
|
|
|
|
struct device_attribute *dev_attr, char *buf)
|
|
|
|
{
|
|
|
|
struct hv_device *hv_dev = device_to_hv_device(dev);
|
|
|
|
struct hv_ring_buffer_debug_info outbound;
|
|
|
|
|
|
|
|
if (!hv_dev->channel)
|
|
|
|
return -ENODEV;
|
|
|
|
hv_ringbuffer_get_debuginfo(&hv_dev->channel->outbound, &outbound);
|
|
|
|
return sprintf(buf, "%d\n", outbound.current_read_index);
|
|
|
|
}
|
|
|
|
static DEVICE_ATTR_RO(out_read_index);
|
|
|
|
|
|
|
|
static ssize_t out_write_index_show(struct device *dev,
|
|
|
|
struct device_attribute *dev_attr,
|
|
|
|
char *buf)
|
|
|
|
{
|
|
|
|
struct hv_device *hv_dev = device_to_hv_device(dev);
|
|
|
|
struct hv_ring_buffer_debug_info outbound;
|
|
|
|
|
|
|
|
if (!hv_dev->channel)
|
|
|
|
return -ENODEV;
|
|
|
|
hv_ringbuffer_get_debuginfo(&hv_dev->channel->outbound, &outbound);
|
|
|
|
return sprintf(buf, "%d\n", outbound.current_write_index);
|
|
|
|
}
|
|
|
|
static DEVICE_ATTR_RO(out_write_index);
|
|
|
|
|
|
|
|
static ssize_t out_read_bytes_avail_show(struct device *dev,
|
|
|
|
struct device_attribute *dev_attr,
|
|
|
|
char *buf)
|
|
|
|
{
|
|
|
|
struct hv_device *hv_dev = device_to_hv_device(dev);
|
|
|
|
struct hv_ring_buffer_debug_info outbound;
|
|
|
|
|
|
|
|
if (!hv_dev->channel)
|
|
|
|
return -ENODEV;
|
|
|
|
hv_ringbuffer_get_debuginfo(&hv_dev->channel->outbound, &outbound);
|
|
|
|
return sprintf(buf, "%d\n", outbound.bytes_avail_toread);
|
|
|
|
}
|
|
|
|
static DEVICE_ATTR_RO(out_read_bytes_avail);
|
|
|
|
|
|
|
|
static ssize_t out_write_bytes_avail_show(struct device *dev,
|
|
|
|
struct device_attribute *dev_attr,
|
|
|
|
char *buf)
|
|
|
|
{
|
|
|
|
struct hv_device *hv_dev = device_to_hv_device(dev);
|
|
|
|
struct hv_ring_buffer_debug_info outbound;
|
|
|
|
|
|
|
|
if (!hv_dev->channel)
|
|
|
|
return -ENODEV;
|
|
|
|
hv_ringbuffer_get_debuginfo(&hv_dev->channel->outbound, &outbound);
|
|
|
|
return sprintf(buf, "%d\n", outbound.bytes_avail_towrite);
|
|
|
|
}
|
|
|
|
static DEVICE_ATTR_RO(out_write_bytes_avail);
|
|
|
|
|
|
|
|
static ssize_t in_intr_mask_show(struct device *dev,
|
|
|
|
struct device_attribute *dev_attr, char *buf)
|
|
|
|
{
|
|
|
|
struct hv_device *hv_dev = device_to_hv_device(dev);
|
|
|
|
struct hv_ring_buffer_debug_info inbound;
|
|
|
|
|
|
|
|
if (!hv_dev->channel)
|
|
|
|
return -ENODEV;
|
|
|
|
hv_ringbuffer_get_debuginfo(&hv_dev->channel->inbound, &inbound);
|
|
|
|
return sprintf(buf, "%d\n", inbound.current_interrupt_mask);
|
|
|
|
}
|
|
|
|
static DEVICE_ATTR_RO(in_intr_mask);
|
|
|
|
|
|
|
|
static ssize_t in_read_index_show(struct device *dev,
|
|
|
|
struct device_attribute *dev_attr, char *buf)
|
|
|
|
{
|
|
|
|
struct hv_device *hv_dev = device_to_hv_device(dev);
|
|
|
|
struct hv_ring_buffer_debug_info inbound;
|
|
|
|
|
|
|
|
if (!hv_dev->channel)
|
|
|
|
return -ENODEV;
|
|
|
|
hv_ringbuffer_get_debuginfo(&hv_dev->channel->inbound, &inbound);
|
|
|
|
return sprintf(buf, "%d\n", inbound.current_read_index);
|
|
|
|
}
|
|
|
|
static DEVICE_ATTR_RO(in_read_index);
|
|
|
|
|
|
|
|
static ssize_t in_write_index_show(struct device *dev,
|
|
|
|
struct device_attribute *dev_attr, char *buf)
|
|
|
|
{
|
|
|
|
struct hv_device *hv_dev = device_to_hv_device(dev);
|
|
|
|
struct hv_ring_buffer_debug_info inbound;
|
|
|
|
|
|
|
|
if (!hv_dev->channel)
|
|
|
|
return -ENODEV;
|
|
|
|
hv_ringbuffer_get_debuginfo(&hv_dev->channel->inbound, &inbound);
|
|
|
|
return sprintf(buf, "%d\n", inbound.current_write_index);
|
|
|
|
}
|
|
|
|
static DEVICE_ATTR_RO(in_write_index);
|
|
|
|
|
|
|
|
static ssize_t in_read_bytes_avail_show(struct device *dev,
|
|
|
|
struct device_attribute *dev_attr,
|
|
|
|
char *buf)
|
|
|
|
{
|
|
|
|
struct hv_device *hv_dev = device_to_hv_device(dev);
|
|
|
|
struct hv_ring_buffer_debug_info inbound;
|
|
|
|
|
|
|
|
if (!hv_dev->channel)
|
|
|
|
return -ENODEV;
|
|
|
|
hv_ringbuffer_get_debuginfo(&hv_dev->channel->inbound, &inbound);
|
|
|
|
return sprintf(buf, "%d\n", inbound.bytes_avail_toread);
|
|
|
|
}
|
|
|
|
static DEVICE_ATTR_RO(in_read_bytes_avail);
|
|
|
|
|
|
|
|
static ssize_t in_write_bytes_avail_show(struct device *dev,
|
|
|
|
struct device_attribute *dev_attr,
|
|
|
|
char *buf)
|
|
|
|
{
|
|
|
|
struct hv_device *hv_dev = device_to_hv_device(dev);
|
|
|
|
struct hv_ring_buffer_debug_info inbound;
|
|
|
|
|
|
|
|
if (!hv_dev->channel)
|
|
|
|
return -ENODEV;
|
|
|
|
hv_ringbuffer_get_debuginfo(&hv_dev->channel->inbound, &inbound);
|
|
|
|
return sprintf(buf, "%d\n", inbound.bytes_avail_towrite);
|
|
|
|
}
|
|
|
|
static DEVICE_ATTR_RO(in_write_bytes_avail);
|
|
|
|
|
|
|
|
/* Set up per device attributes in /sys/bus/vmbus/devices/<bus device> */
|
2013-09-14 02:32:49 +08:00
|
|
|
static struct attribute *vmbus_attrs[] = {
|
|
|
|
&dev_attr_id.attr,
|
2013-09-14 02:32:50 +08:00
|
|
|
&dev_attr_state.attr,
|
2013-09-14 02:32:51 +08:00
|
|
|
&dev_attr_monitor_id.attr,
|
2013-09-14 02:32:53 +08:00
|
|
|
&dev_attr_class_id.attr,
|
2013-09-14 02:32:54 +08:00
|
|
|
&dev_attr_device_id.attr,
|
2013-09-14 02:32:52 +08:00
|
|
|
&dev_attr_modalias.attr,
|
2013-09-14 02:32:56 +08:00
|
|
|
&dev_attr_server_monitor_pending.attr,
|
|
|
|
&dev_attr_client_monitor_pending.attr,
|
2013-09-14 02:32:57 +08:00
|
|
|
&dev_attr_server_monitor_latency.attr,
|
|
|
|
&dev_attr_client_monitor_latency.attr,
|
2013-09-14 02:32:58 +08:00
|
|
|
&dev_attr_server_monitor_conn_id.attr,
|
|
|
|
&dev_attr_client_monitor_conn_id.attr,
|
2013-09-14 02:33:01 +08:00
|
|
|
&dev_attr_out_intr_mask.attr,
|
|
|
|
&dev_attr_out_read_index.attr,
|
|
|
|
&dev_attr_out_write_index.attr,
|
|
|
|
&dev_attr_out_read_bytes_avail.attr,
|
|
|
|
&dev_attr_out_write_bytes_avail.attr,
|
|
|
|
&dev_attr_in_intr_mask.attr,
|
|
|
|
&dev_attr_in_read_index.attr,
|
|
|
|
&dev_attr_in_write_index.attr,
|
|
|
|
&dev_attr_in_read_bytes_avail.attr,
|
|
|
|
&dev_attr_in_write_bytes_avail.attr,
|
2013-09-14 02:32:49 +08:00
|
|
|
NULL,
|
|
|
|
};
|
|
|
|
ATTRIBUTE_GROUPS(vmbus);
|
|
|
|
|
2011-03-16 06:03:37 +08:00
|
|
|
/*
|
|
|
|
* vmbus_uevent - add uevent for our device
|
|
|
|
*
|
|
|
|
* This routine is invoked when a device is added or removed on the vmbus to
|
|
|
|
* generate a uevent to udev in the userspace. The udev will then look at its
|
|
|
|
* rule and the uevent generated here to load the appropriate driver
|
2011-08-26 00:48:38 +08:00
|
|
|
*
|
|
|
|
* The alias string will be of the form vmbus:guid where guid is the string
|
|
|
|
* representation of the device guid (each byte of the guid will be
|
|
|
|
* represented with two hex characters.
|
2011-03-16 06:03:37 +08:00
|
|
|
*/
|
|
|
|
static int vmbus_uevent(struct device *device, struct kobj_uevent_env *env)
|
|
|
|
{
|
|
|
|
struct hv_device *dev = device_to_hv_device(device);
|
2011-09-03 00:25:56 +08:00
|
|
|
int ret;
|
|
|
|
char alias_name[VMBUS_ALIAS_LEN + 1];
|
2011-08-26 00:48:38 +08:00
|
|
|
|
2011-09-03 00:25:56 +08:00
|
|
|
print_alias_name(dev, alias_name);
|
2011-08-26 00:48:38 +08:00
|
|
|
ret = add_uevent_var(env, "MODALIAS=vmbus:%s", alias_name);
|
|
|
|
return ret;
|
2011-03-16 06:03:37 +08:00
|
|
|
}
|
|
|
|
|
2014-06-03 23:38:15 +08:00
|
|
|
static const uuid_le null_guid;
|
2011-08-26 00:48:39 +08:00
|
|
|
|
|
|
|
static inline bool is_null_guid(const __u8 *guid)
|
|
|
|
{
|
|
|
|
if (memcmp(guid, &null_guid, sizeof(uuid_le)))
|
|
|
|
return false;
|
|
|
|
return true;
|
|
|
|
}
|
|
|
|
|
2011-09-14 01:59:37 +08:00
|
|
|
/*
|
|
|
|
* Return a matching hv_vmbus_device_id pointer.
|
|
|
|
* If there is no match, return NULL.
|
|
|
|
*/
|
|
|
|
static const struct hv_vmbus_device_id *hv_vmbus_get_id(
|
|
|
|
const struct hv_vmbus_device_id *id,
|
2014-06-03 23:38:15 +08:00
|
|
|
const __u8 *guid)
|
2011-09-14 01:59:37 +08:00
|
|
|
{
|
|
|
|
for (; !is_null_guid(id->guid); id++)
|
|
|
|
if (!memcmp(&id->guid, guid, sizeof(uuid_le)))
|
|
|
|
return id;
|
|
|
|
|
|
|
|
return NULL;
|
|
|
|
}
|
|
|
|
|
|
|
|
|
2011-03-16 06:03:38 +08:00
|
|
|
|
|
|
|
/*
|
|
|
|
* vmbus_match - Attempt to match the specified device to the specified driver
|
|
|
|
*/
|
|
|
|
static int vmbus_match(struct device *device, struct device_driver *driver)
|
|
|
|
{
|
|
|
|
struct hv_driver *drv = drv_to_hv_drv(driver);
|
2011-06-07 06:50:04 +08:00
|
|
|
struct hv_device *hv_dev = device_to_hv_device(device);
|
2011-03-16 06:03:38 +08:00
|
|
|
|
2011-09-14 01:59:37 +08:00
|
|
|
if (hv_vmbus_get_id(drv->id_table, hv_dev->dev_type.b))
|
|
|
|
return 1;
|
2011-04-27 00:20:24 +08:00
|
|
|
|
2011-08-26 00:48:39 +08:00
|
|
|
return 0;
|
2011-03-16 06:03:38 +08:00
|
|
|
}
|
|
|
|
|
2011-03-16 06:03:39 +08:00
|
|
|
/*
|
|
|
|
* vmbus_probe - Add the new vmbus's child device
|
|
|
|
*/
|
|
|
|
static int vmbus_probe(struct device *child_device)
|
|
|
|
{
|
|
|
|
int ret = 0;
|
|
|
|
struct hv_driver *drv =
|
|
|
|
drv_to_hv_drv(child_device->driver);
|
2011-04-30 04:45:10 +08:00
|
|
|
struct hv_device *dev = device_to_hv_device(child_device);
|
2011-09-14 01:59:38 +08:00
|
|
|
const struct hv_vmbus_device_id *dev_id;
|
2011-03-16 06:03:39 +08:00
|
|
|
|
2011-09-14 01:59:38 +08:00
|
|
|
dev_id = hv_vmbus_get_id(drv->id_table, dev->dev_type.b);
|
2011-04-30 04:45:10 +08:00
|
|
|
if (drv->probe) {
|
2011-09-14 01:59:38 +08:00
|
|
|
ret = drv->probe(dev, dev_id);
|
2011-04-30 04:45:03 +08:00
|
|
|
if (ret != 0)
|
2011-03-30 04:58:47 +08:00
|
|
|
pr_err("probe failed for device %s (%d)\n",
|
|
|
|
dev_name(child_device), ret);
|
2011-03-16 06:03:39 +08:00
|
|
|
|
|
|
|
} else {
|
2011-03-30 04:58:47 +08:00
|
|
|
pr_err("probe not set for driver %s\n",
|
|
|
|
dev_name(child_device));
|
2011-06-07 06:50:07 +08:00
|
|
|
ret = -ENODEV;
|
2011-03-16 06:03:39 +08:00
|
|
|
}
|
|
|
|
return ret;
|
|
|
|
}
|
|
|
|
|
2011-03-16 06:03:40 +08:00
|
|
|
/*
|
|
|
|
* vmbus_remove - Remove a vmbus device
|
|
|
|
*/
|
|
|
|
static int vmbus_remove(struct device *child_device)
|
|
|
|
{
|
2015-03-01 03:18:16 +08:00
|
|
|
struct hv_driver *drv;
|
2011-04-30 04:45:12 +08:00
|
|
|
struct hv_device *dev = device_to_hv_device(child_device);
|
2015-03-01 03:18:17 +08:00
|
|
|
u32 relid = dev->channel->offermsg.child_relid;
|
2011-03-16 06:03:40 +08:00
|
|
|
|
2015-03-01 03:18:16 +08:00
|
|
|
if (child_device->driver) {
|
|
|
|
drv = drv_to_hv_drv(child_device->driver);
|
|
|
|
if (drv->remove)
|
|
|
|
drv->remove(dev);
|
2015-03-01 03:18:17 +08:00
|
|
|
else {
|
|
|
|
hv_process_channel_removal(dev->channel, relid);
|
2015-03-01 03:18:16 +08:00
|
|
|
pr_err("remove not set for driver %s\n",
|
|
|
|
dev_name(child_device));
|
2015-03-01 03:18:17 +08:00
|
|
|
}
|
|
|
|
} else {
|
|
|
|
/*
|
|
|
|
* We don't have a driver for this device; deal with the
|
|
|
|
* rescind message by removing the channel.
|
|
|
|
*/
|
|
|
|
hv_process_channel_removal(dev->channel, relid);
|
2015-03-01 03:18:16 +08:00
|
|
|
}
|
2011-03-16 06:03:40 +08:00
|
|
|
|
|
|
|
return 0;
|
|
|
|
}
|
|
|
|
|
2011-03-16 06:03:41 +08:00
|
|
|
|
|
|
|
/*
|
|
|
|
* vmbus_shutdown - Shutdown a vmbus device
|
|
|
|
*/
|
|
|
|
static void vmbus_shutdown(struct device *child_device)
|
|
|
|
{
|
|
|
|
struct hv_driver *drv;
|
2011-04-30 04:45:14 +08:00
|
|
|
struct hv_device *dev = device_to_hv_device(child_device);
|
2011-03-16 06:03:41 +08:00
|
|
|
|
|
|
|
|
|
|
|
/* The device may not be attached yet */
|
|
|
|
if (!child_device->driver)
|
|
|
|
return;
|
|
|
|
|
|
|
|
drv = drv_to_hv_drv(child_device->driver);
|
|
|
|
|
2011-04-30 04:45:14 +08:00
|
|
|
if (drv->shutdown)
|
|
|
|
drv->shutdown(dev);
|
2011-03-16 06:03:41 +08:00
|
|
|
|
|
|
|
return;
|
|
|
|
}
|
|
|
|
|
2011-03-16 06:03:42 +08:00
|
|
|
|
|
|
|
/*
|
|
|
|
* vmbus_device_release - Final callback release of the vmbus child device
|
|
|
|
*/
|
|
|
|
static void vmbus_device_release(struct device *device)
|
|
|
|
{
|
2011-06-07 06:50:04 +08:00
|
|
|
struct hv_device *hv_dev = device_to_hv_device(device);
|
2011-03-16 06:03:42 +08:00
|
|
|
|
2011-06-07 06:50:04 +08:00
|
|
|
kfree(hv_dev);
|
2011-03-16 06:03:42 +08:00
|
|
|
|
|
|
|
}
|
|
|
|
|
2009-07-28 04:47:24 +08:00
|
|
|
/* The one and only one */
|
2011-04-30 04:45:08 +08:00
|
|
|
static struct bus_type hv_bus = {
|
|
|
|
.name = "vmbus",
|
|
|
|
.match = vmbus_match,
|
|
|
|
.shutdown = vmbus_shutdown,
|
|
|
|
.remove = vmbus_remove,
|
|
|
|
.probe = vmbus_probe,
|
|
|
|
.uevent = vmbus_uevent,
|
2013-09-14 02:32:49 +08:00
|
|
|
.dev_groups = vmbus_groups,
|
2009-07-14 07:02:34 +08:00
|
|
|
};
|
|
|
|
|
2010-12-16 02:48:08 +08:00
|
|
|
struct onmessage_work_context {
|
|
|
|
struct work_struct work;
|
|
|
|
struct hv_message msg;
|
|
|
|
};
|
|
|
|
|
|
|
|
static void vmbus_onmessage_work(struct work_struct *work)
|
|
|
|
{
|
|
|
|
struct onmessage_work_context *ctx;
|
|
|
|
|
2015-02-28 03:25:54 +08:00
|
|
|
/* Do not process messages if we're in DISCONNECTED state */
|
|
|
|
if (vmbus_connection.conn_state == DISCONNECTED)
|
|
|
|
return;
|
|
|
|
|
2010-12-16 02:48:08 +08:00
|
|
|
ctx = container_of(work, struct onmessage_work_context,
|
|
|
|
work);
|
|
|
|
vmbus_onmessage(&ctx->msg);
|
|
|
|
kfree(ctx);
|
|
|
|
}
|
|
|
|
|
2015-01-26 01:17:54 +08:00
|
|
|
static void hv_process_timer_expiration(struct hv_message *msg, int cpu)
|
2015-01-10 15:54:32 +08:00
|
|
|
{
|
|
|
|
struct clock_event_device *dev = hv_context.clk_evt[cpu];
|
|
|
|
|
|
|
|
if (dev->event_handler)
|
|
|
|
dev->event_handler(dev);
|
|
|
|
|
|
|
|
msg->header.message_type = HVMSG_NONE;
|
|
|
|
|
|
|
|
/*
|
|
|
|
* Make sure the write to MessageType (ie set to
|
|
|
|
* HVMSG_NONE) happens before we read the
|
|
|
|
* MessagePending and EOMing. Otherwise, the EOMing
|
|
|
|
* will not deliver any more messages since there is
|
|
|
|
* no empty slot
|
|
|
|
*/
|
|
|
|
mb();
|
|
|
|
|
|
|
|
if (msg->header.message_flags.msg_pending) {
|
|
|
|
/*
|
|
|
|
* This will cause message queue rescan to
|
|
|
|
* possibly deliver another msg from the
|
|
|
|
* hypervisor
|
|
|
|
*/
|
|
|
|
wrmsrl(HV_X64_MSR_EOM, 0);
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
2011-03-11 06:04:53 +08:00
|
|
|
static void vmbus_on_msg_dpc(unsigned long data)
|
2010-12-03 03:59:22 +08:00
|
|
|
{
|
|
|
|
int cpu = smp_processor_id();
|
|
|
|
void *page_addr = hv_context.synic_message_page[cpu];
|
|
|
|
struct hv_message *msg = (struct hv_message *)page_addr +
|
|
|
|
VMBUS_MESSAGE_SINT;
|
2010-12-16 02:48:08 +08:00
|
|
|
struct onmessage_work_context *ctx;
|
2010-12-03 03:59:22 +08:00
|
|
|
|
|
|
|
while (1) {
|
|
|
|
if (msg->header.message_type == HVMSG_NONE) {
|
|
|
|
/* no msg */
|
|
|
|
break;
|
|
|
|
} else {
|
2010-12-16 02:48:08 +08:00
|
|
|
ctx = kmalloc(sizeof(*ctx), GFP_ATOMIC);
|
|
|
|
if (ctx == NULL)
|
2010-12-03 03:59:22 +08:00
|
|
|
continue;
|
2010-12-16 02:48:08 +08:00
|
|
|
INIT_WORK(&ctx->work, vmbus_onmessage_work);
|
|
|
|
memcpy(&ctx->msg, msg, sizeof(*msg));
|
2011-01-27 04:12:14 +08:00
|
|
|
queue_work(vmbus_connection.work_queue, &ctx->work);
|
2010-12-03 03:59:22 +08:00
|
|
|
}
|
|
|
|
|
|
|
|
msg->header.message_type = HVMSG_NONE;
|
|
|
|
|
|
|
|
/*
|
|
|
|
* Make sure the write to MessageType (ie set to
|
|
|
|
* HVMSG_NONE) happens before we read the
|
|
|
|
* MessagePending and EOMing. Otherwise, the EOMing
|
|
|
|
* will not deliver any more messages since there is
|
|
|
|
* no empty slot
|
|
|
|
*/
|
2013-06-18 13:04:23 +08:00
|
|
|
mb();
|
2010-12-03 03:59:22 +08:00
|
|
|
|
|
|
|
if (msg->header.message_flags.msg_pending) {
|
|
|
|
/*
|
|
|
|
* This will cause message queue rescan to
|
|
|
|
* possibly deliver another msg from the
|
|
|
|
* hypervisor
|
|
|
|
*/
|
|
|
|
wrmsrl(HV_X64_MSR_EOM, 0);
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
2014-03-05 20:42:14 +08:00
|
|
|
static void vmbus_isr(void)
|
2010-12-03 03:59:22 +08:00
|
|
|
{
|
|
|
|
int cpu = smp_processor_id();
|
|
|
|
void *page_addr;
|
|
|
|
struct hv_message *msg;
|
|
|
|
union hv_synic_event_flags *event;
|
2011-08-28 02:31:35 +08:00
|
|
|
bool handled = false;
|
2010-12-03 03:59:22 +08:00
|
|
|
|
2012-12-01 22:46:55 +08:00
|
|
|
page_addr = hv_context.synic_event_page[cpu];
|
|
|
|
if (page_addr == NULL)
|
2014-03-05 20:42:14 +08:00
|
|
|
return;
|
2012-12-01 22:46:55 +08:00
|
|
|
|
|
|
|
event = (union hv_synic_event_flags *)page_addr +
|
|
|
|
VMBUS_MESSAGE_SINT;
|
2011-09-01 05:35:56 +08:00
|
|
|
/*
|
|
|
|
* Check for events before checking for messages. This is the order
|
|
|
|
* in which events and messages are checked in Windows guests on
|
|
|
|
* Hyper-V, and the Windows team suggested we do the same.
|
|
|
|
*/
|
2010-12-03 03:59:22 +08:00
|
|
|
|
2012-12-01 22:46:49 +08:00
|
|
|
if ((vmbus_proto_version == VERSION_WS2008) ||
|
|
|
|
(vmbus_proto_version == VERSION_WIN7)) {
|
2010-12-03 03:59:22 +08:00
|
|
|
|
2012-12-01 22:46:49 +08:00
|
|
|
/* Since we are a child, we only need to check bit 0 */
|
|
|
|
if (sync_test_and_clear_bit(0,
|
|
|
|
(unsigned long *) &event->flags32[0])) {
|
|
|
|
handled = true;
|
|
|
|
}
|
|
|
|
} else {
|
|
|
|
/*
|
|
|
|
* Our host is win8 or above. The signaling mechanism
|
|
|
|
* has changed and we can directly look at the event page.
|
|
|
|
* If bit n is set then we have an interrup on the channel
|
|
|
|
* whose id is n.
|
|
|
|
*/
|
2011-08-28 02:31:35 +08:00
|
|
|
handled = true;
|
|
|
|
}
|
2011-03-16 06:03:43 +08:00
|
|
|
|
2012-12-01 22:46:49 +08:00
|
|
|
if (handled)
|
2012-12-01 22:46:53 +08:00
|
|
|
tasklet_schedule(hv_context.event_dpc[cpu]);
|
2012-12-01 22:46:49 +08:00
|
|
|
|
|
|
|
|
2011-09-01 05:35:56 +08:00
|
|
|
page_addr = hv_context.synic_message_page[cpu];
|
|
|
|
msg = (struct hv_message *)page_addr + VMBUS_MESSAGE_SINT;
|
|
|
|
|
|
|
|
/* Check if there are actual msgs to be processed */
|
2015-01-10 15:54:32 +08:00
|
|
|
if (msg->header.message_type != HVMSG_NONE) {
|
|
|
|
if (msg->header.message_type == HVMSG_TIMER_EXPIRED)
|
|
|
|
hv_process_timer_expiration(msg, cpu);
|
|
|
|
else
|
|
|
|
tasklet_schedule(&msg_dpc);
|
|
|
|
}
|
2011-03-16 06:03:43 +08:00
|
|
|
}
|
|
|
|
|
2015-02-28 03:25:51 +08:00
|
|
|
#ifdef CONFIG_HOTPLUG_CPU
|
|
|
|
static int hyperv_cpu_disable(void)
|
|
|
|
{
|
|
|
|
return -ENOSYS;
|
|
|
|
}
|
|
|
|
|
|
|
|
static void hv_cpu_hotplug_quirk(bool vmbus_loaded)
|
|
|
|
{
|
|
|
|
static void *previous_cpu_disable;
|
|
|
|
|
|
|
|
/*
|
|
|
|
* Offlining a CPU when running on newer hypervisors (WS2012R2, Win8,
|
|
|
|
* ...) is not supported at this moment as channel interrupts are
|
|
|
|
* distributed across all of them.
|
|
|
|
*/
|
|
|
|
|
|
|
|
if ((vmbus_proto_version == VERSION_WS2008) ||
|
|
|
|
(vmbus_proto_version == VERSION_WIN7))
|
|
|
|
return;
|
|
|
|
|
|
|
|
if (vmbus_loaded) {
|
|
|
|
previous_cpu_disable = smp_ops.cpu_disable;
|
|
|
|
smp_ops.cpu_disable = hyperv_cpu_disable;
|
|
|
|
pr_notice("CPU offlining is not supported by hypervisor\n");
|
|
|
|
} else if (previous_cpu_disable)
|
|
|
|
smp_ops.cpu_disable = previous_cpu_disable;
|
|
|
|
}
|
|
|
|
#else
|
|
|
|
static void hv_cpu_hotplug_quirk(bool vmbus_loaded)
|
|
|
|
{
|
|
|
|
}
|
|
|
|
#endif
|
|
|
|
|
2010-03-05 06:11:00 +08:00
|
|
|
/*
|
2009-09-02 22:11:14 +08:00
|
|
|
* vmbus_bus_init -Main vmbus driver initialization routine.
|
|
|
|
*
|
|
|
|
* Here, we
|
2010-03-12 06:51:23 +08:00
|
|
|
* - initialize the vmbus driver context
|
|
|
|
* - invoke the vmbus hv main init routine
|
|
|
|
* - get the irq resource
|
|
|
|
* - retrieve the channel offers
|
2009-09-02 22:11:14 +08:00
|
|
|
*/
|
2011-06-07 06:49:37 +08:00
|
|
|
static int vmbus_bus_init(int irq)
|
2009-07-14 07:02:34 +08:00
|
|
|
{
|
2009-09-02 22:11:14 +08:00
|
|
|
int ret;
|
2009-07-14 07:02:34 +08:00
|
|
|
|
2010-12-03 04:08:08 +08:00
|
|
|
/* Hypervisor initialization...setup hypercall page..etc */
|
|
|
|
ret = hv_init();
|
2009-09-02 22:11:14 +08:00
|
|
|
if (ret != 0) {
|
2011-03-30 04:58:47 +08:00
|
|
|
pr_err("Unable to initialize the hypervisor - 0x%x\n", ret);
|
2011-06-07 06:50:08 +08:00
|
|
|
return ret;
|
2009-07-14 07:02:34 +08:00
|
|
|
}
|
|
|
|
|
2011-04-30 04:45:06 +08:00
|
|
|
tasklet_init(&msg_dpc, vmbus_on_msg_dpc, 0);
|
2009-07-14 07:02:34 +08:00
|
|
|
|
2011-04-30 04:45:08 +08:00
|
|
|
ret = bus_register(&hv_bus);
|
2011-06-07 06:50:08 +08:00
|
|
|
if (ret)
|
2011-09-01 05:35:55 +08:00
|
|
|
goto err_cleanup;
|
2009-07-14 07:02:34 +08:00
|
|
|
|
2014-03-05 20:42:14 +08:00
|
|
|
hv_setup_vmbus_irq(vmbus_isr);
|
2009-07-14 07:02:34 +08:00
|
|
|
|
2013-06-19 11:28:10 +08:00
|
|
|
ret = hv_synic_alloc();
|
|
|
|
if (ret)
|
|
|
|
goto err_alloc;
|
2011-03-16 06:03:33 +08:00
|
|
|
/*
|
2013-02-18 03:30:44 +08:00
|
|
|
* Initialize the per-cpu interrupt state and
|
2011-03-16 06:03:33 +08:00
|
|
|
* connect to the host.
|
|
|
|
*/
|
2013-02-18 03:30:44 +08:00
|
|
|
on_each_cpu(hv_synic_init, NULL, 1);
|
2011-03-16 06:03:33 +08:00
|
|
|
ret = vmbus_connect();
|
2011-09-01 05:35:55 +08:00
|
|
|
if (ret)
|
2013-06-19 11:28:10 +08:00
|
|
|
goto err_alloc;
|
2011-03-16 06:03:33 +08:00
|
|
|
|
2015-02-28 03:25:51 +08:00
|
|
|
hv_cpu_hotplug_quirk(true);
|
2010-12-03 00:50:58 +08:00
|
|
|
vmbus_request_offers();
|
2010-05-29 07:22:44 +08:00
|
|
|
|
2011-06-07 06:50:08 +08:00
|
|
|
return 0;
|
2011-09-01 05:35:55 +08:00
|
|
|
|
2013-06-19 11:28:10 +08:00
|
|
|
err_alloc:
|
|
|
|
hv_synic_free();
|
2014-03-05 20:42:14 +08:00
|
|
|
hv_remove_vmbus_irq();
|
2011-09-01 05:35:55 +08:00
|
|
|
|
|
|
|
bus_unregister(&hv_bus);
|
|
|
|
|
|
|
|
err_cleanup:
|
|
|
|
hv_cleanup();
|
|
|
|
|
|
|
|
return ret;
|
2009-07-14 07:02:34 +08:00
|
|
|
}
|
|
|
|
|
2009-09-02 22:11:14 +08:00
|
|
|
/**
|
2011-08-26 06:07:32 +08:00
|
|
|
* __vmbus_child_driver_register - Register a vmbus's driver
|
|
|
|
* @drv: Pointer to driver structure you want to register
|
|
|
|
* @owner: owner module of the drv
|
|
|
|
* @mod_name: module name string
|
2010-03-05 06:11:00 +08:00
|
|
|
*
|
|
|
|
* Registers the given driver with Linux through the 'driver_register()' call
|
2011-08-26 06:07:32 +08:00
|
|
|
* and sets up the hyper-v vmbus handling for this driver.
|
2010-03-05 06:11:00 +08:00
|
|
|
* It will return the state of the 'driver_register()' call.
|
|
|
|
*
|
2009-09-02 22:11:14 +08:00
|
|
|
*/
|
2011-08-26 06:07:32 +08:00
|
|
|
int __vmbus_driver_register(struct hv_driver *hv_driver, struct module *owner, const char *mod_name)
|
2009-07-14 07:02:34 +08:00
|
|
|
{
|
2009-07-28 04:47:36 +08:00
|
|
|
int ret;
|
2009-07-14 07:02:34 +08:00
|
|
|
|
2011-08-26 06:07:32 +08:00
|
|
|
pr_info("registering driver %s\n", hv_driver->name);
|
2009-07-14 07:02:34 +08:00
|
|
|
|
2011-12-02 01:59:34 +08:00
|
|
|
ret = vmbus_exists();
|
|
|
|
if (ret < 0)
|
|
|
|
return ret;
|
|
|
|
|
2011-08-26 06:07:32 +08:00
|
|
|
hv_driver->driver.name = hv_driver->name;
|
|
|
|
hv_driver->driver.owner = owner;
|
|
|
|
hv_driver->driver.mod_name = mod_name;
|
|
|
|
hv_driver->driver.bus = &hv_bus;
|
2009-07-14 07:02:34 +08:00
|
|
|
|
2011-08-26 06:07:32 +08:00
|
|
|
ret = driver_register(&hv_driver->driver);
|
2009-07-14 07:02:34 +08:00
|
|
|
|
2009-07-28 04:47:36 +08:00
|
|
|
return ret;
|
2009-07-14 07:02:34 +08:00
|
|
|
}
|
2011-08-26 06:07:32 +08:00
|
|
|
EXPORT_SYMBOL_GPL(__vmbus_driver_register);
|
2009-07-14 07:02:34 +08:00
|
|
|
|
2009-09-02 22:11:14 +08:00
|
|
|
/**
|
2011-08-26 06:07:32 +08:00
|
|
|
* vmbus_driver_unregister() - Unregister a vmbus's driver
|
|
|
|
* @drv: Pointer to driver structure you want to un-register
|
2010-03-05 06:11:00 +08:00
|
|
|
*
|
2011-08-26 06:07:32 +08:00
|
|
|
* Un-register the given driver that was previous registered with a call to
|
|
|
|
* vmbus_driver_register()
|
2009-09-02 22:11:14 +08:00
|
|
|
*/
|
2011-08-26 06:07:32 +08:00
|
|
|
void vmbus_driver_unregister(struct hv_driver *hv_driver)
|
2009-07-14 07:02:34 +08:00
|
|
|
{
|
2011-08-26 06:07:32 +08:00
|
|
|
pr_info("unregistering driver %s\n", hv_driver->name);
|
2009-07-14 07:02:34 +08:00
|
|
|
|
2011-12-02 01:59:34 +08:00
|
|
|
if (!vmbus_exists())
|
2011-12-28 05:49:37 +08:00
|
|
|
driver_unregister(&hv_driver->driver);
|
2009-07-14 07:02:34 +08:00
|
|
|
}
|
2011-08-26 06:07:32 +08:00
|
|
|
EXPORT_SYMBOL_GPL(vmbus_driver_unregister);
|
2009-07-14 07:02:34 +08:00
|
|
|
|
2010-03-05 06:11:00 +08:00
|
|
|
/*
|
2011-09-08 22:24:12 +08:00
|
|
|
* vmbus_device_create - Creates and registers a new child device
|
2010-03-05 06:11:00 +08:00
|
|
|
* on the vmbus.
|
2009-09-02 22:11:14 +08:00
|
|
|
*/
|
2014-06-03 23:38:15 +08:00
|
|
|
struct hv_device *vmbus_device_create(const uuid_le *type,
|
|
|
|
const uuid_le *instance,
|
|
|
|
struct vmbus_channel *channel)
|
2009-07-14 07:02:34 +08:00
|
|
|
{
|
2009-07-28 23:32:53 +08:00
|
|
|
struct hv_device *child_device_obj;
|
2009-07-14 07:02:34 +08:00
|
|
|
|
2011-03-08 05:35:48 +08:00
|
|
|
child_device_obj = kzalloc(sizeof(struct hv_device), GFP_KERNEL);
|
|
|
|
if (!child_device_obj) {
|
2011-03-30 04:58:47 +08:00
|
|
|
pr_err("Unable to allocate device object for child device\n");
|
2009-07-14 07:02:34 +08:00
|
|
|
return NULL;
|
|
|
|
}
|
|
|
|
|
2010-10-22 00:05:27 +08:00
|
|
|
child_device_obj->channel = channel;
|
2011-08-26 00:48:28 +08:00
|
|
|
memcpy(&child_device_obj->dev_type, type, sizeof(uuid_le));
|
2011-01-27 04:12:11 +08:00
|
|
|
memcpy(&child_device_obj->dev_instance, instance,
|
2011-08-26 00:48:28 +08:00
|
|
|
sizeof(uuid_le));
|
2009-07-14 07:02:34 +08:00
|
|
|
|
|
|
|
|
|
|
|
return child_device_obj;
|
|
|
|
}
|
|
|
|
|
2010-03-05 06:11:00 +08:00
|
|
|
/*
|
2011-09-08 22:24:13 +08:00
|
|
|
* vmbus_device_register - Register the child device
|
2009-09-02 22:11:14 +08:00
|
|
|
*/
|
2011-09-08 22:24:13 +08:00
|
|
|
int vmbus_device_register(struct hv_device *child_device_obj)
|
2009-07-14 07:02:34 +08:00
|
|
|
{
|
2009-09-02 22:11:14 +08:00
|
|
|
int ret = 0;
|
2011-03-08 05:35:48 +08:00
|
|
|
|
2015-02-28 03:25:52 +08:00
|
|
|
dev_set_name(&child_device_obj->device, "vmbus_%d",
|
|
|
|
child_device_obj->channel->id);
|
2009-07-14 07:02:34 +08:00
|
|
|
|
2011-08-28 02:31:39 +08:00
|
|
|
child_device_obj->device.bus = &hv_bus;
|
2011-06-07 06:49:39 +08:00
|
|
|
child_device_obj->device.parent = &hv_acpi_dev->dev;
|
2011-03-08 05:35:48 +08:00
|
|
|
child_device_obj->device.release = vmbus_device_release;
|
2009-07-14 07:02:34 +08:00
|
|
|
|
2009-09-02 22:11:14 +08:00
|
|
|
/*
|
|
|
|
* Register with the LDM. This will kick off the driver/device
|
|
|
|
* binding...which will eventually call vmbus_match() and vmbus_probe()
|
|
|
|
*/
|
2011-03-08 05:35:48 +08:00
|
|
|
ret = device_register(&child_device_obj->device);
|
2009-07-14 07:02:34 +08:00
|
|
|
|
|
|
|
if (ret)
|
2011-03-30 04:58:47 +08:00
|
|
|
pr_err("Unable to register child device\n");
|
2009-07-14 07:02:34 +08:00
|
|
|
else
|
2013-06-15 07:13:35 +08:00
|
|
|
pr_debug("child device %s registered\n",
|
2011-03-30 04:58:47 +08:00
|
|
|
dev_name(&child_device_obj->device));
|
2009-07-14 07:02:34 +08:00
|
|
|
|
|
|
|
return ret;
|
|
|
|
}
|
|
|
|
|
2010-03-05 06:11:00 +08:00
|
|
|
/*
|
2011-09-08 22:24:14 +08:00
|
|
|
* vmbus_device_unregister - Remove the specified child device
|
2010-03-05 06:11:00 +08:00
|
|
|
* from the vmbus.
|
2009-09-02 22:11:14 +08:00
|
|
|
*/
|
2011-09-08 22:24:14 +08:00
|
|
|
void vmbus_device_unregister(struct hv_device *device_obj)
|
2009-07-14 07:02:34 +08:00
|
|
|
{
|
2013-06-15 07:13:35 +08:00
|
|
|
pr_debug("child device %s unregistered\n",
|
|
|
|
dev_name(&device_obj->device));
|
|
|
|
|
2009-09-02 22:11:14 +08:00
|
|
|
/*
|
|
|
|
* Kick off the process of unregistering the device.
|
|
|
|
* This will call vmbus_remove() and eventually vmbus_device_release()
|
|
|
|
*/
|
2011-03-08 05:35:48 +08:00
|
|
|
device_unregister(&device_obj->device);
|
2009-07-14 07:02:34 +08:00
|
|
|
}
|
|
|
|
|
|
|
|
|
2011-04-30 04:45:15 +08:00
|
|
|
/*
|
2014-01-30 10:14:39 +08:00
|
|
|
* VMBUS is an acpi enumerated device. Get the the information we
|
|
|
|
* need from DSDT.
|
2011-04-30 04:45:15 +08:00
|
|
|
*/
|
|
|
|
|
2014-01-30 10:14:39 +08:00
|
|
|
static acpi_status vmbus_walk_resources(struct acpi_resource *res, void *ctx)
|
2011-04-30 04:45:15 +08:00
|
|
|
{
|
2014-01-30 10:14:39 +08:00
|
|
|
switch (res->type) {
|
|
|
|
case ACPI_RESOURCE_TYPE_IRQ:
|
|
|
|
irq = res->data.irq.interrupts[0];
|
2014-02-24 21:17:08 +08:00
|
|
|
break;
|
2011-04-30 04:45:15 +08:00
|
|
|
|
2014-01-30 10:14:39 +08:00
|
|
|
case ACPI_RESOURCE_TYPE_ADDRESS64:
|
2015-01-26 16:58:56 +08:00
|
|
|
hyperv_mmio.start = res->data.address64.address.minimum;
|
|
|
|
hyperv_mmio.end = res->data.address64.address.maximum;
|
2014-02-24 21:17:08 +08:00
|
|
|
break;
|
2011-04-30 04:45:15 +08:00
|
|
|
}
|
|
|
|
|
|
|
|
return AE_OK;
|
|
|
|
}
|
|
|
|
|
|
|
|
static int vmbus_acpi_add(struct acpi_device *device)
|
|
|
|
{
|
|
|
|
acpi_status result;
|
2014-01-30 10:14:39 +08:00
|
|
|
int ret_val = -ENODEV;
|
2011-04-30 04:45:15 +08:00
|
|
|
|
2011-06-07 06:49:39 +08:00
|
|
|
hv_acpi_dev = device;
|
|
|
|
|
2011-08-28 02:31:38 +08:00
|
|
|
result = acpi_walk_resources(device->handle, METHOD_NAME__CRS,
|
2014-01-30 10:14:39 +08:00
|
|
|
vmbus_walk_resources, NULL);
|
2011-04-30 04:45:15 +08:00
|
|
|
|
2014-01-30 10:14:39 +08:00
|
|
|
if (ACPI_FAILURE(result))
|
|
|
|
goto acpi_walk_err;
|
|
|
|
/*
|
|
|
|
* The parent of the vmbus acpi device (Gen2 firmware) is the VMOD that
|
|
|
|
* has the mmio ranges. Get that.
|
|
|
|
*/
|
|
|
|
if (device->parent) {
|
|
|
|
result = acpi_walk_resources(device->parent->handle,
|
|
|
|
METHOD_NAME__CRS,
|
|
|
|
vmbus_walk_resources, NULL);
|
|
|
|
|
|
|
|
if (ACPI_FAILURE(result))
|
|
|
|
goto acpi_walk_err;
|
2014-02-24 21:17:09 +08:00
|
|
|
if (hyperv_mmio.start && hyperv_mmio.end)
|
|
|
|
request_resource(&iomem_resource, &hyperv_mmio);
|
2011-04-30 04:45:15 +08:00
|
|
|
}
|
2014-01-30 10:14:39 +08:00
|
|
|
ret_val = 0;
|
|
|
|
|
|
|
|
acpi_walk_err:
|
2011-04-30 04:45:15 +08:00
|
|
|
complete(&probe_event);
|
2014-01-30 10:14:39 +08:00
|
|
|
return ret_val;
|
2011-04-30 04:45:15 +08:00
|
|
|
}
|
|
|
|
|
|
|
|
static const struct acpi_device_id vmbus_acpi_device_ids[] = {
|
|
|
|
{"VMBUS", 0},
|
2011-06-07 06:49:42 +08:00
|
|
|
{"VMBus", 0},
|
2011-04-30 04:45:15 +08:00
|
|
|
{"", 0},
|
|
|
|
};
|
|
|
|
MODULE_DEVICE_TABLE(acpi, vmbus_acpi_device_ids);
|
|
|
|
|
|
|
|
static struct acpi_driver vmbus_acpi_driver = {
|
|
|
|
.name = "vmbus",
|
|
|
|
.ids = vmbus_acpi_device_ids,
|
|
|
|
.ops = {
|
|
|
|
.add = vmbus_acpi_add,
|
|
|
|
},
|
|
|
|
};
|
|
|
|
|
2011-06-07 06:49:39 +08:00
|
|
|
static int __init hv_acpi_init(void)
|
2011-03-16 06:03:32 +08:00
|
|
|
{
|
2011-07-16 04:38:56 +08:00
|
|
|
int ret, t;
|
2011-04-30 04:45:15 +08:00
|
|
|
|
2012-08-31 13:32:44 +08:00
|
|
|
if (x86_hyper != &x86_hyper_ms_hyperv)
|
2012-08-17 18:52:43 +08:00
|
|
|
return -ENODEV;
|
|
|
|
|
2011-04-30 04:45:15 +08:00
|
|
|
init_completion(&probe_event);
|
|
|
|
|
|
|
|
/*
|
|
|
|
* Get irq resources first.
|
|
|
|
*/
|
2011-06-07 06:49:40 +08:00
|
|
|
ret = acpi_bus_register_driver(&vmbus_acpi_driver);
|
|
|
|
|
2011-04-30 04:45:15 +08:00
|
|
|
if (ret)
|
|
|
|
return ret;
|
|
|
|
|
2011-07-16 04:38:56 +08:00
|
|
|
t = wait_for_completion_timeout(&probe_event, 5*HZ);
|
|
|
|
if (t == 0) {
|
|
|
|
ret = -ETIMEDOUT;
|
|
|
|
goto cleanup;
|
|
|
|
}
|
2011-04-30 04:45:15 +08:00
|
|
|
|
|
|
|
if (irq <= 0) {
|
2011-07-16 04:38:56 +08:00
|
|
|
ret = -ENODEV;
|
|
|
|
goto cleanup;
|
2011-04-30 04:45:15 +08:00
|
|
|
}
|
|
|
|
|
2011-06-17 04:16:38 +08:00
|
|
|
ret = vmbus_bus_init(irq);
|
|
|
|
if (ret)
|
2011-07-16 04:38:56 +08:00
|
|
|
goto cleanup;
|
|
|
|
|
|
|
|
return 0;
|
|
|
|
|
|
|
|
cleanup:
|
|
|
|
acpi_bus_unregister_driver(&vmbus_acpi_driver);
|
2011-12-02 01:59:34 +08:00
|
|
|
hv_acpi_dev = NULL;
|
2011-06-17 04:16:38 +08:00
|
|
|
return ret;
|
2011-03-16 06:03:32 +08:00
|
|
|
}
|
|
|
|
|
2011-12-13 01:29:17 +08:00
|
|
|
static void __exit vmbus_exit(void)
|
|
|
|
{
|
2015-02-28 03:25:55 +08:00
|
|
|
int cpu;
|
|
|
|
|
2015-02-28 03:25:54 +08:00
|
|
|
vmbus_connection.conn_state = DISCONNECTED;
|
2015-02-28 03:25:57 +08:00
|
|
|
hv_synic_clockevents_cleanup();
|
2014-03-05 20:42:14 +08:00
|
|
|
hv_remove_vmbus_irq();
|
2011-12-13 01:29:17 +08:00
|
|
|
vmbus_free_channels();
|
|
|
|
bus_unregister(&hv_bus);
|
|
|
|
hv_cleanup();
|
2015-02-28 03:25:55 +08:00
|
|
|
for_each_online_cpu(cpu)
|
|
|
|
smp_call_function_single(cpu, hv_synic_cleanup, NULL, 1);
|
2011-12-13 01:29:17 +08:00
|
|
|
acpi_bus_unregister_driver(&vmbus_acpi_driver);
|
2015-02-28 03:25:51 +08:00
|
|
|
hv_cpu_hotplug_quirk(false);
|
2015-02-28 03:25:54 +08:00
|
|
|
vmbus_disconnect();
|
2011-12-13 01:29:17 +08:00
|
|
|
}
|
|
|
|
|
2011-03-16 06:03:32 +08:00
|
|
|
|
2009-09-02 22:11:14 +08:00
|
|
|
MODULE_LICENSE("GPL");
|
2009-07-14 07:02:34 +08:00
|
|
|
|
2011-10-25 02:28:12 +08:00
|
|
|
subsys_initcall(hv_acpi_init);
|
2011-12-13 01:29:17 +08:00
|
|
|
module_exit(vmbus_exit);
|