Lines Matching refs:Request
130 // reqBytes treats req as a request (with \n delimiters) and returns it with \r\n delimiters,
172 ch := make(chan *Request)
175 handler := func(res ResponseWriter, req *Request) {
184 var req *Request
187 t.Fatal("Got nil first request.")
190 t.Errorf("For request #1's method, got %q; expected %q",
196 t.Fatal("Got nil first request.")
199 t.Errorf("For request #2's method, got %q; expected %q",
210 func (s stringHandler) ServeHTTP(w ResponseWriter, r *Request) {
258 var req Request
264 t.Errorf("writing request: %v", err)
302 return func(w ResponseWriter, r *Request) {
310 func checkQueryStringHandler(w ResponseWriter, r *Request) {
366 r := &Request{
395 // mux.Handler() shouldn't clear the request's query string.
411 r := &Request{
472 writeBackQuery := func(w ResponseWriter, r *Request) {
480 mux.HandleFunc("/testThree/", func(w ResponseWriter, r *Request) {
589 req *Request
601 req: &Request{Method: "GET", Host: "localhost", URL: &url.URL{Path: p}},
645 ts := httptest.NewUnstartedServer(HandlerFunc(func(res ResponseWriter, req *Request) {
663 return fmt.Errorf("Unexpected response for request #1; got %q ,%v; expected %q, nil",
724 ts := httptest.NewUnstartedServer(HandlerFunc(func(res ResponseWriter, req *Request) {}))
790 ts := httptest.NewUnstartedServer(HandlerFunc(func(res ResponseWriter, req *Request) {
793 return // first request succeeds
795 time.Sleep(timeout) // second request times out
851 ts := httptest.NewUnstartedServer(HandlerFunc(func(res ResponseWriter, req *Request) {
854 return // first request succeeds
856 time.Sleep(timeout) // second request timesout
886 // request) that will never happen.
895 ts := httptest.NewUnstartedServer(HandlerFunc(func(w ResponseWriter, req *Request) {
932 t.Errorf("expected an error from Get request")
964 handler := HandlerFunc(func(rw ResponseWriter, req *Request) {
1058 res, err := ReadResponse(r, &Request{Method: "GET"})
1112 testTCPConnectionCloses(t, "GET / HTTP/1.0\r\n\r\n", HandlerFunc(func(w ResponseWriter, r *Request) {
1119 testTCPConnectionCloses(t, "GET / HTTP/1.1\r\nHost: foo\r\nConnection: close\r\n\r\n", HandlerFunc(func(w ResponseWriter, r *Request) {
1127 testTCPConnectionCloses(t, "GET / HTTP/1.1\r\nHost: foo\r\n\r\n\r\n", HandlerFunc(func(w ResponseWriter, r *Request) {
1133 testTCPConnectionCloses(t, "GET / HTTP/1.0\r\nConnection: keep-alive\r\n\r\n", HandlerFunc(func(w ResponseWriter, r *Request) {
1139 testTCPConnectionCloses(t, "PRI * HTTP/2.0\r\n\r\nSM\r\n\r\n", HandlerFunc(func(w ResponseWriter, r *Request) {
1145 func send204(w ResponseWriter, r *Request) { w.WriteHeader(204) }
1146 func send304(w ResponseWriter, r *Request) { w.WriteHeader(304) }
1167 cst := newClientServerTest(t, false /* h1 */, HandlerFunc(func(w ResponseWriter, r *Request) {
1200 cst := newClientServerTest(t, h2, HandlerFunc(func(w ResponseWriter, r *Request) {
1249 ts := httptest.NewUnstartedServer(HandlerFunc(func(w ResponseWriter, r *Request) {
1268 t.Errorf("Request %d: %v", num, err)
1275 t.Errorf("Request %d: %v", num, err)
1282 // Start a request. The server will block on getting conn.RemoteAddr.
1289 // Start another request and grab its connection
1327 ts := httptest.NewServer(HandlerFunc(func(w ResponseWriter, r *Request) {
1360 cst := newClientServerTest(t, h2, HandlerFunc(func(w ResponseWriter, r *Request) {
1398 ts := httptest.NewUnstartedServer(HandlerFunc(func(w ResponseWriter, r *Request) {}))
1429 ts := httptest.NewTLSServer(HandlerFunc(func(w ResponseWriter, r *Request) {
1497 handler := HandlerFunc(func(w ResponseWriter, r *Request) {})
1655 contentLength int // of request body
1701 // Tests that the server responds to the "Expect" request header
1707 ts := httptest.NewServer(HandlerFunc(func(w ResponseWriter, r *Request) {
1742 t.Errorf("On test %#v, error writing request headers: %v", test, err)
1765 t.Logf("On test %#v, acceptable error writing request body: %v", test, err)
1768 t.Errorf("On test %#v, error writing request body: %v", test, err)
1778 // implementation may send a RST if our request body data was known
1797 // should consume client request bodies that a handler didn't read.
1819 go Serve(ls, HandlerFunc(func(rw ResponseWriter, req *Request) {
1822 t.Errorf("on request, read buffer length is %d; expected about 100 KB", bufLen)
1837 // should ignore client request bodies that a handler didn't read
1855 go Serve(ls, HandlerFunc(func(rw ResponseWriter, req *Request) {
1857 t.Errorf("on request, read buffer length is %d; expected about 1MB", conn.readBuf.Len())
1878 wantNextReq bool // should it find the next request on the same conn?
1889 // Small enough to slurp past to the next request +
1899 // Small enough to slurp past to the next request +
1909 // Small enough to slurp past to the next request +
1920 // Small enough to slurp past to the next request +
2019 go Serve(ls, HandlerFunc(func(rw ResponseWriter, req *Request) {
2041 // vary work done on a request Body.
2070 go Serve(ls, HandlerFunc(func(_ ResponseWriter, req *Request) {
2073 t.Error("Request for /secret encountered, should not have happened.")
2105 go Serve(ln, HandlerFunc(func(_ ResponseWriter, req *Request) {
2108 t.Errorf("Handler %s, Request for /secret encountered, should not have happened.", handler.name)
2120 // request being received piecemeal. Deadlines can be set and enforced in both
2222 600 * time.Millisecond, // Request deadline should hit here
2233 Handler: HandlerFunc(func(_ ResponseWriter, req *Request) {
2236 t.Error("Request for /secret encountered, should not have happened.")
2258 sayHi := HandlerFunc(func(w ResponseWriter, r *Request) {
2281 t.Errorf("got unexpected Write error on first request: %v", g)
2311 delayHi := HandlerFunc(func(w ResponseWriter, r *Request) {
2355 delay204 := HandlerFunc(func(w ResponseWriter, r *Request) {
2394 sayHi := HandlerFunc(func(w ResponseWriter, r *Request) {
2418 t.Errorf("got unexpected Write error on first request: %v", g)
2449 var handler HandlerFunc = func(w ResponseWriter, _ *Request) {
2459 // was created, not when the request. So wait for more than the timeout
2476 var handler HandlerFunc = func(w ResponseWriter, _ *Request) {
2507 req := &Request{
2598 // the previous request's body, which is not optimal for zero-lengthed bodies,
2610 cst := newClientServerTest(t, h2, HandlerFunc(func(rw ResponseWriter, r *Request) {
2685 var handler Handler = HandlerFunc(func(w ResponseWriter, r *Request) {
2744 ts := httptest.NewUnstartedServer(HandlerFunc(func(w ResponseWriter, r *Request) {
2783 cst := newClientServerTest(t, h2, HandlerFunc(func(w ResponseWriter, r *Request) {
2801 h := HandlerFunc(func(w ResponseWriter, r *Request) {
2834 t.Errorf("StripPrefix should not modify the provided Request, but it did")
2843 cst := newClientServerTest(t, h2, HandlerFunc(func(w ResponseWriter, r *Request) {
2844 t.Fatalf("didn't expect to get request in Handler")
2858 // server's SETTINGS before RoundTrip starts sending the request, then RoundTrip
2867 // closing the connection while the request is still being written), but
2904 cst := newClientServerTest(t, h2, HandlerFunc(func(w ResponseWriter, r *Request) {
2924 // request write failed, without reading the response.
2931 t.Errorf("handler restricted the request body to %d bytes, but client managed to write %d",
2937 // side of their TCP connection, the server doesn't send a 400 Bad Request.
2943 ts := httptest.NewServer(HandlerFunc(func(w ResponseWriter, r *Request) {}))
2979 go Serve(ls, HandlerFunc(func(rw ResponseWriter, req *Request) {
2999 ts := httptest.NewServer(HandlerFunc(func(w ResponseWriter, r *Request) {
3044 cst := newClientServerTest(t, h2, HandlerFunc(func(w ResponseWriter, r *Request) {
3061 // request (both keep-alive), when a Handler never writes any
3065 ts := httptest.NewServer(HandlerFunc(func(rw ResponseWriter, req *Request) {}))
3096 ts := httptest.NewServer(HandlerFunc(func(rw ResponseWriter, req *Request) {
3130 // Tests that a pipelined request causes the first request's Handler's CloseNotify
3138 ts := httptest.NewServer(HandlerFunc(func(rw ResponseWriter, req *Request) {
3195 handler := HandlerFunc(func(rw ResponseWriter, r *Request) {
3206 // Tests that we can use CloseNotifier in one request, and later call Hijack
3207 // on a second request on the same connection.
3221 ts := httptest.NewServer(HandlerFunc(func(w ResponseWriter, r *Request) {
3267 ts := httptest.NewServer(HandlerFunc(func(w ResponseWriter, r *Request) {
3280 t.Errorf("Backend read %d request body bytes; want %d", len(slurp), len(requestBody))
3284 t.Error("Backend read wrong request body.") // 1MB; omitting details
3318 mux.HandleFunc("/", func(w ResponseWriter, r *Request) {
3330 // An OPTIONS * request should succeed.
3336 res, err := ReadResponse(br, &Request{Method: "OPTIONS"})
3344 // A GET * request on a ServeMux should fail.
3349 res, err = ReadResponse(br, &Request{Method: "GET"})
3363 t.Errorf("Handler saw request for %q; want /second", got)
3379 handler func(ResponseWriter, *Request)
3384 handler: func(rw ResponseWriter, r *Request) {
3399 handler: func(rw ResponseWriter, r *Request) {
3420 handler: func(rw ResponseWriter, r *Request) {
3433 handler: func(rw ResponseWriter, r *Request) {
3450 handler: func(rw ResponseWriter, r *Request) {
3471 handler: func(rw ResponseWriter, r *Request) {
3484 handler: func(rw ResponseWriter, r *Request) {
3497 handler: func(rw ResponseWriter, r *Request) {
3508 handler: func(rw ResponseWriter, r *Request) {
3520 handler: func(rw ResponseWriter, r *Request) {
3589 Handler: HandlerFunc(HandlerFunc(func(ResponseWriter, *Request) {})),
3607 handler := HandlerFunc(func(rw ResponseWriter, r *Request) {
3638 handler := HandlerFunc(func(rw ResponseWriter, r *Request) {
3656 // Note that this does not test the "request too large"
3665 mux.Handle("/", HandlerFunc(func(ResponseWriter, *Request) {}))
3671 req string // raw http request
3699 resp, err := ReadResponse(bufio.NewReader(conn), &Request{Method: "GET"})
3708 t.Errorf("wrong Connection headers for request %q. Got %q expect %q", tt.req, got, tt.expect)
3721 cst := newClientServerTest(t, h2, HandlerFunc(func(rw ResponseWriter, req *Request) {
3764 ht := newHandlerTest(HandlerFunc(func(w ResponseWriter, r *Request) {
3795 ht := newHandlerTest(HandlerFunc(func(w ResponseWriter, r *Request) {
3810 // A server Handler can receive a Request, and then turn around and
3811 // give a copy of that Request.Body out to the Transport (e.g. any
3812 // proxy). So then two people own that Request.Body (both the server
3838 backend := newClientServerTest(t, h2, HandlerFunc(func(rw ResponseWriter, req *Request) {
3865 proxy = newClientServerTest(t, h2, HandlerFunc(func(rw ResponseWriter, req *Request) {
3873 errorf("Proxy outbound request: %v", err)
3912 t.Fatalf("Original request: %v", err)
3925 // Test that a hanging Request.Body.Read from another goroutine can't
3926 // cause the Handler goroutine's Request.Body.Close to block.
3937 server := httptest.NewServer(HandlerFunc(func(rw ResponseWriter, req *Request) {
3979 ht := newHandlerTest(HandlerFunc(func(w ResponseWriter, r *Request) {
4013 handler := map[string]func(w ResponseWriter, r *Request){
4014 "/": func(w ResponseWriter, r *Request) {
4017 "/close": func(w ResponseWriter, r *Request) {
4021 "/hijack": func(w ResponseWriter, r *Request) {
4026 "/hijack-panic": func(w ResponseWriter, r *Request) {
4033 ts := httptest.NewUnstartedServer(HandlerFunc(func(w ResponseWriter, r *Request) {
4106 if _, err := io.WriteString(c, "BOGUS REQUEST\r\n\r\n"); err != nil {
4175 ts := httptest.NewUnstartedServer(HandlerFunc(func(w ResponseWriter, r *Request) {}))
4196 cst := newClientServerTest(t, h2, HandlerFunc(func(rw ResponseWriter, req *Request) {
4233 Handler: HandlerFunc(func(w ResponseWriter, r *Request) {}), // irrelevant
4276 ts := httptest.NewServer(HandlerFunc(func(w ResponseWriter, r *Request) {
4316 ts := httptest.NewUnstartedServer(HandlerFunc(func(w ResponseWriter, r *Request) {
4368 ts := httptest.NewServer(HandlerFunc(func(w ResponseWriter, r *Request) {
4401 // tolerate extra CRLF(s) before Request-Line on subsequent requests on a conn
4415 go Serve(ln, HandlerFunc(func(rw ResponseWriter, r *Request) {
4444 go Serve(ln, HandlerFunc(func(w ResponseWriter, r *Request) {
4479 go Serve(ln, HandlerFunc(func(w ResponseWriter, r *Request) {
4495 // If a Handler finishes and there's an unread request body,
4508 go Serve(ls, HandlerFunc(func(rw ResponseWriter, req *Request) {
4524 cst := newClientServerTest(t, h2, HandlerFunc(func(w ResponseWriter, r *Request) {
4602 Handler: HandlerFunc(func(ResponseWriter, *Request) {}),
4620 ts := httptest.NewServer(HandlerFunc(func(w ResponseWriter, r *Request) {
4628 t.Errorf("Request.Close = true; want false")
4687 Handler: HandlerFunc(func(ResponseWriter, *Request) {}),
4712 cst := newClientServerTest(t, h2, HandlerFunc(func(w ResponseWriter, r *Request) {
4735 // Tests that the Request.Context available to the Handler is canceled
4744 ts := httptest.NewServer(HandlerFunc(func(w ResponseWriter, r *Request) {
4783 cst := newClientServerTest(t, h2, HandlerFunc(func(w ResponseWriter, r *Request) {
4808 cst := newClientServerTest(t, h2, HandlerFunc(func(w ResponseWriter, r *Request) {
4833 Request) {
4848 ht := newHandlerTest(HandlerFunc(func(w ResponseWriter, r *Request) {
4866 ts := httptest.NewServer(HandlerFunc(func(rw ResponseWriter, r *Request) {
4909 ts := httptest.NewUnstartedServer(HandlerFunc(func(rw ResponseWriter, r *Request) {
4979 ts := httptest.NewServer(HandlerFunc(func(rw ResponseWriter, r *Request) {
5027 HandleFunc("/", func(w ResponseWriter, r *Request) {
5120 handler := HandlerFunc(func(rw ResponseWriter, r *Request) {
5174 handler := HandlerFunc(func(rw ResponseWriter, r *Request) {
5187 // same as above, but representing the most simple possible request
5203 handler := HandlerFunc(func(rw ResponseWriter, r *Request) {
5222 benchmarkHandler(b, HandlerFunc(func(w ResponseWriter, r *Request) {
5231 benchmarkHandler(b, HandlerFunc(func(w ResponseWriter, r *Request) {
5239 benchmarkHandler(b, HandlerFunc(func(w ResponseWriter, r *Request) {
5247 benchmarkHandler(b, HandlerFunc(func(w ResponseWriter, r *Request) {
5263 handler := HandlerFunc(func(rw ResponseWriter, r *Request) {
5280 h := HandlerFunc(func(w ResponseWriter, r *Request) {
5304 ts := httptest.NewServer(HandlerFunc(func(rw ResponseWriter, req *Request) {
5350 ts := httptest.NewUnstartedServer(HandlerFunc(func(w ResponseWriter, r *Request) {
5380 t.Fatal("request three unexpectedly on same connection")
5414 ts := httptest.NewServer(HandlerFunc(func(w ResponseWriter, r *Request) {
5448 t.Fatal("expected third request on new connection")
5461 handler := HandlerFunc(func(w ResponseWriter, r *Request) {
5492 t.Fatal("second request should fail. server should be shut down")
5514 cst := newClientServerTest(t, h2, HandlerFunc(func(w ResponseWriter, r *Request) {
5546 ts := httptest.NewUnstartedServer(HandlerFunc(func(w ResponseWriter, r *Request) {
5650 ts := httptest.NewServer(HandlerFunc(func(w ResponseWriter, r *Request) {
5653 // Tell the client to send more data after the GET request.
5657 // after the GET request. The HTTP server fires the
5659 // request, as documented.
5718 ts := httptest.NewServer(HandlerFunc(func(w ResponseWriter, r *Request) {
5722 // after the GET request. The HTTP server fires the
5724 // request, as documented.
5776 // Issue 18319: test that the Server validates the request method.
