[Date Prev][Date Next][Thread Prev][Thread Next][Date Index][Thread Index]
[Qemu-devel] [PULL 8/8] curl: do not do aio_poll when waiting for a free
From: |
Jeff Cody |
Subject: |
[Qemu-devel] [PULL 8/8] curl: do not do aio_poll when waiting for a free CURLState |
Date: |
Tue, 16 May 2017 11:54:20 -0400 |
From: Paolo Bonzini <address@hidden>
Instead, put the CURLAIOCB on a wait list and yield; curl_clean_state will
wake the corresponding coroutine.
Because of CURL's callback-based structure, we cannot easily convert
everything to CoMutex/CoQueue; keeping the QemuMutex is simpler. However,
CoQueue is a simple wrapper around a linked list, so we can easily
use QSIMPLEQ and open-code a CoQueue, protected by the BDRVCURLState
QemuMutex instead of a CoMutex.
Reviewed-by: Jeff Cody <address@hidden>
Signed-off-by: Paolo Bonzini <address@hidden>
Reviewed-by: Max Reitz <address@hidden>
Message-id: address@hidden
Signed-off-by: Jeff Cody <address@hidden>
---
block/curl.c | 16 +++++++++++++++-
1 file changed, 15 insertions(+), 1 deletion(-)
diff --git a/block/curl.c b/block/curl.c
index 1c04903..2a244e2 100644
--- a/block/curl.c
+++ b/block/curl.c
@@ -99,6 +99,8 @@ typedef struct CURLAIOCB {
size_t start;
size_t end;
+
+ QSIMPLEQ_ENTRY(CURLAIOCB) next;
} CURLAIOCB;
typedef struct CURLSocket {
@@ -134,6 +136,7 @@ typedef struct BDRVCURLState {
bool accept_range;
AioContext *aio_context;
QemuMutex mutex;
+ QSIMPLEQ_HEAD(, CURLAIOCB) free_state_waitq;
char *username;
char *password;
char *proxyusername;
@@ -533,6 +536,7 @@ static int curl_init_state(BDRVCURLState *s, CURLState
*state)
/* Called with s->mutex held. */
static void curl_clean_state(CURLState *s)
{
+ CURLAIOCB *next;
int j;
for (j = 0; j < CURL_NUM_ACB; j++) {
assert(!s->acb[j]);
@@ -549,6 +553,14 @@ static void curl_clean_state(CURLState *s)
}
s->in_use = 0;
+
+ next = QSIMPLEQ_FIRST(&s->s->free_state_waitq);
+ if (next) {
+ QSIMPLEQ_REMOVE_HEAD(&s->s->free_state_waitq, next);
+ qemu_mutex_unlock(&s->s->mutex);
+ aio_co_wake(next->co);
+ qemu_mutex_lock(&s->s->mutex);
+ }
}
static void curl_parse_filename(const char *filename, QDict *options,
@@ -766,6 +778,7 @@ static int curl_open(BlockDriverState *bs, QDict *options,
int flags,
}
DPRINTF("CURL: Opening %s\n", file);
+ QSIMPLEQ_INIT(&s->free_state_waitq);
s->aio_context = bdrv_get_aio_context(bs);
s->url = g_strdup(file);
qemu_mutex_lock(&s->mutex);
@@ -866,8 +879,9 @@ static void curl_setup_preadv(BlockDriverState *bs,
CURLAIOCB *acb)
if (state) {
break;
}
+ QSIMPLEQ_INSERT_TAIL(&s->free_state_waitq, acb, next);
qemu_mutex_unlock(&s->mutex);
- aio_poll(bdrv_get_aio_context(bs), true);
+ qemu_coroutine_yield();
qemu_mutex_lock(&s->mutex);
}
--
2.9.3
- [Qemu-devel] [PULL 0/8] Block patches for curl, Jeff Cody, 2017/05/16
- [Qemu-devel] [PULL 2/8] curl: strengthen assertion in curl_clean_state, Jeff Cody, 2017/05/16
- [Qemu-devel] [PULL 1/8] block: curl: Allow passing cookies via QCryptoSecret, Jeff Cody, 2017/05/16
- [Qemu-devel] [PULL 3/8] curl: never invoke callbacks with s->mutex held, Jeff Cody, 2017/05/16
- [Qemu-devel] [PULL 4/8] curl: avoid recursive locking of BDRVCURLState mutex, Jeff Cody, 2017/05/16
- [Qemu-devel] [PULL 5/8] curl: split curl_find_state/curl_init_state, Jeff Cody, 2017/05/16
- [Qemu-devel] [PULL 7/8] curl: convert readv to coroutines, Jeff Cody, 2017/05/16
- [Qemu-devel] [PULL 6/8] curl: convert CURLAIOCB to byte values, Jeff Cody, 2017/05/16
- [Qemu-devel] [PULL 8/8] curl: do not do aio_poll when waiting for a free CURLState,
Jeff Cody <=
- Re: [Qemu-devel] [Qemu-block] [PULL 0/8] Block patches for curl, Stefan Hajnoczi, 2017/05/17