hyper: use wakers for curl pause/resume

Closes #9070

diff --git a/lib/c-hyper.c b/lib/c-hyper.c
index 69b904e53157fbd1af63e3bc02165bd6aa7d617e..93b912c47cf1a87234281b0e23c0583084fe34a5 100644 (file)
--- a/lib/c-hyper.c
+++ b/lib/c-hyper.c
@@ -692,9 +692,18 @@ static int uploadstreamed(void *userdata, hyper_context *ctx,
     data->state.hresult = result;
     return HYPER_POLL_ERROR;
   }
-  if(!fillcount)
-    /* done! */
-    *chunk = NULL;
+  if(!fillcount) {
+    if((data->req.keepon & KEEP_SEND_PAUSE) != KEEP_SEND_PAUSE)
+      /* done! */
+      *chunk = NULL;
+    else {
+      /* paused, save a waker */
+      if(data->hyp.send_body_waker)
+        hyper_waker_free(data->hyp.send_body_waker);
+      data->hyp.send_body_waker = hyper_context_waker(ctx);
+      return HYPER_POLL_PENDING;
+    }
+  }
   else {
     hyper_buf *copy = hyper_buf_copy((uint8_t *)data->state.ulbuf, fillcount);
     if(copy)

diff --git a/lib/c-hyper.h b/lib/c-hyper.h
index 91a62619c38c9eeccefce0f31fe90535b6976504..70507ad2a4a81dc2593fccd46cd501074446caed 100644 (file)
--- a/lib/c-hyper.h
+++ b/lib/c-hyper.h
@@ -36,6 +36,7 @@ struct hyptransfer {
   const hyper_executor *exec;
   hyper_task *endtask;
   hyper_waker *exp100_waker;
+  hyper_waker *send_body_waker;
 };
 
 size_t Curl_hyper_recv(void *userp, hyper_context *ctx,

diff --git a/lib/easy.c b/lib/easy.c
index 704a59df624441dbec3d402bd756cc09d35a1e88..06a94b01b03f8c5425a7fb36b4e872eb28dfcfef 100644 (file)
--- a/lib/easy.c
+++ b/lib/easy.c
@@ -1132,6 +1132,16 @@ CURLcode curl_easy_pause(struct Curl_easy *data, int action)
     }
   }
 
+#ifdef USE_HYPER
+  if(!(newstate & KEEP_SEND_PAUSE)) {
+    /* need to wake the send body waker */
+    if(data->hyp.send_body_waker) {
+      hyper_waker_wake(data->hyp.send_body_waker);
+      data->hyp.send_body_waker = NULL;
+    }
+  }
+#endif
+
   /* if there's no error and we're not pausing both directions, we want
      to have this handle checked soon */
   if((newstate & (KEEP_RECV_PAUSE|KEEP_SEND_PAUSE)) !=

diff --git a/tests/data/DISABLED b/tests/data/DISABLED
index 00ebebc94999e18fdbc9f689c0671f9bd4527c09..4d62fb615eb12e1ce58be0c82dcbc6b6c2cd7bb2 100644 (file)
--- a/tests/data/DISABLED
+++ b/tests/data/DISABLED
@@ -69,10 +69,6 @@
 565
 579
 587
-670
-671
-672
-673
 # 1021 re-added here due to flakiness
 1021
 1117