github/kubernetes
1
0
Fork 0
mirror of https://github.com/k3s-io/kubernetes.git synced 2025-08-03 17:30:00 +00:00
Code Issues Projects Releases Wiki Activity

ignore NotFound error in etcd

Browse Source
This commit is contained in:
Chao Xu 2016-03-02 23:31:44 -08:00
parent 2cf3c7809e
commit a3a6130f44
1 changed files with 19 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

20
pkg/registry/generic/etcd/etcd.go
View File

@ -402,6 +402,8 @@ func (e *Etcd) Delete(ctx api.Context, name string, options *api.DeleteOptions)
if pendingGraceful { if pendingGraceful {
return e.finalizeDelete(obj, false) return e.finalizeDelete(obj, false)
} }
var ignoreNotFound bool = false
var lastExisting runtime.Object = nil
if graceful { if graceful {
out := e.NewFunc() out := e.NewFunc()
lastGraceful := int64(0) lastGraceful := int64(0)
@ -419,6 +421,7 @@ func (e *Etcd) Delete(ctx api.Context, name string, options *api.DeleteOptions)
return nil, errDeleteNow return nil, errDeleteNow
} }
lastGraceful = *options.GracePeriodSeconds lastGraceful = *options.GracePeriodSeconds
lastExisting = existing
return existing, nil return existing, nil
}), }),
) )
@ -427,7 +430,15 @@ func (e *Etcd) Delete(ctx api.Context, name string, options *api.DeleteOptions)
if lastGraceful > 0 { if lastGraceful > 0 {
return out, nil return out, nil
} }
// fall through and delete immediately // If we are here, the registry supports grace period mechanism and
// we are intentionally delete gracelessly. In this case, we may
// enter a race with other k8s components. If other component wins
// the race, the object will not be found, and we should tolerate
// the NotFound error. See
// https://github.com/kubernetes/kubernetes/issues/19403 for
// details.
ignoreNotFound = true
// exit the switch and delete immediately
case errDeleteNow: case errDeleteNow:
// we've updated the object to have a zero grace period, or it's already at 0, so // we've updated the object to have a zero grace period, or it's already at 0, so
// we should fall through and truly delete the object. // we should fall through and truly delete the object.
@ -441,6 +452,13 @@ func (e *Etcd) Delete(ctx api.Context, name string, options *api.DeleteOptions)
// delete immediately, or no graceful deletion supported // delete immediately, or no graceful deletion supported
out := e.NewFunc() out := e.NewFunc()
if err := e.Storage.Delete(ctx, key, out); err != nil { if err := e.Storage.Delete(ctx, key, out); err != nil {
// Please refer to the place where we set ignoreNotFound for the reason
// why we ignore the NotFound error .
if storage.IsNotFound(err) && ignoreNotFound && lastExisting != nil {
// The lastExisting object may not be the last state of the object
// before its deletion, but it's the best approximation.
return e.finalizeDelete(lastExisting, true)
}
return nil, etcderr.InterpretDeleteError(err, e.QualifiedResource, name) return nil, etcderr.InterpretDeleteError(err, e.QualifiedResource, name)
} }
return e.finalizeDelete(out, true) return e.finalizeDelete(out, true)