// SPDX-License-Identifier: GPL-2.0-only /* * Copyright (c) 2009, Microsoft Corporation. * * Authors: * Haiyang Zhang <[email protected]> * Hank Janssen <[email protected]> */ #define pr_fmt(fmt) … #include <linux/kernel.h> #include <linux/interrupt.h> #include <linux/sched.h> #include <linux/wait.h> #include <linux/mm.h> #include <linux/slab.h> #include <linux/list.h> #include <linux/module.h> #include <linux/completion.h> #include <linux/delay.h> #include <linux/cpu.h> #include <linux/hyperv.h> #include <asm/mshyperv.h> #include <linux/sched/isolation.h> #include "hyperv_vmbus.h" static void init_vp_index(struct vmbus_channel *channel); const struct vmbus_device vmbus_devs[] = …; EXPORT_SYMBOL_GPL(…); static const struct { … } vmbus_unsupported_devs[] = …; /* * The rescinded channel may be blocked waiting for a response from the host; * take care of that. */ static void vmbus_rescind_cleanup(struct vmbus_channel *channel) { … } static bool is_unsupported_vmbus_devs(const guid_t *guid) { … } static u16 hv_get_dev_type(const struct vmbus_channel *channel) { … } /** * vmbus_prep_negotiate_resp() - Create default response for Negotiate message * @icmsghdrp: Pointer to msg header structure * @buf: Raw buffer channel data * @buflen: Length of the raw buffer channel data. * @fw_version: The framework versions we can support. * @fw_vercnt: The size of @fw_version. * @srv_version: The service versions we can support. * @srv_vercnt: The size of @srv_version. * @nego_fw_version: The selected framework version. * @nego_srv_version: The selected service version. * * Note: Versions are given in decreasing order. * * Set up and fill in default negotiate response message. * Mainly used by Hyper-V drivers. */ bool vmbus_prep_negotiate_resp(struct icmsg_hdr *icmsghdrp, u8 *buf, u32 buflen, const int *fw_version, int fw_vercnt, const int *srv_version, int srv_vercnt, int *nego_fw_version, int *nego_srv_version) { … } EXPORT_SYMBOL_GPL(…); /* * alloc_channel - Allocate and initialize a vmbus channel object */ static struct vmbus_channel *alloc_channel(void) { … } /* * free_channel - Release the resources used by the vmbus channel object */ static void free_channel(struct vmbus_channel *channel) { … } void vmbus_channel_map_relid(struct vmbus_channel *channel) { … } void vmbus_channel_unmap_relid(struct vmbus_channel *channel) { … } static void vmbus_release_relid(u32 relid) { … } void hv_process_channel_removal(struct vmbus_channel *channel) { … } void vmbus_free_channels(void) { … } /* Note: the function can run concurrently for primary/sub channels. */ static void vmbus_add_channel_work(struct work_struct *work) { … } /* * vmbus_process_offer - Process the offer by creating a channel/device * associated with this offer */ static void vmbus_process_offer(struct vmbus_channel *newchannel) { … } /* * Check if CPUs used by other channels of the same device. * It should only be called by init_vp_index(). */ static bool hv_cpuself_used(u32 cpu, struct vmbus_channel *chn) { … } /* * We use this state to statically distribute the channel interrupt load. */ static int next_numa_node_id; /* * We can statically distribute the incoming channel interrupt load * by binding a channel to VCPU. * * For non-performance critical channels we assign the VMBUS_CONNECT_CPU. * Performance critical channels will be distributed evenly among all * the available NUMA nodes. Once the node is assigned, we will assign * the CPU based on a simple round robin scheme. */ static void init_vp_index(struct vmbus_channel *channel) { … } #define UNLOAD_DELAY_UNIT_MS … #define UNLOAD_WAIT_MS … #define UNLOAD_WAIT_LOOPS … #define UNLOAD_MSG_MS … #define UNLOAD_MSG_LOOPS … static void vmbus_wait_for_unload(void) { … } /* * vmbus_unload_response - Handler for the unload response. */ static void vmbus_unload_response(struct vmbus_channel_message_header *hdr) { … } void vmbus_initiate_unload(bool crash) { … } static void check_ready_for_resume_event(void) { … } static void vmbus_setup_channel_state(struct vmbus_channel *channel, struct vmbus_channel_offer_channel *offer) { … } /* * find_primary_channel_by_offer - Get the channel object given the new offer. * This is only used in the resume path of hibernation. */ static struct vmbus_channel * find_primary_channel_by_offer(const struct vmbus_channel_offer_channel *offer) { … } static bool vmbus_is_valid_offer(const struct vmbus_channel_offer_channel *offer) { … } /* * vmbus_onoffer - Handler for channel offers from vmbus in parent partition. * */ static void vmbus_onoffer(struct vmbus_channel_message_header *hdr) { … } static void check_ready_for_suspend_event(void) { … } /* * vmbus_onoffer_rescind - Rescind offer handler. * * We queue a work item to process this offer synchronously */ static void vmbus_onoffer_rescind(struct vmbus_channel_message_header *hdr) { … } void vmbus_hvsock_device_unregister(struct vmbus_channel *channel) { … } EXPORT_SYMBOL_GPL(…); /* * vmbus_onoffers_delivered - * This is invoked when all offers have been delivered. * * Nothing to do here. */ static void vmbus_onoffers_delivered( struct vmbus_channel_message_header *hdr) { … } /* * vmbus_onopen_result - Open result handler. * * This is invoked when we received a response to our channel open request. * Find the matching request, copy the response and signal the requesting * thread. */ static void vmbus_onopen_result(struct vmbus_channel_message_header *hdr) { … } /* * vmbus_ongpadl_created - GPADL created handler. * * This is invoked when we received a response to our gpadl create request. * Find the matching request, copy the response and signal the requesting * thread. */ static void vmbus_ongpadl_created(struct vmbus_channel_message_header *hdr) { … } /* * vmbus_onmodifychannel_response - Modify Channel response handler. * * This is invoked when we received a response to our channel modify request. * Find the matching request, copy the response and signal the requesting thread. */ static void vmbus_onmodifychannel_response(struct vmbus_channel_message_header *hdr) { … } /* * vmbus_ongpadl_torndown - GPADL torndown handler. * * This is invoked when we received a response to our gpadl teardown request. * Find the matching request, copy the response and signal the requesting * thread. */ static void vmbus_ongpadl_torndown( struct vmbus_channel_message_header *hdr) { … } /* * vmbus_onversion_response - Version response handler * * This is invoked when we received a response to our initiate contact request. * Find the matching request, copy the response and signal the requesting * thread. */ static void vmbus_onversion_response( struct vmbus_channel_message_header *hdr) { … } /* Channel message dispatch table */ const struct vmbus_channel_message_table_entry channel_message_table[CHANNELMSG_COUNT] = …; /* * vmbus_onmessage - Handler for channel protocol messages. * * This is invoked in the vmbus worker thread context. */ void vmbus_onmessage(struct vmbus_channel_message_header *hdr) { … } /* * vmbus_request_offers - Send a request to get all our pending offers. */ int vmbus_request_offers(void) { … } void vmbus_set_sc_create_callback(struct vmbus_channel *primary_channel, void (*sc_cr_cb)(struct vmbus_channel *new_sc)) { … } EXPORT_SYMBOL_GPL(…); void vmbus_set_chn_rescind_callback(struct vmbus_channel *channel, void (*chn_rescind_cb)(struct vmbus_channel *)) { … } EXPORT_SYMBOL_GPL(…);
Codebase Browser
linux