Gecko [ 167.86.127.34 ]

Name	Size	Permission
cgi	[ DIR ]	drwxr-xr-x
cookiejar	[ DIR ]	drwxr-xr-x
fcgi	[ DIR ]	drwxr-xr-x
httptest	[ DIR ]	drwxr-xr-x
httptrace	[ DIR ]	drwxr-xr-x
httputil	[ DIR ]	drwxr-xr-x
internal	[ DIR ]	drwxr-xr-x
pprof	[ DIR ]	drwxr-xr-x
testdata	[ DIR ]	drwxr-xr-x
alpn_test.go	3.03 KB	-rw-r--r--
client.go	31.47 KB	-rw-r--r--
client_test.go	55.36 KB	-rw-r--r--
clientserver_test.go	42.36 KB	-rw-r--r--
clone.go	1.56 KB	-rw-r--r--
cookie.go	10.76 KB	-rw-r--r--
cookie_test.go	17.74 KB	-rw-r--r--
doc.go	3.44 KB	-rw-r--r--
example_filesystem_test.go	2.03 KB	-rw-r--r--
example_handle_test.go	560 B	-rw-r--r--
example_test.go	5.28 KB	-rw-r--r--
export_test.go	7.43 KB	-rw-r--r--
filetransport.go	2.9 KB	-rw-r--r--
filetransport_test.go	1.61 KB	-rw-r--r--
fs.go	23.36 KB	-rw-r--r--
fs_test.go	35.21 KB	-rw-r--r--
h2_bundle.go	320.65 KB	-rw-r--r--
header.go	7.36 KB	-rw-r--r--
header_test.go	5.58 KB	-rw-r--r--
http.go	4.95 KB	-rw-r--r--
http_test.go	4.43 KB	-rw-r--r--
jar.go	900 B	-rw-r--r--
main_test.go	4.41 KB	-rw-r--r--
method.go	517 B	-rw-r--r--
omithttp2.go	1.85 KB	-rw-r--r--
proxy_test.go	1.13 KB	-rw-r--r--
range_test.go	2.38 KB	-rw-r--r--
readrequest_test.go	9.71 KB	-rw-r--r--
request.go	44.68 KB	-rw-r--r--
request_test.go	31.96 KB	-rw-r--r--
requestwrite_test.go	22.79 KB	-rw-r--r--
response.go	10.76 KB	-rw-r--r--
response_test.go	24.05 KB	-rw-r--r--
responsewrite_test.go	6.94 KB	-rw-r--r--
roundtrip.go	563 B	-rw-r--r--
roundtrip_js.go	9.11 KB	-rw-r--r--
serve_test.go	171.18 KB	-rw-r--r--
server.go	105.67 KB	-rw-r--r--
server_test.go	1.19 KB	-rw-r--r--
sniff.go	8 KB	-rw-r--r--
sniff_test.go	8.09 KB	-rw-r--r--
socks_bundle.go	12.93 KB	-rw-r--r--
status.go	7.26 KB	-rw-r--r--
transfer.go	30.3 KB	-rw-r--r--
transfer_test.go	7.31 KB	-rw-r--r--
transport.go	81.6 KB	-rw-r--r--
transport_internal_test.go	5.91 KB	-rw-r--r--
transport_test.go	159.07 KB	-rw-r--r--
triv.go	3.2 KB	-rw-r--r--

Code Editor : main_test.go

// Copyright 2013 The Go Authors. All rights reserved.
// Use of this source code is governed by a BSD-style
// license that can be found in the LICENSE file.

package http_test

import (
	"fmt"
	"io/ioutil"
	"log"
	"net/http"
	"os"
	"runtime"
	"sort"
	"strings"
	"testing"
	"time"
)

var quietLog = log.New(ioutil.Discard, "", 0)

func TestMain(m *testing.M) {
	v := m.Run()
	if v == 0 && goroutineLeaked() {
		os.Exit(1)
	}
	os.Exit(v)
}

func interestingGoroutines() (gs []string) {
	buf := make([]byte, 2<<20)
	buf = buf[:runtime.Stack(buf, true)]
	for _, g := range strings.Split(string(buf), "\n\n") {
		sl := strings.SplitN(g, "\n", 2)
		if len(sl) != 2 {
			continue
		}
		stack := strings.TrimSpace(sl[1])
		if stack == "" ||
			strings.Contains(stack, "testing.(*M).before.func1") ||
			strings.Contains(stack, "os/signal.signal_recv") ||
			strings.Contains(stack, "created by net.startServer") ||
			strings.Contains(stack, "created by testing.RunTests") ||
			strings.Contains(stack, "closeWriteAndWait") ||
			strings.Contains(stack, "testing.Main(") ||
			// These only show up with GOTRACEBACK=2; Issue 5005 (comment 28)
			strings.Contains(stack, "runtime.goexit") ||
			strings.Contains(stack, "created by runtime.gc") ||
			strings.Contains(stack, "net/http_test.interestingGoroutines") ||
			strings.Contains(stack, "runtime.MHeap_Scavenger") {
			continue
		}
		gs = append(gs, stack)
	}
	sort.Strings(gs)
	return
}

// Verify the other tests didn't leave any goroutines running.
func goroutineLeaked() bool {
	if testing.Short() || runningBenchmarks() {
		// Don't worry about goroutine leaks in -short mode or in
		// benchmark mode. Too distracting when there are false positives.
		return false
	}

var stackCount map[string]int
	for i := 0; i < 5; i++ {
		n := 0
		stackCount = make(map[string]int)
		gs := interestingGoroutines()
		for _, g := range gs {
			stackCount[g]++
			n++
		}
		if n == 0 {
			return false
		}
		// Wait for goroutines to schedule and die off:
		time.Sleep(100 * time.Millisecond)
	}
	fmt.Fprintf(os.Stderr, "Too many goroutines running after net/http test(s).\n")
	for stack, count := range stackCount {
		fmt.Fprintf(os.Stderr, "%d instances of:\n%s\n", count, stack)
	}
	return true
}

// setParallel marks t as a parallel test if we're in short mode
// (all.bash), but as a serial test otherwise. Using t.Parallel isn't
// compatible with the afterTest func in non-short mode.
func setParallel(t *testing.T) {
	if strings.Contains(t.Name(), "HTTP2") {
		http.CondSkipHTTP2(t)
	}
	if testing.Short() {
		t.Parallel()
	}
}

func runningBenchmarks() bool {
	for i, arg := range os.Args {
		if strings.HasPrefix(arg, "-test.bench=") && !strings.HasSuffix(arg, "=") {
			return true
		}
		if arg == "-test.bench" && i < len(os.Args)-1 && os.Args[i+1] != "" {
			return true
		}
	}
	return false
}

func afterTest(t testing.TB) {
	http.DefaultTransport.(*http.Transport).CloseIdleConnections()
	if testing.Short() {
		return
	}
	var bad string
	badSubstring := map[string]string{
		").readLoop(":  "a Transport",
		").writeLoop(": "a Transport",
		"created by net/http/httptest.(*Server).Start": "an httptest.Server",
		"timeoutHandler":        "a TimeoutHandler",
		"net.(*netFD).connect(": "a timing out dial",
		").noteClientGone(":     "a closenotifier sender",
	}
	var stacks string
	for i := 0; i < 10; i++ {
		bad = ""
		stacks = strings.Join(interestingGoroutines(), "\n\n")
		for substr, what := range badSubstring {
			if strings.Contains(stacks, substr) {
				bad = what
			}
		}
		if bad == "" {
			return
		}
		// Bad stuff found, but goroutines might just still be
		// shutting down, so give it some time.
		time.Sleep(250 * time.Millisecond)
	}
	t.Errorf("Test appears to have leaked %s:\n%s", bad, stacks)
}

// waitCondition reports whether fn eventually returned true,
// checking immediately and then every checkEvery amount,
// until waitFor has elapsed, at which point it returns false.
func waitCondition(waitFor, checkEvery time.Duration, fn func() bool) bool {
	deadline := time.Now().Add(waitFor)
	for time.Now().Before(deadline) {
		if fn() {
			return true
		}
		time.Sleep(checkEvery)
	}
	return false
}

// waitErrCondition is like waitCondition but with errors instead of bools.
func waitErrCondition(waitFor, checkEvery time.Duration, fn func() error) error {
	deadline := time.Now().Add(waitFor)
	var err error
	for time.Now().Before(deadline) {
		if err = fn(); err == nil {
			return nil
		}
		time.Sleep(checkEvery)
	}
	return err
}

${this.title}

Code Editor : main_test.go