- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 41 for errClosed (0.16 sec)
-
src/net/net_test.go
_ Error = InvalidAddrError("") _ Error = &timeoutError{} _ Error = &DNSConfigError{} _ Error = &DNSError{} ) // ErrClosed was introduced as type error, so we can't check // it using a declaration. if _, ok := ErrClosed.(Error); !ok { t.Fatal("ErrClosed does not implement Error") }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Jan 22 21:04:44 UTC 2024 - 13.3K bytes - Viewed (0) -
src/os/pipe_test.go
} else if pe, ok := err.(*fs.PathError); !ok { t.Errorf("I/O on closed pipe returned unexpected error type %T; expected fs.PathError", pe) } else if pe.Err != fs.ErrClosed { t.Errorf("got error %q but expected %q", pe.Err, fs.ErrClosed) } else { t.Logf("I/O returned expected error %q", err) } } func TestClosedPipeRaceRead(t *testing.T) { testClosedPipeRace(t, true) }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Sep 05 23:35:29 UTC 2023 - 12.4K bytes - Viewed (0) -
src/net/net.go
// error and return a [DNSError] for which Temporary returns false. func (e *DNSError) Temporary() bool { return e.IsTimeout || e.IsTemporary } // errClosed exists just so that the docs for ErrClosed don't mention // the internal package poll. var errClosed = poll.ErrNetClosing // ErrClosed is the error returned by an I/O call on a network // connection that has already been closed, or that is closed by
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/net/http/roundtrip_js.go
// Abort the Fetch request. ac.Call("abort") } return nil, req.Context().Err() case resp := <-respCh: return resp, nil case err := <-errCh: return nil, err } } var errClosed = errors.New("net/http: reader is closed") // streamReader implements an io.ReadCloser wrapper for ReadableStream. // See https://fetch.spec.whatwg.org/#readablestream for more information. type streamReader struct {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Jan 10 03:29:50 UTC 2024 - 11.8K bytes - Viewed (0) -
src/compress/lzw/reader.go
} } // Flush pending output. r.toRead = r.output[:r.o] r.o = 0 } var errClosed = errors.New("lzw: reader/writer is closed") // Close closes the [Reader] and returns an error for any future read operation. // It does not close the underlying [io.Reader]. func (r *Reader) Close() error { r.err = errClosed // in case any Reads come along return nil }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Oct 12 14:39:39 UTC 2023 - 8K 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/runtime/semasleep_test.go
// stdout to close. Wait closes the read/parent end of stdout, so // starting this goroutine prior to io.ReadAll introduces a race // condition where ReadAll may get fs.ErrClosed if the child exits too // quickly. waiting = true go func() { doneCh <- cmd.Wait() close(doneCh) }() // Wait for an arbitrary timeout longer than one second. The subprocess itself
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Apr 06 17:48:24 UTC 2023 - 3.5K bytes - Viewed (0) -
src/cmd/go/internal/lockedfile/lockedfile.go
// Close may be called multiple times; all calls after the first will return a // non-nil error. func (f *File) Close() error { if f.closed { return &fs.PathError{ Op: "close", Path: f.Name(), Err: fs.ErrClosed, } } f.closed = true err := closeFile(f.osFile.File) runtime.SetFinalizer(f, nil) return err } // Read opens the named file with a read-lock and returns its contents.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Oct 20 18:41:18 UTC 2020 - 5.1K bytes - Viewed (0) -
src/os/file_plan9.go
// 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() } func (file *file) close() error { if !file.fdmu.IncrefAndClose() { return &PathError{Op: "close", Path: file.name, Err: ErrClosed} }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Apr 30 15:35:30 UTC 2024 - 16K bytes - Viewed (0) -
src/net/tcpsock_test.go
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Feb 20 06:04:31 UTC 2024 - 17.7K bytes - Viewed (0)