github/injoyai-tdx
1
0
Fork 0
mirror of https://github.com/injoyai/tdx.git synced 2025-11-26 21:25:35 +08:00
Code Issues Packages Projects Releases Wiki Activity

去除超时时间参数

Browse Source
This commit is contained in:
钱纯净
2024-11-16 22:31:26 +08:00
parent 1863c20be5
commit c30866e110
2 changed files with 3 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
dial.go
View File

@@ -5,10 +5,9 @@ import (
"github.com/injoyai/ios" "github.com/injoyai/ios"
"net" "net"
"strings" "strings"
"time"
) )
func NewHostDial(hosts []string, timeout time.Duration) ios.DialFunc { func NewHostDial(hosts []string) ios.DialFunc {
if len(hosts) == 0 { if len(hosts) == 0 {
hosts = Hosts hosts = Hosts
} }
@@ -23,7 +22,7 @@ func NewHostDial(hosts []string, timeout time.Duration) ios.DialFunc {
if !strings.Contains(addr, ":") { if !strings.Contains(addr, ":") {
addr += ":7709" addr += ":7709"
} }
c, err := net.DialTimeout("tcp", addr, timeout) c, err := net.Dial("tcp", addr)
return c, hosts[index], err return c, hosts[index], err
} }
} }

2
example/common/common.go
View File

@@ -8,7 +8,7 @@ import (
func Test(f func(c *tdx.Client)) { func Test(f func(c *tdx.Client)) {
//重连方式1,优点,同一个客户端指针 //重连方式1,优点,同一个客户端指针
c, err := tdx.DialWith(tdx.NewHostDial(tdx.Hosts, 0), tdx.WithDebug()) c, err := tdx.DialWith(tdx.NewHostDial(tdx.Hosts), tdx.WithDebug())
logs.PanicErr(err) logs.PanicErr(err)
f(c) f(c)
<-c.Done() <-c.Done()