- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 22 for errDeadlineExceeded (0.32 sec)
-
src/os/error.go
ErrDeadlineExceeded = errDeadlineExceeded() // "i/o timeout" ) func errNoDeadline() error { return poll.ErrNoDeadline } // errDeadlineExceeded returns the value for os.ErrDeadlineExceeded. // This error comes from the internal/poll package, which is also // used by package net. Doing it this way ensures that the net // package will return os.ErrDeadlineExceeded for an exceeded deadline,
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Feb 26 21:33:12 UTC 2024 - 4.8K bytes - Viewed (0) -
src/internal/poll/fd_plan9.go
if len(b) == 0 { return 0, nil } fd.rmu.Lock() if fd.rtimedout { fd.rmu.Unlock() return 0, ErrDeadlineExceeded } fd.raio = newAsyncIO(fn, b) fd.rmu.Unlock() n, err := fd.raio.Wait() fd.raio = nil if isHangup(err) { err = io.EOF } if isInterrupted(err) { err = ErrDeadlineExceeded } return n, err } // Write implements io.Writer.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon May 06 14:00:54 UTC 2024 - 5.4K bytes - Viewed (0) -
src/internal/poll/fd.go
func errClosing(isFile bool) error { if isFile { return ErrFileClosing } return ErrNetClosing } // ErrDeadlineExceeded is returned for an expired deadline. // This is exported by the os package as os.ErrDeadlineExceeded. var ErrDeadlineExceeded error = &DeadlineExceededError{} // DeadlineExceededError is returned for an expired deadline. type DeadlineExceededError struct{}
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Nov 17 23:16:28 UTC 2023 - 3.3K bytes - Viewed (0) -
src/net/pipe.go
case isClosedChan(p.readDeadline.wait()): return 0, os.ErrDeadlineExceeded } select { case bw := <-p.rdRx: nr := copy(b, bw) p.rdTx <- nr return nr, nil case <-p.localDone: return 0, io.ErrClosedPipe case <-p.remoteDone: return 0, io.EOF case <-p.readDeadline.wait(): return 0, os.ErrDeadlineExceeded } } func (p *pipe) Write(b []byte) (int, error) {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Jan 10 03:29:50 UTC 2024 - 5.4K bytes - Viewed (0) -
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/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) -
src/internal/poll/fd_poll_runtime.go
) func convertErr(res int, isFile bool) error { switch res { case pollNoError: return nil case pollErrClosing: return errClosing(isFile) case pollErrTimeout: return ErrDeadlineExceeded case pollErrNotPollable: return ErrNotPollable } println("unreachable: ", res) panic("unreachable") } // SetDeadline sets the read and write deadlines associated with fd.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 00:18:59 UTC 2024 - 4.2K 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)