Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 41 for errClosed (0.16 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. src/net/tcpsock_test.go

    		t.Error(err)
    	}
    	time.Sleep(10 * time.Millisecond)
    	cancel()
    	wg.Wait()
    	ln.Close()
    
    	c, err = ln.Accept()
    	if !errors.Is(err, ErrClosed) {
    		if err == nil {
    			c.Close()
    		}
    		t.Errorf("after l.Close(), l.Accept() = _, %v\nwant %v", err, ErrClosed)
    	}
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue Feb 20 06:04:31 UTC 2024
    - 17.7K bytes
    - Viewed (0)
Back to top