git » go-net » commit be28236

diff --git a/http2/client_conn_pool.go b/http2/client_conn_pool.go
index 547e238..cb34cc2 100644
--- a/http2/client_conn_pool.go
+++ b/http2/client_conn_pool.go
@@ -53,7 +53,7 @@ const (
 )
 
 func (p *clientConnPool) getClientConn(req *http.Request, addr string, dialOnMiss bool) (*ClientConn, error) {
-	if req.Close && dialOnMiss {
+	if isConnectionCloseRequest(req) && dialOnMiss {
 		// It gets its own connection.
 		cc, err := p.t.dialClientConn(addr)
 		if err != nil {
diff --git a/http2/transport.go b/http2/transport.go
index fb8dd99..de3f5fe 100644
--- a/http2/transport.go
+++ b/http2/transport.go
@@ -1593,7 +1593,7 @@ func (rl *clientConnReadLoop) endStreamError(cs *clientStream, err error) {
 	}
 	cs.bufPipe.closeWithErrorAndCode(err, code)
 	delete(rl.activeRes, cs.ID)
-	if cs.req.Close || cs.req.Header.Get("Connection") == "close" {
+	if isConnectionCloseRequest(cs.req) {
 		rl.closeWhenIdle = true
 	}
 }
@@ -1866,3 +1866,9 @@ func (s bodyWriterState) scheduleBodyWrite() {
 		s.timer.Reset(s.delay)
 	}
 }
+
+// isConnectionCloseRequest reports whether req should use its own
+// connection for a single request and then close the connection.
+func isConnectionCloseRequest(req *http.Request) bool {
+	return req.Close || httplex.HeaderValuesContainsToken(req.Header["Connection"], "close")
+}