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(datanode): adjust log level for no leader

Browse Source 
close:#1000001079

Signed-off-by: chihe <chihe@oppo.com>
This commit is contained in:
chihe 2025-04-15 10:43:03 +08:00 committed by zhumingze1108
parent 30d76f57df
commit 78c727cda3
2 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
datanode/wrap_operator.go
View File

@ -107,7 +107,7 @@ func (s *DataNode) OperatePacket(p *repl.Packet, c net.Conn) (err error) {
err = fmt.Errorf("op(%v) error(%v)", p.GetOpMsg(), string(p.Data[:resultSize]))
logContent := fmt.Sprintf("action[OperatePacket] %v.",
p.LogMessage(p.GetOpMsg(), c.RemoteAddr().String(), start, err))
if p.IsWriteOpOfPacketProtoVerForbidden() {
if p.IsWriteOpOfPacketProtoVerForbidden() || strings.Contains(logContent, raft.ErrNotLeader.Error()) {
log.LogWarnf(logContent)
} else if isColdVolExtentDelErr(p) {
log.LogInfof(logContent)

2
util/timeutil/time.go
View File

@ -44,7 +44,7 @@ func newNowTime() *nowTime {
t.time.Store(n)
go func() {
ticker := time.NewTicker(10 * time.Millisecond)
ticker := time.NewTicker(time.Second)
defer ticker.Stop()
for {
<-ticker.C