diff options
| author | Mikhail Osipov <mike.osipov@gmail.com> | 2020-05-26 03:22:32 +0300 |
|---|---|---|
| committer | Mikhail Osipov <mike.osipov@gmail.com> | 2020-05-26 03:22:32 +0300 |
| commit | e43c60b56401be7515d7fbfdfe3e4e56d1886a23 (patch) | |
| tree | 58711f3bbbe2b34e91836087c274773564e29029 /pkg/server/tunnel.go | |
| parent | 97802849e3a21952e6c5896622d52153b2d96ee7 (diff) | |
add tproxy listen option
Diffstat (limited to 'pkg/server/tunnel.go')
| -rw-r--r-- | pkg/server/tunnel.go | 3 |
1 files changed, 1 insertions, 2 deletions
diff --git a/pkg/server/tunnel.go b/pkg/server/tunnel.go index d54208b..ccd501e 100644 --- a/pkg/server/tunnel.go +++ b/pkg/server/tunnel.go @@ -157,6 +157,7 @@ func (t *tunnel) serve() { env := t.env.Fork() env.Set("tunnel", t.id) + env.Set("stream", strconv.Itoa(t.nextSid)) if in, err := t.in.Open(env); err != nil { if t.alive() { @@ -195,8 +196,6 @@ func (t *tunnel) newStream(env env.Env, in, out socket.Conn, pipes []*hook.Pipe) since: time.Now(), } - s.env.Set("stream", strconv.Itoa(s.id)) - s.run() t.mu.Lock() |