修改连接方法
This commit is contained in:
@@ -8,10 +8,15 @@ import (
|
|||||||
"net"
|
"net"
|
||||||
"os"
|
"os"
|
||||||
"strconv"
|
"strconv"
|
||||||
|
"sync"
|
||||||
"time"
|
"time"
|
||||||
)
|
)
|
||||||
|
|
||||||
|
var mu sync.Mutex
|
||||||
|
|
||||||
func DialADB(addr string, timeout time.Duration) (net.Conn, error) {
|
func DialADB(addr string, timeout time.Duration) (net.Conn, error) {
|
||||||
|
mu.Lock()
|
||||||
|
defer mu.Unlock()
|
||||||
d := net.Dialer{Timeout: timeout}
|
d := net.Dialer{Timeout: timeout}
|
||||||
return d.Dial("tcp", addr)
|
return d.Dial("tcp", addr)
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user