Method ServeHTTP

pkg/server/filters/timeout.go:75–95

(w http.ResponseWriter, r *http.Request)

}

func (t *timeoutHandler) ServeHTTP(w http.ResponseWriter, r *http.Request) {
	after, recordFn, err := t.timeout(r)
	if after == nil {
		t.handler.ServeHTTP(w, r)
		return
	}

	done := make(chan struct{})
	tw := newTimeoutWriter(w)
	go func() {
		t.handler.ServeHTTP(tw, r)
		close(done)
	}()
	select {
	case <-done:
	case <-after.C:
		recordFn()
		tw.timeout(err)
	}
	after.Stop()
}

type timeoutWriter interface {
	http.ResponseWriter