From fcf63a6c4b8d9bab4ba3a5ae9cfeb041ddaf0435 Mon Sep 17 00:00:00 2001 From: Hongchao Deng Date: Thu, 12 May 2016 10:53:28 -0700 Subject: [PATCH] etcd_watcher: make Deleted Event.Object's version consistent --- pkg/storage/etcd/etcd_watcher.go | 3 +++ 1 file changed, 3 insertions(+) diff --git a/pkg/storage/etcd/etcd_watcher.go b/pkg/storage/etcd/etcd_watcher.go index 93c1f7a9ae5..c856b59ccf8 100644 --- a/pkg/storage/etcd/etcd_watcher.go +++ b/pkg/storage/etcd/etcd_watcher.go @@ -399,6 +399,9 @@ func (w *etcdWatcher) sendModify(res *etcd.Response) { if res.PrevNode != nil && res.PrevNode.Value != "" { // Ignore problems reading the old object. if oldObj, err = w.decodeObject(res.PrevNode); err == nil { + if err := w.versioner.UpdateObject(oldObj, res.Node.ModifiedIndex); err != nil { + utilruntime.HandleError(fmt.Errorf("failure to version api object (%d) %#v: %v", res.Node.ModifiedIndex, oldObj, err)) + } oldObjPasses = w.filter(oldObj) } }