diff options
| author | Chris Lu <chris.lu@gmail.com> | 2021-08-08 22:33:31 -0700 |
|---|---|---|
| committer | Chris Lu <chris.lu@gmail.com> | 2021-08-08 22:33:31 -0700 |
| commit | 96ce85f5ae6281c14a4a190dcf5f527321c50472 (patch) | |
| tree | 229148965d2ec27d7b3c4a4cefd0ff4e3cb929a3 /weed/server/volume_server.go | |
| parent | c5f38c365d7d5cd4dc74e5cafefc0c461a0d478e (diff) | |
| download | seaweedfs-96ce85f5ae6281c14a4a190dcf5f527321c50472.tar.xz seaweedfs-96ce85f5ae6281c14a4a190dcf5f527321c50472.zip | |
rename
Diffstat (limited to 'weed/server/volume_server.go')
| -rw-r--r-- | weed/server/volume_server.go | 30 |
1 files changed, 15 insertions, 15 deletions
diff --git a/weed/server/volume_server.go b/weed/server/volume_server.go index 3bf740dc0..a0f32700b 100644 --- a/weed/server/volume_server.go +++ b/weed/server/volume_server.go @@ -17,9 +17,9 @@ import ( ) type VolumeServer struct { - inFlightDataSize int64 - concurrentUploadLimit int64 - inFlightDataLimitCond *sync.Cond + inFlightUploadDataSize int64 + concurrentUploadLimit int64 + inFlightUploadDataLimitCond *sync.Cond SeedMasterNodes []string currentMaster string @@ -68,18 +68,18 @@ func NewVolumeServer(adminMux, publicMux *http.ServeMux, ip string, vs := &VolumeServer{ pulseSeconds: pulseSeconds, - dataCenter: dataCenter, - rack: rack, - needleMapKind: needleMapKind, - FixJpgOrientation: fixJpgOrientation, - ReadMode: readMode, - grpcDialOption: security.LoadClientTLS(util.GetViper(), "grpc.volume"), - compactionBytePerSecond: int64(compactionMBPerSecond) * 1024 * 1024, - fileSizeLimitBytes: int64(fileSizeLimitMB) * 1024 * 1024, - isHeartbeating: true, - stopChan: make(chan bool), - inFlightDataLimitCond: sync.NewCond(new(sync.Mutex)), - concurrentUploadLimit: concurrentUploadLimit, + dataCenter: dataCenter, + rack: rack, + needleMapKind: needleMapKind, + FixJpgOrientation: fixJpgOrientation, + ReadMode: readMode, + grpcDialOption: security.LoadClientTLS(util.GetViper(), "grpc.volume"), + compactionBytePerSecond: int64(compactionMBPerSecond) * 1024 * 1024, + fileSizeLimitBytes: int64(fileSizeLimitMB) * 1024 * 1024, + isHeartbeating: true, + stopChan: make(chan bool), + inFlightUploadDataLimitCond: sync.NewCond(new(sync.Mutex)), + concurrentUploadLimit: concurrentUploadLimit, } vs.SeedMasterNodes = masterNodes |
