- Sort Score
- Result 10 results
- Languages All
Results 61 - 70 of 625 for dial (0.2 sec)
-
staging/src/k8s.io/apimachinery/pkg/util/httpstream/httpstream.go
// Dialer knows how to open a streaming connection to a server. type Dialer interface { // Dial opens a streaming connection to a server using one of the protocols // specified (in order of most preferred to least preferred). Dial(protocols ...string) (Connection, string, error) } // UpgradeRoundTripper is a type of http.RoundTripper that is able to upgrade
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Oct 23 22:33:38 UTC 2023 - 6.4K bytes - Viewed (0) -
src/net/http/serve_test.go
string(got), err, expected) } // Slow client that should timeout. t1 := time.Now() conn, err := net.Dial("tcp", ts.Listener.Addr().String()) if err != nil { return fmt.Errorf("Dial: %v", err) } buf := make([]byte, 1) n, err := conn.Read(buf) conn.Close() latency := time.Since(t1) if n != 0 || err != io.EOF {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Jun 07 17:57:01 UTC 2024 - 202K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/util/webhook/client.go
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Jan 04 09:09:10 UTC 2024 - 7.3K bytes - Viewed (0) -
src/net/sock_posix.go
} return fd, nil case syscall.SOCK_DGRAM: if err := fd.listenDatagram(ctx, laddr, ctrlCtxFn); err != nil { fd.Close() return nil, err } return fd, nil } } if err := fd.dial(ctx, laddr, raddr, ctrlCtxFn); err != nil { fd.Close() return nil, err } return fd, nil } func (fd *netFD) ctrlNetwork() string { switch fd.net { case "unix", "unixgram", "unixpacket":
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Sep 18 17:20:52 UTC 2023 - 6.3K bytes - Viewed (0) -
src/net/unixsock_test.go
if !testableNetwork("unixgram") { t.Skip("unixgram test") } c1 := newLocalPacketListener(t, "unixgram") defer os.Remove(c1.LocalAddr().String()) defer c1.Close() c2, err := Dial("unixgram", c1.LocalAddr().String()) if err != nil { t.Fatal(err) } defer os.Remove(c2.LocalAddr().String()) defer c2.Close() for _, genericRead := range []bool{false, true} { n, err := c2.Write(nil)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Sep 18 17:20:52 UTC 2023 - 10.6K bytes - Viewed (0) -
cni/pkg/plugin/cnieventclient.go
url string } func buildClient(address, path string) CNIEventClient { c := &http.Client{ Transport: &http.Transport{ DialContext: func(_ context.Context, _, _ string) (net.Conn, error) { return net.Dial("unix", address) }, }, Timeout: 1000 * time.Millisecond, } eventC := CNIEventClient{ client: c, url: "http://unix" + path, } return eventC }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Jan 26 20:34:28 UTC 2024 - 2.4K bytes - Viewed (0) -
pkg/kubelet/util/queue/work_queue_test.go
q.Enqueue(types.UID("foo4"), 1*time.Minute) expected := []types.UID{types.UID("foo1"), types.UID("foo2")} compareResults(t, expected, q.GetWork()) compareResults(t, []types.UID{}, q.GetWork()) // Dial the time to 1 hour ahead. clock.Step(time.Hour) expected = []types.UID{types.UID("foo3"), types.UID("foo4")} compareResults(t, expected, q.GetWork()) compareResults(t, []types.UID{}, q.GetWork()) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 2.4K bytes - Viewed (0) -
src/net/unixsock_posix.go
sotype = syscall.SOCK_STREAM case "unixgram": sotype = syscall.SOCK_DGRAM case "unixpacket": sotype = syscall.SOCK_SEQPACKET default: return nil, UnknownNetworkError(net) } switch mode { case "dial": if laddr != nil && laddr.isWildcard() { laddr = nil } if raddr != nil && raddr.isWildcard() { raddr = nil } if raddr == nil && (sotype != syscall.SOCK_DGRAM || laddr == nil) {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 16 16:54:32 UTC 2024 - 6.6K bytes - Viewed (0) -
src/runtime/internal/wasitest/tcpecho_test.go
subProcess.Stderr = &b if err := subProcess.Start(); err != nil { t.Log(b.String()) t.Fatal(err) } defer subProcess.Process.Kill() var conn net.Conn for { var err error conn, err = net.Dial("tcp", host) if err == nil { break } time.Sleep(500 * time.Millisecond) } defer conn.Close() payload := []byte("foobar") if _, err := conn.Write(payload); err != nil { t.Fatal(err) }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Feb 26 22:01:11 UTC 2024 - 2.4K bytes - Viewed (0) -
src/net/http/roundtrip_js.go
// If they aren't set then the documented contract is to use Dial or DialTLS, even // though they are deprecated. Therefore, if any of these are set, we should obey // the contract and dial using the regular round-trip instead. Otherwise, we'll try // to fall back on the Fetch API, unless it's not available.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Jan 10 03:29:50 UTC 2024 - 11.8K bytes - Viewed (0)