mirror of
https://github.com/Mrs4s/MiraiGo.git
synced 2025-05-04 11:07:40 +08:00
fix socket block (#236)
This commit is contained in:
parent
7bec167fa7
commit
4f3862fd87
@ -8,6 +8,7 @@ import (
|
||||
"net"
|
||||
"net/http"
|
||||
"sync/atomic"
|
||||
"time"
|
||||
|
||||
"github.com/pkg/errors"
|
||||
|
||||
@ -48,7 +49,7 @@ type Input struct {
|
||||
func (s *Session) Upload(addr Addr, input Input) error {
|
||||
fh, length := utils.ComputeMd5AndLength(input.Body)
|
||||
_, _ = input.Body.Seek(0, io.SeekStart)
|
||||
conn, err := net.DialTCP("tcp", nil, addr.asTcpAddr())
|
||||
conn, err := net.DialTimeout("tcp", addr.String(), time.Second*3)
|
||||
if err != nil {
|
||||
return errors.Wrap(err, "connect error")
|
||||
}
|
||||
|
Loading…
x
Reference in New Issue
Block a user