diff options
| author | chrislu <chris.lu@gmail.com> | 2022-07-08 01:04:15 -0700 |
|---|---|---|
| committer | chrislu <chris.lu@gmail.com> | 2022-07-08 01:04:15 -0700 |
| commit | e2ecf137a21b27c34c3b163f09f3660745daceeb (patch) | |
| tree | f95152be198d8c57073f0ef7aa4ec1cb24a2b4c2 /weed/mount/filehandle.go | |
| parent | 185332b91f5c3dd8f32dd8573eec843dda9c29c2 (diff) | |
| download | seaweedfs-e2ecf137a21b27c34c3b163f09f3660745daceeb.tar.xz seaweedfs-e2ecf137a21b27c34c3b163f09f3660745daceeb.zip | |
fix resetting fh.reader
Diffstat (limited to 'weed/mount/filehandle.go')
| -rw-r--r-- | weed/mount/filehandle.go | 5 |
1 files changed, 2 insertions, 3 deletions
diff --git a/weed/mount/filehandle.go b/weed/mount/filehandle.go index f0cf2a380..0dfcbd7f6 100644 --- a/weed/mount/filehandle.go +++ b/weed/mount/filehandle.go @@ -98,16 +98,15 @@ func (fh *FileHandle) AddChunks(chunks []*filer_pb.FileChunk) { fh.entryViewCache = nil } -func (fh *FileHandle) SetReader(reader *filer.ChunkReadAt) { +func (fh *FileHandle) CloseReader() { if fh.reader != nil { fh.reader.Close() } - fh.reader = reader } func (fh *FileHandle) Release() { fh.dirtyPages.Destroy() - fh.SetReader(nil) + fh.CloseReader() } func lessThan(a, b *filer_pb.FileChunk) bool { |