diff options
| author | wusong <75450248+wusongANKANG@users.noreply.github.com> | 2023-02-01 11:36:59 +0800 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2023-01-31 19:36:59 -0800 |
| commit | fe573f26a8db0a4c3bbd5e645c4fa2192683c97e (patch) | |
| tree | 9d668f64b14e3194bd09c9f68c1b4c5eed743c74 | |
| parent | b9b613a78e2832565e0ec6fc703e3cd4e066ee16 (diff) | |
| download | seaweedfs-fe573f26a8db0a4c3bbd5e645c4fa2192683c97e.tar.xz seaweedfs-fe573f26a8db0a4c3bbd5e645c4fa2192683c97e.zip | |
memchunk save content twice (#4174)
| -rw-r--r-- | weed/mount/page_writer/page_chunk_mem.go | 10 |
1 files changed, 3 insertions, 7 deletions
diff --git a/weed/mount/page_writer/page_chunk_mem.go b/weed/mount/page_writer/page_chunk_mem.go index 3928f7077..70814262d 100644 --- a/weed/mount/page_writer/page_chunk_mem.go +++ b/weed/mount/page_writer/page_chunk_mem.go @@ -1,10 +1,11 @@ package page_writer import ( - "github.com/seaweedfs/seaweedfs/weed/util" - "github.com/seaweedfs/seaweedfs/weed/util/mem" "sync" "sync/atomic" + + "github.com/seaweedfs/seaweedfs/weed/util" + "github.com/seaweedfs/seaweedfs/weed/util/mem" ) var ( @@ -100,11 +101,6 @@ func (mc *MemChunk) SaveContent(saveFn SaveToStorageFunc) { if saveFn == nil { return } - for t := mc.usage.head.next; t != mc.usage.tail; t = t.next { - reader := util.NewBytesReader(mc.buf[t.StartOffset:t.stopOffset]) - saveFn(reader, int64(mc.logicChunkIndex)*mc.chunkSize+t.StartOffset, t.Size(), t.TsNs, func() { - }) - } for t := mc.usage.head.next; t != mc.usage.tail; t = t.next { startOffset := t.StartOffset |