wg.Add(1)
		go func() {
			defer wg.Done()
			mu.Lock()
			mu.Unlock()
		}()
	}
	wg.Wait()
}

func blockCond(t *testing.T) {
	var mu sync.Mutex
	c := sync.NewCond(&mu)
	mu.Lock()
	go func() {
		awaitBlockedGoroutine(t, "sync.Cond.Wait", "blockCond", 1)
		mu.Lock()
		c.Signal()
		mu.Unlock()
	}()
	c.Wait()
	mu.Unlock()
}

	// our real tests. This idle connection used to block forever
	// in the TLS handshake, preventing future connections from
	// being accepted. It may prevent future accidental blocking
	// in newConn.
	idleConn, err := net.Dial("tcp", ts.Listener.Addr().String())
	if err != nil {
		t.Fatalf("Dial: %v", err)
	}
	defer idleConn.Close()

	if !strings.HasPrefix(ts.URL, "https://") {

		{"Conn.Reader", Field, 0},
		{"Conn.Writer", Field, 0},
		{"Dial", Func, 0},
		{"Error", Type, 0},
		{"Error.Code", Field, 0},
		{"Error.Msg", Field, 0},
		{"MIMEHeader", Type, 0},
		{"NewConn", Func, 0},
		{"NewReader", Func, 0},
		{"NewWriter", Func, 0},
		{"Pipeline", Type, 0},
		{"ProtocolError", Type, 0},
		{"Reader", Type, 0},
		{"Reader.R", Field, 0},
		{"TrimBytes", Func, 1},

		t.http2transportTestHooks.newclientconn(cc)
		c = cc.tconn
	}
	if http2VerboseLogs {
		t.vlogf("http2: Transport creating client conn %p to %v", cc, c.RemoteAddr())
	}

	cc.cond = sync.NewCond(&cc.mu)
	cc.flow.add(int32(http2initialWindowSize))

	// TODO: adjust this writer size to account for frame size +
	// MTU + crypto/tls record padding.
	cc.bw = bufio.NewWriter(http2stickyErrWriter{

pkg net/smtp, type ServerInfo struct, TLS bool
pkg net/textproto, func CanonicalMIMEHeaderKey(string) string
pkg net/textproto, func Dial(string, string) (*Conn, error)
pkg net/textproto, func NewConn(io.ReadWriteCloser) *Conn
pkg net/textproto, func NewReader(*bufio.Reader) *Reader
pkg net/textproto, func NewWriter(*bufio.Writer) *Writer
pkg net/textproto, method (*Conn) Close() error