diff options
Diffstat (limited to 'pkg/server/socket/socket.go')
| -rw-r--r-- | pkg/server/socket/socket.go | 18 |
1 files changed, 9 insertions, 9 deletions
diff --git a/pkg/server/socket/socket.go b/pkg/server/socket/socket.go index c6219a5..48a650c 100644 --- a/pkg/server/socket/socket.go +++ b/pkg/server/socket/socket.go @@ -1,14 +1,14 @@ package socket import ( - "tunnel/pkg/server/queue" - "tunnel/pkg/server/opts" - "tunnel/pkg/server/env" - "strings" - "sync" "fmt" "log" "net" + "strings" + "sync" + "tunnel/pkg/server/env" + "tunnel/pkg/server/opts" + "tunnel/pkg/server/queue" ) type Channel interface { @@ -24,7 +24,7 @@ type S interface { type listenSocket struct { proto, addr string - listen net.Listener + listen net.Listener } type dialSocket struct { @@ -69,7 +69,7 @@ func (cc *connChannel) String() string { func (cc *connChannel) shutdown(err *error) { miss := true - cc.once.Do(func () { + cc.once.Do(func() { miss = false log.Println("close", cc) if e := cc.conn.Close(); e != nil && *err != nil { @@ -100,8 +100,8 @@ func newListenSocket(proto, addr string) (S, error) { } s := &listenSocket{ - proto: proto, - addr: addr, + proto: proto, + addr: addr, listen: listen, } |