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: filetransport.go

// Copyright 2011 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

import (
	"fmt"
	"io"
	"io/fs"
)

// fileTransport implements RoundTripper for the 'file' protocol.
type fileTransport struct {
	fh fileHandler
}

// NewFileTransport returns a new [RoundTripper], serving the provided
// [FileSystem]. The returned RoundTripper ignores the URL host in its
// incoming requests, as well as most other properties of the
// request.
//
// The typical use case for NewFileTransport is to register the "file"
// protocol with a [Transport], as in:
//
//	t := &http.Transport{}
//	t.RegisterProtocol("file", http.NewFileTransport(http.Dir("/")))
//	c := &http.Client{Transport: t}
//	res, err := c.Get("file:///etc/passwd")
//	...
func NewFileTransport(fs FileSystem) RoundTripper {
	return fileTransport{fileHandler{fs}}
}

// NewFileTransportFS returns a new [RoundTripper], serving the provided
// file system fsys. The returned RoundTripper ignores the URL host in its
// incoming requests, as well as most other properties of the
// request.
//
// The typical use case for NewFileTransportFS is to register the "file"
// protocol with a [Transport], as in:
//
//	fsys := os.DirFS("/")
//	t := &http.Transport{}
//	t.RegisterProtocol("file", http.NewFileTransportFS(fsys))
//	c := &http.Client{Transport: t}
//	res, err := c.Get("file:///etc/passwd")
//	...
func NewFileTransportFS(fsys fs.FS) RoundTripper {
	return NewFileTransport(FS(fsys))
}

func (t fileTransport) RoundTrip(req *Request) (resp *Response, err error) {
	// We start ServeHTTP in a goroutine, which may take a long
	// time if the file is large. The newPopulateResponseWriter
	// call returns a channel which either ServeHTTP or finish()
	// sends our *Response on, once the *Response itself has been
	// populated (even if the body itself is still being
	// written to the res.Body, a pipe)
	rw, resc := newPopulateResponseWriter()
	go func() {
		t.fh.ServeHTTP(rw, req)
		rw.finish()
	}()
	return <-resc, nil
}

func newPopulateResponseWriter() (*populateResponse, <-chan *Response) {
	pr, pw := io.Pipe()
	rw := &populateResponse{
		ch: make(chan *Response),
		pw: pw,
		res: &Response{
			Proto:      "HTTP/1.0",
			ProtoMajor: 1,
			Header:     make(Header),
			Close:      true,
			Body:       pr,
		},
	}
	return rw, rw.ch
}

// populateResponse is a ResponseWriter that populates the *Response
// in res, and writes its body to a pipe connected to the response
// body. Once writes begin or finish() is called, the response is sent
// on ch.
type populateResponse struct {
	res          *Response
	ch           chan *Response
	wroteHeader  bool
	hasContent   bool
	sentResponse bool
	pw           *io.PipeWriter
}

func (pr *populateResponse) finish() {
	if !pr.wroteHeader {
		pr.WriteHeader(500)
	}
	if !pr.sentResponse {
		pr.sendResponse()
	}
	pr.pw.Close()
}

func (pr *populateResponse) sendResponse() {
	if pr.sentResponse {
		return
	}
	pr.sentResponse = true

if pr.hasContent {
		pr.res.ContentLength = -1
	}
	pr.ch <- pr.res
}

func (pr *populateResponse) Header() Header {
	return pr.res.Header
}

func (pr *populateResponse) WriteHeader(code int) {
	if pr.wroteHeader {
		return
	}
	pr.wroteHeader = true

pr.res.StatusCode = code
	pr.res.Status = fmt.Sprintf("%d %s", code, StatusText(code))
}

func (pr *populateResponse) Write(p []byte) (n int, err error) {
	if !pr.wroteHeader {
		pr.WriteHeader(StatusOK)
	}
	pr.hasContent = true
	if !pr.sentResponse {
		pr.sendResponse()
	}
	return pr.pw.Write(p)
}

X7ROOT File Manager

Editing: filetransport.go

Upload File

Create Folder