This commit is contained in:
gospider
2025-06-30 14:34:45 +08:00
parent 90d1fd4015
commit aec0c7aa25

View File

@@ -89,8 +89,8 @@ func (obj *connPool) taskMain(conn *connecotr, task *reqTask) (err error) {
select {
case <-conn.forceCtx.Done():
err = context.Cause(conn.forceCtx)
case <-task.ctx.Done():
err = context.Cause(task.ctx)
case <-task.reqCtx.Context().Done():
err = context.Cause(task.reqCtx.Context())
case <-task.bodyCtx.Done():
if context.Cause(task.bodyCtx) != errNoErr {
err = context.Cause(task.bodyCtx)