aboutsummaryrefslogtreecommitdiff
diff options
context:
space:
mode:
-rw-r--r--src/transport/plugin_transport_http.c5
1 files changed, 3 insertions, 2 deletions
diff --git a/src/transport/plugin_transport_http.c b/src/transport/plugin_transport_http.c
index 44e4c9aba..15b335aa3 100644
--- a/src/transport/plugin_transport_http.c
+++ b/src/transport/plugin_transport_http.c
@@ -1455,6 +1455,7 @@ static void curl_perform (void *cls,
1455 struct Plugin *plugin = cls; 1455 struct Plugin *plugin = cls;
1456 static unsigned int handles_last_run; 1456 static unsigned int handles_last_run;
1457 int running; 1457 int running;
1458 int msgs_in_queue;
1458 struct CURLMsg *msg; 1459 struct CURLMsg *msg;
1459 CURLMcode mret; 1460 CURLMcode mret;
1460 struct Session *ps = NULL; 1461 struct Session *ps = NULL;
@@ -1478,7 +1479,7 @@ static void curl_perform (void *cls,
1478 do 1479 do
1479 { 1480 {
1480 1481
1481 msg = curl_multi_info_read (plugin->multi_handle, &running); 1482 msg = curl_multi_info_read (plugin->multi_handle, &msgs_in_queue);
1482 if (running == 0) 1483 if (running == 0)
1483 break; 1484 break;
1484 /* get session for affected curl handle */ 1485 /* get session for affected curl handle */
@@ -1593,7 +1594,7 @@ static void curl_perform (void *cls,
1593 } 1594 }
1594 1595
1595 } 1596 }
1596 while ( (running > 0) ); 1597 while ( (msgs_in_queue > 0) );
1597 } 1598 }
1598 handles_last_run = running; 1599 handles_last_run = running;
1599 } 1600 }