[Date Prev][Date Next][Thread Prev][Thread Next][Date Index][Thread Index]
[Qemu-devel] [PATCH v4 01/10] curl: introduce CURLSockInfo to BDRVCURLSt
From: |
Fam Zheng |
Subject: |
[Qemu-devel] [PATCH v4 01/10] curl: introduce CURLSockInfo to BDRVCURLState. |
Date: |
Wed, 22 May 2013 11:16:41 +0800 |
We use socket provided by curl in the driver. Libcurl multi interface
has option CURLMOPT_SOCKETFUNCTION for socket.
Per man 3 curl_multi_setopt:
...
CURLMOPT_SOCKETFUNCTION
Pass a pointer to a function matching the curl_socket_callback
prototype. The curl_multi_socket_action(3) function informs the
application about updates in the socket (file descriptor) status by
doing none, one, or multiple calls to the curl_socket_callback given in
the param argument. They update the status with changes since the
previous time a curl_multi_socket(3) function was called. If the given
callback pointer is NULL, no callback will be called. Set the callback's
userp argument with CURLMOPT_SOCKETDATA. See curl_multi_socket(3) for
more callback details.
...
The added structure store information for all the socket returned by
libcurl. The most important field is action, which is used to keep what
actions are needed when this socket's fd handler is called.
CURLSockInfo is added here and used in later commits to save the socket
actions.
Signed-off-by: Fam Zheng <address@hidden>
---
block/curl.c | 31 +++++++++++++++++++++++++++++--
1 file changed, 29 insertions(+), 2 deletions(-)
diff --git a/block/curl.c b/block/curl.c
index b8935fd..2e42cd1 100644
--- a/block/curl.c
+++ b/block/curl.c
@@ -75,10 +75,18 @@ typedef struct CURLState
char in_use;
} CURLState;
+typedef struct CURLSockInfo {
+ curl_socket_t fd;
+ int action;
+ struct BDRVCURLState *s;
+ QLIST_ENTRY(CURLSockInfo) next;
+} CURLSockInfo;
+
typedef struct BDRVCURLState {
CURLM *multi;
size_t len;
CURLState states[CURL_NUM_STATES];
+ QLIST_HEAD(, CURLSockInfo) socks;
char *url;
size_t readahead_size;
} BDRVCURLState;
@@ -90,7 +98,16 @@ static int curl_aio_flush(void *opaque);
static int curl_sock_cb(CURL *curl, curl_socket_t fd, int action,
void *s, void *sp)
{
+ BDRVCURLState *bs = s;
DPRINTF("CURL (AIO): Sock action %d on fd %d\n", action, fd);
+ CURLSockInfo *sock = sp;
+ if (!sp) {
+ sock = g_malloc0(sizeof(CURLSockInfo));
+ sock->fd = fd;
+ sock->s = bs;
+ QLIST_INSERT_HEAD(&bs->socks, sock, next);
+ curl_multi_assign(bs->multi, fd, sock);
+ }
switch (action) {
case CURL_POLL_IN:
qemu_aio_set_fd_handler(fd, curl_multi_do, NULL, curl_aio_flush,
s);
@@ -433,6 +450,8 @@ static int curl_open(BlockDriverState *bs, QDict *options,
int flags)
inited = 1;
}
+ QLIST_INIT(&s->socks);
+
DPRINTF("CURL: Opening %s\n", file);
s->url = g_strdup(file);
state = curl_init_state(s);
@@ -462,8 +481,8 @@ static int curl_open(BlockDriverState *bs, QDict *options,
int flags)
// initialize the multi interface!
s->multi = curl_multi_init();
- curl_multi_setopt( s->multi, CURLMOPT_SOCKETDATA, s);
- curl_multi_setopt( s->multi, CURLMOPT_SOCKETFUNCTION, curl_sock_cb );
+ curl_multi_setopt(s->multi, CURLMOPT_SOCKETDATA, s);
+ curl_multi_setopt(s->multi, CURLMOPT_SOCKETFUNCTION, curl_sock_cb);
curl_multi_do(s);
qemu_opts_del(opts);
@@ -603,6 +622,14 @@ static void curl_close(BlockDriverState *bs)
}
if (s->multi)
curl_multi_cleanup(s->multi);
+
+ while (!QLIST_EMPTY(&s->socks)) {
+ CURLSockInfo *sock = QLIST_FIRST(&s->socks);
+ QLIST_REMOVE(sock, next);
+ g_free(sock);
+ sock = NULL;
+ }
+
g_free(s->url);
}
--
1.8.2.3
- [Qemu-devel] [PATCH v4 00/10] curl: fix curl read, Fam Zheng, 2013/05/21
- [Qemu-devel] [PATCH v4 02/10] curl: change magic number to sizeof, Fam Zheng, 2013/05/21
- [Qemu-devel] [PATCH v4 01/10] curl: introduce CURLSockInfo to BDRVCURLState.,
Fam Zheng <=
- [Qemu-devel] [PATCH v4 03/10] curl: change curl_multi_do to curl_fd_handler, Fam Zheng, 2013/05/21
- [Qemu-devel] [PATCH v4 04/10] curl: fix curl_open, Fam Zheng, 2013/05/21
- [Qemu-devel] [PATCH v4 05/10] curl: add timer to BDRVCURLState, Fam Zheng, 2013/05/21
- [Qemu-devel] [PATCH v4 06/10] curl: introduce CURLDataCache, Fam Zheng, 2013/05/21
- [Qemu-devel] [PATCH v4 07/10] curl: make use of CURLDataCache., Fam Zheng, 2013/05/21
- [Qemu-devel] [PATCH v4 08/10] curl: use list to store CURLState, Fam Zheng, 2013/05/21
- [Qemu-devel] [PATCH v4 09/10] curl: add cache quota., Fam Zheng, 2013/05/21
- [Qemu-devel] [PATCH v4 10/10] curl: introduce ssl_no_cert runtime option., Fam Zheng, 2013/05/21
- Re: [Qemu-devel] [PATCH v4 00/10] curl: fix curl read, Fam Zheng, 2013/05/22
- Re: [Qemu-devel] [PATCH v4 00/10] curl: fix curl read, Richard W.M. Jones, 2013/05/22