- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 25 for errDeadlineExceeded (0.23 sec)
-
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) -
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) -
api/go1.15.txt
pkg net/url, method (*URL) EscapedFragment() string pkg net/url, method (*URL) Redacted() string pkg net/url, type URL struct, RawFragment string pkg os, method (*File) ReadFrom(io.Reader) (int64, error) pkg os, var ErrDeadlineExceeded error pkg regexp, method (*Regexp) SubexpIndex(string) int pkg strconv, func FormatComplex(complex128, uint8, int, int) string pkg strconv, func ParseComplex(string, int) (complex128, error)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Jul 17 02:15:01 UTC 2020 - 7.6K bytes - Viewed (0) -
src/net/dnsclient_unix_test.go
switch s { case "[2001:4860:4860::8888]:53", "8.8.8.8:53": break default: time.Sleep(10 * time.Millisecond) return dnsmessage.Message{}, os.ErrDeadlineExceeded } r := dnsmessage.Message{ Header: dnsmessage.Header{ ID: q.ID, Response: true, }, Questions: q.Questions, } for _, question := range q.Questions {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Sun Apr 14 18:23:45 UTC 2024 - 72.4K 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) -
cmd/server-main.go
errors.Is(err, io.ErrUnexpectedEOF) || errors.As(err, &rquorum) || errors.As(err, &wquorum) || isErrObjectNotFound(err) || isErrBucketNotFound(err) || errors.Is(err, os.ErrDeadlineExceeded) || notInitialized } func bootstrapTraceMsg(msg string) { info := madmin.TraceInfo{ TraceType: madmin.TraceBootstrap, Time: UTCNow(), NodeName: globalLocalNodeName,
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Tue Jun 04 15:12:57 UTC 2024 - 34.5K bytes - Viewed (2) -
src/internal/poll/fd_windows.go
} return 0, err } return int(o.qty), nil } // IO is interrupted by "close" or "timeout" netpollErr := err switch netpollErr { case ErrNetClosing, ErrFileClosing, ErrDeadlineExceeded: // will deal with those. default: panic("unexpected runtime.netpoll error: " + netpollErr.Error()) } // Cancel our request. err = syscall.CancelIoEx(fd.Sysfd, &o.o)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Jan 31 16:50:42 UTC 2024 - 34.1K bytes - Viewed (0)