diff options
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() |