diff --git a/Godeps/Godeps.json b/Godeps/Godeps.json index 2c215582..fe805e8e 100644 --- a/Godeps/Godeps.json +++ b/Godeps/Godeps.json @@ -1,7 +1,7 @@ { "ImportPath": "k8s.io/client-go", "GoVersion": "go1.11", - "GodepVersion": "v80", + "GodepVersion": "v80-k8s-r1", "Packages": [ "./..." ], @@ -404,207 +404,207 @@ }, { "ImportPath": "k8s.io/apimachinery/pkg/api/apitesting", - "Rev": "2a7c9300402896b3c073f2f47df85527c94f83a0" + "Rev": "a33c8200050fc0751848276811abf3fc029b3133" }, { "ImportPath": "k8s.io/apimachinery/pkg/api/apitesting/fuzzer", - "Rev": "2a7c9300402896b3c073f2f47df85527c94f83a0" + "Rev": "a33c8200050fc0751848276811abf3fc029b3133" }, { "ImportPath": "k8s.io/apimachinery/pkg/api/apitesting/roundtrip", - "Rev": "2a7c9300402896b3c073f2f47df85527c94f83a0" + "Rev": "a33c8200050fc0751848276811abf3fc029b3133" }, { "ImportPath": "k8s.io/apimachinery/pkg/api/equality", - "Rev": "2a7c9300402896b3c073f2f47df85527c94f83a0" + "Rev": "a33c8200050fc0751848276811abf3fc029b3133" }, { "ImportPath": "k8s.io/apimachinery/pkg/api/errors", - "Rev": "2a7c9300402896b3c073f2f47df85527c94f83a0" + "Rev": "a33c8200050fc0751848276811abf3fc029b3133" }, { "ImportPath": "k8s.io/apimachinery/pkg/api/meta", - "Rev": "2a7c9300402896b3c073f2f47df85527c94f83a0" + "Rev": "a33c8200050fc0751848276811abf3fc029b3133" }, { "ImportPath": "k8s.io/apimachinery/pkg/api/resource", - "Rev": "2a7c9300402896b3c073f2f47df85527c94f83a0" + "Rev": "a33c8200050fc0751848276811abf3fc029b3133" }, { "ImportPath": "k8s.io/apimachinery/pkg/apis/meta/fuzzer", - "Rev": "2a7c9300402896b3c073f2f47df85527c94f83a0" + "Rev": "a33c8200050fc0751848276811abf3fc029b3133" }, { "ImportPath": "k8s.io/apimachinery/pkg/apis/meta/internalversion", - "Rev": "2a7c9300402896b3c073f2f47df85527c94f83a0" + "Rev": "a33c8200050fc0751848276811abf3fc029b3133" }, { "ImportPath": "k8s.io/apimachinery/pkg/apis/meta/v1", - "Rev": "2a7c9300402896b3c073f2f47df85527c94f83a0" + "Rev": "a33c8200050fc0751848276811abf3fc029b3133" }, { "ImportPath": "k8s.io/apimachinery/pkg/apis/meta/v1/unstructured", - "Rev": "2a7c9300402896b3c073f2f47df85527c94f83a0" + "Rev": "a33c8200050fc0751848276811abf3fc029b3133" }, { "ImportPath": "k8s.io/apimachinery/pkg/apis/meta/v1beta1", - "Rev": "2a7c9300402896b3c073f2f47df85527c94f83a0" + "Rev": "a33c8200050fc0751848276811abf3fc029b3133" }, { "ImportPath": "k8s.io/apimachinery/pkg/conversion", - "Rev": "2a7c9300402896b3c073f2f47df85527c94f83a0" + "Rev": "a33c8200050fc0751848276811abf3fc029b3133" }, { "ImportPath": "k8s.io/apimachinery/pkg/conversion/queryparams", - "Rev": "2a7c9300402896b3c073f2f47df85527c94f83a0" + "Rev": "a33c8200050fc0751848276811abf3fc029b3133" }, { "ImportPath": "k8s.io/apimachinery/pkg/fields", - "Rev": "2a7c9300402896b3c073f2f47df85527c94f83a0" + "Rev": "a33c8200050fc0751848276811abf3fc029b3133" }, { "ImportPath": "k8s.io/apimachinery/pkg/labels", - "Rev": "2a7c9300402896b3c073f2f47df85527c94f83a0" + "Rev": "a33c8200050fc0751848276811abf3fc029b3133" }, { "ImportPath": "k8s.io/apimachinery/pkg/runtime", - "Rev": "2a7c9300402896b3c073f2f47df85527c94f83a0" + "Rev": "a33c8200050fc0751848276811abf3fc029b3133" }, { "ImportPath": "k8s.io/apimachinery/pkg/runtime/schema", - "Rev": "2a7c9300402896b3c073f2f47df85527c94f83a0" + "Rev": "a33c8200050fc0751848276811abf3fc029b3133" }, { "ImportPath": "k8s.io/apimachinery/pkg/runtime/serializer", - "Rev": "2a7c9300402896b3c073f2f47df85527c94f83a0" + "Rev": "a33c8200050fc0751848276811abf3fc029b3133" }, { "ImportPath": "k8s.io/apimachinery/pkg/runtime/serializer/json", - "Rev": "2a7c9300402896b3c073f2f47df85527c94f83a0" + "Rev": "a33c8200050fc0751848276811abf3fc029b3133" }, { "ImportPath": "k8s.io/apimachinery/pkg/runtime/serializer/protobuf", - "Rev": "2a7c9300402896b3c073f2f47df85527c94f83a0" + "Rev": "a33c8200050fc0751848276811abf3fc029b3133" }, { "ImportPath": "k8s.io/apimachinery/pkg/runtime/serializer/recognizer", - "Rev": "2a7c9300402896b3c073f2f47df85527c94f83a0" + "Rev": "a33c8200050fc0751848276811abf3fc029b3133" }, { "ImportPath": "k8s.io/apimachinery/pkg/runtime/serializer/streaming", - "Rev": "2a7c9300402896b3c073f2f47df85527c94f83a0" + "Rev": "a33c8200050fc0751848276811abf3fc029b3133" }, { "ImportPath": "k8s.io/apimachinery/pkg/runtime/serializer/versioning", - "Rev": "2a7c9300402896b3c073f2f47df85527c94f83a0" + "Rev": "a33c8200050fc0751848276811abf3fc029b3133" }, { "ImportPath": "k8s.io/apimachinery/pkg/selection", - "Rev": "2a7c9300402896b3c073f2f47df85527c94f83a0" + "Rev": "a33c8200050fc0751848276811abf3fc029b3133" }, { "ImportPath": "k8s.io/apimachinery/pkg/types", - "Rev": "2a7c9300402896b3c073f2f47df85527c94f83a0" + "Rev": "a33c8200050fc0751848276811abf3fc029b3133" }, { "ImportPath": "k8s.io/apimachinery/pkg/util/cache", - "Rev": "2a7c9300402896b3c073f2f47df85527c94f83a0" + "Rev": "a33c8200050fc0751848276811abf3fc029b3133" }, { "ImportPath": "k8s.io/apimachinery/pkg/util/clock", - "Rev": "2a7c9300402896b3c073f2f47df85527c94f83a0" + "Rev": "a33c8200050fc0751848276811abf3fc029b3133" }, { "ImportPath": "k8s.io/apimachinery/pkg/util/diff", - "Rev": "2a7c9300402896b3c073f2f47df85527c94f83a0" + "Rev": "a33c8200050fc0751848276811abf3fc029b3133" }, { "ImportPath": "k8s.io/apimachinery/pkg/util/errors", - "Rev": "2a7c9300402896b3c073f2f47df85527c94f83a0" + "Rev": "a33c8200050fc0751848276811abf3fc029b3133" }, { "ImportPath": "k8s.io/apimachinery/pkg/util/framer", - "Rev": "2a7c9300402896b3c073f2f47df85527c94f83a0" + "Rev": "a33c8200050fc0751848276811abf3fc029b3133" }, { "ImportPath": "k8s.io/apimachinery/pkg/util/httpstream", - "Rev": "2a7c9300402896b3c073f2f47df85527c94f83a0" + "Rev": "a33c8200050fc0751848276811abf3fc029b3133" }, { "ImportPath": "k8s.io/apimachinery/pkg/util/httpstream/spdy", - "Rev": "2a7c9300402896b3c073f2f47df85527c94f83a0" + "Rev": "a33c8200050fc0751848276811abf3fc029b3133" }, { "ImportPath": "k8s.io/apimachinery/pkg/util/intstr", - "Rev": "2a7c9300402896b3c073f2f47df85527c94f83a0" + "Rev": "a33c8200050fc0751848276811abf3fc029b3133" }, { "ImportPath": "k8s.io/apimachinery/pkg/util/json", - "Rev": "2a7c9300402896b3c073f2f47df85527c94f83a0" + "Rev": "a33c8200050fc0751848276811abf3fc029b3133" }, { "ImportPath": "k8s.io/apimachinery/pkg/util/mergepatch", - "Rev": "2a7c9300402896b3c073f2f47df85527c94f83a0" + "Rev": "a33c8200050fc0751848276811abf3fc029b3133" }, { "ImportPath": "k8s.io/apimachinery/pkg/util/naming", - "Rev": "2a7c9300402896b3c073f2f47df85527c94f83a0" + "Rev": "a33c8200050fc0751848276811abf3fc029b3133" }, { "ImportPath": "k8s.io/apimachinery/pkg/util/net", - "Rev": "2a7c9300402896b3c073f2f47df85527c94f83a0" + "Rev": "a33c8200050fc0751848276811abf3fc029b3133" }, { "ImportPath": "k8s.io/apimachinery/pkg/util/remotecommand", - "Rev": "2a7c9300402896b3c073f2f47df85527c94f83a0" + "Rev": "a33c8200050fc0751848276811abf3fc029b3133" }, { "ImportPath": "k8s.io/apimachinery/pkg/util/runtime", - "Rev": "2a7c9300402896b3c073f2f47df85527c94f83a0" + "Rev": "a33c8200050fc0751848276811abf3fc029b3133" }, { "ImportPath": "k8s.io/apimachinery/pkg/util/sets", - "Rev": "2a7c9300402896b3c073f2f47df85527c94f83a0" + "Rev": "a33c8200050fc0751848276811abf3fc029b3133" }, { "ImportPath": "k8s.io/apimachinery/pkg/util/strategicpatch", - "Rev": "2a7c9300402896b3c073f2f47df85527c94f83a0" + "Rev": "a33c8200050fc0751848276811abf3fc029b3133" }, { "ImportPath": "k8s.io/apimachinery/pkg/util/validation", - "Rev": "2a7c9300402896b3c073f2f47df85527c94f83a0" + "Rev": "a33c8200050fc0751848276811abf3fc029b3133" }, { "ImportPath": "k8s.io/apimachinery/pkg/util/validation/field", - "Rev": "2a7c9300402896b3c073f2f47df85527c94f83a0" + "Rev": "a33c8200050fc0751848276811abf3fc029b3133" }, { "ImportPath": "k8s.io/apimachinery/pkg/util/wait", - "Rev": "2a7c9300402896b3c073f2f47df85527c94f83a0" + "Rev": "a33c8200050fc0751848276811abf3fc029b3133" }, { "ImportPath": "k8s.io/apimachinery/pkg/util/yaml", - "Rev": "2a7c9300402896b3c073f2f47df85527c94f83a0" + "Rev": "a33c8200050fc0751848276811abf3fc029b3133" }, { "ImportPath": "k8s.io/apimachinery/pkg/version", - "Rev": "2a7c9300402896b3c073f2f47df85527c94f83a0" + "Rev": "a33c8200050fc0751848276811abf3fc029b3133" }, { "ImportPath": "k8s.io/apimachinery/pkg/watch", - "Rev": "2a7c9300402896b3c073f2f47df85527c94f83a0" + "Rev": "a33c8200050fc0751848276811abf3fc029b3133" }, { "ImportPath": "k8s.io/apimachinery/third_party/forked/golang/json", - "Rev": "2a7c9300402896b3c073f2f47df85527c94f83a0" + "Rev": "a33c8200050fc0751848276811abf3fc029b3133" }, { "ImportPath": "k8s.io/apimachinery/third_party/forked/golang/netutil", - "Rev": "2a7c9300402896b3c073f2f47df85527c94f83a0" + "Rev": "a33c8200050fc0751848276811abf3fc029b3133" }, { "ImportPath": "k8s.io/apimachinery/third_party/forked/golang/reflect", - "Rev": "2a7c9300402896b3c073f2f47df85527c94f83a0" + "Rev": "a33c8200050fc0751848276811abf3fc029b3133" }, { "ImportPath": "k8s.io/klog", diff --git a/tools/cache/delta_fifo.go b/tools/cache/delta_fifo.go index ded637ac..f818a293 100644 --- a/tools/cache/delta_fifo.go +++ b/tools/cache/delta_fifo.go @@ -320,17 +320,15 @@ func (f *DeltaFIFO) queueActionLocked(actionType DeltaType, obj interface{}) err newDeltas := append(f.items[id], Delta{actionType, obj}) newDeltas = dedupDeltas(newDeltas) - _, exists := f.items[id] if len(newDeltas) > 0 { - if !exists { + if _, exists := f.items[id]; !exists { f.queue = append(f.queue, id) } f.items[id] = newDeltas f.cond.Broadcast() - } else if exists { - // We need to remove this from our map (extra items - // in the queue are ignored if they are not in the - // map). + } else { + // We need to remove this from our map (extra items in the queue are + // ignored if they are not in the map). delete(f.items, id) } return nil @@ -348,9 +346,6 @@ func (f *DeltaFIFO) List() []interface{} { func (f *DeltaFIFO) listLocked() []interface{} { list := make([]interface{}, 0, len(f.items)) for _, item := range f.items { - // Copy item's slice so operations on this slice - // won't interfere with the object we return. - item = copyDeltas(item) list = append(list, item.Newest().Object) } return list @@ -398,10 +393,7 @@ func (f *DeltaFIFO) GetByKey(key string) (item interface{}, exists bool, err err func (f *DeltaFIFO) IsClosed() bool { f.closedLock.Lock() defer f.closedLock.Unlock() - if f.closed { - return true - } - return false + return f.closed } // Pop blocks until an item is added to the queue, and then returns it. If @@ -432,10 +424,10 @@ func (f *DeltaFIFO) Pop(process PopProcessFunc) (interface{}, error) { } id := f.queue[0] f.queue = f.queue[1:] - item, ok := f.items[id] if f.initialPopulationCount > 0 { f.initialPopulationCount-- } + item, ok := f.items[id] if !ok { // Item may have been deleted subsequently. continue