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

refactor(master): add log for master raft op. #22766129

Browse Source 
Signed-off-by: Victor1319 <zengxuewei@oppo.com>
This commit is contained in:
Victor1319 2024-11-08 14:29:16 +08:00 committed by AmazingChi
parent 0c09436c98
commit c36d41d8a5
2 changed files with 4 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
master/metadata_fsm.go
View File

@ -110,13 +110,14 @@ func (mf *MetadataFsm) Apply(command []byte, index uint64) (resp interface{}, er
mf.raftLk.Lock()
defer mf.raftLk.Unlock()
log.LogDebugf("action[Apply] apply index(%v)", index)
cmd := new(RaftCmd)
if err = cmd.Unmarshal(command); err != nil {
log.LogErrorf("action[fsmApply],unmarshal data:%v, err:%v", command, err.Error())
panic(err)
}
log.LogDebugf("action[Apply] apply index(%v), op %d", index, cmd.Op)
if cmd.Op == opSyncUpdateDataPartition || cmd.Op == opSyncDeleteDataPartition {
dpv := &dataPartitionValue{}
if err := json.Unmarshal(cmd.V, dpv); err != nil {

2
sdk/meta/conn.go
View File

@ -120,6 +120,8 @@ sendWithList:
log.LogWarnf("sendToMetaPartition: leader failed and goto retry, req(%v) mp(%v) mc(%v) err(%v) resp(%v)", req, mp, mc, err, resp)
goto sendWithList
}
log.LogWarnf("sendToMetaPartition: leader failed and goto retry, req(%v) mp(%v) mc(%v) err(%v), addr(%s)",
req, mp, mc, err, addr)
mw.putConn(mc, err)
retry:
start = time.Now()