package main

import (
	"fmt"
	"net"
	"net/http"
	"time"
)

func main() {
	srv := &http.Server{
		WriteTimeout: -1 * time.Second,
	}

	ln, err := net.Listen("tcp", ":8088")
	if err != nil {
		panic(err)
	}
	go srv.Serve(ln)

	ln, err = net.Listen("tcp", ":8089")
	if err != nil {
		panic(err)
	}
	go runClient()

	err = srv.ServeTLS(ln, "/etc/nginx/openssl/eudore.cn/www.eudore.cn.pem", "/etc/nginx/openssl/eudore.cn/www.eudore.cn.key")
	if err != nil {
		panic(err)
	}
}

func runClient() {
	time.Sleep(time.Second)
	fmt.Println(http.Get("http://www.eudore.cn:8088"))
	fmt.Println(http.Get("https://www.eudore.cn:8089"))
}

func (c *conn) readRequest(ctx context.Context) (w *response, err error) {
	...
	if d := c.server.WriteTimeout; d > 0 {
		defer func() {
			c.rwc.SetWriteDeadline(time.Now().Add(d))
		}()
	}
	...
}

func (sc *http2serverConn) newStream(id, pusherID uint32, state http2streamState) *http2stream {
	...
	if sc.hs.WriteTimeout != 0 {
		st.writeDeadline = time.AfterFunc(sc.hs.WriteTimeout, st.onWriteTimeout)
	}
	...
}