diff options
| author | Mikhail Osipov <mike.osipov@gmail.com> | 2020-02-20 04:56:03 +0300 |
|---|---|---|
| committer | Mikhail Osipov <mike.osipov@gmail.com> | 2020-02-20 05:01:44 +0300 |
| commit | 9e04a8bee8492cb662ebc8b7fd50a23c48c7d03f (patch) | |
| tree | b6185612b4d324953b29938ba1c342ce818ba947 /pkg/server/server.go | |
| parent | 14a67d759db99a2f9b87825e34dc45f6012c1549 (diff) | |
streams and tunnels
Diffstat (limited to 'pkg/server/server.go')
| -rw-r--r-- | pkg/server/server.go | 14 |
1 files changed, 7 insertions, 7 deletions
diff --git a/pkg/server/server.go b/pkg/server/server.go index 4f012d0..ce910f3 100644 --- a/pkg/server/server.go +++ b/pkg/server/server.go @@ -24,24 +24,24 @@ type Server struct { once sync.Once done chan struct{} - streams streams + tunnels automap env env - nextCid uint64 + nextCid int } type client struct { - id uint64 + id int s *Server conn net.Conn - nextRid uint64 + nextRid int } type request struct { - id uint64 + id int c *client @@ -135,7 +135,7 @@ func New() (*Server, error) { listen: listen, since: time.Now(), done: make(chan struct{}), - streams: make(streams), + tunnels: make(automap), } return s, nil @@ -307,7 +307,7 @@ func (r *request) run(query string) { r.parse(query) - log.Printf("%s %s run [%s] '%s'", r.c, r, r.cmd.name, strings.Join(r.args, " ")) + log.Println(r.c, r, ">", r.cmd.name, strings.Join(r.args, " ")) r.c.s.mu.Lock() defer r.c.s.mu.Unlock() |
