From e43c60b56401be7515d7fbfdfe3e4e56d1886a23 Mon Sep 17 00:00:00 2001 From: Mikhail Osipov Date: Tue, 26 May 2020 03:22:32 +0300 Subject: add tproxy listen option --- pkg/server/tunnel.go | 3 +-- 1 file changed, 1 insertion(+), 2 deletions(-) (limited to 'pkg/server/tunnel.go') 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() -- cgit v1.2.3-70-g09d2