diff options
| author | Chris Lu <chris.lu@gmail.com> | 2020-10-21 02:42:23 -0700 |
|---|---|---|
| committer | Chris Lu <chris.lu@gmail.com> | 2020-10-21 02:42:23 -0700 |
| commit | 81cf8d04dfcbb84093044de4f10a8a92d9c8bd1c (patch) | |
| tree | 35c3169aa7964cacc42abb79ab8e458c4fa2127e | |
| parent | d90e7ee3cc5dea1e78088869f74cfd1ea0109d7d (diff) | |
| download | seaweedfs-81cf8d04dfcbb84093044de4f10a8a92d9c8bd1c.tar.xz seaweedfs-81cf8d04dfcbb84093044de4f10a8a92d9c8bd1c.zip | |
minor
| -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 9c059aae0..7a3e859f5 100644 --- a/weed/filesys/dirty_page.go +++ b/weed/filesys/dirty_page.go @@ -99,7 +99,7 @@ func (pages *ContinuousDirtyPages) saveExistingLargestPageToStorage() (hasSavedD func (pages *ContinuousDirtyPages) saveToStorage(reader io.Reader, offset int64, size int64) { if pages.chunkSaveErrChanClosed { - pages.chunkSaveErrChan = make(chan error, 8) + pages.chunkSaveErrChan = make(chan error, concurrentWriterLimit) pages.chunkSaveErrChanClosed = false } |