diff options
| author | Chris Lu <chris.lu@gmail.com> | 2015-01-18 17:03:38 -0800 |
|---|---|---|
| committer | Chris Lu <chris.lu@gmail.com> | 2015-01-18 17:03:38 -0800 |
| commit | 7b4a53b2c1195a459198e2ee9217b1b8b958e727 (patch) | |
| tree | 5a8af9c4a936000b3629b2a046f8637c9589fb0e /go/topology/topology.go | |
| parent | 7b10d62096272d165727c9e30ed748b5561e8769 (diff) | |
| download | seaweedfs-7b4a53b2c1195a459198e2ee9217b1b8b958e727.tar.xz seaweedfs-7b4a53b2c1195a459198e2ee9217b1b8b958e727.zip | |
Add optional admin port to volume server, to seperate admin operations from normal file operations.
Diffstat (limited to 'go/topology/topology.go')
| -rw-r--r-- | go/topology/topology.go | 8 |
1 files changed, 7 insertions, 1 deletions
diff --git a/go/topology/topology.go b/go/topology/topology.go index 4cfd070db..e1f35f7a3 100644 --- a/go/topology/topology.go +++ b/go/topology/topology.go @@ -157,7 +157,13 @@ func (t *Topology) ProcessJoinMessage(joinMessage *operation.JoinMessage) { if *joinMessage.IsInit && dn != nil { t.UnRegisterDataNode(dn) } - dn = rack.GetOrCreateDataNode(*joinMessage.Ip, int(*joinMessage.Port), *joinMessage.PublicUrl, int(*joinMessage.MaxVolumeCount)) + adminPort = *joinMessage.Port + if joinMessage.AdminPort != nil { + adminPort = *joinMessage.AdminPort + } + dn = rack.GetOrCreateDataNode(*joinMessage.Ip, + int(*joinMessage.Port), int(adminPort), *joinMessage.PublicUrl, + int(*joinMessage.MaxVolumeCount)) var volumeInfos []storage.VolumeInfo for _, v := range joinMessage.Volumes { if vi, err := storage.NewVolumeInfo(v); err == nil { |