mirror/freebsd
1
0
Fork 0
mirror of https://git.FreeBSD.org/src.git synced 2025-02-08 06:02:59 +00:00
Code Issues Releases Activity

hyperv/vmbus: Add result polling support for xact API.

Browse Source 
MFC after:	1 week
Sponsored by:	Microsoft
Differential Revision:	https://reviews.freebsd.org/D8633
This commit is contained in:
Sepherosa Ziehau 2016-11-28 07:27:08 +00:00
parent 4dceaf94fa
commit 1b34e69534
Notes: svn2git 2020-12-20 02:59:44 +00:00 
svn path=/head/; revision=309240
2 changed files with 58 additions and 20 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
sys/dev/hyperv/include/vmbus_xact.h
View File

@ -55,6 +55,8 @@ const void *vmbus_xact_wait(struct vmbus_xact *xact,
size_t *resp_len);
const void *vmbus_xact_busywait(struct vmbus_xact *xact,
size_t *resp_len);
const void *vmbus_xact_poll(struct vmbus_xact *xact,
size_t *resp_len);
void vmbus_xact_wakeup(struct vmbus_xact *xact,
const void *data, size_t dlen);
void vmbus_xact_ctx_wakeup(struct vmbus_xact_ctx *ctx,

76
sys/dev/hyperv/vmbus/vmbus_xact.c
View File

@ -71,8 +71,10 @@ static struct vmbus_xact *vmbus_xact_alloc(struct vmbus_xact_ctx *,
static void vmbus_xact_free(struct vmbus_xact *);
static struct vmbus_xact *vmbus_xact_get1(struct vmbus_xact_ctx *,
uint32_t);
const void *vmbus_xact_wait1(struct vmbus_xact *, size_t *,
static const void *vmbus_xact_wait1(struct vmbus_xact *, size_t *,
bool);
static const void *vmbus_xact_return(struct vmbus_xact *,
size_t *);
static void vmbus_xact_save_resp(struct vmbus_xact *,
const void *, size_t);
static void vmbus_xact_ctx_free(struct vmbus_xact_ctx *);
@ -277,7 +279,36 @@ vmbus_xact_deactivate(struct vmbus_xact *xact)
mtx_unlock(&ctx->xc_lock);
}
const void *
static const void *
vmbus_xact_return(struct vmbus_xact *xact, size_t *resp_len)
{
struct vmbus_xact_ctx *ctx = xact->x_ctx;
const void *resp;
mtx_assert(&ctx->xc_lock, MA_OWNED);
KASSERT(ctx->xc_active == xact, ("xact trashed"));
if ((ctx->xc_flags & VMBUS_XACT_CTXF_DESTROY) && xact->x_resp == NULL) {
uint8_t b = 0;
/*
* Orphaned and no response was received yet; fake up
* an one byte response.
*/
printf("vmbus: xact ctx was orphaned w/ pending xact\n");
vmbus_xact_save_resp(ctx->xc_active, &b, sizeof(b));
}
KASSERT(xact->x_resp != NULL, ("no response"));
ctx->xc_active = NULL;
resp = xact->x_resp;
*resp_len = xact->x_resp_len;
return (resp);
}
static const void *
vmbus_xact_wait1(struct vmbus_xact *xact, size_t *resp_len,
bool can_sleep)
{
@ -298,24 +329,7 @@ vmbus_xact_wait1(struct vmbus_xact *xact, size_t *resp_len,
mtx_lock(&ctx->xc_lock);
}
}
KASSERT(ctx->xc_active == xact, ("xact trashed"));
if ((ctx->xc_flags & VMBUS_XACT_CTXF_DESTROY) && xact->x_resp == NULL) {
uint8_t b = 0;
/*
* Orphaned and no response was received yet; fake up
* an one byte response.
*/
printf("vmbus: xact ctx was orphaned w/ pending xact\n");
vmbus_xact_save_resp(ctx->xc_active, &b, sizeof(b));
}
KASSERT(xact->x_resp != NULL, ("no response"));
ctx->xc_active = NULL;
resp = xact->x_resp;
*resp_len = xact->x_resp_len;
resp = vmbus_xact_return(xact, resp_len);
mtx_unlock(&ctx->xc_lock);
@ -336,6 +350,28 @@ vmbus_xact_busywait(struct vmbus_xact *xact, size_t *resp_len)
return (vmbus_xact_wait1(xact, resp_len, false /* can't sleep */));
}
const void *
vmbus_xact_poll(struct vmbus_xact *xact, size_t *resp_len)
{
struct vmbus_xact_ctx *ctx = xact->x_ctx;
const void *resp;
mtx_lock(&ctx->xc_lock);
KASSERT(ctx->xc_active == xact, ("xact mismatch"));
if (xact->x_resp == NULL &&
(ctx->xc_flags & VMBUS_XACT_CTXF_DESTROY) == 0) {
mtx_unlock(&ctx->xc_lock);
*resp_len = 0;
return (NULL);
}
resp = vmbus_xact_return(xact, resp_len);
mtx_unlock(&ctx->xc_lock);
return (resp);
}
static void
vmbus_xact_save_resp(struct vmbus_xact *xact, const void *data, size_t dlen)
{