diff options
| author | chrislu <chris.lu@gmail.com> | 2025-07-15 10:51:00 -0700 |
|---|---|---|
| committer | chrislu <chris.lu@gmail.com> | 2025-07-15 10:51:07 -0700 |
| commit | 64c5dde2f321dbdc24b3cdc00a17c7b6b2c8f0bd (patch) | |
| tree | ea8ba039a913c7f7b08bf73d215b4fbdceccb31b /weed/admin/dash/cluster_topology.go | |
| parent | d78aa3d2de1a18c9802f72c926efa8e80ff2fa64 (diff) | |
| download | seaweedfs-64c5dde2f321dbdc24b3cdc00a17c7b6b2c8f0bd.tar.xz seaweedfs-64c5dde2f321dbdc24b3cdc00a17c7b6b2c8f0bd.zip | |
support multiple masters
fix https://github.com/seaweedfs/seaweedfs/issues/6988
Diffstat (limited to 'weed/admin/dash/cluster_topology.go')
| -rw-r--r-- | weed/admin/dash/cluster_topology.go | 6 |
1 files changed, 4 insertions, 2 deletions
diff --git a/weed/admin/dash/cluster_topology.go b/weed/admin/dash/cluster_topology.go index 3670220ad..9abc8ac2a 100644 --- a/weed/admin/dash/cluster_topology.go +++ b/weed/admin/dash/cluster_topology.go @@ -23,7 +23,8 @@ func (s *AdminServer) GetClusterTopology() (*ClusterTopology, error) { // Use gRPC only err := s.getTopologyViaGRPC(topology) if err != nil { - glog.Errorf("Failed to connect to master server %s: %v", s.masterAddress, err) + currentMaster := s.masterClient.GetMaster(context.Background()) + glog.Errorf("Failed to connect to master server %s: %v", currentMaster, err) return nil, fmt.Errorf("gRPC topology request failed: %v", err) } @@ -40,7 +41,8 @@ func (s *AdminServer) getTopologyViaGRPC(topology *ClusterTopology) error { err := s.WithMasterClient(func(client master_pb.SeaweedClient) error { resp, err := client.VolumeList(context.Background(), &master_pb.VolumeListRequest{}) if err != nil { - glog.Errorf("Failed to get volume list from master %s: %v", s.masterAddress, err) + currentMaster := s.masterClient.GetMaster(context.Background()) + glog.Errorf("Failed to get volume list from master %s: %v", currentMaster, err) return err } |
