diff options
| -rw-r--r-- | src/internal/poll/fd_mutex.go | 4 | ||||
| -rw-r--r-- | src/os/os_test.go | 28 |
2 files changed, 31 insertions, 1 deletions
diff --git a/src/internal/poll/fd_mutex.go b/src/internal/poll/fd_mutex.go index c1c9297687..f71c7739a1 100644 --- a/src/internal/poll/fd_mutex.go +++ b/src/internal/poll/fd_mutex.go @@ -265,7 +265,9 @@ func (fd *FD) readWriteLock() error { // is no remaining reference. func (fd *FD) readWriteUnlock() { fd.fdmu.rwunlock(true) - fd.fdmu.rwunlock(false) + if fd.fdmu.rwunlock(false) { + fd.destroy() + } } // closing returns true if fd is closing. diff --git a/src/os/os_test.go b/src/os/os_test.go index 29f2e6d3b2..47f4163220 100644 --- a/src/os/os_test.go +++ b/src/os/os_test.go @@ -3468,6 +3468,34 @@ func TestWriteStringAlloc(t *testing.T) { } } +// Test that it's OK to have parallel I/O and Close on a file. +func TestFileIOCloseRace(t *testing.T) { + t.Parallel() + file, err := Create(filepath.Join(t.TempDir(), "test.txt")) + if err != nil { + t.Fatal(err) + } + var wg sync.WaitGroup + wg.Go(func() { + var tmp [100]byte + if _, err := file.Write(tmp[:]); err != nil && !errors.Is(err, ErrClosed) { + t.Error(err) + } + }) + wg.Go(func() { + var tmp [100]byte + if _, err := file.Read(tmp[:]); err != nil && err != io.EOF && !errors.Is(err, ErrClosed) { + t.Error(err) + } + }) + wg.Go(func() { + if err := file.Close(); err != nil { + t.Error(err) + } + }) + wg.Wait() +} + // Test that it's OK to have parallel I/O and Close on a pipe. func TestPipeIOCloseRace(t *testing.T) { // Skip on wasm, which doesn't have pipes. |