backend/curl wake from loop when unpause fails

bdbai · bdbai · commit 0536daa936f6 · 2026-03-11T00:19:29.000+08:00
diff --git a/backends/curl/src/async/loop.rs b/backends/curl/src/async/loop.rs
@@ -422,6 +422,7 @@ fn run_loop(multl_waker_tx: oneshot::Sender<LoopManagerShared>) {
                     {
                         let res = Err(e.into());
                         ctx.state.lock().unwrap().result = RequestResult::Done { res, id };
+                        ctx.waker.wake();
                     }
                 }
                 LoopTask::UnpauseSendHandle(id) => {
@@ -437,6 +438,7 @@ fn run_loop(multl_waker_tx: oneshot::Sender<LoopManagerShared>) {
                     }) {
                         let res = Err(e.into());
                         ctx.state.lock().unwrap().result = RequestResult::Done { res, id };
+                        ctx.waker.wake();
                     }
                 }
                 LoopTask::DropHandle(id) => {

Original file line number	Diff line number	Diff line change
`@@ -422,6 +422,7 @@ fn run_loop(multl_waker_tx: oneshot::Sender<LoopManagerShared>) {`
`422`	`422`	`{`
`423`	`423`	`let res = Err(e.into());`
`424`	`424`	`ctx.state.lock().unwrap().result = RequestResult::Done { res, id };`
	`425`	`+ ctx.waker.wake();`
`425`	`426`	`}`
`426`	`427`	`}`
`427`	`428`	`LoopTask::UnpauseSendHandle(id) => {`
`@@ -437,6 +438,7 @@ fn run_loop(multl_waker_tx: oneshot::Sender<LoopManagerShared>) {`
`437`	`438`	`}) {`
`438`	`439`	`let res = Err(e.into());`
`439`	`440`	`ctx.state.lock().unwrap().result = RequestResult::Done { res, id };`
	`441`	`+ ctx.waker.wake();`
`440`	`442`	`}`
`441`	`443`	`}`
`442`	`444`	`LoopTask::DropHandle(id) => {`