summaryrefslogtreecommitdiff
path: root/pkg/server/socket
diff options
context:
space:
mode:
authorMikhail Osipov <mike.osipov@gmail.com>2020-02-23 16:07:22 +0300
committerMikhail Osipov <mike.osipov@gmail.com>2020-02-23 16:07:22 +0300
commitd3e48b2676c70ef20c33d70220c4a4b22f3a0e5b (patch)
tree76abee3f20891c4e1ef2077193e3d2389075ddeb /pkg/server/socket
parent7f71e4fc69e2b27d8ff6375cc6f4be2092721186 (diff)
make fmt
Diffstat (limited to 'pkg/server/socket')
-rw-r--r--pkg/server/socket/socket.go18
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,
}