aboutsummaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorChris Lu <chris.lu@gmail.com>2020-10-05 14:06:18 -0700
committerChris Lu <chris.lu@gmail.com>2020-10-05 14:06:18 -0700
commit36492c47ec71b7c229b213118a9241d6e9bedf71 (patch)
treed8b981d37ba4147481a3ffb73dc7ad94b5472e59
parent8f8e9ddbde6e4d8eff79474d891a21de50bc6527 (diff)
downloadseaweedfs-36492c47ec71b7c229b213118a9241d6e9bedf71.tar.xz
seaweedfs-36492c47ec71b7c229b213118a9241d6e9bedf71.zip
adjust
-rw-r--r--weed/filer/reader_at.go10
1 files changed, 4 insertions, 6 deletions
diff --git a/weed/filer/reader_at.go b/weed/filer/reader_at.go
index 17a1ba517..3aeb9a94d 100644
--- a/weed/filer/reader_at.go
+++ b/weed/filer/reader_at.go
@@ -159,13 +159,11 @@ func (c *ChunkReadAt) readFromWholeChunkData(chunkView *ChunkView, nextChunkView
c.lastChunkData = chunkData
c.lastChunkFileId = chunkView.FileId
- go func() {
- for _, nextChunkView := range nextChunkViews {
- if c.chunkCache != nil && nextChunkView != nil {
- c.readOneWholeChunk(nextChunkView)
- }
+ for _, nextChunkView := range nextChunkViews {
+ if c.chunkCache != nil && nextChunkView != nil {
+ go c.readOneWholeChunk(nextChunkView)
}
- }()
+ }
return
}