unistack-org/micro
4
0
Fork 3
Code Issues 20 Pull Requests 1 Actions Packages Projects Releases 282 Wiki Activity

tunnel skip zero length nodes

Browse Source
This commit is contained in:
Asim Aslam 2019-08-08 13:15:30 +01:00
parent 1e496938b7
commit 59b13aef22
1 changed files with 8 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
tunnel/default.go
View File

@ -250,7 +250,7 @@ func (t *tun) connect() error {
go func() { go func() {
// accept inbound connections // accept inbound connections
err := l.Accept(func(sock transport.Socket) { err := l.Accept(func(sock transport.Socket) {
log.Debugf("Accepted connection from %s", sock.Remote()) log.Debugf("Tunnel accepted connection from %s", sock.Remote())
// save the link // save the link
id := uuid.New().String() id := uuid.New().String()
t.Lock() t.Lock()
@ -281,13 +281,18 @@ func (t *tun) connect() error {
}() }()
for _, node := range t.options.Nodes { for _, node := range t.options.Nodes {
log.Debugf("Dialing %s", node) // skip zero length nodes
if len(node) == 0 {
continue
}
log.Debugf("Tunnel dialing %s", node)
c, err := t.options.Transport.Dial(node) c, err := t.options.Transport.Dial(node)
if err != nil { if err != nil {
log.Debugf("Tunnel failed to connect to %s: %v", node, err) log.Debugf("Tunnel failed to connect to %s: %v", node, err)
continue continue
} }
log.Debugf("Connected to %s", node) log.Debugf("Tunnel connected to %s", node)
if err := c.Send(&transport.Message{ if err := c.Send(&transport.Message{
Header: map[string]string{ Header: map[string]string{