From ec8ad89900bafc5afe3bb181981ebe3eadb35140 Mon Sep 17 00:00:00 2001 From: "zhenshan.cao" Date: Mon, 15 Mar 2021 19:47:13 +0800 Subject: [PATCH] Delete uncessary print Signed-off-by: zhenshan.cao --- internal/proxynode/paramtable.go | 1 - internal/proxynode/task_scheduler.go | 10 ++++++++-- internal/proxynode/timetick.go | 2 -- 3 files changed, 8 insertions(+), 5 deletions(-) diff --git a/internal/proxynode/paramtable.go b/internal/proxynode/paramtable.go index 4db9adc93b..a1d935e99b 100644 --- a/internal/proxynode/paramtable.go +++ b/internal/proxynode/paramtable.go @@ -94,7 +94,6 @@ func (pt *ParamTable) LoadConfigFromInitParams(initParams *internalpb.InitParams log.Debug("proxynode", zap.String("error", "Undefined config type, key="+key)) } } - log.Debug("proxynode", zap.String(key, str)) err = pt.Save(key, str) if err != nil { panic(err) diff --git a/internal/proxynode/task_scheduler.go b/internal/proxynode/task_scheduler.go index 16c00615e7..b959134b22 100644 --- a/internal/proxynode/task_scheduler.go +++ b/internal/proxynode/task_scheduler.go @@ -172,10 +172,16 @@ func (queue *BaseTaskQueue) Enqueue(t task) error { return err } - ts, _ := queue.sched.tsoAllocator.AllocOne() + ts, err := queue.sched.tsoAllocator.AllocOne() + if err != nil { + return err + } t.SetTs(ts) - reqID, _ := queue.sched.idAllocator.AllocOne() + reqID, err := queue.sched.idAllocator.AllocOne() + if err != nil { + return err + } t.SetID(reqID) return queue.addUnissuedTask(t) diff --git a/internal/proxynode/timetick.go b/internal/proxynode/timetick.go index 5577b44748..30911031a6 100644 --- a/internal/proxynode/timetick.go +++ b/internal/proxynode/timetick.go @@ -89,8 +89,6 @@ func (tt *timeTick) tick() error { err := tt.tickMsgStream.Produce(tt.ctx, &msgPack) if err != nil { log.Warn("proxynode", zap.String("error", err.Error())) - } else { - log.Debug("proxynode send time tick message") } tt.tickLock.Lock() defer tt.tickLock.Unlock()