yggdrasil-network/yggdrasil-go
1
0
Fork 0
mirror of https://github.com/yggdrasil-network/yggdrasil-go.git synced 2025-04-29 14:45:07 +03:00
Code Issues Projects Releases Packages Wiki Activity Actions

1. merge isses fix

Browse source
This commit is contained in:
vadym 2022-10-28 18:00:08 +03:00
parent d8a4000141
commit d73c77e9d1
1 changed files with 4 additions and 4 deletions
Download patch file Download diff file Expand all files Collapse all files

8
src/core/link_other.go
View file

@ -72,14 +72,14 @@ func (l *links) call(u *url.URL, sintf string) (linkInfo, error) {
switch info.linkType { switch info.linkType {
case "tcp": case "tcp":
go func() { go func() {
if err := l.tcp.dial(u, options, sintf); err != nil && err != io.EOF if err := l.tcp.dial(u, options, sintf); err != nil && err != io.EOF {
l.core.log.Warnf("Failed to dial TCP %s: %s\n", u.Host, err) l.core.log.Warnf("Failed to dial TCP %s: %s\n", u.Host, err)
} }
}() }()
case "socks": case "socks":
go func() { go func() {
if err := l.socks.dial(u, options); err != nil && err != io.EOF if err := l.socks.dial(u, options); err != nil && err != io.EOF {
l.core.log.Warnf("Failed to dial SOCKS %s: %s\n", u.Host, err) l.core.log.Warnf("Failed to dial SOCKS %s: %s\n", u.Host, err)
} }
}() }()
@ -103,7 +103,7 @@ func (l *links) call(u *url.URL, sintf string) (linkInfo, error) {
} }
} }
go func() { go func() {
if err := l.tls.dial(u, options, sintf, tlsSNI); err != nil && err != io.EOF if err := l.tls.dial(u, options, sintf, tlsSNI); err != nil && err != io.EOF {
l.core.log.Warnf("Failed to dial TLS %s: %s\n", u.Host, err) l.core.log.Warnf("Failed to dial TLS %s: %s\n", u.Host, err)
} }
}() }()
@ -111,10 +111,10 @@ func (l *links) call(u *url.URL, sintf string) (linkInfo, error) {
case "unix": case "unix":
go func() { go func() {
if err := l.unix.dial(u, options, sintf); err != nil && err != io.EOF { if err := l.unix.dial(u, options, sintf); err != nil && err != io.EOF {
if err := l.unix.dial(u, options, sintf); err != nil {
l.core.log.Warnf("Failed to dial UNIX %s: %s\n", u.Host, err) l.core.log.Warnf("Failed to dial UNIX %s: %s\n", u.Host, err)
} }
}() }()
case "mpath": case "mpath":
go func() { go func() {
if err := l.mpath.dial(u, options, sintf); err != nil && err != io.EOF { if err := l.mpath.dial(u, options, sintf); err != nil && err != io.EOF {