idk/goSam
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Improve the parser, automatically set empty destinations to TRANSIENT when using a dialer, better error handling, when a socket gets closed, increment the ID and re-create it

Browse Source
This commit is contained in:
idk
2020-11-29 16:30:51 -05:00
parent 5fda56e88d
commit e2f73efb10
1 changed files with 5 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
dial.go
View File

@ -36,10 +36,10 @@ func (c *Client) DialContext(ctx context.Context, network, addr string) (net.Con
func (c *Client) dialCheck(addr string) (int32, bool) {
if c.lastaddr == "invalid" {
fmt.Println("Preparing to dial new address.")
return c.NewID(), true
} else if addr == "" {
return c.id, false
} else if c.lastaddr != addr {
fmt.Println("Preparing to dial next new address.")
return c.NewID(), true
}
return c.id, false
@ -58,7 +58,9 @@ func (c *Client) Dial(network, addr string) (net.Conn, error) {
return nil, err
}
// var test bool
c.id, _ = c.dialCheck(addr)
// if test {
c.destination, err = c.CreateStreamSession(c.id, c.destination)
if err != nil {
c.id += 1
@ -76,7 +78,7 @@ func (c *Client) Dial(network, addr string) (net.Conn, error) {
return nil, err
}
c.lastaddr = addr
//}
err = c.StreamConnect(c.id, addr)
if err != nil {
return nil, err