package/requests
1
0
Fork 0
mirror of https://github.com/gospider007/requests.git synced 2025-12-24 13:57:52 +08:00
Code Issues Packages Projects Releases Wiki Activity

sync

Browse Source
This commit is contained in:
gospider
2024-12-15 22:07:56 +08:00
parent 59673bc7b2
commit a99675518f
1 changed files with 11 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

12
roundTripper.go
View File

@@ -264,7 +264,17 @@ func (obj *roundTripper) poolRoundTrip(option *RequestOption, pool *connPool, ta
func (obj *roundTripper) createPool(option *RequestOption, task *reqTask, key string) (isOk bool, err error) {
option.isNewConn = true
conn, err := obj.dial(option, task.req)
var conn *connecotr
done := make(chan struct{})
go func() {
conn, err = obj.dial(option, task.req)
close(done)
}()
select {
case <-obj.ctx.Done():
return true, obj.ctx.Err()
case <-done:
}
if err != nil {
if task.option.ErrCallBack != nil {
if err2 := task.option.ErrCallBack(task.req.Context(), task.option, nil, err); err2 != nil {