volume server: rename readBufferSize to readBufferSizeMB
This commit is contained in:
@@ -29,7 +29,7 @@ type VolumeServer struct {
|
||||
inFlightDownloadDataLimitCond *sync.Cond
|
||||
inflightUploadDataTimeout time.Duration
|
||||
hasSlowRead bool
|
||||
readBufferSize int
|
||||
readBufferSizeMB int
|
||||
|
||||
SeedMasterNodes []pb.ServerAddress
|
||||
currentMaster pb.ServerAddress
|
||||
@@ -67,7 +67,7 @@ func NewVolumeServer(adminMux, publicMux *http.ServeMux, ip string,
|
||||
concurrentDownloadLimit int64,
|
||||
inflightUploadDataTimeout time.Duration,
|
||||
hasSlowRead bool,
|
||||
readBufferSize int,
|
||||
readBufferSizeMB int,
|
||||
) *VolumeServer {
|
||||
|
||||
v := util.GetViper()
|
||||
@@ -98,7 +98,7 @@ func NewVolumeServer(adminMux, publicMux *http.ServeMux, ip string,
|
||||
concurrentDownloadLimit: concurrentDownloadLimit,
|
||||
inflightUploadDataTimeout: inflightUploadDataTimeout,
|
||||
hasSlowRead: hasSlowRead,
|
||||
readBufferSize: readBufferSize,
|
||||
readBufferSizeMB: readBufferSizeMB,
|
||||
}
|
||||
vs.SeedMasterNodes = masterNodes
|
||||
|
||||
|
||||
@@ -118,7 +118,7 @@ func (vs *VolumeServer) GetOrHeadHandler(w http.ResponseWriter, r *http.Request)
|
||||
readOption := &storage.ReadOption{
|
||||
ReadDeleted: r.FormValue("readDeleted") == "true",
|
||||
HasSlowRead: vs.hasSlowRead,
|
||||
ReadBufferSize: vs.readBufferSize,
|
||||
ReadBufferSize: vs.readBufferSizeMB * 1024 * 1024,
|
||||
}
|
||||
|
||||
var count int
|
||||
|
||||
Reference in New Issue
Block a user