[Date Prev][Date Next][Thread Prev][Thread Next][Date Index][Thread Index]
[Qemu-devel] [PULL 05/14] curl: convert to CoQueue
From: |
Fam Zheng |
Subject: |
[Qemu-devel] [PULL 05/14] curl: convert to CoQueue |
Date: |
Thu, 25 Jan 2018 13:46:39 +0800 |
From: Paolo Bonzini <address@hidden>
Now that CoQueues can use a QemuMutex for thread-safety, there is no
need for curl to roll its own coroutine queue. Coroutines can be
placed directly on the queue instead of using a list of CURLAIOCBs.
Signed-off-by: Paolo Bonzini <address@hidden>
Message-Id: <address@hidden>
Reviewed-by: Fam Zheng <address@hidden>
Signed-off-by: Fam Zheng <address@hidden>
---
block/curl.c | 20 ++++----------------
1 file changed, 4 insertions(+), 16 deletions(-)
diff --git a/block/curl.c b/block/curl.c
index 35cf417f59..cd578d3d14 100644
--- a/block/curl.c
+++ b/block/curl.c
@@ -101,8 +101,6 @@ typedef struct CURLAIOCB {
size_t start;
size_t end;
-
- QSIMPLEQ_ENTRY(CURLAIOCB) next;
} CURLAIOCB;
typedef struct CURLSocket {
@@ -138,7 +136,7 @@ typedef struct BDRVCURLState {
bool accept_range;
AioContext *aio_context;
QemuMutex mutex;
- QSIMPLEQ_HEAD(, CURLAIOCB) free_state_waitq;
+ CoQueue free_state_waitq;
char *username;
char *password;
char *proxyusername;
@@ -538,7 +536,6 @@ 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]);
@@ -556,13 +553,7 @@ 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);
- }
+ qemu_co_enter_next(&s->s->free_state_waitq, &s->s->mutex);
}
static void curl_parse_filename(const char *filename, QDict *options,
@@ -784,7 +775,7 @@ static int curl_open(BlockDriverState *bs, QDict *options,
int flags,
}
DPRINTF("CURL: Opening %s\n", file);
- QSIMPLEQ_INIT(&s->free_state_waitq);
+ qemu_co_queue_init(&s->free_state_waitq);
s->aio_context = bdrv_get_aio_context(bs);
s->url = g_strdup(file);
qemu_mutex_lock(&s->mutex);
@@ -888,10 +879,7 @@ 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);
- qemu_coroutine_yield();
- qemu_mutex_lock(&s->mutex);
+ qemu_co_queue_wait(&s->free_state_waitq, &s->mutex);
}
if (curl_init_state(s, state) < 0) {
--
2.14.3
- [Qemu-devel] [PULL 00/14] Block and docker patches, Fam Zheng, 2018/01/25
- [Qemu-devel] [PULL 01/14] docker: change Fedora base image to fedora:27, Fam Zheng, 2018/01/25
- [Qemu-devel] [PULL 02/14] lockable: add QemuLockable, Fam Zheng, 2018/01/25
- [Qemu-devel] [PULL 03/14] coroutine-lock: convert CoQueue to use QemuLockable, Fam Zheng, 2018/01/25
- [Qemu-devel] [PULL 05/14] curl: convert to CoQueue,
Fam Zheng <=
- [Qemu-devel] [PULL 04/14] coroutine-lock: make qemu_co_enter_next thread-safe, Fam Zheng, 2018/01/25
- [Qemu-devel] [PULL 06/14] stubs: Add stubs for ram block API, Fam Zheng, 2018/01/25
- [Qemu-devel] [PULL 07/14] util: Introduce vfio helpers, Fam Zheng, 2018/01/25
- [Qemu-devel] [PULL 09/14] block: Introduce buf register API, Fam Zheng, 2018/01/25
- [Qemu-devel] [PULL 10/14] block/nvme: Implement .bdrv_(un)register_buf, Fam Zheng, 2018/01/25
- [Qemu-devel] [PULL 08/14] block: Add VFIO based NVMe driver, Fam Zheng, 2018/01/25
- [Qemu-devel] [PULL 11/14] qemu-img: Map bench buffer, Fam Zheng, 2018/01/25
- [Qemu-devel] [PULL 13/14] docs: Add section for NVMe VFIO driver, Fam Zheng, 2018/01/25
- [Qemu-devel] [PULL 14/14] qapi: Add NVMe driver options to the schema, Fam Zheng, 2018/01/25
- [Qemu-devel] [PULL 12/14] block: Move NVMe constants to a separate header, Fam Zheng, 2018/01/25