diff options
| author | msementsov <47177265+m-sementsov@users.noreply.github.com> | 2025-12-05 23:24:38 +0300 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2025-12-05 12:24:38 -0800 |
| commit | c0dad091f149d80c6737f006c7ab98f4cd69478b (patch) | |
| tree | 81001c4dc20746261701723b63c7669029a884c3 /weed/server/volume_grpc_copy.go | |
| parent | 4cc6a2a4e58ac03ae79816b636bc8bbf5797b707 (diff) | |
| download | seaweedfs-c0dad091f149d80c6737f006c7ab98f4cd69478b.tar.xz seaweedfs-c0dad091f149d80c6737f006c7ab98f4cd69478b.zip | |
Separate vacuum speed from replication speed (#7632)
Diffstat (limited to 'weed/server/volume_grpc_copy.go')
| -rw-r--r-- | weed/server/volume_grpc_copy.go | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/weed/server/volume_grpc_copy.go b/weed/server/volume_grpc_copy.go index 5ff8bb587..410c6b05d 100644 --- a/weed/server/volume_grpc_copy.go +++ b/weed/server/volume_grpc_copy.go @@ -115,7 +115,7 @@ func (vs *VolumeServer) VolumeCopy(req *volume_server_pb.VolumeCopyRequest, stre var sendErr error var ioBytePerSecond int64 if req.IoBytePerSecond <= 0 { - ioBytePerSecond = vs.compactionBytePerSecond + ioBytePerSecond = vs.maintenanceBytePerSecond } else { ioBytePerSecond = req.IoBytePerSecond } @@ -199,7 +199,7 @@ func (vs *VolumeServer) VolumeCopy(req *volume_server_pb.VolumeCopyRequest, stre } func (vs *VolumeServer) doCopyFile(client volume_server_pb.VolumeServerClient, isEcVolume bool, collection string, vid, compactRevision uint32, stopOffset uint64, baseFileName, ext string, isAppend, ignoreSourceFileNotFound bool, progressFn storage.ProgressFunc) (modifiedTsNs int64, err error) { - return vs.doCopyFileWithThrottler(client, isEcVolume, collection, vid, compactRevision, stopOffset, baseFileName, ext, isAppend, ignoreSourceFileNotFound, progressFn, util.NewWriteThrottler(vs.compactionBytePerSecond)) + return vs.doCopyFileWithThrottler(client, isEcVolume, collection, vid, compactRevision, stopOffset, baseFileName, ext, isAppend, ignoreSourceFileNotFound, progressFn, util.NewWriteThrottler(vs.maintenanceBytePerSecond)) } func (vs *VolumeServer) doCopyFileWithThrottler(client volume_server_pb.VolumeServerClient, isEcVolume bool, collection string, vid, compactRevision uint32, stopOffset uint64, baseFileName, ext string, isAppend, ignoreSourceFileNotFound bool, progressFn storage.ProgressFunc, throttler *util.WriteThrottler) (modifiedTsNs int64, err error) { |