diff options
| author | Chris Lu <chris.lu@gmail.com> | 2018-05-28 13:44:27 -0700 |
|---|---|---|
| committer | Chris Lu <chris.lu@gmail.com> | 2018-05-28 13:44:27 -0700 |
| commit | be0e88a6068e61f17330502e3128723f0b2640d4 (patch) | |
| tree | a4abb9c1ec6b3261afc5cf6cd2d89e9b86f85d4a | |
| parent | 5c4480ec6c941e16efd4157ee98e67d21b5859fb (diff) | |
| download | seaweedfs-be0e88a6068e61f17330502e3128723f0b2640d4.tar.xz seaweedfs-be0e88a6068e61f17330502e3128723f0b2640d4.zip | |
fix chunk size limit for default 0
| -rw-r--r-- | weed/filesys/dirty_page.go | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/weed/filesys/dirty_page.go b/weed/filesys/dirty_page.go index a78fdb47d..e4e743166 100644 --- a/weed/filesys/dirty_page.go +++ b/weed/filesys/dirty_page.go @@ -60,7 +60,7 @@ func (pages *ContinuousDirtyPages) AddPage(ctx context.Context, offset int64, da Data: data, }) - if pages.totalSize() >= pages.f.wfs.chunkSizeLimit { + if pages.f.wfs.chunkSizeLimit > 0 && pages.totalSize() >= pages.f.wfs.chunkSizeLimit { chunk, err = pages.saveToStorage(ctx) pages.pages = nil glog.V(3).Infof("%s/%s add split [%d,%d)", pages.f.dir.Path, pages.f.Name, chunk.Offset, chunk.Offset+int64(chunk.Size)) |