Page MenuHomeFreeBSD
Differential D7480 Diff 19272 head/sys/dev/hyperv/netvsc/hv_rndis_filter.c

Changeset View

Standalone View

View Options

head/sys/dev/hyperv/netvsc/hv_rndis_filter.c

Show All 40 Lines
#include <sys/types.h> #include <sys/types.h>
#include <machine/atomic.h> #include <machine/atomic.h>
#include <sys/sema.h> #include <sys/sema.h>
#include <vm/vm.h> #include <vm/vm.h>
#include <vm/vm_param.h> #include <vm/vm_param.h>
#include <vm/pmap.h> #include <vm/pmap.h>
#include <dev/hyperv/include/hyperv.h> #include <dev/hyperv/include/hyperv.h>
#include "hv_net_vsc.h" #include <dev/hyperv/include/vmbus_xact.h>
#include "hv_rndis.h" #include <dev/hyperv/netvsc/hv_net_vsc.h>
#include "hv_rndis_filter.h" #include <dev/hyperv/netvsc/hv_rndis.h>
#include <dev/hyperv/netvsc/hv_rndis_filter.h>
#include <dev/hyperv/netvsc/if_hnreg.h>
struct hv_rf_recvinfo { struct hv_rf_recvinfo {
const ndis_8021q_info *vlan_info; const ndis_8021q_info *vlan_info;
const rndis_tcp_ip_csum_info *csum_info; const rndis_tcp_ip_csum_info *csum_info;
const struct rndis_hash_info *hash_info; const struct rndis_hash_info *hash_info;
const struct rndis_hash_value *hash_value; const struct rndis_hash_value *hash_value;
}; };
▲ Show 20 Lines • Show All 995 Lines • ▼ Show 20 Lines
int int
hv_rf_on_device_add(struct hn_softc *sc, void *additl_info, hv_rf_on_device_add(struct hn_softc *sc, void *additl_info,
int nchan, struct hn_rx_ring *rxr) int nchan, struct hn_rx_ring *rxr)
{ {
struct hn_send_ctx sndc; struct hn_send_ctx sndc;
int ret; int ret;
netvsc_dev *net_dev; netvsc_dev *net_dev;
rndis_device *rndis_dev; rndis_device *rndis_dev;
nvsp_msg *init_pkt;
rndis_offload_params offloads; rndis_offload_params offloads;
struct rndis_recv_scale_cap rsscaps; struct rndis_recv_scale_cap rsscaps;
uint32_t rsscaps_size = sizeof(struct rndis_recv_scale_cap); uint32_t rsscaps_size = sizeof(struct rndis_recv_scale_cap);
netvsc_device_info *dev_info = (netvsc_device_info *)additl_info; netvsc_device_info *dev_info = (netvsc_device_info *)additl_info;
device_t dev = sc->hn_dev; device_t dev = sc->hn_dev;
struct hn_nvs_subch_req *req;
const struct hn_nvs_subch_resp *resp;
size_t resp_len;
struct vmbus_xact *xact;
uint32_t status, nsubch;
rndis_dev = hv_get_rndis_device(); rndis_dev = hv_get_rndis_device();
if (rndis_dev == NULL) { if (rndis_dev == NULL) {
return (ENOMEM); return (ENOMEM);
} }
/* /*
* Let the inner driver handle this first to create the netvsc channel * Let the inner driver handle this first to create the netvsc channel
▲ Show 20 Lines • Show All 71 Lines • ▼ Show 20 Lines if (nchan > rsscaps.num_recv_que)
nchan = rsscaps.num_recv_que; nchan = rsscaps.num_recv_que;
net_dev->num_channel = nchan; net_dev->num_channel = nchan;
if (net_dev->num_channel == 1) { if (net_dev->num_channel == 1) {
device_printf(dev, "net_dev->num_channel == 1 under VRSS\n"); device_printf(dev, "net_dev->num_channel == 1 under VRSS\n");
goto out; goto out;
} }
/* request host to create sub channels */ /*
init_pkt = &net_dev->channel_init_packet; * Ask NVS to allocate sub-channels.
memset(init_pkt, 0, sizeof(nvsp_msg)); */
xact = vmbus_xact_get(sc->hn_xact, sizeof(*req));
if (xact == NULL) {
if_printf(sc->hn_ifp, "no xact for nvs subch req\n");
ret = ENXIO;
goto out;
}
init_pkt->hdr.msg_type = nvsp_msg5_type_subchannel; req = vmbus_xact_req_data(xact);
init_pkt->msgs.vers_5_msgs.subchannel_request.op = req->nvs_type = HN_NVS_TYPE_SUBCH_REQ;
NVSP_SUBCHANNE_ALLOCATE; req->nvs_op = HN_NVS_SUBCH_OP_ALLOC;
init_pkt->msgs.vers_5_msgs.subchannel_request.num_subchannels = req->nvs_nsubch = net_dev->num_channel - 1;
net_dev->num_channel - 1;
hn_send_ctx_init_simple(&sndc, hn_nvs_sent_wakeup, NULL); hn_send_ctx_init_simple(&sndc, hn_nvs_sent_xact, xact);
vmbus_xact_activate(xact);
ret = vmbus_chan_send(sc->hn_prichan, ret = vmbus_chan_send(sc->hn_prichan,
VMBUS_CHANPKT_TYPE_INBAND, VMBUS_CHANPKT_FLAG_RC, VMBUS_CHANPKT_TYPE_INBAND, VMBUS_CHANPKT_FLAG_RC,
init_pkt, sizeof(nvsp_msg), (uint64_t)(uintptr_t)&sndc); req, sizeof(*req), (uint64_t)(uintptr_t)&sndc);
if (ret != 0) { if (ret != 0) {
device_printf(dev, "Fail to allocate subchannel\n"); if_printf(sc->hn_ifp, "send nvs subch req failed: %d\n", ret);
vmbus_xact_deactivate(xact);
vmbus_xact_put(xact);
goto out; goto out;
} }
sema_wait(&net_dev->channel_init_sema); resp = vmbus_xact_wait(xact, &resp_len);
if (resp_len < sizeof(*resp)) {
if (init_pkt->msgs.vers_5_msgs.subchn_complete.status != if_printf(sc->hn_ifp, "invalid subch resp length %zu\n",
nvsp_status_success) { resp_len);
ret = ENODEV; vmbus_xact_put(xact);
device_printf(dev, "sub channel complete error\n"); ret = EINVAL;
goto out; goto out;
} }
if (resp->nvs_type != HN_NVS_TYPE_SUBCH_RESP) {
if_printf(sc->hn_ifp, "not subch resp, type %u\n",
resp->nvs_type);
vmbus_xact_put(xact);
ret = EINVAL;
goto out;
}
net_dev->num_channel = 1 + status = resp->nvs_status;
init_pkt->msgs.vers_5_msgs.subchn_complete.num_subchannels; nsubch = resp->nvs_nsubch;
vmbus_xact_put(xact);
if (status != HN_NVS_STATUS_OK) {
if_printf(sc->hn_ifp, "subch req failed: %x\n", status);
ret = EIO;
goto out;
}
if (nsubch > net_dev->num_channel - 1) {
if_printf(sc->hn_ifp, "%u subchans are allocated, requested %u\n",
nsubch, net_dev->num_channel - 1);
nsubch = net_dev->num_channel - 1;
}
net_dev->num_channel = nsubch + 1;
ret = hv_rf_set_rss_param(rndis_dev, net_dev->num_channel); ret = hv_rf_set_rss_param(rndis_dev, net_dev->num_channel);
out: out:
if (ret) if (ret)
net_dev->num_channel = 1; net_dev->num_channel = 1;
return (ret); return (ret);
▲ Show 20 Lines • Show All 79 Lines • Show Last 20 Lines