aboutsummaryrefslogtreecommitdiff
path: root/weed/server/volume_server.go
diff options
context:
space:
mode:
authorChris Lu <chris.lu@gmail.com>2021-08-08 22:33:31 -0700
committerChris Lu <chris.lu@gmail.com>2021-08-08 22:33:31 -0700
commit96ce85f5ae6281c14a4a190dcf5f527321c50472 (patch)
tree229148965d2ec27d7b3c4a4cefd0ff4e3cb929a3 /weed/server/volume_server.go
parentc5f38c365d7d5cd4dc74e5cafefc0c461a0d478e (diff)
downloadseaweedfs-96ce85f5ae6281c14a4a190dcf5f527321c50472.tar.xz
seaweedfs-96ce85f5ae6281c14a4a190dcf5f527321c50472.zip
rename
Diffstat (limited to 'weed/server/volume_server.go')
-rw-r--r--weed/server/volume_server.go30
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