Commit fcf63a6c authored by Hongchao Deng's avatar Hongchao Deng

etcd_watcher: make Deleted Event.Object's version consistent

parent e8dc9eae
...@@ -399,6 +399,9 @@ func (w *etcdWatcher) sendModify(res *etcd.Response) { ...@@ -399,6 +399,9 @@ func (w *etcdWatcher) sendModify(res *etcd.Response) {
if res.PrevNode != nil && res.PrevNode.Value != "" { if res.PrevNode != nil && res.PrevNode.Value != "" {
// Ignore problems reading the old object. // Ignore problems reading the old object.
if oldObj, err = w.decodeObject(res.PrevNode); err == nil { 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) oldObjPasses = w.filter(oldObj)
} }
} }
......
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