gian/cubefs
1
0
Fork 0
mirror of https://github.com/cubefs/cubefs.git synced 2026-08-02 02:00:56 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

fix(raft): use raftfsm.replicas instead of get peers.@formatter:off

Browse Source 
Signed-off-by: Wu Huocheng <wuhuocheng@oppo.com>
This commit is contained in:
Wu Huocheng 2025-02-18 16:20:28 +08:00 committed by zhumingze1108
parent ed61daa568
commit 45afc5aee0
3 changed files with 8 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
datanode/server_handler.go
View File

@ -801,7 +801,7 @@ func (s *DataNode) loadDataPartition(w http.ResponseWriter, r *http.Request) {
func (s *DataNode) getRaftPeers(w http.ResponseWriter, r *http.Request) {
const (
paramRaftID = "raftID"
paramRaftID = "id"
)
if err := r.ParseForm(); err != nil {
err = fmt.Errorf("parse form fail: %v", err)

7
depends/tiglabs/raft/server.go
View File

@ -516,5 +516,10 @@ func (rs *RaftServer) GetPeers(id uint64) []uint64 {
return []uint64{}
}
return raft.getPeers()
ret := make([]uint64, 0, len(raft.raftFsm.replicas))
for id := range raft.raftFsm.replicas {
ret = append(ret, id)
}
return ret
}

2
metanode/api_handler.go
View File

@ -1189,7 +1189,7 @@ func (m *MetaNode) getRaftPeersHandler(w http.ResponseWriter, r *http.Request) {
defer func() {
data, _ := resp.Marshal()
if _, err := w.Write(data); err != nil {
log.LogErrorf("[getRaftStatusHandler] response %s", err)
log.LogErrorf("[getRaftPeersHandler] response %s", err)
}
}()