diff options
Diffstat (limited to 'pkg/server')
| -rw-r--r-- | pkg/server/hook/info-http.go (renamed from pkg/server/hook/look-http.go) | 20 | ||||
| -rw-r--r-- | pkg/server/tunnel.go | 2 |
2 files changed, 11 insertions, 11 deletions
diff --git a/pkg/server/hook/look-http.go b/pkg/server/hook/info-http.go index 50ec663..7941072 100644 --- a/pkg/server/hook/look-http.go +++ b/pkg/server/hook/info-http.go @@ -8,13 +8,13 @@ import ( "tunnel/pkg/server/queue" ) -type lookHttpHook struct{} +type infoHttpHook struct{} -type lookHttp struct { +type infoHttp struct { env env.Env } -func (look *lookHttp) Send(rq, wq queue.Q) error { +func (info *infoHttp) Send(rq, wq queue.Q) error { q := queue.New() s := bufio.NewScanner(q.Reader()) @@ -29,7 +29,7 @@ func (look *lookHttp) Send(rq, wq queue.Q) error { if s.Scan() { if method, uri, _, ok := http.ParseRequestLine(s.Text()); ok { - look.env.Set("look.info", method+" "+uri) + info.env.Set("info", method+" "+uri) } } @@ -38,18 +38,18 @@ func (look *lookHttp) Send(rq, wq queue.Q) error { return nil } -func (look *lookHttp) Recv(rq, wq queue.Q) error { +func (info *infoHttp) Recv(rq, wq queue.Q) error { return queue.Copy(rq, wq) } -func (lookHttpHook) Open(env env.Env) (interface{}, error) { - return &lookHttp{env: env}, nil +func (infoHttpHook) Open(env env.Env) (interface{}, error) { + return &infoHttp{env: env}, nil } -func newLookHttpHook(opts opts.Opts, env env.Env) (hook, error) { - return lookHttpHook{}, nil +func newInfoHttpHook(opts opts.Opts, env env.Env) (hook, error) { + return infoHttpHook{}, nil } func init() { - register("look-http", newLookHttpHook) + register("info-http", newInfoHttpHook) } diff --git a/pkg/server/tunnel.go b/pkg/server/tunnel.go index e47215e..309c272 100644 --- a/pkg/server/tunnel.go +++ b/pkg/server/tunnel.go @@ -205,7 +205,7 @@ func (s *stream) info() string { } return fmt.Sprintf("%.3fs [%s] %d/%d -> %d/%d", - float64(d)/1000.0, s.env.Get("look.info"), + float64(d)/1000.0, s.env.Get("info"), s.m.in.tx, s.m.in.rx, s.m.out.rx, |
