diff options
| author | Chris Lu <chris.lu@gmail.com> | 2020-06-16 00:27:48 -0700 |
|---|---|---|
| committer | Chris Lu <chris.lu@gmail.com> | 2020-06-16 00:27:48 -0700 |
| commit | 7ccc31853cac1833a3a1372aac2327e744a7c5ba (patch) | |
| tree | bc8a0af4a35487ee24828b5a5c3d867079eab94d | |
| parent | 48880edc2c4f5076338dbbdf831deea41e073196 (diff) | |
| download | seaweedfs-7ccc31853cac1833a3a1372aac2327e744a7c5ba.tar.xz seaweedfs-7ccc31853cac1833a3a1372aac2327e744a7c5ba.zip | |
hard limit volume file size
| -rw-r--r-- | weed/storage/needle/needle_read_write.go | 4 |
1 files changed, 4 insertions, 0 deletions
diff --git a/weed/storage/needle/needle_read_write.go b/weed/storage/needle/needle_read_write.go index 7f8aa4823..e89e253cd 100644 --- a/weed/storage/needle/needle_read_write.go +++ b/weed/storage/needle/needle_read_write.go @@ -140,6 +140,10 @@ func (n *Needle) Append(w backend.BackendStorageFile, version Version) (offset u err = fmt.Errorf("Cannot Read Current Volume Position: %v", e) return } + if offset >= MaxPossibleVolumeSize { + err = fmt.Errorf("Volume Size %d Exeededs %d", offset, MaxPossibleVolumeSize) + return + } bytesToWrite, size, actualSize, err := n.prepareWriteBuffer(version) |