aboutsummaryrefslogtreecommitdiff
path: root/weed/topology/rack.go
diff options
context:
space:
mode:
authorChris Lu <chris.lu@gmail.com>2019-04-04 19:27:00 -0700
committerChris Lu <chris.lu@gmail.com>2019-04-04 19:27:00 -0700
commit766396d249652c1b29771fa1fce65250f9707d1d (patch)
treeaa1036504df20a663d58077836b6a39f797892b3 /weed/topology/rack.go
parent715a38da1e4fce05631f230ccf09ce92c99a4fd4 (diff)
downloadseaweedfs-766396d249652c1b29771fa1fce65250f9707d1d.tar.xz
seaweedfs-766396d249652c1b29771fa1fce65250f9707d1d.zip
weed master: atomic volume counting
possible fix for https://github.com/chrislusf/seaweedfs/issues/913
Diffstat (limited to 'weed/topology/rack.go')
-rw-r--r--weed/topology/rack.go2
1 files changed, 1 insertions, 1 deletions
diff --git a/weed/topology/rack.go b/weed/topology/rack.go
index f8f8ce34a..932c1a804 100644
--- a/weed/topology/rack.go
+++ b/weed/topology/rack.go
@@ -28,7 +28,7 @@ func (r *Rack) FindDataNode(ip string, port int) *DataNode {
}
return nil
}
-func (r *Rack) GetOrCreateDataNode(ip string, port int, publicUrl string, maxVolumeCount int) *DataNode {
+func (r *Rack) GetOrCreateDataNode(ip string, port int, publicUrl string, maxVolumeCount int64) *DataNode {
for _, c := range r.Children() {
dn := c.(*DataNode)
if dn.MatchLocation(ip, port) {