From 84c07b0bbfcd5cf2f29c2de88be0e900972ba9a1 Mon Sep 17 00:00:00 2001 From: Hongchao Deng Date: Tue, 3 May 2016 14:42:29 +0800 Subject: [PATCH] etcd3/store: userUpdate error should be returned --- pkg/storage/etcd3/store.go | 3 +++ 1 file changed, 3 insertions(+) diff --git a/pkg/storage/etcd3/store.go b/pkg/storage/etcd3/store.go index 4758331cbbd..4ac455df5d6 100644 --- a/pkg/storage/etcd3/store.go +++ b/pkg/storage/etcd3/store.go @@ -375,6 +375,9 @@ func (s *store) getState(getResp *clientv3.GetResponse, key string, v reflect.Va func (s *store) updateState(st *objState, userUpdate storage.UpdateFunc) (runtime.Object, uint64, error) { ret, ttlPtr, err := userUpdate(st.obj, *st.meta) + if err != nil { + return nil, 0, err + } version, err := s.versioner.ObjectResourceVersion(ret) if err != nil {