diff options
| author | Chris Lu <chris.lu@gmail.com> | 2019-05-27 11:59:03 -0700 |
|---|---|---|
| committer | Chris Lu <chris.lu@gmail.com> | 2019-05-27 11:59:03 -0700 |
| commit | b4b407e4038943ca5b7dc440d2848f23c11b73ca (patch) | |
| tree | f90a49fa2cac3361efa224b13c0ecfaade054b76 /weed/server/volume_grpc_copy.go | |
| parent | a4f3d82c57bca13321dca257891836ff36c7eca5 (diff) | |
| download | seaweedfs-b4b407e4038943ca5b7dc440d2848f23c11b73ca.tar.xz seaweedfs-b4b407e4038943ca5b7dc440d2848f23c11b73ca.zip | |
add grpc ec shard read
Diffstat (limited to 'weed/server/volume_grpc_copy.go')
| -rw-r--r-- | weed/server/volume_grpc_copy.go | 5 |
1 files changed, 3 insertions, 2 deletions
diff --git a/weed/server/volume_grpc_copy.go b/weed/server/volume_grpc_copy.go index 7b681aa53..e5a3d6edf 100644 --- a/weed/server/volume_grpc_copy.go +++ b/weed/server/volume_grpc_copy.go @@ -16,6 +16,8 @@ import ( "github.com/chrislusf/seaweedfs/weed/util" ) +const BufferSizeLimit = 1024 * 1024 * 2 + // VolumeCopy copy the .idx .dat files, and mount the volume func (vs *VolumeServer) VolumeCopy(ctx context.Context, req *volume_server_pb.VolumeCopyRequest) (*volume_server_pb.VolumeCopyResponse, error) { @@ -190,7 +192,6 @@ func (vs *VolumeServer) CopyFile(req *volume_server_pb.CopyFileRequest, stream v bytesToRead := int64(req.StopOffset) - const BufferSize = 1024 * 1024 * 2 var fileName = v.FileName() + req.Ext file, err := os.Open(fileName) if err != nil { @@ -198,7 +199,7 @@ func (vs *VolumeServer) CopyFile(req *volume_server_pb.CopyFileRequest, stream v } defer file.Close() - buffer := make([]byte, BufferSize) + buffer := make([]byte, BufferSizeLimit) for bytesToRead > 0 { bytesread, err := file.Read(buffer) |