diff options
| author | chrislusf <chris.lu@gmail.com> | 2015-03-09 01:10:01 -0700 |
|---|---|---|
| committer | chrislusf <chris.lu@gmail.com> | 2015-03-09 01:10:04 -0700 |
| commit | f511b507a5230e931d0250b446f744073be879b3 (patch) | |
| tree | e9728b47902fc4f31aa93d24a937cb2654becc6c /go/topology/topology.go | |
| parent | d48d76cb4f419a58539fb84c7a45c7eb863b854f (diff) | |
| download | seaweedfs-f511b507a5230e931d0250b446f744073be879b3.tar.xz seaweedfs-f511b507a5230e931d0250b446f744073be879b3.zip | |
Add read only public port on volume server
Add read only public port on volume server
Diffstat (limited to 'go/topology/topology.go')
| -rw-r--r-- | go/topology/topology.go | 6 |
1 files changed, 1 insertions, 5 deletions
diff --git a/go/topology/topology.go b/go/topology/topology.go index e06df6227..b64ff420a 100644 --- a/go/topology/topology.go +++ b/go/topology/topology.go @@ -157,12 +157,8 @@ func (t *Topology) ProcessJoinMessage(joinMessage *operation.JoinMessage) { if *joinMessage.IsInit && dn != nil { t.UnRegisterDataNode(dn) } - adminPort := *joinMessage.Port - if joinMessage.AdminPort != nil { - adminPort = *joinMessage.AdminPort - } dn = rack.GetOrCreateDataNode(*joinMessage.Ip, - int(*joinMessage.Port), int(adminPort), *joinMessage.PublicUrl, + int(*joinMessage.Port), *joinMessage.PublicUrl, int(*joinMessage.MaxVolumeCount)) var volumeInfos []storage.VolumeInfo for _, v := range joinMessage.Volumes { |