diff options
| author | Konstantin Lebedev <9497591+kmlebedev@users.noreply.github.com> | 2022-04-04 18:52:08 +0500 |
|---|---|---|
| committer | Konstantin Lebedev <9497591+kmlebedev@users.noreply.github.com> | 2022-04-04 18:52:08 +0500 |
| commit | 1a1e5778c38308fc0cf5f8a96aed9914029e1aa7 (patch) | |
| tree | e3b217d9e5f35f674abe130102e34071cc1c9742 /weed/server/raft_server.go | |
| parent | 14dd97189011d2a8802d5c9cc1726802cf19f2b2 (diff) | |
| download | seaweedfs-1a1e5778c38308fc0cf5f8a96aed9914029e1aa7.tar.xz seaweedfs-1a1e5778c38308fc0cf5f8a96aed9914029e1aa7.zip | |
fix cluster status
Diffstat (limited to 'weed/server/raft_server.go')
| -rw-r--r-- | weed/server/raft_server.go | 15 |
1 files changed, 10 insertions, 5 deletions
diff --git a/weed/server/raft_server.go b/weed/server/raft_server.go index 3fedc843e..8c372f0cc 100644 --- a/weed/server/raft_server.go +++ b/weed/server/raft_server.go @@ -171,12 +171,17 @@ func NewRaftServer(option *RaftServerOption) (*RaftServer, error) { } func (s *RaftServer) Peers() (members []string) { - peers := s.raftServer.Peers() - - for _, p := range peers { - members = append(members, p.Name) + if s.raftServer != nil { + peers := s.raftServer.Peers() + for _, p := range peers { + members = append(members, p.Name) + } + } else if s.RaftHashicorp != nil { + cfg := s.RaftHashicorp.GetConfiguration() + for _, p := range cfg.Configuration().Servers { + members = append(members, string(p.ID)) + } } - return } |