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/rack.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/rack.go')
| -rw-r--r-- | go/topology/rack.go | 3 |
1 files changed, 2 insertions, 1 deletions
diff --git a/go/topology/rack.go b/go/topology/rack.go index 40e19dd0d..50ad5f009 100644 --- a/go/topology/rack.go +++ b/go/topology/rack.go @@ -27,7 +27,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, adminPort int, publicUrl string, maxVolumeCount int) *DataNode { for _, c := range r.Children() { dn := c.(*DataNode) if dn.MatchLocation(ip, port) { @@ -43,6 +43,7 @@ func (r *Rack) GetOrCreateDataNode(ip string, port int, publicUrl string, maxVol dn := NewDataNode(ip + ":" + strconv.Itoa(port)) dn.Ip = ip dn.Port = port + dn.AdminPort = adminPort dn.PublicUrl = publicUrl dn.maxVolumeCount = maxVolumeCount dn.LastSeen = time.Now().Unix() |