DevFW-CICD/ingress-nginx-helm
14
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

remove timestamp when requeuing Element (#7440)

Browse source 
Signed-off-by: xiayu.lyt <xiayu.lyt@alibaba-inc.com>
This commit is contained in:
Tony Li 2021-09-07 01:12:28 +08:00 committed by GitHub
parent 9f9122c381
commit f27deed2e8
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
1 changed files with 2 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

4
internal/task/queue.go
View file

@ -118,7 +118,7 @@ func (t *Queue) worker() {
ts := time.Now().UnixNano() ts := time.Now().UnixNano()
item := key.(Element) item := key.(Element)
if t.lastSync > item.Timestamp { if item.Timestamp != 0 && t.lastSync > item.Timestamp {
klog.V(3).InfoS("skipping sync", "key", item.Key, "last", t.lastSync, "now", item.Timestamp) klog.V(3).InfoS("skipping sync", "key", item.Key, "last", t.lastSync, "now", item.Timestamp)
t.queue.Forget(key) t.queue.Forget(key)
t.queue.Done(key) t.queue.Done(key)
@ -130,7 +130,7 @@ func (t *Queue) worker() {
klog.ErrorS(err, "requeuing", "key", item.Key) klog.ErrorS(err, "requeuing", "key", item.Key)
t.queue.AddRateLimited(Element{ t.queue.AddRateLimited(Element{
Key: item.Key, Key: item.Key,
Timestamp: time.Now().UnixNano(), Timestamp: 0,
}) })
} else { } else {
t.queue.Forget(key) t.queue.Forget(key)