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/storage | |
| 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/storage')
| -rw-r--r-- | go/storage/store.go | 8 |
1 files changed, 5 insertions, 3 deletions
diff --git a/go/storage/store.go b/go/storage/store.go index 7e2b23058..2c4434b81 100644 --- a/go/storage/store.go +++ b/go/storage/store.go @@ -73,8 +73,9 @@ func (mn *MasterNodes) findMaster() (string, error) { * A VolumeServer contains one Store */ type Store struct { - Port int Ip string + Port int + AdminPort int PublicUrl string Locations []*DiskLocation dataCenter string //optional informaton, overwriting master setting if exists @@ -89,8 +90,8 @@ func (s *Store) String() (str string) { return } -func NewStore(port int, ip, publicUrl string, dirnames []string, maxVolumeCounts []int) (s *Store) { - s = &Store{Port: port, Ip: ip, PublicUrl: publicUrl} +func NewStore(port, adminPort int, ip, publicUrl string, dirnames []string, maxVolumeCounts []int) (s *Store) { + s = &Store{Port: port, AdminPort: adminPort, Ip: ip, PublicUrl: publicUrl} s.Locations = make([]*DiskLocation, 0) for i := 0; i < len(dirnames); i++ { location := &DiskLocation{Directory: dirnames[i], MaxVolumeCount: maxVolumeCounts[i]} @@ -308,6 +309,7 @@ func (s *Store) Join() (masterNode string, e error) { DataCenter: proto.String(s.dataCenter), Rack: proto.String(s.rack), Volumes: volumeMessages, + AdminPort: proto.Uint32(uint32(s.AdminPort)), } data, err := proto.Marshal(joinMessage) |