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 : 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"
)

// 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}}
}

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)
}

${this.title}

Code Editor : filetransport.go