From patchwork Mon May 20 07:03:35 2013 Content-Type: text/plain; charset="utf-8" MIME-Version: 1.0 Content-Transfer-Encoding: 7bit X-Patchwork-Submitter: Fam Zheng X-Patchwork-Id: 244852 Return-Path: X-Original-To: incoming@patchwork.ozlabs.org Delivered-To: patchwork-incoming@bilbo.ozlabs.org Received: from lists.gnu.org (lists.gnu.org [208.118.235.17]) (using TLSv1 with cipher AES256-SHA (256/256 bits)) (Client did not present a certificate) by ozlabs.org (Postfix) with ESMTPS id B75B32C0079 for ; Mon, 20 May 2013 17:04:35 +1000 (EST) Received: from localhost ([::1]:35717 helo=lists.gnu.org) by lists.gnu.org with esmtp (Exim 4.71) (envelope-from ) id 1UeK92-0006ID-F8 for incoming@patchwork.ozlabs.org; Mon, 20 May 2013 03:04:32 -0400 Received: from eggs.gnu.org ([208.118.235.92]:58967) by lists.gnu.org with esmtp (Exim 4.71) (envelope-from ) id 1UeK8V-0006FB-Se for qemu-devel@nongnu.org; Mon, 20 May 2013 03:04:02 -0400 Received: from Debian-exim by eggs.gnu.org with spam-scanned (Exim 4.71) (envelope-from ) id 1UeK8T-0003gr-64 for qemu-devel@nongnu.org; Mon, 20 May 2013 03:03:59 -0400 Received: from mx1.redhat.com ([209.132.183.28]:45669) by eggs.gnu.org with esmtp (Exim 4.71) (envelope-from ) id 1UeK8S-0003gn-UX for qemu-devel@nongnu.org; Mon, 20 May 2013 03:03:57 -0400 Received: from int-mx11.intmail.prod.int.phx2.redhat.com (int-mx11.intmail.prod.int.phx2.redhat.com [10.5.11.24]) by mx1.redhat.com (8.14.4/8.14.4) with ESMTP id r4K73trB002373 (version=TLSv1/SSLv3 cipher=DHE-RSA-AES256-SHA bits=256 verify=OK) for ; Mon, 20 May 2013 03:03:56 -0400 Received: from fam-laptop.nay.redhat.com ([10.66.7.14]) by int-mx11.intmail.prod.int.phx2.redhat.com (8.14.4/8.14.4) with ESMTP id r4K73nLe026470; Mon, 20 May 2013 03:03:53 -0400 From: Fam Zheng To: qemu-devel@nongnu.org Date: Mon, 20 May 2013 15:03:35 +0800 Message-Id: <1369033424-14594-2-git-send-email-famz@redhat.com> In-Reply-To: <1369033424-14594-1-git-send-email-famz@redhat.com> References: <1369033424-14594-1-git-send-email-famz@redhat.com> X-Scanned-By: MIMEDefang 2.68 on 10.5.11.24 X-detected-operating-system: by eggs.gnu.org: GNU/Linux 3.x X-Received-From: 209.132.183.28 Cc: kwolf@redhat.com, jcody@redhat.com, Fam Zheng , stefanha@redhat.com Subject: [Qemu-devel] [PATCH v3 01/10] curl: introduce CURLSockInfo to BDRVCURLState. X-BeenThere: qemu-devel@nongnu.org X-Mailman-Version: 2.1.14 Precedence: list List-Id: List-Unsubscribe: , List-Archive: List-Post: List-Help: List-Subscribe: , Errors-To: qemu-devel-bounces+incoming=patchwork.ozlabs.org@nongnu.org Sender: qemu-devel-bounces+incoming=patchwork.ozlabs.org@nongnu.org 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 --- block/curl.c | 29 +++++++++++++++++++++++++++-- 1 file changed, 27 insertions(+), 2 deletions(-) diff --git a/block/curl.c b/block/curl.c index b8935fd..0aede58 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); @@ -462,8 +479,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 +620,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); }