- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 12 for errDeadlineExceeded (0.25 sec)
-
src/net/timeout_test.go
xerrs [2]error // expected errors in transition }{ // Tests that read deadlines work, even if there's data ready // to be read. {-5 * time.Second, [2]error{os.ErrDeadlineExceeded, os.ErrDeadlineExceeded}}, {50 * time.Millisecond, [2]error{nil, os.ErrDeadlineExceeded}}, } // There is a very similar copy of this in os/timeout_test.go. func TestReadTimeout(t *testing.T) { handler := func(ls *localServer, ln Listener) {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Jan 24 18:06:55 UTC 2024 - 30K bytes - Viewed (0) -
src/net/http/responsecontroller_test.go
if err == nil { t.Errorf("client reading from truncated request body: got nil error, want non-nil") } err = <-errc // io.Copy error if !errors.Is(err, os.ErrDeadlineExceeded) { t.Errorf("server timed out writing request body: got err %v; want os.ErrDeadlineExceeded", err) } } func TestResponseControllerSetPastReadDeadline(t *testing.T) { run(t, testResponseControllerSetPastReadDeadline) }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Mar 06 19:20:31 UTC 2024 - 10.2K bytes - Viewed (0) -
src/os/timeout_test.go
xerrs [2]error // expected errors in transition }{ // Tests that read deadlines work, even if there's data ready // to be read. {-5 * time.Second, [2]error{os.ErrDeadlineExceeded, os.ErrDeadlineExceeded}}, {50 * time.Millisecond, [2]error{nil, os.ErrDeadlineExceeded}}, } // There is a very similar copy of this in net/timeout_test.go. func TestReadTimeout(t *testing.T) { t.Parallel() r, w, err := os.Pipe()
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Jun 14 00:03:57 UTC 2023 - 17.1K bytes - Viewed (0) -
src/net/net_fake.go
ok bool ) expired := ffd.readDeadline.Load().expired select { case <-expired: return nil, os.ErrDeadlineExceeded case incoming, ok = <-ffd.incoming: if !ok { return nil, ErrClosed } select { case <-expired: ffd.incoming <- incoming return nil, os.ErrDeadlineExceeded default: } case incoming, ok = <-ffd.incomingFull: select { case <-expired:
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Feb 27 19:24:21 UTC 2024 - 26.4K bytes - Viewed (0) -
src/net/net.go
// // If the deadline is exceeded a call to Read or Write or to other // I/O methods will return an error that wraps os.ErrDeadlineExceeded. // This can be tested using errors.Is(err, os.ErrDeadlineExceeded). // The error's Timeout method will return true, but note that there // are other possible errors for which the Timeout method will
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 29 17:58:53 UTC 2024 - 26.8K bytes - Viewed (0) -
cni/pkg/nodeagent/ztunnelserver.go
// something first, we expect to get an os.ErrDeadlineExceeded error // here if the connection is still alive. // note that unlike tcp connections, reading is a good enough test here. _, err := conn.readMessage(time.Second / 100) switch { case !errors.Is(err, os.ErrDeadlineExceeded): log.Debugf("ztunnel keepalive failed: %v", err) if errors.Is(err, io.EOF) {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 22:07:03 UTC 2024 - 12.3K bytes - Viewed (0) -
src/net/error_test.go
return nil } switch err := nestedErr.(type) { case *os.SyscallError: nestedErr = err.Err goto third } switch nestedErr { case ErrClosed, errTimeout, poll.ErrNotPollable, os.ErrDeadlineExceeded: return nil } return fmt.Errorf("unexpected type on 2nd nested level: %T", nestedErr) third: if isPlatformError(nestedErr) { return nil }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Sep 18 17:20:52 UTC 2023 - 20.3K bytes - Viewed (0) -
src/net/sendfile_test.go
// it didn't handle the operation, resulting in a non-sendfile retry. // So don't use expectSendfile here. _, err = io.Copy(conn, f) if errors.Is(err, os.ErrDeadlineExceeded) { return nil } if err == nil { err = fmt.Errorf("expected ErrDeadlineExceeded, but got nil") } return err }(ln) conn, err := Dial("tcp", ln.Addr().String()) if err != nil { t.Fatal(err) }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Apr 26 18:12:56 UTC 2024 - 12.1K bytes - Viewed (0) -
src/net/udpsock_test.go
if err != nil { t.Fatal(err) } defer c.Close() c.SetDeadline(time.Now()) b := make([]byte, 1) n, addr, err := c.ReadFromUDP(b) if !errors.Is(err, os.ErrDeadlineExceeded) { t.Errorf("ReadFromUDP got err %v want os.ErrDeadlineExceeded", err) } if n != 0 { t.Errorf("ReadFromUDP got n %d want 0", n) } if addr != nil { t.Errorf("ReadFromUDP got addr %+#v want nil", addr) } }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Sep 18 17:20:52 UTC 2023 - 17.2K bytes - Viewed (0) -
src/os/file.go
// by setting a deadline in the future. // // If the deadline is exceeded a call to Read or Write or to other I/O // methods will return an error that wraps ErrDeadlineExceeded. // This can be tested using errors.Is(err, os.ErrDeadlineExceeded). // That error implements the Timeout method, and calling the Timeout // method will return true, but there are other possible errors for which
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Apr 26 23:07:37 UTC 2024 - 25.4K bytes - Viewed (0)