2 * Copyright (c) 2009, Microsoft Corporation.
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.
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
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.
18 * Haiyang Zhang <haiyangz@microsoft.com>
19 * Hank Janssen <hjanssen@microsoft.com>
22 #include <linux/kernel.h>
24 #include <linux/slab.h>
27 #include "version_info.h"
28 #include "vmbus_private.h"
30 static const char *gDriverName = "vmbus";
33 * Windows vmbus does not defined this.
34 * We defined this to be consistent with other devices
36 /* {c5295816-f63a-4d5f-8d1a-4daf999ca185} */
37 static const struct hv_guid gVmbusDeviceType = {
39 0x16, 0x58, 0x29, 0xc5, 0x3a, 0xf6, 0x5f, 0x4d,
40 0x8d, 0x1a, 0x4d, 0xaf, 0x99, 0x9c, 0xa1, 0x85
44 /* {ac3760fc-9adf-40aa-9427-a70ed6de95c5} */
45 static const struct hv_guid gVmbusDeviceId = {
47 0xfc, 0x60, 0x37, 0xac, 0xdf, 0x9a, 0xaa, 0x40,
48 0x94, 0x27, 0xa7, 0x0e, 0xd6, 0xde, 0x95, 0xc5
52 static struct hv_driver *gDriver; /* vmbus driver object */
53 static struct hv_device *gDevice; /* vmbus root device */
56 * VmbusGetChannelOffers - Retrieve the channel offers from the parent partition
58 static void VmbusGetChannelOffers(void)
60 vmbus_request_offers();
64 * VmbusChildDeviceAdd - Registers the child device with the vmbus
66 int VmbusChildDeviceAdd(struct hv_device *ChildDevice)
68 struct vmbus_driver *vmbusDriver = (struct vmbus_driver *)gDriver;
70 return vmbusDriver->OnChildDeviceAdd(gDevice, ChildDevice);
74 * VmbusOnDeviceAdd - Callback when the root bus device is added
76 static int VmbusOnDeviceAdd(struct hv_device *dev, void *AdditionalInfo)
78 u32 *irqvector = AdditionalInfo;
83 memcpy(&gDevice->deviceType, &gVmbusDeviceType, sizeof(struct hv_guid));
84 memcpy(&gDevice->deviceInstance, &gVmbusDeviceId,
85 sizeof(struct hv_guid));
87 /* strcpy(dev->name, "vmbus"); */
89 on_each_cpu(hv_synic_init, (void *)irqvector, 1);
91 /* Connect to VMBus in the root partition */
94 /* VmbusSendEvent(device->localPortId+1); */
99 * VmbusOnDeviceRemove - Callback when the root bus device is removed
101 static int VmbusOnDeviceRemove(struct hv_device *dev)
105 vmbus_release_unattached_channels();
107 on_each_cpu(hv_synic_cleanup, NULL, 1);
112 * VmbusOnCleanup - Perform any cleanup when the driver is removed
114 static void VmbusOnCleanup(struct hv_driver *drv)
116 /* struct vmbus_driver *driver = (struct vmbus_driver *)drv; */
122 * VmbusOnMsgDPC - DPC routine to handle messages from the hypervisior
124 static void VmbusOnMsgDPC(struct hv_driver *drv)
126 int cpu = smp_processor_id();
127 void *page_addr = hv_context.synic_message_page[cpu];
128 struct hv_message *msg = (struct hv_message *)page_addr +
130 struct hv_message *copied;
133 if (msg->header.message_type == HVMSG_NONE) {
137 copied = kmemdup(msg, sizeof(*copied), GFP_ATOMIC);
141 osd_schedule_callback(gVmbusConnection.WorkQueue,
146 msg->header.message_type = HVMSG_NONE;
149 * Make sure the write to MessageType (ie set to
150 * HVMSG_NONE) happens before we read the
151 * MessagePending and EOMing. Otherwise, the EOMing
152 * will not deliver any more messages since there is
157 if (msg->header.message_flags.msg_pending) {
159 * This will cause message queue rescan to
160 * possibly deliver another msg from the
163 wrmsrl(HV_X64_MSR_EOM, 0);
169 * VmbusOnEventDPC - DPC routine to handle events from the hypervisior
171 static void VmbusOnEventDPC(struct hv_driver *drv)
173 /* TODO: Process any events */
178 * VmbusOnISR - ISR routine
180 static int VmbusOnISR(struct hv_driver *drv)
183 int cpu = smp_processor_id();
185 struct hv_message *msg;
186 union hv_synic_event_flags *event;
188 page_addr = hv_context.synic_message_page[cpu];
189 msg = (struct hv_message *)page_addr + VMBUS_MESSAGE_SINT;
191 /* Check if there are actual msgs to be process */
192 if (msg->header.message_type != HVMSG_NONE) {
193 DPRINT_DBG(VMBUS, "received msg type %d size %d",
194 msg->header.message_type,
195 msg->header.payload_size);
199 /* TODO: Check if there are events to be process */
200 page_addr = hv_context.synic_event_page[cpu];
201 event = (union hv_synic_event_flags *)page_addr + VMBUS_MESSAGE_SINT;
203 /* Since we are a child, we only need to check bit 0 */
204 if (test_and_clear_bit(0, (unsigned long *) &event->flags32[0])) {
205 DPRINT_DBG(VMBUS, "received event %d", event->flags32[0]);
213 * VmbusInitialize - Main entry point
215 int VmbusInitialize(struct hv_driver *drv)
217 struct vmbus_driver *driver = (struct vmbus_driver *)drv;
220 DPRINT_INFO(VMBUS, "+++++++ HV Driver version = %s +++++++",
222 DPRINT_INFO(VMBUS, "+++++++ Vmbus supported version = %d +++++++",
223 VMBUS_REVISION_NUMBER);
224 DPRINT_INFO(VMBUS, "+++++++ Vmbus using SINT %d +++++++",
226 DPRINT_DBG(VMBUS, "sizeof(vmbus_channel_packet_page_buffer)=%zd, "
227 "sizeof(VMBUS_CHANNEL_PACKET_MULITPAGE_BUFFER)=%zd",
228 sizeof(struct vmbus_channel_packet_page_buffer),
229 sizeof(struct vmbus_channel_packet_multipage_buffer));
231 drv->name = gDriverName;
232 memcpy(&drv->deviceType, &gVmbusDeviceType, sizeof(struct hv_guid));
234 /* Setup dispatch table */
235 driver->Base.OnDeviceAdd = VmbusOnDeviceAdd;
236 driver->Base.OnDeviceRemove = VmbusOnDeviceRemove;
237 driver->Base.OnCleanup = VmbusOnCleanup;
238 driver->OnIsr = VmbusOnISR;
239 driver->OnMsgDpc = VmbusOnMsgDPC;
240 driver->OnEventDpc = VmbusOnEventDPC;
241 driver->GetChannelOffers = VmbusGetChannelOffers;
243 /* Hypervisor initialization...setup hypercall page..etc */
246 DPRINT_ERR(VMBUS, "Unable to initialize the hypervisor - 0x%x",