- Sort Score
- Result 10 results
- Languages All
Results 91 - 100 of 155 for roundTrip (0.16 sec)
-
src/net/http/httputil/dump.go
return &dumpConn{io.MultiWriter(&buf, pw), dr}, nil }, } defer t.CloseIdleConnections() // We need this channel to ensure that the reader // goroutine exits if t.RoundTrip returns an error. // See golang.org/issue/32571. quitReadCh := make(chan struct{}) // Wait for the request before replying with a dummy response: go func() { req, err := http.ReadRequest(bufio.NewReader(pr))
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Jan 10 03:29:50 UTC 2024 - 9.3K bytes - Viewed (0) -
misc/linkcheck/linkcheck.go
} } } func doCrawl(url string) error { defer wg.Done() req, err := http.NewRequest("GET", url, nil) if err != nil { return err } res, err := http.DefaultTransport.RoundTrip(req) if err != nil { return err } // Handle redirects. if res.StatusCode/100 == 3 { newURL, err := res.Location() if err != nil { return fmt.Errorf("resolving redirect: %v", err) }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Oct 06 15:53:04 UTC 2021 - 3.9K bytes - Viewed (0) -
pkg/api/testing/serialization_test.go
"reflect" "testing" "github.com/google/go-cmp/cmp" appsv1 "k8s.io/api/apps/v1" v1 "k8s.io/api/core/v1" "k8s.io/apimachinery/pkg/api/apitesting/fuzzer" "k8s.io/apimachinery/pkg/api/apitesting/roundtrip" apiequality "k8s.io/apimachinery/pkg/api/equality" "k8s.io/apimachinery/pkg/api/meta" metav1 "k8s.io/apimachinery/pkg/apis/meta/v1" "k8s.io/apimachinery/pkg/conversion" "k8s.io/apimachinery/pkg/runtime"
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Sep 25 11:04:08 UTC 2023 - 19.3K bytes - Viewed (0) -
tensorflow/compiler/jit/xla_host_send_recv_device_context_test.cc
TF_ASSERT_OK(stream->BlockHostUntilDone()); tensorflow::test::ExpectClose(origin_cpu_tensor, dest_cpu_tensor); device_context->Unref(); } TEST_F(XlaHostSendRecvDeviceContextTest, RoundTrip) { SetDevice("GPU"); Tensor origin_cpu_tensor(host_allocator_, DT_FLOAT, TensorShape({2, 2})); test::FillValues<float>(&origin_cpu_tensor, {1.2, 2.3, 3.4, 4.5});
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Fri May 17 22:46:36 UTC 2024 - 7.2K bytes - Viewed (0) -
src/syscall/wtf8_windows_test.go
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon May 15 09:26:16 UTC 2023 - 4.3K bytes - Viewed (0) -
pkg/api/testing/defaulting_test.go
"sort" "testing" "github.com/google/go-cmp/cmp" fuzz "github.com/google/gofuzz" apiv1 "k8s.io/api/core/v1" extensionsv1beta1 "k8s.io/api/extensions/v1beta1" "k8s.io/apimachinery/pkg/api/apitesting/roundtrip" metav1 "k8s.io/apimachinery/pkg/apis/meta/v1" "k8s.io/apimachinery/pkg/runtime" "k8s.io/apimachinery/pkg/runtime/schema" "k8s.io/kubernetes/pkg/api/legacyscheme" )
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Mar 06 00:00:21 UTC 2024 - 20.3K bytes - Viewed (0) -
src/net/http/client_test.go
} } type roundTripperWithoutCloseIdle struct{} func (roundTripperWithoutCloseIdle) RoundTrip(*Request) (*Response, error) { panic("unused") } type roundTripperWithCloseIdle func() // underlying func is CloseIdleConnections func func (roundTripperWithCloseIdle) RoundTrip(*Request) (*Response, error) { panic("unused") } func (f roundTripperWithCloseIdle) CloseIdleConnections() { f() }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 22 21:30:50 UTC 2024 - 63.8K bytes - Viewed (0) -
src/net/http/http_test.go
if err != nil { t.Fatalf("go tool nm: %v: %s", err, out) } wantSym := map[string]bool{ // Verify these exist: (sanity checking this test) "net/http.(*Client).do": true, "net/http.(*Transport).RoundTrip": true, // Verify these don't exist: "net/http.http2Server": false, "net/http.(*Server).Serve": false, "net/http.(*ServeMux).ServeHTTP": false, "net/http.DefaultServeMux": false, }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Aug 22 18:18:19 UTC 2023 - 5.2K bytes - Viewed (0) -
src/net/http/httputil/reverseproxy_test.go
} resp.Body.Close() } } type failingRoundTripper struct{} func (failingRoundTripper) RoundTrip(*http.Request) (*http.Response, error) { return nil, errors.New("some error") } type staticResponseRoundTripper struct{ res *http.Response } func (rt staticResponseRoundTripper) RoundTrip(*http.Request) (*http.Response, error) { return rt.res, nil } func TestReverseProxyErrorHandler(t *testing.T) {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 01:00:11 UTC 2024 - 54.6K bytes - Viewed (0) -
pkg/hbone/dialer.go
if err != nil { return fmt.Errorf("new request: %v", err) } r.Host = address // Initiate CONNECT. log.Infof("initiate CONNECT to %v via %v", r.Host, url) resp, err := d.transport.RoundTrip(r) if err != nil { return fmt.Errorf("round trip: %v", err) } var remoteID string if resp.TLS != nil && len(resp.TLS.PeerCertificates) > 0 {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 24 15:56:41 UTC 2023 - 5.1K bytes - Viewed (0)