Skip to content

N
nodemanager
Commit c1d4c265 authored by vicotor's avatar vicotor
Browse files
Options

update

parent 024fdef8
Hide whitespace changes
Inline Side-by-side
Showing with 1 addition and 0 deletions
server/workerManager.go
View file @ c1d4c265
...@@ -520,6 +520,7 @@ func (wm *WorkerManager) handleWorkerMsg(worker *Worker) { ...@@ -520,6 +520,7 @@ func (wm *WorkerManager) handleWorkerMsg(worker *Worker) {
if time.Now().Unix()-int64(msg.RegisteMessage.Timestamp) > config.GetConfig().GetWorkerSignatureExpiredTime() { if time.Now().Unix()-int64(msg.RegisteMessage.Timestamp) > config.GetConfig().GetWorkerSignatureExpiredTime() {
l.WithFields(log.Fields{ l.WithFields(log.Fields{
"worker-addr": worker.workerAddr, "worker-addr": worker.workerAddr,
"timestamp": msg.RegisteMessage.Timestamp,
}).Error("message signature expired") }).Error("message signature expired")
worker.quit <- ErrExpiredMsgSignature worker.quit <- ErrExpiredMsgSignature
return return
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment