File Manager

X7ROOT File Manager

Current Path: /opt/golang/1.22.0/src/net/http

opt / golang / 1.22.0 / src / net / http /

📁 ..
📄 alpn_test.go(3.01 KB)
📁 cgi
📄 client.go(33.4 KB)
📄 client_test.go(63.24 KB)
📄 clientserver_test.go(46.07 KB)
📄 clone.go(1.56 KB)
📄 cookie.go(11.53 KB)
📄 cookie_test.go(19.26 KB)
📁 cookiejar
📄 doc.go(3.42 KB)
📄 example_filesystem_test.go(2.04 KB)
📄 example_handle_test.go(560 B)
📄 example_test.go(5.38 KB)
📄 export_test.go(8.43 KB)
📁 fcgi
📄 filetransport.go(3.52 KB)
📄 filetransport_test.go(2.62 KB)
📄 fs.go(30.36 KB)
📄 fs_test.go(46.7 KB)
📄 h2_bundle.go(357.28 KB)
📄 h2_error.go(812 B)
📄 h2_error_test.go(1.04 KB)
📄 header.go(7.9 KB)
📄 header_test.go(6.05 KB)
📄 http.go(5.13 KB)
📄 http_test.go(5.22 KB)
📁 httptest
📁 httptrace
📁 httputil
📁 internal
📄 jar.go(900 B)
📄 main_test.go(4.94 KB)
📄 mapping.go(1.68 KB)
📄 mapping_test.go(2.95 KB)
📄 method.go(517 B)
📄 omithttp2.go(1.91 KB)
📄 pattern.go(15.17 KB)
📄 pattern_test.go(14.5 KB)
📁 pprof
📄 proxy_test.go(1.16 KB)
📄 range_test.go(2.38 KB)
📄 readrequest_test.go(9.7 KB)
📄 request.go(48.34 KB)
📄 request_test.go(42.39 KB)
📄 requestwrite_test.go(23.3 KB)
📄 response.go(11.1 KB)
📄 response_test.go(23.63 KB)
📄 responsecontroller.go(4.17 KB)
📄 responsecontroller_test.go(9.81 KB)
📄 responsewrite_test.go(6.89 KB)
📄 roundtrip.go(566 B)
📄 roundtrip_js.go(11.8 KB)
📄 routing_index.go(3.95 KB)
📄 routing_index_test.go(4.02 KB)
📄 routing_tree.go(7.48 KB)
📄 routing_tree_test.go(6.89 KB)
📄 serve_test.go(192.54 KB)
📄 servemux121.go(5.6 KB)
📄 server.go(120.67 KB)
📄 server_test.go(6.95 KB)
📄 sniff.go(7.9 KB)
📄 sniff_test.go(9.56 KB)
📄 socks_bundle.go(12.9 KB)
📄 status.go(7.45 KB)
📁 testdata
📄 transfer.go(30.89 KB)
📄 transfer_test.go(9.13 KB)
📄 transport.go(87.81 KB)
📄 transport_default_other.go(362 B)
📄 transport_default_wasm.go(364 B)
📄 transport_internal_test.go(6.05 KB)
📄 transport_test.go(186.06 KB)
📄 triv.go(3.22 KB)

Editing: transport_internal_test.go

// Copyright 2016 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.

// White-box tests for transport.go (in package http instead of http_test).

package http

import (
	"bytes"
	"crypto/tls"
	"errors"
	"io"
	"net"
	"net/http/internal/testcert"
	"strings"
	"testing"
)

// Issue 15446: incorrect wrapping of errors when server closes an idle connection.
func TestTransportPersistConnReadLoopEOF(t *testing.T) {
	ln := newLocalListener(t)
	defer ln.Close()

connc := make(chan net.Conn, 1)
	go func() {
		defer close(connc)
		c, err := ln.Accept()
		if err != nil {
			t.Error(err)
			return
		}
		connc <- c
	}()

tr := new(Transport)
	req, _ := NewRequest("GET", "http://"+ln.Addr().String(), nil)
	req = req.WithT(t)
	treq := &transportRequest{Request: req}
	cm := connectMethod{targetScheme: "http", targetAddr: ln.Addr().String()}
	pc, err := tr.getConn(treq, cm)
	if err != nil {
		t.Fatal(err)
	}
	defer pc.close(errors.New("test over"))

conn := <-connc
	if conn == nil {
		// Already called t.Error in the accept goroutine.
		return
	}
	conn.Close() // simulate the server hanging up on the client

_, err = pc.roundTrip(treq)
	if !isNothingWrittenError(err) && !isTransportReadFromServerError(err) && err != errServerClosedIdle {
		t.Errorf("roundTrip = %#v, %v; want errServerClosedIdle, transportReadFromServerError, or nothingWrittenError", err, err)
	}

<-pc.closech
	err = pc.closed
	if !isTransportReadFromServerError(err) && err != errServerClosedIdle {
		t.Errorf("pc.closed = %#v, %v; want errServerClosedIdle or transportReadFromServerError", err, err)
	}
}

func isNothingWrittenError(err error) bool {
	_, ok := err.(nothingWrittenError)
	return ok
}

func isTransportReadFromServerError(err error) bool {
	_, ok := err.(transportReadFromServerError)
	return ok
}

func newLocalListener(t *testing.T) net.Listener {
	ln, err := net.Listen("tcp", "127.0.0.1:0")
	if err != nil {
		ln, err = net.Listen("tcp6", "[::1]:0")
	}
	if err != nil {
		t.Fatal(err)
	}
	return ln
}

func dummyRequest(method string) *Request {
	req, err := NewRequest(method, "http://fake.tld/", nil)
	if err != nil {
		panic(err)
	}
	return req
}
func dummyRequestWithBody(method string) *Request {
	req, err := NewRequest(method, "http://fake.tld/", strings.NewReader("foo"))
	if err != nil {
		panic(err)
	}
	return req
}

func dummyRequestWithBodyNoGetBody(method string) *Request {
	req := dummyRequestWithBody(method)
	req.GetBody = nil
	return req
}

// issue22091Error acts like a golang.org/x/net/http2.ErrNoCachedConn.
type issue22091Error struct{}

func (issue22091Error) IsHTTP2NoCachedConnError() {}
func (issue22091Error) Error() string             { return "issue22091Error" }

func TestTransportShouldRetryRequest(t *testing.T) {
	tests := []struct {
		pc  *persistConn
		req *Request

err  error
		want bool
	}{
		0: {
			pc:   &persistConn{reused: false},
			req:  dummyRequest("POST"),
			err:  nothingWrittenError{},
			want: false,
		},
		1: {
			pc:   &persistConn{reused: true},
			req:  dummyRequest("POST"),
			err:  nothingWrittenError{},
			want: true,
		},
		2: {
			pc:   &persistConn{reused: true},
			req:  dummyRequest("POST"),
			err:  http2ErrNoCachedConn,
			want: true,
		},
		3: {
			pc:   nil,
			req:  nil,
			err:  issue22091Error{}, // like an external http2ErrNoCachedConn
			want: true,
		},
		4: {
			pc:   &persistConn{reused: true},
			req:  dummyRequest("POST"),
			err:  errMissingHost,
			want: false,
		},
		5: {
			pc:   &persistConn{reused: true},
			req:  dummyRequest("POST"),
			err:  transportReadFromServerError{},
			want: false,
		},
		6: {
			pc:   &persistConn{reused: true},
			req:  dummyRequest("GET"),
			err:  transportReadFromServerError{},
			want: true,
		},
		7: {
			pc:   &persistConn{reused: true},
			req:  dummyRequest("GET"),
			err:  errServerClosedIdle,
			want: true,
		},
		8: {
			pc:   &persistConn{reused: true},
			req:  dummyRequestWithBody("POST"),
			err:  nothingWrittenError{},
			want: true,
		},
		9: {
			pc:   &persistConn{reused: true},
			req:  dummyRequestWithBodyNoGetBody("POST"),
			err:  nothingWrittenError{},
			want: false,
		},
	}
	for i, tt := range tests {
		got := tt.pc.shouldRetryRequest(tt.req, tt.err)
		if got != tt.want {
			t.Errorf("%d. shouldRetryRequest = %v; want %v", i, got, tt.want)
		}
	}
}

type roundTripFunc func(r *Request) (*Response, error)

func (f roundTripFunc) RoundTrip(r *Request) (*Response, error) {
	return f(r)
}

// Issue 25009
func TestTransportBodyAltRewind(t *testing.T) {
	cert, err := tls.X509KeyPair(testcert.LocalhostCert, testcert.LocalhostKey)
	if err != nil {
		t.Fatal(err)
	}
	ln := newLocalListener(t)
	defer ln.Close()

go func() {
		tln := tls.NewListener(ln, &tls.Config{
			NextProtos:   []string{"foo"},
			Certificates: []tls.Certificate{cert},
		})
		for i := 0; i < 2; i++ {
			sc, err := tln.Accept()
			if err != nil {
				t.Error(err)
				return
			}
			if err := sc.(*tls.Conn).Handshake(); err != nil {
				t.Error(err)
				return
			}
			sc.Close()
		}
	}()

addr := ln.Addr().String()
	req, _ := NewRequest("POST", "https://example.org/", bytes.NewBufferString("request"))
	roundTripped := false
	tr := &Transport{
		DisableKeepAlives: true,
		TLSNextProto: map[string]func(string, *tls.Conn) RoundTripper{
			"foo": func(authority string, c *tls.Conn) RoundTripper {
				return roundTripFunc(func(r *Request) (*Response, error) {
					n, _ := io.Copy(io.Discard, r.Body)
					if n == 0 {
						t.Error("body length is zero")
					}
					if roundTripped {
						return &Response{
							Body:       NoBody,
							StatusCode: 200,
						}, nil
					}
					roundTripped = true
					return nil, http2noCachedConnError{}
				})
			},
		},
		DialTLS: func(_, _ string) (net.Conn, error) {
			tc, err := tls.Dial("tcp", addr, &tls.Config{
				InsecureSkipVerify: true,
				NextProtos:         []string{"foo"},
			})
			if err != nil {
				return nil, err
			}
			if err := tc.Handshake(); err != nil {
				return nil, err
			}
			return tc, nil
		},
	}
	c := &Client{Transport: tr}
	_, err = c.Do(req)
	if err != nil {
		t.Error(err)
	}
}

X7ROOT File Manager

Editing: transport_internal_test.go

Upload File

Create Folder