hyperv/vmbus: Add APIs for various types of transactions.
Reviewed by: Jun Su <junsu microsoft com> MFC after: 1 week Sponsored by: Microsoft Differential Revision: https://reviews.freebsd.org/D7456
This commit is contained in:
Sepherosa Ziehau
parent
c357102c5b
commit
6212aa15fc
@ -294,6 +294,7 @@ dev/hyperv/vmbus/vmbus_br.c optional hyperv
|
||||
dev/hyperv/vmbus/vmbus_chan.c optional hyperv
|
||||
dev/hyperv/vmbus/vmbus_et.c optional hyperv
|
||||
dev/hyperv/vmbus/vmbus_if.m optional hyperv
|
||||
dev/hyperv/vmbus/vmbus_xact.c optional hyperv
|
||||
dev/hyperv/vmbus/amd64/hyperv_machdep.c optional hyperv
|
||||
dev/hyperv/vmbus/amd64/vmbus_vector.S optional hyperv
|
||||
dev/nfe/if_nfe.c optional nfe pci
|
||||
|
||||
@ -253,6 +253,7 @@ dev/hyperv/vmbus/vmbus_br.c optional hyperv
|
||||
dev/hyperv/vmbus/vmbus_chan.c optional hyperv
|
||||
dev/hyperv/vmbus/vmbus_et.c optional hyperv
|
||||
dev/hyperv/vmbus/vmbus_if.m optional hyperv
|
||||
dev/hyperv/vmbus/vmbus_xact.c optional hyperv
|
||||
dev/hyperv/vmbus/i386/hyperv_machdep.c optional hyperv
|
||||
dev/hyperv/vmbus/i386/vmbus_vector.S optional hyperv
|
||||
dev/ichwd/ichwd.c optional ichwd
|
||||
|
||||
54
sys/dev/hyperv/include/vmbus_xact.h
Normal file
54
sys/dev/hyperv/include/vmbus_xact.h
Normal file
@ -0,0 +1,54 @@
|
||||
/*-
|
||||
* Copyright (c) 2016 Microsoft Corp.
|
||||
* All rights reserved.
|
||||
*
|
||||
* Redistribution and use in source and binary forms, with or without
|
||||
* modification, are permitted provided that the following conditions
|
||||
* are met:
|
||||
* 1. Redistributions of source code must retain the above copyright
|
||||
* notice unmodified, this list of conditions, and the following
|
||||
* disclaimer.
|
||||
* 2. Redistributions in binary form must reproduce the above copyright
|
||||
* notice, this list of conditions and the following disclaimer in the
|
||||
* documentation and/or other materials provided with the distribution.
|
||||
*
|
||||
* THIS SOFTWARE IS PROVIDED BY THE AUTHOR ``AS IS'' AND ANY EXPRESS OR
|
||||
* IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES
|
||||
* OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE DISCLAIMED.
|
||||
* IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR ANY DIRECT, INDIRECT,
|
||||
* INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT
|
||||
* NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE,
|
||||
* DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY
|
||||
* THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
|
||||
* (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF
|
||||
* THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
|
||||
*
|
||||
* $FreeBSD$
|
||||
*/
|
||||
|
||||
#ifndef _VMBUS_XACT_H_
|
||||
#define _VMBUS_XACT_H_
|
||||
|
||||
#include <sys/param.h>
|
||||
#include <sys/bus.h>
|
||||
|
||||
struct vmbus_xact;
|
||||
struct vmbus_xact_ctx;
|
||||
|
||||
struct vmbus_xact_ctx *vmbus_xact_ctx_create(bus_dma_tag_t dtag,
|
||||
size_t req_size, size_t resp_size);
|
||||
void vmbus_xact_ctx_destroy(struct vmbus_xact_ctx *ctx);
|
||||
struct vmbus_xact *vmbus_xact_get(struct vmbus_xact_ctx *ctx,
|
||||
size_t req_len);
|
||||
void vmbus_xact_put(struct vmbus_xact *xact);
|
||||
|
||||
void *vmbus_xact_req_data(const struct vmbus_xact *xact);
|
||||
bus_addr_t vmbus_xact_req_paddr(const struct vmbus_xact *xact);
|
||||
void vmbus_xact_activate(struct vmbus_xact *xact);
|
||||
void vmbus_xact_deactivate(struct vmbus_xact *xact);
|
||||
const void *vmbus_xact_wait(struct vmbus_xact *xact,
|
||||
size_t *resp_len);
|
||||
void vmbus_xact_wakeup(struct vmbus_xact *xact,
|
||||
const void *data, size_t dlen);
|
||||
|
||||
#endif /* !_VMBUS_XACT_H_ */
|
||||
278
sys/dev/hyperv/vmbus/vmbus_xact.c
Normal file
278
sys/dev/hyperv/vmbus/vmbus_xact.c
Normal file
@ -0,0 +1,278 @@
|
||||
/*-
|
||||
* Copyright (c) 2016 Microsoft Corp.
|
||||
* All rights reserved.
|
||||
*
|
||||
* Redistribution and use in source and binary forms, with or without
|
||||
* modification, are permitted provided that the following conditions
|
||||
* are met:
|
||||
* 1. Redistributions of source code must retain the above copyright
|
||||
* notice unmodified, this list of conditions, and the following
|
||||
* disclaimer.
|
||||
* 2. Redistributions in binary form must reproduce the above copyright
|
||||
* notice, this list of conditions and the following disclaimer in the
|
||||
* documentation and/or other materials provided with the distribution.
|
||||
*
|
||||
* THIS SOFTWARE IS PROVIDED BY THE AUTHOR ``AS IS'' AND ANY EXPRESS OR
|
||||
* IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES
|
||||
* OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE DISCLAIMED.
|
||||
* IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR ANY DIRECT, INDIRECT,
|
||||
* INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT
|
||||
* NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE,
|
||||
* DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY
|
||||
* THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
|
||||
* (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF
|
||||
* THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
|
||||
*/
|
||||
|
||||
#include <sys/cdefs.h>
|
||||
__FBSDID("$FreeBSD$");
|
||||
|
||||
#include <sys/param.h>
|
||||
#include <sys/lock.h>
|
||||
#include <sys/malloc.h>
|
||||
#include <sys/mutex.h>
|
||||
#include <sys/proc.h>
|
||||
#include <sys/systm.h>
|
||||
|
||||
#include <dev/hyperv/include/hyperv_busdma.h>
|
||||
#include <dev/hyperv/include/vmbus_xact.h>
|
||||
|
||||
struct vmbus_xact {
|
||||
struct vmbus_xact_ctx *x_ctx;
|
||||
|
||||
void *x_req;
|
||||
struct hyperv_dma x_req_dma;
|
||||
|
||||
const void *x_resp;
|
||||
size_t x_resp_len;
|
||||
void *x_resp0;
|
||||
};
|
||||
|
||||
struct vmbus_xact_ctx {
|
||||
uint32_t xc_flags;
|
||||
size_t xc_req_size;
|
||||
size_t xc_resp_size;
|
||||
|
||||
struct vmbus_xact *xc_free;
|
||||
struct mtx xc_free_lock;
|
||||
|
||||
struct vmbus_xact *xc_active;
|
||||
struct mtx xc_active_lock;
|
||||
};
|
||||
|
||||
#define VMBUS_XACT_CTXF_DESTROY 0x0001
|
||||
|
||||
static struct vmbus_xact *vmbus_xact_alloc(struct vmbus_xact_ctx *,
|
||||
bus_dma_tag_t);
|
||||
static void vmbus_xact_free(struct vmbus_xact *);
|
||||
static struct vmbus_xact *vmbus_xact_get1(struct vmbus_xact_ctx *,
|
||||
uint32_t);
|
||||
|
||||
static struct vmbus_xact *
|
||||
vmbus_xact_alloc(struct vmbus_xact_ctx *ctx, bus_dma_tag_t parent_dtag)
|
||||
{
|
||||
struct vmbus_xact *xact;
|
||||
|
||||
xact = malloc(sizeof(*xact), M_DEVBUF, M_WAITOK | M_ZERO);
|
||||
xact->x_ctx = ctx;
|
||||
|
||||
/* XXX assume that page aligned is enough */
|
||||
xact->x_req = hyperv_dmamem_alloc(parent_dtag, PAGE_SIZE, 0,
|
||||
ctx->xc_req_size, &xact->x_req_dma, BUS_DMA_WAITOK);
|
||||
if (xact->x_req == NULL) {
|
||||
free(xact, M_DEVBUF);
|
||||
return (NULL);
|
||||
}
|
||||
xact->x_resp0 = malloc(ctx->xc_resp_size, M_DEVBUF, M_WAITOK);
|
||||
|
||||
return (xact);
|
||||
}
|
||||
|
||||
static void
|
||||
vmbus_xact_free(struct vmbus_xact *xact)
|
||||
{
|
||||
|
||||
hyperv_dmamem_free(&xact->x_req_dma, xact->x_req);
|
||||
free(xact->x_resp0, M_DEVBUF);
|
||||
free(xact, M_DEVBUF);
|
||||
}
|
||||
|
||||
static struct vmbus_xact *
|
||||
vmbus_xact_get1(struct vmbus_xact_ctx *ctx, uint32_t dtor_flag)
|
||||
{
|
||||
struct vmbus_xact *xact;
|
||||
|
||||
mtx_lock(&ctx->xc_free_lock);
|
||||
|
||||
while ((ctx->xc_flags & dtor_flag) == 0 && ctx->xc_free == NULL)
|
||||
mtx_sleep(&ctx->xc_free, &ctx->xc_free_lock, 0, "gxact", 0);
|
||||
if (ctx->xc_flags & dtor_flag) {
|
||||
/* Being destroyed */
|
||||
xact = NULL;
|
||||
} else {
|
||||
xact = ctx->xc_free;
|
||||
KASSERT(xact != NULL, ("no free xact"));
|
||||
KASSERT(xact->x_resp == NULL, ("xact has pending response"));
|
||||
ctx->xc_free = NULL;
|
||||
}
|
||||
|
||||
mtx_unlock(&ctx->xc_free_lock);
|
||||
|
||||
return (xact);
|
||||
}
|
||||
|
||||
struct vmbus_xact_ctx *
|
||||
vmbus_xact_ctx_create(bus_dma_tag_t dtag, size_t req_size, size_t resp_size)
|
||||
{
|
||||
struct vmbus_xact_ctx *ctx;
|
||||
|
||||
ctx = malloc(sizeof(*ctx), M_DEVBUF, M_WAITOK | M_ZERO);
|
||||
ctx->xc_req_size = req_size;
|
||||
ctx->xc_resp_size = resp_size;
|
||||
|
||||
ctx->xc_free = vmbus_xact_alloc(ctx, dtag);
|
||||
if (ctx->xc_free == NULL) {
|
||||
free(ctx, M_DEVBUF);
|
||||
return (NULL);
|
||||
}
|
||||
|
||||
mtx_init(&ctx->xc_free_lock, "vmbus xact free", NULL, MTX_DEF);
|
||||
mtx_init(&ctx->xc_active_lock, "vmbus xact active", NULL, MTX_DEF);
|
||||
|
||||
return (ctx);
|
||||
}
|
||||
|
||||
void
|
||||
vmbus_xact_ctx_destroy(struct vmbus_xact_ctx *ctx)
|
||||
{
|
||||
struct vmbus_xact *xact;
|
||||
|
||||
mtx_lock(&ctx->xc_free_lock);
|
||||
ctx->xc_flags |= VMBUS_XACT_CTXF_DESTROY;
|
||||
mtx_unlock(&ctx->xc_free_lock);
|
||||
wakeup(&ctx->xc_free);
|
||||
|
||||
xact = vmbus_xact_get1(ctx, 0);
|
||||
if (xact == NULL)
|
||||
panic("can't get xact");
|
||||
|
||||
vmbus_xact_free(xact);
|
||||
mtx_destroy(&ctx->xc_free_lock);
|
||||
mtx_destroy(&ctx->xc_active_lock);
|
||||
free(ctx, M_DEVBUF);
|
||||
}
|
||||
|
||||
struct vmbus_xact *
|
||||
vmbus_xact_get(struct vmbus_xact_ctx *ctx, size_t req_len)
|
||||
{
|
||||
struct vmbus_xact *xact;
|
||||
|
||||
if (req_len > ctx->xc_req_size)
|
||||
panic("invalid request size %zu", req_len);
|
||||
|
||||
xact = vmbus_xact_get1(ctx, VMBUS_XACT_CTXF_DESTROY);
|
||||
if (xact == NULL)
|
||||
return (NULL);
|
||||
|
||||
memset(xact->x_req, 0, req_len);
|
||||
return (xact);
|
||||
}
|
||||
|
||||
void
|
||||
vmbus_xact_put(struct vmbus_xact *xact)
|
||||
{
|
||||
struct vmbus_xact_ctx *ctx = xact->x_ctx;
|
||||
|
||||
KASSERT(ctx->xc_active == NULL, ("pending active xact"));
|
||||
xact->x_resp = NULL;
|
||||
|
||||
mtx_lock(&ctx->xc_free_lock);
|
||||
KASSERT(ctx->xc_free == NULL, ("has free xact"));
|
||||
ctx->xc_free = xact;
|
||||
mtx_unlock(&ctx->xc_free_lock);
|
||||
wakeup(&ctx->xc_free);
|
||||
}
|
||||
|
||||
void *
|
||||
vmbus_xact_req_data(const struct vmbus_xact *xact)
|
||||
{
|
||||
|
||||
return (xact->x_req);
|
||||
}
|
||||
|
||||
bus_addr_t
|
||||
vmbus_xact_req_paddr(const struct vmbus_xact *xact)
|
||||
{
|
||||
|
||||
return (xact->x_req_dma.hv_paddr);
|
||||
}
|
||||
|
||||
void
|
||||
vmbus_xact_activate(struct vmbus_xact *xact)
|
||||
{
|
||||
struct vmbus_xact_ctx *ctx = xact->x_ctx;
|
||||
|
||||
KASSERT(xact->x_resp == NULL, ("xact has pending response"));
|
||||
|
||||
mtx_lock(&ctx->xc_active_lock);
|
||||
KASSERT(ctx->xc_active == NULL, ("pending active xact"));
|
||||
ctx->xc_active = xact;
|
||||
mtx_unlock(&ctx->xc_active_lock);
|
||||
}
|
||||
|
||||
void
|
||||
vmbus_xact_deactivate(struct vmbus_xact *xact)
|
||||
{
|
||||
struct vmbus_xact_ctx *ctx = xact->x_ctx;
|
||||
|
||||
mtx_lock(&ctx->xc_active_lock);
|
||||
KASSERT(ctx->xc_active == xact, ("xact mismatch"));
|
||||
ctx->xc_active = NULL;
|
||||
mtx_unlock(&ctx->xc_active_lock);
|
||||
}
|
||||
|
||||
const void *
|
||||
vmbus_xact_wait(struct vmbus_xact *xact, size_t *resp_len)
|
||||
{
|
||||
struct vmbus_xact_ctx *ctx = xact->x_ctx;
|
||||
const void *resp;
|
||||
|
||||
mtx_lock(&ctx->xc_active_lock);
|
||||
|
||||
KASSERT(ctx->xc_active == xact, ("xact mismatch"));
|
||||
while (xact->x_resp == NULL) {
|
||||
mtx_sleep(&ctx->xc_active, &ctx->xc_active_lock, 0,
|
||||
"wxact", 0);
|
||||
}
|
||||
ctx->xc_active = NULL;
|
||||
|
||||
resp = xact->x_resp;
|
||||
*resp_len = xact->x_resp_len;
|
||||
|
||||
mtx_unlock(&ctx->xc_active_lock);
|
||||
|
||||
return (resp);
|
||||
}
|
||||
|
||||
void
|
||||
vmbus_xact_wakeup(struct vmbus_xact *xact, const void *data, size_t dlen)
|
||||
{
|
||||
struct vmbus_xact_ctx *ctx = xact->x_ctx;
|
||||
size_t cplen = dlen;
|
||||
|
||||
if (cplen > ctx->xc_resp_size) {
|
||||
printf("vmbus: xact response truncated %zu -> %zu\n",
|
||||
cplen, ctx->xc_resp_size);
|
||||
cplen = ctx->xc_resp_size;
|
||||
}
|
||||
|
||||
mtx_lock(&ctx->xc_active_lock);
|
||||
|
||||
KASSERT(ctx->xc_active == xact, ("xact mismatch"));
|
||||
memcpy(xact->x_resp0, data, cplen);
|
||||
xact->x_resp_len = cplen;
|
||||
xact->x_resp = xact->x_resp0;
|
||||
|
||||
mtx_unlock(&ctx->xc_active_lock);
|
||||
wakeup(&ctx->xc_active);
|
||||
}
|
||||
@ -10,7 +10,8 @@ SRCS= hyperv.c \
|
||||
vmbus.c \
|
||||
vmbus_br.c \
|
||||
vmbus_chan.c \
|
||||
vmbus_et.c
|
||||
vmbus_et.c \
|
||||
vmbus_xact.c
|
||||
SRCS+= acpi_if.h bus_if.h device_if.h opt_acpi.h vmbus_if.h
|
||||
|
||||
# XXX: for assym.s
|
||||
|
||||
Loading…
Reference in New Issue
Block a user