- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 41 for errClosed (0.16 sec)
-
src/os/readfrom_linux_test.go
// closed, skip the error. if !errors.Is(err, net.ErrClosed) { t.Errorf("error writing to socket: %v", err) } return } } client.Close() }() wg.Add(1) go func() { defer wg.Done() buf := make([]byte, 32) for { if _, err := pty.Read(buf); err != nil { if err != io.EOF && !errors.Is(err, ErrClosed) { // An error here doesn't matter for
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Apr 02 21:49:26 UTC 2024 - 20.3K bytes - Viewed (0) -
src/os/file_posix.go
"runtime" "syscall" "time" ) // Close closes the [File], rendering it unusable for I/O. // On files that support [File.SetDeadline], any pending I/O operations will // be canceled and return immediately with an [ErrClosed] error. // Close will return an error if it has already been called. func (f *File) Close() error { if f == nil { return ErrInvalid } return f.file.close() }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Feb 26 21:33:12 UTC 2024 - 7.1K bytes - Viewed (0) -
internal/event/target/amqp.go
var err error var conn *amqp091.Connection var ch *amqp091.Channel isAMQPClosedErr := func(err error) bool { if err == amqp091.ErrClosed { return true } if nerr, ok := err.(*net.OpError); ok { return (nerr.Err.Error() == "use of closed network connection") } return false } target.connMutex.Lock()
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 10K bytes - Viewed (0) -
src/database/sql/fakedb_test.go
} s.touchMem() if !s.closed { s.c.incrStat(&s.c.stmtsClosed) s.closed = true } if s.next != nil { s.next.Close() } return nil } var errClosed = errors.New("fakedb: statement has been closed") // hook to simulate broken connections var hookExecBadConn func() bool func (s *fakeStmt) Exec(args []driver.Value) (driver.Result, error) {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Apr 01 12:38:07 UTC 2024 - 30.3K bytes - Viewed (0) -
src/os/os_test.go
} // Reading a closed file should return ErrClosed error func TestReadClosed(t *testing.T) { t.Parallel() path := sfdir + "/" + sfname file, err := Open(path) if err != nil { t.Fatal("open failed:", err) } file.Close() // close immediately b := make([]byte, 100) _, err = file.Read(b) e, ok := err.(*PathError) if !ok || e.Err != ErrClosed {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 01:00:11 UTC 2024 - 83.1K bytes - Viewed (0) -
cni/pkg/nodeagent/ztunnelserver.go
func (z *ztunnelServer) Run(ctx context.Context) { context.AfterFunc(ctx, func() { _ = z.Close() }) for { log.Debug("accepting conn") conn, err := z.accept() if err != nil { if errors.Is(err, net.ErrClosed) { log.Debug("listener closed - returning") return } log.Errorf("failed to accept conn: %v", err) continue } log.Debug("connection accepted") go func() {
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/os/file.go
// It passes io.EOF through unchanged, otherwise converts // poll.ErrFileClosing to ErrClosed and wraps the error in a PathError. func (f *File) wrapErr(op string, err error) error { if err == nil || err == io.EOF { return err } if err == poll.ErrFileClosing { err = ErrClosed } else if checkWrapErr && errors.Is(err, poll.ErrFileClosing) {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Apr 26 23:07:37 UTC 2024 - 25.4K bytes - Viewed (0) -
src/os/file_windows.go
return syscall.EINVAL } if info := file.dirinfo.Swap(nil); info != nil { info.close() } var err error if e := file.pfd.Close(); e != nil { if e == poll.ErrFileClosing { e = ErrClosed } err = &PathError{Op: "close", Path: file.name, Err: e} } // no need for a finalizer anymore runtime.SetFinalizer(file, nil) return err }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Apr 30 15:38:38 UTC 2024 - 13.4K bytes - Viewed (0) -
api/go1.8.txt
pkg net/url, method (*URL) Port() string pkg net/url, method (*URL) UnmarshalBinary([]uint8) error pkg net, var DefaultResolver *Resolver pkg os, func Executable() (string, error) pkg os, var ErrClosed error pkg plugin, func Open(string) (*Plugin, error) pkg plugin, method (*Plugin) Lookup(string) (Symbol, error) pkg plugin, type Plugin struct pkg plugin, type Symbol interface {}
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Dec 21 05:25:57 UTC 2016 - 16.3K bytes - Viewed (0) -
src/os/file_unix.go
return syscall.EINVAL } if info := file.dirinfo.Swap(nil); info != nil { info.close() } var err error if e := file.pfd.Close(); e != nil { if e == poll.ErrFileClosing { e = ErrClosed } err = &PathError{Op: "close", Path: file.name, Err: e} } // no need for a finalizer anymore runtime.SetFinalizer(file, nil) return err }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 29 13:52:34 UTC 2024 - 14.9K bytes - Viewed (0)