From 70c7a568e3c1384704228622990d6aaa2350e44e Mon Sep 17 00:00:00 2001

From: Max Reitz <mreitz@redhat.com>

Date: Tue, 19 Nov 2019 15:29:58 +0000

Subject: [PATCH 6/8] curl: Report only ready sockets

MIME-Version: 1.0

Content-Type: text/plain; charset=UTF-8

Content-Transfer-Encoding: 8bit

RH-Author: Max Reitz <mreitz@redhat.com>

Message-id: <20191119153000.101646-6-mreitz@redhat.com>

Patchwork-id: 92519

O-Subject: [RHEL-8.2.0 qemu-kvm PATCH 5/7] curl: Report only ready sockets

Bugzilla: 1744602

RH-Acked-by: Maxim Levitsky <mlevitsk@redhat.com>

RH-Acked-by: Philippe Mathieu-Daudé <philmd@redhat.com>

RH-Acked-by: Stefano Garzarella <sgarzare@redhat.com>

Instead of reporting all sockets to cURL, only report the one that has

caused curl_multi_do_locked() to be called.  This lets us get rid of the

QLIST_FOREACH_SAFE() list, which was actually wrong: SAFE foreaches are

only safe when the current element is removed in each iteration.  If it

possible for the list to be concurrently modified, we cannot guarantee

that only the current element will be removed.  Therefore, we must not

use QLIST_FOREACH_SAFE() here.

Fixes: ff5ca1664af85b24a4180d595ea6873fd3deac57

Cc: qemu-stable@nongnu.org

Signed-off-by: Max Reitz <mreitz@redhat.com>

Message-id: 20190910124136.10565-6-mreitz@redhat.com

Reviewed-by: Maxim Levitsky <mlevitsk@redhat.com>

Reviewed-by: John Snow <jsnow@redhat.com>

Signed-off-by: Max Reitz <mreitz@redhat.com>

(cherry picked from commit 9abaf9fc474c3dd53e8e119326abc774c977c331)

Signed-off-by: Max Reitz <mreitz@redhat.com>

Signed-off-by: Danilo C. L. de Paula <ddepaula@redhat.com>

---

 block/curl.c | 17 ++++++-----------

 1 file changed, 6 insertions(+), 11 deletions(-)

diff --git a/block/curl.c b/block/curl.c

index de00ec8..f776615 100644

--- a/block/curl.c

+++ b/block/curl.c

@@ -401,24 +401,19 @@ static void curl_multi_check_completion(BDRVCURLState *s)

 }

 /* Called with s->mutex held.  */

-static void curl_multi_do_locked(CURLSocket *ready_socket)

+static void curl_multi_do_locked(CURLSocket *socket)

 {

-    CURLSocket *socket, *next_socket;

-    CURLState *s = ready_socket->state;

+    BDRVCURLState *s = socket->state->s;

     int running;

     int r;

-    if (!s->s->multi) {

+    if (!s->multi) {

         return;

     }

-    /* Need to use _SAFE because curl_multi_socket_action() may trigger

-     * curl_sock_cb() which might modify this list */

-    QLIST_FOREACH_SAFE(socket, &s->sockets, next, next_socket) {

-        do {

-            r = curl_multi_socket_action(s->s->multi, socket->fd, 0, &running);

-        } while (r == CURLM_CALL_MULTI_PERFORM);

-    }

+    do {

+        r = curl_multi_socket_action(s->multi, socket->fd, 0, &running);

+    } while (r == CURLM_CALL_MULTI_PERFORM);

 }

 static void curl_multi_do(void *arg)

-- 

1.8.3.1