From f307e97f8709b65abbbdd99859c201ac0c1cc36a Mon Sep 17 00:00:00 2001 From: Derek Parker Date: Thu, 5 May 2016 15:24:54 -0700 Subject: [PATCH] kubelet: Add --exit-on-lock-contention flag This patch adds the --exit-on-lock-contention flag, which must be used in conjunction with the --lock-file flag. When provided, it causes the kubelet to wait for inotify events for that lock file. When an 'open' event is received, the kubelet will exit. --- cmd/kubelet/app/options/options.go | 2 + cmd/kubelet/app/server.go | 16 +- cmd/kubelet/app/server_linux.go | 44 + cmd/kubelet/app/server_test.go | 3 +- cmd/kubelet/app/server_unsupported.go | 25 + docs/admin/kubelet.md | 3 +- hack/verify-flags/known-flags.txt | 1 + .../componentconfig/deep_copy_generated.go | 1 + pkg/apis/componentconfig/types.generated.go | 1401 +++++++++-------- pkg/apis/componentconfig/types.go | 5 + pkg/kubelet/container/runtime.go | 2 +- 11 files changed, 818 insertions(+), 685 deletions(-) create mode 100644 cmd/kubelet/app/server_linux.go create mode 100644 cmd/kubelet/app/server_unsupported.go diff --git a/cmd/kubelet/app/options/options.go b/cmd/kubelet/app/options/options.go index 871e5b21f7..33fcaff275 100644 --- a/cmd/kubelet/app/options/options.go +++ b/cmd/kubelet/app/options/options.go @@ -116,6 +116,7 @@ func NewKubeletServer() *KubeletServer { NodeLabels: make(map[string]string), OOMScoreAdj: int32(qos.KubeletOOMScoreAdj), LockFilePath: "", + ExitOnLockContention: false, PodInfraContainerImage: GetDefaultPodInfraContainerImage(), Port: ports.KubeletPort, ReadOnlyPort: ports.KubeletReadOnlyPort, @@ -220,6 +221,7 @@ func (s *KubeletServer) AddFlags(fs *pflag.FlagSet) { fs.StringVar(&s.CgroupRoot, "cgroup-root", s.CgroupRoot, "Optional root cgroup to use for pods. This is handled by the container runtime on a best effort basis. Default: '', which means use the container runtime default.") fs.StringVar(&s.ContainerRuntime, "container-runtime", s.ContainerRuntime, "The container runtime to use. Possible values: 'docker', 'rkt'. Default: 'docker'.") fs.StringVar(&s.LockFilePath, "lock-file", s.LockFilePath, " The path to file for kubelet to use as a lock file.") + fs.BoolVar(&s.ExitOnLockContention, "exit-on-lock-contention", s.ExitOnLockContention, "Whether kubelet should exit upon lock-file contention.") fs.StringVar(&s.RktPath, "rkt-path", s.RktPath, "Path of rkt binary. Leave empty to use the first rkt in $PATH. Only used if --container-runtime='rkt'.") fs.StringVar(&s.RktAPIEndpoint, "rkt-api-endpoint", s.RktAPIEndpoint, "The endpoint of the rkt API service to communicate with. Only used if --container-runtime='rkt'.") fs.StringVar(&s.RktStage1Image, "rkt-stage1-image", s.RktStage1Image, "image to use as stage1. Local paths and http/https URLs are supported. If empty, the 'stage1.aci' in the same directory as '--rkt-path' will be used.") diff --git a/cmd/kubelet/app/server.go b/cmd/kubelet/app/server.go index bf2cc623d9..ad3d674aa3 100644 --- a/cmd/kubelet/app/server.go +++ b/cmd/kubelet/app/server.go @@ -19,6 +19,7 @@ package app import ( "crypto/tls" + "errors" "fmt" "math/rand" "net" @@ -289,11 +290,22 @@ func Run(s *options.KubeletServer, kcfg *KubeletConfig) error { } func run(s *options.KubeletServer, kcfg *KubeletConfig) (err error) { + if s.ExitOnLockContention && s.LockFilePath == "" { + return errors.New("cannot exit on lock file contention: no lock file specified") + } + + done := make(chan struct{}) if s.LockFilePath != "" { glog.Infof("aquiring lock on %q", s.LockFilePath) if err := flock.Acquire(s.LockFilePath); err != nil { return fmt.Errorf("unable to aquire file lock on %q: %v", s.LockFilePath, err) } + if s.ExitOnLockContention { + glog.Infof("watching for inotify events for: %v", s.LockFilePath) + if err := watchForLockfileContention(s.LockFilePath, done); err != nil { + return err + } + } } if c, err := configz.New("componentconfig"); err == nil { c.Set(s.KubeletConfiguration) @@ -383,8 +395,8 @@ func run(s *options.KubeletServer, kcfg *KubeletConfig) (err error) { return nil } - // run forever - select {} + <-done + return nil } // InitializeTLS checks for a configured TLSCertFile and TLSPrivateKeyFile: if unspecified a new self-signed diff --git a/cmd/kubelet/app/server_linux.go b/cmd/kubelet/app/server_linux.go new file mode 100644 index 0000000000..a687f6f8da --- /dev/null +++ b/cmd/kubelet/app/server_linux.go @@ -0,0 +1,44 @@ +/* +Copyright 2015 The Kubernetes Authors All rights reserved. + +Licensed under the Apache License, Version 2.0 (the "License"); +you may not use this file except in compliance with the License. +You may obtain a copy of the License at + + http://www.apache.org/licenses/LICENSE-2.0 + +Unless required by applicable law or agreed to in writing, software +distributed under the License is distributed on an "AS IS" BASIS, +WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. +See the License for the specific language governing permissions and +limitations under the License. +*/ + +package app + +import ( + "github.com/golang/glog" + "golang.org/x/exp/inotify" +) + +func watchForLockfileContention(path string, done chan struct{}) error { + watcher, err := inotify.NewWatcher() + if err != nil { + glog.Errorf("unable to create watcher for lockfile: %v", err) + return err + } + if err = watcher.AddWatch(path, inotify.IN_OPEN|inotify.IN_DELETE_SELF); err != nil { + glog.Errorf("unable to watch lockfile: %v", err) + return err + } + go func() { + select { + case ev := <-watcher.Event: + glog.Infof("inotify event: %v", ev) + case err = <-watcher.Error: + glog.Errorf("inotify watcher error: %v", err) + } + close(done) + }() + return nil +} diff --git a/cmd/kubelet/app/server_test.go b/cmd/kubelet/app/server_test.go index fac4e7bf3e..ff130b24b0 100644 --- a/cmd/kubelet/app/server_test.go +++ b/cmd/kubelet/app/server_test.go @@ -17,8 +17,9 @@ limitations under the License. package app import ( - "k8s.io/kubernetes/pkg/util/config" "testing" + + "k8s.io/kubernetes/pkg/util/config" ) func TestValueOfAllocatableResources(t *testing.T) { diff --git a/cmd/kubelet/app/server_unsupported.go b/cmd/kubelet/app/server_unsupported.go new file mode 100644 index 0000000000..8647b8b68b --- /dev/null +++ b/cmd/kubelet/app/server_unsupported.go @@ -0,0 +1,25 @@ +// +build !linux + +/* +Copyright 2015 The Kubernetes Authors All rights reserved. + +Licensed under the Apache License, Version 2.0 (the "License"); +you may not use this file except in compliance with the License. +You may obtain a copy of the License at + + http://www.apache.org/licenses/LICENSE-2.0 + +Unless required by applicable law or agreed to in writing, software +distributed under the License is distributed on an "AS IS" BASIS, +WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. +See the License for the specific language governing permissions and +limitations under the License. +*/ + +package app + +import "errors" + +func watchForLockfileContention(path string, done chan struct{}) error { + return errors.New("kubelet unsupported in this build") +} diff --git a/docs/admin/kubelet.md b/docs/admin/kubelet.md index c89f698d18..2ad24fdfeb 100644 --- a/docs/admin/kubelet.md +++ b/docs/admin/kubelet.md @@ -92,6 +92,7 @@ kubelet --eviction-pressure-transition-period=5m0s: Duration for which the kubelet has to wait before transitioning out of an eviction pressure condition. --eviction-soft="": A set of eviction thresholds (e.g. memory.available<1.5Gi) that if met over a corresponding grace period would trigger a pod eviction. --eviction-soft-grace-period="": A set of eviction grace periods (e.g. memory.available=1m30s) that correspond to how long a soft eviction threshold must hold before triggering a pod eviction. + --exit-on-lock-contention[=false]: Whether kubelet should exit upon lock-file contention. --experimental-flannel-overlay[=false]: Experimental support for starting the kubelet with the default overlay network (flannel). Assumes flanneld is already running in client mode. [default=false] --experimental-nvidia-gpus=0: Number of NVIDIA GPU devices on this node. Only 0 (default) and 1 are currently supported. --file-check-frequency=20s: Duration between checking config files for new data @@ -159,7 +160,7 @@ kubelet --volume-stats-agg-period=1m0s: Specifies interval for kubelet to calculate and cache the volume disk usage for all pods and volumes. To disable volume calculations, set to 0. Default: '1m' ``` -###### Auto generated by spf13/cobra on 13-May-2016 +###### Auto generated by spf13/cobra on 18-May-2016 diff --git a/hack/verify-flags/known-flags.txt b/hack/verify-flags/known-flags.txt index 6befaeb17d..fc249cb317 100644 --- a/hack/verify-flags/known-flags.txt +++ b/hack/verify-flags/known-flags.txt @@ -133,6 +133,7 @@ experimental-nvidia-gpus experimental-prefix external-hostname external-ip +exit-on-lock-contention failover-timeout failure-domains fake-clientset diff --git a/pkg/apis/componentconfig/deep_copy_generated.go b/pkg/apis/componentconfig/deep_copy_generated.go index bb85bdb016..56e8da3c93 100644 --- a/pkg/apis/componentconfig/deep_copy_generated.go +++ b/pkg/apis/componentconfig/deep_copy_generated.go @@ -272,6 +272,7 @@ func DeepCopy_componentconfig_KubeletConfiguration(in KubeletConfiguration, out out.RktAPIEndpoint = in.RktAPIEndpoint out.RktStage1Image = in.RktStage1Image out.LockFilePath = in.LockFilePath + out.ExitOnLockContention = in.ExitOnLockContention out.ConfigureCBR0 = in.ConfigureCBR0 out.HairpinMode = in.HairpinMode out.BabysitDaemons = in.BabysitDaemons diff --git a/pkg/apis/componentconfig/types.generated.go b/pkg/apis/componentconfig/types.generated.go index 14f452a40e..c607799ebb 100644 --- a/pkg/apis/componentconfig/types.generated.go +++ b/pkg/apis/componentconfig/types.generated.go @@ -1175,7 +1175,7 @@ func (x *KubeletConfiguration) CodecEncodeSelf(e *codec1978.Encoder) { } else { yysep2 := !z.EncBinary() yy2arr2 := z.EncBasicHandle().StructToArray - var yyq2 [86]bool + var yyq2 [87]bool _, _, _ = yysep2, yyq2, yy2arr2 const yyr2 bool = false yyq2[47] = x.CloudProvider != "" @@ -1187,18 +1187,18 @@ func (x *KubeletConfiguration) CodecEncodeSelf(e *codec1978.Encoder) { yyq2[54] = x.RktPath != "" yyq2[55] = x.RktAPIEndpoint != "" yyq2[56] = x.RktStage1Image != "" - yyq2[76] = true - yyq2[77] = x.NodeIP != "" - yyq2[81] = x.EvictionHard != "" - yyq2[82] = x.EvictionSoft != "" - yyq2[83] = x.EvictionSoftGracePeriod != "" - yyq2[84] = true - yyq2[85] = x.EvictionMaxPodGracePeriod != 0 + yyq2[77] = true + yyq2[78] = x.NodeIP != "" + yyq2[82] = x.EvictionHard != "" + yyq2[83] = x.EvictionSoft != "" + yyq2[84] = x.EvictionSoftGracePeriod != "" + yyq2[85] = true + yyq2[86] = x.EvictionMaxPodGracePeriod != 0 var yynn2 int if yyr2 || yy2arr2 { - r.EncodeArrayStart(86) + r.EncodeArrayStart(87) } else { - yynn2 = 70 + yynn2 = 71 for _, b := range yyq2 { if b { yynn2++ @@ -2433,17 +2433,17 @@ func (x *KubeletConfiguration) CodecEncodeSelf(e *codec1978.Encoder) { _ = yym194 if false { } else { - r.EncodeBool(bool(x.ConfigureCBR0)) + r.EncodeBool(bool(x.ExitOnLockContention)) } } else { z.EncSendContainerState(codecSelfer_containerMapKey1234) - r.EncodeString(codecSelferC_UTF81234, string("configureCbr0")) + r.EncodeString(codecSelferC_UTF81234, string("exitOnLockContention")) z.EncSendContainerState(codecSelfer_containerMapValue1234) yym195 := z.EncBinary() _ = yym195 if false { } else { - r.EncodeBool(bool(x.ConfigureCBR0)) + r.EncodeBool(bool(x.ExitOnLockContention)) } } if yyr2 || yy2arr2 { @@ -2452,17 +2452,17 @@ func (x *KubeletConfiguration) CodecEncodeSelf(e *codec1978.Encoder) { _ = yym197 if false { } else { - r.EncodeString(codecSelferC_UTF81234, string(x.HairpinMode)) + r.EncodeBool(bool(x.ConfigureCBR0)) } } else { z.EncSendContainerState(codecSelfer_containerMapKey1234) - r.EncodeString(codecSelferC_UTF81234, string("hairpinMode")) + r.EncodeString(codecSelferC_UTF81234, string("configureCbr0")) z.EncSendContainerState(codecSelfer_containerMapValue1234) yym198 := z.EncBinary() _ = yym198 if false { } else { - r.EncodeString(codecSelferC_UTF81234, string(x.HairpinMode)) + r.EncodeBool(bool(x.ConfigureCBR0)) } } if yyr2 || yy2arr2 { @@ -2471,17 +2471,17 @@ func (x *KubeletConfiguration) CodecEncodeSelf(e *codec1978.Encoder) { _ = yym200 if false { } else { - r.EncodeBool(bool(x.BabysitDaemons)) + r.EncodeString(codecSelferC_UTF81234, string(x.HairpinMode)) } } else { z.EncSendContainerState(codecSelfer_containerMapKey1234) - r.EncodeString(codecSelferC_UTF81234, string("babysitDaemons")) + r.EncodeString(codecSelferC_UTF81234, string("hairpinMode")) z.EncSendContainerState(codecSelfer_containerMapValue1234) yym201 := z.EncBinary() _ = yym201 if false { } else { - r.EncodeBool(bool(x.BabysitDaemons)) + r.EncodeString(codecSelferC_UTF81234, string(x.HairpinMode)) } } if yyr2 || yy2arr2 { @@ -2490,17 +2490,17 @@ func (x *KubeletConfiguration) CodecEncodeSelf(e *codec1978.Encoder) { _ = yym203 if false { } else { - r.EncodeInt(int64(x.MaxPods)) + r.EncodeBool(bool(x.BabysitDaemons)) } } else { z.EncSendContainerState(codecSelfer_containerMapKey1234) - r.EncodeString(codecSelferC_UTF81234, string("maxPods")) + r.EncodeString(codecSelferC_UTF81234, string("babysitDaemons")) z.EncSendContainerState(codecSelfer_containerMapValue1234) yym204 := z.EncBinary() _ = yym204 if false { } else { - r.EncodeInt(int64(x.MaxPods)) + r.EncodeBool(bool(x.BabysitDaemons)) } } if yyr2 || yy2arr2 { @@ -2509,17 +2509,17 @@ func (x *KubeletConfiguration) CodecEncodeSelf(e *codec1978.Encoder) { _ = yym206 if false { } else { - r.EncodeInt(int64(x.NvidiaGPUs)) + r.EncodeInt(int64(x.MaxPods)) } } else { z.EncSendContainerState(codecSelfer_containerMapKey1234) - r.EncodeString(codecSelferC_UTF81234, string("nvidiaGPUs")) + r.EncodeString(codecSelferC_UTF81234, string("maxPods")) z.EncSendContainerState(codecSelfer_containerMapValue1234) yym207 := z.EncBinary() _ = yym207 if false { } else { - r.EncodeInt(int64(x.NvidiaGPUs)) + r.EncodeInt(int64(x.MaxPods)) } } if yyr2 || yy2arr2 { @@ -2528,17 +2528,17 @@ func (x *KubeletConfiguration) CodecEncodeSelf(e *codec1978.Encoder) { _ = yym209 if false { } else { - r.EncodeString(codecSelferC_UTF81234, string(x.DockerExecHandlerName)) + r.EncodeInt(int64(x.NvidiaGPUs)) } } else { z.EncSendContainerState(codecSelfer_containerMapKey1234) - r.EncodeString(codecSelferC_UTF81234, string("dockerExecHandlerName")) + r.EncodeString(codecSelferC_UTF81234, string("nvidiaGPUs")) z.EncSendContainerState(codecSelfer_containerMapValue1234) yym210 := z.EncBinary() _ = yym210 if false { } else { - r.EncodeString(codecSelferC_UTF81234, string(x.DockerExecHandlerName)) + r.EncodeInt(int64(x.NvidiaGPUs)) } } if yyr2 || yy2arr2 { @@ -2547,17 +2547,17 @@ func (x *KubeletConfiguration) CodecEncodeSelf(e *codec1978.Encoder) { _ = yym212 if false { } else { - r.EncodeString(codecSelferC_UTF81234, string(x.PodCIDR)) + r.EncodeString(codecSelferC_UTF81234, string(x.DockerExecHandlerName)) } } else { z.EncSendContainerState(codecSelfer_containerMapKey1234) - r.EncodeString(codecSelferC_UTF81234, string("podCIDR")) + r.EncodeString(codecSelferC_UTF81234, string("dockerExecHandlerName")) z.EncSendContainerState(codecSelfer_containerMapValue1234) yym213 := z.EncBinary() _ = yym213 if false { } else { - r.EncodeString(codecSelferC_UTF81234, string(x.PodCIDR)) + r.EncodeString(codecSelferC_UTF81234, string(x.DockerExecHandlerName)) } } if yyr2 || yy2arr2 { @@ -2566,17 +2566,17 @@ func (x *KubeletConfiguration) CodecEncodeSelf(e *codec1978.Encoder) { _ = yym215 if false { } else { - r.EncodeString(codecSelferC_UTF81234, string(x.ResolverConfig)) + r.EncodeString(codecSelferC_UTF81234, string(x.PodCIDR)) } } else { z.EncSendContainerState(codecSelfer_containerMapKey1234) - r.EncodeString(codecSelferC_UTF81234, string("resolvConf")) + r.EncodeString(codecSelferC_UTF81234, string("podCIDR")) z.EncSendContainerState(codecSelfer_containerMapValue1234) yym216 := z.EncBinary() _ = yym216 if false { } else { - r.EncodeString(codecSelferC_UTF81234, string(x.ResolverConfig)) + r.EncodeString(codecSelferC_UTF81234, string(x.PodCIDR)) } } if yyr2 || yy2arr2 { @@ -2585,17 +2585,17 @@ func (x *KubeletConfiguration) CodecEncodeSelf(e *codec1978.Encoder) { _ = yym218 if false { } else { - r.EncodeBool(bool(x.CPUCFSQuota)) + r.EncodeString(codecSelferC_UTF81234, string(x.ResolverConfig)) } } else { z.EncSendContainerState(codecSelfer_containerMapKey1234) - r.EncodeString(codecSelferC_UTF81234, string("cpuCFSQuota")) + r.EncodeString(codecSelferC_UTF81234, string("resolvConf")) z.EncSendContainerState(codecSelfer_containerMapValue1234) yym219 := z.EncBinary() _ = yym219 if false { } else { - r.EncodeBool(bool(x.CPUCFSQuota)) + r.EncodeString(codecSelferC_UTF81234, string(x.ResolverConfig)) } } if yyr2 || yy2arr2 { @@ -2604,17 +2604,17 @@ func (x *KubeletConfiguration) CodecEncodeSelf(e *codec1978.Encoder) { _ = yym221 if false { } else { - r.EncodeBool(bool(x.Containerized)) + r.EncodeBool(bool(x.CPUCFSQuota)) } } else { z.EncSendContainerState(codecSelfer_containerMapKey1234) - r.EncodeString(codecSelferC_UTF81234, string("containerized")) + r.EncodeString(codecSelferC_UTF81234, string("cpuCFSQuota")) z.EncSendContainerState(codecSelfer_containerMapValue1234) yym222 := z.EncBinary() _ = yym222 if false { } else { - r.EncodeBool(bool(x.Containerized)) + r.EncodeBool(bool(x.CPUCFSQuota)) } } if yyr2 || yy2arr2 { @@ -2623,17 +2623,17 @@ func (x *KubeletConfiguration) CodecEncodeSelf(e *codec1978.Encoder) { _ = yym224 if false { } else { - r.EncodeUint(uint64(x.MaxOpenFiles)) + r.EncodeBool(bool(x.Containerized)) } } else { z.EncSendContainerState(codecSelfer_containerMapKey1234) - r.EncodeString(codecSelferC_UTF81234, string("maxOpenFiles")) + r.EncodeString(codecSelferC_UTF81234, string("containerized")) z.EncSendContainerState(codecSelfer_containerMapValue1234) yym225 := z.EncBinary() _ = yym225 if false { } else { - r.EncodeUint(uint64(x.MaxOpenFiles)) + r.EncodeBool(bool(x.Containerized)) } } if yyr2 || yy2arr2 { @@ -2642,17 +2642,17 @@ func (x *KubeletConfiguration) CodecEncodeSelf(e *codec1978.Encoder) { _ = yym227 if false { } else { - r.EncodeBool(bool(x.ReconcileCIDR)) + r.EncodeUint(uint64(x.MaxOpenFiles)) } } else { z.EncSendContainerState(codecSelfer_containerMapKey1234) - r.EncodeString(codecSelferC_UTF81234, string("reconcileCIDR")) + r.EncodeString(codecSelferC_UTF81234, string("maxOpenFiles")) z.EncSendContainerState(codecSelfer_containerMapValue1234) yym228 := z.EncBinary() _ = yym228 if false { } else { - r.EncodeBool(bool(x.ReconcileCIDR)) + r.EncodeUint(uint64(x.MaxOpenFiles)) } } if yyr2 || yy2arr2 { @@ -2661,17 +2661,17 @@ func (x *KubeletConfiguration) CodecEncodeSelf(e *codec1978.Encoder) { _ = yym230 if false { } else { - r.EncodeBool(bool(x.RegisterSchedulable)) + r.EncodeBool(bool(x.ReconcileCIDR)) } } else { z.EncSendContainerState(codecSelfer_containerMapKey1234) - r.EncodeString(codecSelferC_UTF81234, string("registerSchedulable")) + r.EncodeString(codecSelferC_UTF81234, string("reconcileCIDR")) z.EncSendContainerState(codecSelfer_containerMapValue1234) yym231 := z.EncBinary() _ = yym231 if false { } else { - r.EncodeBool(bool(x.RegisterSchedulable)) + r.EncodeBool(bool(x.ReconcileCIDR)) } } if yyr2 || yy2arr2 { @@ -2680,17 +2680,17 @@ func (x *KubeletConfiguration) CodecEncodeSelf(e *codec1978.Encoder) { _ = yym233 if false { } else { - r.EncodeString(codecSelferC_UTF81234, string(x.ContentType)) + r.EncodeBool(bool(x.RegisterSchedulable)) } } else { z.EncSendContainerState(codecSelfer_containerMapKey1234) - r.EncodeString(codecSelferC_UTF81234, string("contentType")) + r.EncodeString(codecSelferC_UTF81234, string("registerSchedulable")) z.EncSendContainerState(codecSelfer_containerMapValue1234) yym234 := z.EncBinary() _ = yym234 if false { } else { - r.EncodeString(codecSelferC_UTF81234, string(x.ContentType)) + r.EncodeBool(bool(x.RegisterSchedulable)) } } if yyr2 || yy2arr2 { @@ -2699,17 +2699,17 @@ func (x *KubeletConfiguration) CodecEncodeSelf(e *codec1978.Encoder) { _ = yym236 if false { } else { - r.EncodeFloat32(float32(x.KubeAPIQPS)) + r.EncodeString(codecSelferC_UTF81234, string(x.ContentType)) } } else { z.EncSendContainerState(codecSelfer_containerMapKey1234) - r.EncodeString(codecSelferC_UTF81234, string("kubeAPIQPS")) + r.EncodeString(codecSelferC_UTF81234, string("contentType")) z.EncSendContainerState(codecSelfer_containerMapValue1234) yym237 := z.EncBinary() _ = yym237 if false { } else { - r.EncodeFloat32(float32(x.KubeAPIQPS)) + r.EncodeString(codecSelferC_UTF81234, string(x.ContentType)) } } if yyr2 || yy2arr2 { @@ -2718,17 +2718,17 @@ func (x *KubeletConfiguration) CodecEncodeSelf(e *codec1978.Encoder) { _ = yym239 if false { } else { - r.EncodeInt(int64(x.KubeAPIBurst)) + r.EncodeFloat32(float32(x.KubeAPIQPS)) } } else { z.EncSendContainerState(codecSelfer_containerMapKey1234) - r.EncodeString(codecSelferC_UTF81234, string("kubeAPIBurst")) + r.EncodeString(codecSelferC_UTF81234, string("kubeAPIQPS")) z.EncSendContainerState(codecSelfer_containerMapValue1234) yym240 := z.EncBinary() _ = yym240 if false { } else { - r.EncodeInt(int64(x.KubeAPIBurst)) + r.EncodeFloat32(float32(x.KubeAPIQPS)) } } if yyr2 || yy2arr2 { @@ -2737,17 +2737,17 @@ func (x *KubeletConfiguration) CodecEncodeSelf(e *codec1978.Encoder) { _ = yym242 if false { } else { - r.EncodeBool(bool(x.SerializeImagePulls)) + r.EncodeInt(int64(x.KubeAPIBurst)) } } else { z.EncSendContainerState(codecSelfer_containerMapKey1234) - r.EncodeString(codecSelferC_UTF81234, string("serializeImagePulls")) + r.EncodeString(codecSelferC_UTF81234, string("kubeAPIBurst")) z.EncSendContainerState(codecSelfer_containerMapValue1234) yym243 := z.EncBinary() _ = yym243 if false { } else { - r.EncodeBool(bool(x.SerializeImagePulls)) + r.EncodeInt(int64(x.KubeAPIBurst)) } } if yyr2 || yy2arr2 { @@ -2755,6 +2755,25 @@ func (x *KubeletConfiguration) CodecEncodeSelf(e *codec1978.Encoder) { yym245 := z.EncBinary() _ = yym245 if false { + } else { + r.EncodeBool(bool(x.SerializeImagePulls)) + } + } else { + z.EncSendContainerState(codecSelfer_containerMapKey1234) + r.EncodeString(codecSelferC_UTF81234, string("serializeImagePulls")) + z.EncSendContainerState(codecSelfer_containerMapValue1234) + yym246 := z.EncBinary() + _ = yym246 + if false { + } else { + r.EncodeBool(bool(x.SerializeImagePulls)) + } + } + if yyr2 || yy2arr2 { + z.EncSendContainerState(codecSelfer_containerArrayElem1234) + yym248 := z.EncBinary() + _ = yym248 + if false { } else { r.EncodeBool(bool(x.ExperimentalFlannelOverlay)) } @@ -2762,8 +2781,8 @@ func (x *KubeletConfiguration) CodecEncodeSelf(e *codec1978.Encoder) { z.EncSendContainerState(codecSelfer_containerMapKey1234) r.EncodeString(codecSelferC_UTF81234, string("experimentalFlannelOverlay")) z.EncSendContainerState(codecSelfer_containerMapValue1234) - yym246 := z.EncBinary() - _ = yym246 + yym249 := z.EncBinary() + _ = yym249 if false { } else { r.EncodeBool(bool(x.ExperimentalFlannelOverlay)) @@ -2771,42 +2790,42 @@ func (x *KubeletConfiguration) CodecEncodeSelf(e *codec1978.Encoder) { } if yyr2 || yy2arr2 { z.EncSendContainerState(codecSelfer_containerArrayElem1234) - if yyq2[76] { - yy248 := &x.OutOfDiskTransitionFrequency - yym249 := z.EncBinary() - _ = yym249 + if yyq2[77] { + yy251 := &x.OutOfDiskTransitionFrequency + yym252 := z.EncBinary() + _ = yym252 if false { - } else if z.HasExtensions() && z.EncExt(yy248) { - } else if !yym249 && z.IsJSONHandle() { - z.EncJSONMarshal(yy248) + } else if z.HasExtensions() && z.EncExt(yy251) { + } else if !yym252 && z.IsJSONHandle() { + z.EncJSONMarshal(yy251) } else { - z.EncFallback(yy248) + z.EncFallback(yy251) } } else { r.EncodeNil() } } else { - if yyq2[76] { + if yyq2[77] { z.EncSendContainerState(codecSelfer_containerMapKey1234) r.EncodeString(codecSelferC_UTF81234, string("outOfDiskTransitionFrequency")) z.EncSendContainerState(codecSelfer_containerMapValue1234) - yy250 := &x.OutOfDiskTransitionFrequency - yym251 := z.EncBinary() - _ = yym251 + yy253 := &x.OutOfDiskTransitionFrequency + yym254 := z.EncBinary() + _ = yym254 if false { - } else if z.HasExtensions() && z.EncExt(yy250) { - } else if !yym251 && z.IsJSONHandle() { - z.EncJSONMarshal(yy250) + } else if z.HasExtensions() && z.EncExt(yy253) { + } else if !yym254 && z.IsJSONHandle() { + z.EncJSONMarshal(yy253) } else { - z.EncFallback(yy250) + z.EncFallback(yy253) } } } if yyr2 || yy2arr2 { z.EncSendContainerState(codecSelfer_containerArrayElem1234) - if yyq2[77] { - yym253 := z.EncBinary() - _ = yym253 + if yyq2[78] { + yym256 := z.EncBinary() + _ = yym256 if false { } else { r.EncodeString(codecSelferC_UTF81234, string(x.NodeIP)) @@ -2815,12 +2834,12 @@ func (x *KubeletConfiguration) CodecEncodeSelf(e *codec1978.Encoder) { r.EncodeString(codecSelferC_UTF81234, "") } } else { - if yyq2[77] { + if yyq2[78] { z.EncSendContainerState(codecSelfer_containerMapKey1234) r.EncodeString(codecSelferC_UTF81234, string("nodeIP")) z.EncSendContainerState(codecSelfer_containerMapValue1234) - yym254 := z.EncBinary() - _ = yym254 + yym257 := z.EncBinary() + _ = yym257 if false { } else { r.EncodeString(codecSelferC_UTF81234, string(x.NodeIP)) @@ -2832,8 +2851,8 @@ func (x *KubeletConfiguration) CodecEncodeSelf(e *codec1978.Encoder) { if x.NodeLabels == nil { r.EncodeNil() } else { - yym256 := z.EncBinary() - _ = yym256 + yym259 := z.EncBinary() + _ = yym259 if false { } else { z.F.EncMapStringStringV(x.NodeLabels, false, e) @@ -2846,8 +2865,8 @@ func (x *KubeletConfiguration) CodecEncodeSelf(e *codec1978.Encoder) { if x.NodeLabels == nil { r.EncodeNil() } else { - yym257 := z.EncBinary() - _ = yym257 + yym260 := z.EncBinary() + _ = yym260 if false { } else { z.F.EncMapStringStringV(x.NodeLabels, false, e) @@ -2856,8 +2875,8 @@ func (x *KubeletConfiguration) CodecEncodeSelf(e *codec1978.Encoder) { } if yyr2 || yy2arr2 { z.EncSendContainerState(codecSelfer_containerArrayElem1234) - yym259 := z.EncBinary() - _ = yym259 + yym262 := z.EncBinary() + _ = yym262 if false { } else { r.EncodeString(codecSelferC_UTF81234, string(x.NonMasqueradeCIDR)) @@ -2866,8 +2885,8 @@ func (x *KubeletConfiguration) CodecEncodeSelf(e *codec1978.Encoder) { z.EncSendContainerState(codecSelfer_containerMapKey1234) r.EncodeString(codecSelferC_UTF81234, string("nonMasqueradeCIDR")) z.EncSendContainerState(codecSelfer_containerMapValue1234) - yym260 := z.EncBinary() - _ = yym260 + yym263 := z.EncBinary() + _ = yym263 if false { } else { r.EncodeString(codecSelferC_UTF81234, string(x.NonMasqueradeCIDR)) @@ -2875,8 +2894,8 @@ func (x *KubeletConfiguration) CodecEncodeSelf(e *codec1978.Encoder) { } if yyr2 || yy2arr2 { z.EncSendContainerState(codecSelfer_containerArrayElem1234) - yym262 := z.EncBinary() - _ = yym262 + yym265 := z.EncBinary() + _ = yym265 if false { } else { r.EncodeBool(bool(x.EnableCustomMetrics)) @@ -2885,38 +2904,13 @@ func (x *KubeletConfiguration) CodecEncodeSelf(e *codec1978.Encoder) { z.EncSendContainerState(codecSelfer_containerMapKey1234) r.EncodeString(codecSelferC_UTF81234, string("enableCustomMetrics")) z.EncSendContainerState(codecSelfer_containerMapValue1234) - yym263 := z.EncBinary() - _ = yym263 + yym266 := z.EncBinary() + _ = yym266 if false { } else { r.EncodeBool(bool(x.EnableCustomMetrics)) } } - if yyr2 || yy2arr2 { - z.EncSendContainerState(codecSelfer_containerArrayElem1234) - if yyq2[81] { - yym265 := z.EncBinary() - _ = yym265 - if false { - } else { - r.EncodeString(codecSelferC_UTF81234, string(x.EvictionHard)) - } - } else { - r.EncodeString(codecSelferC_UTF81234, "") - } - } else { - if yyq2[81] { - z.EncSendContainerState(codecSelfer_containerMapKey1234) - r.EncodeString(codecSelferC_UTF81234, string("evictionHard")) - z.EncSendContainerState(codecSelfer_containerMapValue1234) - yym266 := z.EncBinary() - _ = yym266 - if false { - } else { - r.EncodeString(codecSelferC_UTF81234, string(x.EvictionHard)) - } - } - } if yyr2 || yy2arr2 { z.EncSendContainerState(codecSelfer_containerArrayElem1234) if yyq2[82] { @@ -2924,7 +2918,7 @@ func (x *KubeletConfiguration) CodecEncodeSelf(e *codec1978.Encoder) { _ = yym268 if false { } else { - r.EncodeString(codecSelferC_UTF81234, string(x.EvictionSoft)) + r.EncodeString(codecSelferC_UTF81234, string(x.EvictionHard)) } } else { r.EncodeString(codecSelferC_UTF81234, "") @@ -2932,13 +2926,13 @@ func (x *KubeletConfiguration) CodecEncodeSelf(e *codec1978.Encoder) { } else { if yyq2[82] { z.EncSendContainerState(codecSelfer_containerMapKey1234) - r.EncodeString(codecSelferC_UTF81234, string("evictionSoft")) + r.EncodeString(codecSelferC_UTF81234, string("evictionHard")) z.EncSendContainerState(codecSelfer_containerMapValue1234) yym269 := z.EncBinary() _ = yym269 if false { } else { - r.EncodeString(codecSelferC_UTF81234, string(x.EvictionSoft)) + r.EncodeString(codecSelferC_UTF81234, string(x.EvictionHard)) } } } @@ -2949,7 +2943,7 @@ func (x *KubeletConfiguration) CodecEncodeSelf(e *codec1978.Encoder) { _ = yym271 if false { } else { - r.EncodeString(codecSelferC_UTF81234, string(x.EvictionSoftGracePeriod)) + r.EncodeString(codecSelferC_UTF81234, string(x.EvictionSoft)) } } else { r.EncodeString(codecSelferC_UTF81234, "") @@ -2957,11 +2951,36 @@ func (x *KubeletConfiguration) CodecEncodeSelf(e *codec1978.Encoder) { } else { if yyq2[83] { z.EncSendContainerState(codecSelfer_containerMapKey1234) - r.EncodeString(codecSelferC_UTF81234, string("evictionSoftGracePeriod")) + r.EncodeString(codecSelferC_UTF81234, string("evictionSoft")) z.EncSendContainerState(codecSelfer_containerMapValue1234) yym272 := z.EncBinary() _ = yym272 if false { + } else { + r.EncodeString(codecSelferC_UTF81234, string(x.EvictionSoft)) + } + } + } + if yyr2 || yy2arr2 { + z.EncSendContainerState(codecSelfer_containerArrayElem1234) + if yyq2[84] { + yym274 := z.EncBinary() + _ = yym274 + if false { + } else { + r.EncodeString(codecSelferC_UTF81234, string(x.EvictionSoftGracePeriod)) + } + } else { + r.EncodeString(codecSelferC_UTF81234, "") + } + } else { + if yyq2[84] { + z.EncSendContainerState(codecSelfer_containerMapKey1234) + r.EncodeString(codecSelferC_UTF81234, string("evictionSoftGracePeriod")) + z.EncSendContainerState(codecSelfer_containerMapValue1234) + yym275 := z.EncBinary() + _ = yym275 + if false { } else { r.EncodeString(codecSelferC_UTF81234, string(x.EvictionSoftGracePeriod)) } @@ -2969,42 +2988,42 @@ func (x *KubeletConfiguration) CodecEncodeSelf(e *codec1978.Encoder) { } if yyr2 || yy2arr2 { z.EncSendContainerState(codecSelfer_containerArrayElem1234) - if yyq2[84] { - yy274 := &x.EvictionPressureTransitionPeriod - yym275 := z.EncBinary() - _ = yym275 + if yyq2[85] { + yy277 := &x.EvictionPressureTransitionPeriod + yym278 := z.EncBinary() + _ = yym278 if false { - } else if z.HasExtensions() && z.EncExt(yy274) { - } else if !yym275 && z.IsJSONHandle() { - z.EncJSONMarshal(yy274) + } else if z.HasExtensions() && z.EncExt(yy277) { + } else if !yym278 && z.IsJSONHandle() { + z.EncJSONMarshal(yy277) } else { - z.EncFallback(yy274) + z.EncFallback(yy277) } } else { r.EncodeNil() } } else { - if yyq2[84] { + if yyq2[85] { z.EncSendContainerState(codecSelfer_containerMapKey1234) r.EncodeString(codecSelferC_UTF81234, string("evictionPressureTransitionPeriod")) z.EncSendContainerState(codecSelfer_containerMapValue1234) - yy276 := &x.EvictionPressureTransitionPeriod - yym277 := z.EncBinary() - _ = yym277 + yy279 := &x.EvictionPressureTransitionPeriod + yym280 := z.EncBinary() + _ = yym280 if false { - } else if z.HasExtensions() && z.EncExt(yy276) { - } else if !yym277 && z.IsJSONHandle() { - z.EncJSONMarshal(yy276) + } else if z.HasExtensions() && z.EncExt(yy279) { + } else if !yym280 && z.IsJSONHandle() { + z.EncJSONMarshal(yy279) } else { - z.EncFallback(yy276) + z.EncFallback(yy279) } } } if yyr2 || yy2arr2 { z.EncSendContainerState(codecSelfer_containerArrayElem1234) - if yyq2[85] { - yym279 := z.EncBinary() - _ = yym279 + if yyq2[86] { + yym282 := z.EncBinary() + _ = yym282 if false { } else { r.EncodeInt(int64(x.EvictionMaxPodGracePeriod)) @@ -3013,12 +3032,12 @@ func (x *KubeletConfiguration) CodecEncodeSelf(e *codec1978.Encoder) { r.EncodeInt(0) } } else { - if yyq2[85] { + if yyq2[86] { z.EncSendContainerState(codecSelfer_containerMapKey1234) r.EncodeString(codecSelferC_UTF81234, string("evictionMaxPodGracePeriod")) z.EncSendContainerState(codecSelfer_containerMapValue1234) - yym280 := z.EncBinary() - _ = yym280 + yym283 := z.EncBinary() + _ = yym283 if false { } else { r.EncodeInt(int64(x.EvictionMaxPodGracePeriod)) @@ -3506,6 +3525,12 @@ func (x *KubeletConfiguration) codecDecodeSelfFromMap(l int, d *codec1978.Decode } else { x.LockFilePath = string(r.DecodeString()) } + case "exitOnLockContention": + if r.TryDecodeAsNil() { + x.ExitOnLockContention = false + } else { + x.ExitOnLockContention = bool(r.DecodeBool()) + } case "configureCbr0": if r.TryDecodeAsNil() { x.ConfigureCBR0 = false @@ -3618,15 +3643,15 @@ func (x *KubeletConfiguration) codecDecodeSelfFromMap(l int, d *codec1978.Decode if r.TryDecodeAsNil() { x.OutOfDiskTransitionFrequency = pkg1_unversioned.Duration{} } else { - yyv88 := &x.OutOfDiskTransitionFrequency - yym89 := z.DecBinary() - _ = yym89 + yyv89 := &x.OutOfDiskTransitionFrequency + yym90 := z.DecBinary() + _ = yym90 if false { - } else if z.HasExtensions() && z.DecExt(yyv88) { - } else if !yym89 && z.IsJSONHandle() { - z.DecJSONUnmarshal(yyv88) + } else if z.HasExtensions() && z.DecExt(yyv89) { + } else if !yym90 && z.IsJSONHandle() { + z.DecJSONUnmarshal(yyv89) } else { - z.DecFallback(yyv88, false) + z.DecFallback(yyv89, false) } } case "nodeIP": @@ -3639,12 +3664,12 @@ func (x *KubeletConfiguration) codecDecodeSelfFromMap(l int, d *codec1978.Decode if r.TryDecodeAsNil() { x.NodeLabels = nil } else { - yyv91 := &x.NodeLabels - yym92 := z.DecBinary() - _ = yym92 + yyv92 := &x.NodeLabels + yym93 := z.DecBinary() + _ = yym93 if false { } else { - z.F.DecMapStringStringX(yyv91, false, d) + z.F.DecMapStringStringX(yyv92, false, d) } } case "nonMasqueradeCIDR": @@ -3681,15 +3706,15 @@ func (x *KubeletConfiguration) codecDecodeSelfFromMap(l int, d *codec1978.Decode if r.TryDecodeAsNil() { x.EvictionPressureTransitionPeriod = pkg1_unversioned.Duration{} } else { - yyv98 := &x.EvictionPressureTransitionPeriod - yym99 := z.DecBinary() - _ = yym99 + yyv99 := &x.EvictionPressureTransitionPeriod + yym100 := z.DecBinary() + _ = yym100 if false { - } else if z.HasExtensions() && z.DecExt(yyv98) { - } else if !yym99 && z.IsJSONHandle() { - z.DecJSONUnmarshal(yyv98) + } else if z.HasExtensions() && z.DecExt(yyv99) { + } else if !yym100 && z.IsJSONHandle() { + z.DecJSONUnmarshal(yyv99) } else { - z.DecFallback(yyv98, false) + z.DecFallback(yyv99, false) } } case "evictionMaxPodGracePeriod": @@ -3709,16 +3734,16 @@ func (x *KubeletConfiguration) codecDecodeSelfFromArray(l int, d *codec1978.Deco var h codecSelfer1234 z, r := codec1978.GenHelperDecoder(d) _, _, _ = h, z, r - var yyj101 int - var yyb101 bool - var yyhl101 bool = l >= 0 - yyj101++ - if yyhl101 { - yyb101 = yyj101 > l + var yyj102 int + var yyb102 bool + var yyhl102 bool = l >= 0 + yyj102++ + if yyhl102 { + yyb102 = yyj102 > l } else { - yyb101 = r.CheckBreak() + yyb102 = r.CheckBreak() } - if yyb101 { + if yyb102 { z.DecSendContainerState(codecSelfer_containerArrayEnd1234) return } @@ -3728,13 +3753,13 @@ func (x *KubeletConfiguration) codecDecodeSelfFromArray(l int, d *codec1978.Deco } else { x.Config = string(r.DecodeString()) } - yyj101++ - if yyhl101 { - yyb101 = yyj101 > l + yyj102++ + if yyhl102 { + yyb102 = yyj102 > l } else { - yyb101 = r.CheckBreak() + yyb102 = r.CheckBreak() } - if yyb101 { + if yyb102 { z.DecSendContainerState(codecSelfer_containerArrayEnd1234) return } @@ -3742,24 +3767,24 @@ func (x *KubeletConfiguration) codecDecodeSelfFromArray(l int, d *codec1978.Deco if r.TryDecodeAsNil() { x.SyncFrequency = pkg1_unversioned.Duration{} } else { - yyv103 := &x.SyncFrequency - yym104 := z.DecBinary() - _ = yym104 + yyv104 := &x.SyncFrequency + yym105 := z.DecBinary() + _ = yym105 if false { - } else if z.HasExtensions() && z.DecExt(yyv103) { - } else if !yym104 && z.IsJSONHandle() { - z.DecJSONUnmarshal(yyv103) + } else if z.HasExtensions() && z.DecExt(yyv104) { + } else if !yym105 && z.IsJSONHandle() { + z.DecJSONUnmarshal(yyv104) } else { - z.DecFallback(yyv103, false) + z.DecFallback(yyv104, false) } } - yyj101++ - if yyhl101 { - yyb101 = yyj101 > l + yyj102++ + if yyhl102 { + yyb102 = yyj102 > l } else { - yyb101 = r.CheckBreak() + yyb102 = r.CheckBreak() } - if yyb101 { + if yyb102 { z.DecSendContainerState(codecSelfer_containerArrayEnd1234) return } @@ -3767,24 +3792,24 @@ func (x *KubeletConfiguration) codecDecodeSelfFromArray(l int, d *codec1978.Deco if r.TryDecodeAsNil() { x.FileCheckFrequency = pkg1_unversioned.Duration{} } else { - yyv105 := &x.FileCheckFrequency - yym106 := z.DecBinary() - _ = yym106 + yyv106 := &x.FileCheckFrequency + yym107 := z.DecBinary() + _ = yym107 if false { - } else if z.HasExtensions() && z.DecExt(yyv105) { - } else if !yym106 && z.IsJSONHandle() { - z.DecJSONUnmarshal(yyv105) + } else if z.HasExtensions() && z.DecExt(yyv106) { + } else if !yym107 && z.IsJSONHandle() { + z.DecJSONUnmarshal(yyv106) } else { - z.DecFallback(yyv105, false) + z.DecFallback(yyv106, false) } } - yyj101++ - if yyhl101 { - yyb101 = yyj101 > l + yyj102++ + if yyhl102 { + yyb102 = yyj102 > l } else { - yyb101 = r.CheckBreak() + yyb102 = r.CheckBreak() } - if yyb101 { + if yyb102 { z.DecSendContainerState(codecSelfer_containerArrayEnd1234) return } @@ -3792,24 +3817,24 @@ func (x *KubeletConfiguration) codecDecodeSelfFromArray(l int, d *codec1978.Deco if r.TryDecodeAsNil() { x.HTTPCheckFrequency = pkg1_unversioned.Duration{} } else { - yyv107 := &x.HTTPCheckFrequency - yym108 := z.DecBinary() - _ = yym108 + yyv108 := &x.HTTPCheckFrequency + yym109 := z.DecBinary() + _ = yym109 if false { - } else if z.HasExtensions() && z.DecExt(yyv107) { - } else if !yym108 && z.IsJSONHandle() { - z.DecJSONUnmarshal(yyv107) + } else if z.HasExtensions() && z.DecExt(yyv108) { + } else if !yym109 && z.IsJSONHandle() { + z.DecJSONUnmarshal(yyv108) } else { - z.DecFallback(yyv107, false) + z.DecFallback(yyv108, false) } } - yyj101++ - if yyhl101 { - yyb101 = yyj101 > l + yyj102++ + if yyhl102 { + yyb102 = yyj102 > l } else { - yyb101 = r.CheckBreak() + yyb102 = r.CheckBreak() } - if yyb101 { + if yyb102 { z.DecSendContainerState(codecSelfer_containerArrayEnd1234) return } @@ -3819,13 +3844,13 @@ func (x *KubeletConfiguration) codecDecodeSelfFromArray(l int, d *codec1978.Deco } else { x.ManifestURL = string(r.DecodeString()) } - yyj101++ - if yyhl101 { - yyb101 = yyj101 > l + yyj102++ + if yyhl102 { + yyb102 = yyj102 > l } else { - yyb101 = r.CheckBreak() + yyb102 = r.CheckBreak() } - if yyb101 { + if yyb102 { z.DecSendContainerState(codecSelfer_containerArrayEnd1234) return } @@ -3835,13 +3860,13 @@ func (x *KubeletConfiguration) codecDecodeSelfFromArray(l int, d *codec1978.Deco } else { x.ManifestURLHeader = string(r.DecodeString()) } - yyj101++ - if yyhl101 { - yyb101 = yyj101 > l + yyj102++ + if yyhl102 { + yyb102 = yyj102 > l } else { - yyb101 = r.CheckBreak() + yyb102 = r.CheckBreak() } - if yyb101 { + if yyb102 { z.DecSendContainerState(codecSelfer_containerArrayEnd1234) return } @@ -3851,13 +3876,13 @@ func (x *KubeletConfiguration) codecDecodeSelfFromArray(l int, d *codec1978.Deco } else { x.EnableServer = bool(r.DecodeBool()) } - yyj101++ - if yyhl101 { - yyb101 = yyj101 > l + yyj102++ + if yyhl102 { + yyb102 = yyj102 > l } else { - yyb101 = r.CheckBreak() + yyb102 = r.CheckBreak() } - if yyb101 { + if yyb102 { z.DecSendContainerState(codecSelfer_containerArrayEnd1234) return } @@ -3867,13 +3892,13 @@ func (x *KubeletConfiguration) codecDecodeSelfFromArray(l int, d *codec1978.Deco } else { x.Address = string(r.DecodeString()) } - yyj101++ - if yyhl101 { - yyb101 = yyj101 > l + yyj102++ + if yyhl102 { + yyb102 = yyj102 > l } else { - yyb101 = r.CheckBreak() + yyb102 = r.CheckBreak() } - if yyb101 { + if yyb102 { z.DecSendContainerState(codecSelfer_containerArrayEnd1234) return } @@ -3883,13 +3908,13 @@ func (x *KubeletConfiguration) codecDecodeSelfFromArray(l int, d *codec1978.Deco } else { x.Port = uint(r.DecodeUint(codecSelferBitsize1234)) } - yyj101++ - if yyhl101 { - yyb101 = yyj101 > l + yyj102++ + if yyhl102 { + yyb102 = yyj102 > l } else { - yyb101 = r.CheckBreak() + yyb102 = r.CheckBreak() } - if yyb101 { + if yyb102 { z.DecSendContainerState(codecSelfer_containerArrayEnd1234) return } @@ -3899,13 +3924,13 @@ func (x *KubeletConfiguration) codecDecodeSelfFromArray(l int, d *codec1978.Deco } else { x.ReadOnlyPort = uint(r.DecodeUint(codecSelferBitsize1234)) } - yyj101++ - if yyhl101 { - yyb101 = yyj101 > l + yyj102++ + if yyhl102 { + yyb102 = yyj102 > l } else { - yyb101 = r.CheckBreak() + yyb102 = r.CheckBreak() } - if yyb101 { + if yyb102 { z.DecSendContainerState(codecSelfer_containerArrayEnd1234) return } @@ -3915,13 +3940,13 @@ func (x *KubeletConfiguration) codecDecodeSelfFromArray(l int, d *codec1978.Deco } else { x.TLSCertFile = string(r.DecodeString()) } - yyj101++ - if yyhl101 { - yyb101 = yyj101 > l + yyj102++ + if yyhl102 { + yyb102 = yyj102 > l } else { - yyb101 = r.CheckBreak() + yyb102 = r.CheckBreak() } - if yyb101 { + if yyb102 { z.DecSendContainerState(codecSelfer_containerArrayEnd1234) return } @@ -3931,13 +3956,13 @@ func (x *KubeletConfiguration) codecDecodeSelfFromArray(l int, d *codec1978.Deco } else { x.TLSPrivateKeyFile = string(r.DecodeString()) } - yyj101++ - if yyhl101 { - yyb101 = yyj101 > l + yyj102++ + if yyhl102 { + yyb102 = yyj102 > l } else { - yyb101 = r.CheckBreak() + yyb102 = r.CheckBreak() } - if yyb101 { + if yyb102 { z.DecSendContainerState(codecSelfer_containerArrayEnd1234) return } @@ -3947,13 +3972,13 @@ func (x *KubeletConfiguration) codecDecodeSelfFromArray(l int, d *codec1978.Deco } else { x.CertDirectory = string(r.DecodeString()) } - yyj101++ - if yyhl101 { - yyb101 = yyj101 > l + yyj102++ + if yyhl102 { + yyb102 = yyj102 > l } else { - yyb101 = r.CheckBreak() + yyb102 = r.CheckBreak() } - if yyb101 { + if yyb102 { z.DecSendContainerState(codecSelfer_containerArrayEnd1234) return } @@ -3963,13 +3988,13 @@ func (x *KubeletConfiguration) codecDecodeSelfFromArray(l int, d *codec1978.Deco } else { x.HostnameOverride = string(r.DecodeString()) } - yyj101++ - if yyhl101 { - yyb101 = yyj101 > l + yyj102++ + if yyhl102 { + yyb102 = yyj102 > l } else { - yyb101 = r.CheckBreak() + yyb102 = r.CheckBreak() } - if yyb101 { + if yyb102 { z.DecSendContainerState(codecSelfer_containerArrayEnd1234) return } @@ -3979,13 +4004,13 @@ func (x *KubeletConfiguration) codecDecodeSelfFromArray(l int, d *codec1978.Deco } else { x.PodInfraContainerImage = string(r.DecodeString()) } - yyj101++ - if yyhl101 { - yyb101 = yyj101 > l + yyj102++ + if yyhl102 { + yyb102 = yyj102 > l } else { - yyb101 = r.CheckBreak() + yyb102 = r.CheckBreak() } - if yyb101 { + if yyb102 { z.DecSendContainerState(codecSelfer_containerArrayEnd1234) return } @@ -3995,13 +4020,13 @@ func (x *KubeletConfiguration) codecDecodeSelfFromArray(l int, d *codec1978.Deco } else { x.DockerEndpoint = string(r.DecodeString()) } - yyj101++ - if yyhl101 { - yyb101 = yyj101 > l + yyj102++ + if yyhl102 { + yyb102 = yyj102 > l } else { - yyb101 = r.CheckBreak() + yyb102 = r.CheckBreak() } - if yyb101 { + if yyb102 { z.DecSendContainerState(codecSelfer_containerArrayEnd1234) return } @@ -4011,13 +4036,13 @@ func (x *KubeletConfiguration) codecDecodeSelfFromArray(l int, d *codec1978.Deco } else { x.RootDirectory = string(r.DecodeString()) } - yyj101++ - if yyhl101 { - yyb101 = yyj101 > l + yyj102++ + if yyhl102 { + yyb102 = yyj102 > l } else { - yyb101 = r.CheckBreak() + yyb102 = r.CheckBreak() } - if yyb101 { + if yyb102 { z.DecSendContainerState(codecSelfer_containerArrayEnd1234) return } @@ -4027,13 +4052,13 @@ func (x *KubeletConfiguration) codecDecodeSelfFromArray(l int, d *codec1978.Deco } else { x.AllowPrivileged = bool(r.DecodeBool()) } - yyj101++ - if yyhl101 { - yyb101 = yyj101 > l + yyj102++ + if yyhl102 { + yyb102 = yyj102 > l } else { - yyb101 = r.CheckBreak() + yyb102 = r.CheckBreak() } - if yyb101 { + if yyb102 { z.DecSendContainerState(codecSelfer_containerArrayEnd1234) return } @@ -4043,13 +4068,13 @@ func (x *KubeletConfiguration) codecDecodeSelfFromArray(l int, d *codec1978.Deco } else { x.HostNetworkSources = string(r.DecodeString()) } - yyj101++ - if yyhl101 { - yyb101 = yyj101 > l + yyj102++ + if yyhl102 { + yyb102 = yyj102 > l } else { - yyb101 = r.CheckBreak() + yyb102 = r.CheckBreak() } - if yyb101 { + if yyb102 { z.DecSendContainerState(codecSelfer_containerArrayEnd1234) return } @@ -4059,13 +4084,13 @@ func (x *KubeletConfiguration) codecDecodeSelfFromArray(l int, d *codec1978.Deco } else { x.HostPIDSources = string(r.DecodeString()) } - yyj101++ - if yyhl101 { - yyb101 = yyj101 > l + yyj102++ + if yyhl102 { + yyb102 = yyj102 > l } else { - yyb101 = r.CheckBreak() + yyb102 = r.CheckBreak() } - if yyb101 { + if yyb102 { z.DecSendContainerState(codecSelfer_containerArrayEnd1234) return } @@ -4075,13 +4100,13 @@ func (x *KubeletConfiguration) codecDecodeSelfFromArray(l int, d *codec1978.Deco } else { x.HostIPCSources = string(r.DecodeString()) } - yyj101++ - if yyhl101 { - yyb101 = yyj101 > l + yyj102++ + if yyhl102 { + yyb102 = yyj102 > l } else { - yyb101 = r.CheckBreak() + yyb102 = r.CheckBreak() } - if yyb101 { + if yyb102 { z.DecSendContainerState(codecSelfer_containerArrayEnd1234) return } @@ -4091,13 +4116,13 @@ func (x *KubeletConfiguration) codecDecodeSelfFromArray(l int, d *codec1978.Deco } else { x.RegistryPullQPS = float64(r.DecodeFloat(false)) } - yyj101++ - if yyhl101 { - yyb101 = yyj101 > l + yyj102++ + if yyhl102 { + yyb102 = yyj102 > l } else { - yyb101 = r.CheckBreak() + yyb102 = r.CheckBreak() } - if yyb101 { + if yyb102 { z.DecSendContainerState(codecSelfer_containerArrayEnd1234) return } @@ -4107,13 +4132,13 @@ func (x *KubeletConfiguration) codecDecodeSelfFromArray(l int, d *codec1978.Deco } else { x.RegistryBurst = int32(r.DecodeInt(32)) } - yyj101++ - if yyhl101 { - yyb101 = yyj101 > l + yyj102++ + if yyhl102 { + yyb102 = yyj102 > l } else { - yyb101 = r.CheckBreak() + yyb102 = r.CheckBreak() } - if yyb101 { + if yyb102 { z.DecSendContainerState(codecSelfer_containerArrayEnd1234) return } @@ -4123,13 +4148,13 @@ func (x *KubeletConfiguration) codecDecodeSelfFromArray(l int, d *codec1978.Deco } else { x.EventRecordQPS = float32(r.DecodeFloat(true)) } - yyj101++ - if yyhl101 { - yyb101 = yyj101 > l + yyj102++ + if yyhl102 { + yyb102 = yyj102 > l } else { - yyb101 = r.CheckBreak() + yyb102 = r.CheckBreak() } - if yyb101 { + if yyb102 { z.DecSendContainerState(codecSelfer_containerArrayEnd1234) return } @@ -4139,13 +4164,13 @@ func (x *KubeletConfiguration) codecDecodeSelfFromArray(l int, d *codec1978.Deco } else { x.EventBurst = int32(r.DecodeInt(32)) } - yyj101++ - if yyhl101 { - yyb101 = yyj101 > l + yyj102++ + if yyhl102 { + yyb102 = yyj102 > l } else { - yyb101 = r.CheckBreak() + yyb102 = r.CheckBreak() } - if yyb101 { + if yyb102 { z.DecSendContainerState(codecSelfer_containerArrayEnd1234) return } @@ -4155,13 +4180,13 @@ func (x *KubeletConfiguration) codecDecodeSelfFromArray(l int, d *codec1978.Deco } else { x.EnableDebuggingHandlers = bool(r.DecodeBool()) } - yyj101++ - if yyhl101 { - yyb101 = yyj101 > l + yyj102++ + if yyhl102 { + yyb102 = yyj102 > l } else { - yyb101 = r.CheckBreak() + yyb102 = r.CheckBreak() } - if yyb101 { + if yyb102 { z.DecSendContainerState(codecSelfer_containerArrayEnd1234) return } @@ -4169,24 +4194,24 @@ func (x *KubeletConfiguration) codecDecodeSelfFromArray(l int, d *codec1978.Deco if r.TryDecodeAsNil() { x.MinimumGCAge = pkg1_unversioned.Duration{} } else { - yyv131 := &x.MinimumGCAge - yym132 := z.DecBinary() - _ = yym132 + yyv132 := &x.MinimumGCAge + yym133 := z.DecBinary() + _ = yym133 if false { - } else if z.HasExtensions() && z.DecExt(yyv131) { - } else if !yym132 && z.IsJSONHandle() { - z.DecJSONUnmarshal(yyv131) + } else if z.HasExtensions() && z.DecExt(yyv132) { + } else if !yym133 && z.IsJSONHandle() { + z.DecJSONUnmarshal(yyv132) } else { - z.DecFallback(yyv131, false) + z.DecFallback(yyv132, false) } } - yyj101++ - if yyhl101 { - yyb101 = yyj101 > l + yyj102++ + if yyhl102 { + yyb102 = yyj102 > l } else { - yyb101 = r.CheckBreak() + yyb102 = r.CheckBreak() } - if yyb101 { + if yyb102 { z.DecSendContainerState(codecSelfer_containerArrayEnd1234) return } @@ -4196,13 +4221,13 @@ func (x *KubeletConfiguration) codecDecodeSelfFromArray(l int, d *codec1978.Deco } else { x.MaxPerPodContainerCount = int32(r.DecodeInt(32)) } - yyj101++ - if yyhl101 { - yyb101 = yyj101 > l + yyj102++ + if yyhl102 { + yyb102 = yyj102 > l } else { - yyb101 = r.CheckBreak() + yyb102 = r.CheckBreak() } - if yyb101 { + if yyb102 { z.DecSendContainerState(codecSelfer_containerArrayEnd1234) return } @@ -4212,13 +4237,13 @@ func (x *KubeletConfiguration) codecDecodeSelfFromArray(l int, d *codec1978.Deco } else { x.MaxContainerCount = int32(r.DecodeInt(32)) } - yyj101++ - if yyhl101 { - yyb101 = yyj101 > l + yyj102++ + if yyhl102 { + yyb102 = yyj102 > l } else { - yyb101 = r.CheckBreak() + yyb102 = r.CheckBreak() } - if yyb101 { + if yyb102 { z.DecSendContainerState(codecSelfer_containerArrayEnd1234) return } @@ -4228,13 +4253,13 @@ func (x *KubeletConfiguration) codecDecodeSelfFromArray(l int, d *codec1978.Deco } else { x.CAdvisorPort = uint(r.DecodeUint(codecSelferBitsize1234)) } - yyj101++ - if yyhl101 { - yyb101 = yyj101 > l + yyj102++ + if yyhl102 { + yyb102 = yyj102 > l } else { - yyb101 = r.CheckBreak() + yyb102 = r.CheckBreak() } - if yyb101 { + if yyb102 { z.DecSendContainerState(codecSelfer_containerArrayEnd1234) return } @@ -4244,13 +4269,13 @@ func (x *KubeletConfiguration) codecDecodeSelfFromArray(l int, d *codec1978.Deco } else { x.HealthzPort = int32(r.DecodeInt(32)) } - yyj101++ - if yyhl101 { - yyb101 = yyj101 > l + yyj102++ + if yyhl102 { + yyb102 = yyj102 > l } else { - yyb101 = r.CheckBreak() + yyb102 = r.CheckBreak() } - if yyb101 { + if yyb102 { z.DecSendContainerState(codecSelfer_containerArrayEnd1234) return } @@ -4260,13 +4285,13 @@ func (x *KubeletConfiguration) codecDecodeSelfFromArray(l int, d *codec1978.Deco } else { x.HealthzBindAddress = string(r.DecodeString()) } - yyj101++ - if yyhl101 { - yyb101 = yyj101 > l + yyj102++ + if yyhl102 { + yyb102 = yyj102 > l } else { - yyb101 = r.CheckBreak() + yyb102 = r.CheckBreak() } - if yyb101 { + if yyb102 { z.DecSendContainerState(codecSelfer_containerArrayEnd1234) return } @@ -4276,13 +4301,13 @@ func (x *KubeletConfiguration) codecDecodeSelfFromArray(l int, d *codec1978.Deco } else { x.OOMScoreAdj = int32(r.DecodeInt(32)) } - yyj101++ - if yyhl101 { - yyb101 = yyj101 > l + yyj102++ + if yyhl102 { + yyb102 = yyj102 > l } else { - yyb101 = r.CheckBreak() + yyb102 = r.CheckBreak() } - if yyb101 { + if yyb102 { z.DecSendContainerState(codecSelfer_containerArrayEnd1234) return } @@ -4292,13 +4317,13 @@ func (x *KubeletConfiguration) codecDecodeSelfFromArray(l int, d *codec1978.Deco } else { x.RegisterNode = bool(r.DecodeBool()) } - yyj101++ - if yyhl101 { - yyb101 = yyj101 > l + yyj102++ + if yyhl102 { + yyb102 = yyj102 > l } else { - yyb101 = r.CheckBreak() + yyb102 = r.CheckBreak() } - if yyb101 { + if yyb102 { z.DecSendContainerState(codecSelfer_containerArrayEnd1234) return } @@ -4308,13 +4333,13 @@ func (x *KubeletConfiguration) codecDecodeSelfFromArray(l int, d *codec1978.Deco } else { x.ClusterDomain = string(r.DecodeString()) } - yyj101++ - if yyhl101 { - yyb101 = yyj101 > l + yyj102++ + if yyhl102 { + yyb102 = yyj102 > l } else { - yyb101 = r.CheckBreak() + yyb102 = r.CheckBreak() } - if yyb101 { + if yyb102 { z.DecSendContainerState(codecSelfer_containerArrayEnd1234) return } @@ -4324,13 +4349,13 @@ func (x *KubeletConfiguration) codecDecodeSelfFromArray(l int, d *codec1978.Deco } else { x.MasterServiceNamespace = string(r.DecodeString()) } - yyj101++ - if yyhl101 { - yyb101 = yyj101 > l + yyj102++ + if yyhl102 { + yyb102 = yyj102 > l } else { - yyb101 = r.CheckBreak() + yyb102 = r.CheckBreak() } - if yyb101 { + if yyb102 { z.DecSendContainerState(codecSelfer_containerArrayEnd1234) return } @@ -4340,13 +4365,13 @@ func (x *KubeletConfiguration) codecDecodeSelfFromArray(l int, d *codec1978.Deco } else { x.ClusterDNS = string(r.DecodeString()) } - yyj101++ - if yyhl101 { - yyb101 = yyj101 > l + yyj102++ + if yyhl102 { + yyb102 = yyj102 > l } else { - yyb101 = r.CheckBreak() + yyb102 = r.CheckBreak() } - if yyb101 { + if yyb102 { z.DecSendContainerState(codecSelfer_containerArrayEnd1234) return } @@ -4354,24 +4379,24 @@ func (x *KubeletConfiguration) codecDecodeSelfFromArray(l int, d *codec1978.Deco if r.TryDecodeAsNil() { x.StreamingConnectionIdleTimeout = pkg1_unversioned.Duration{} } else { - yyv143 := &x.StreamingConnectionIdleTimeout - yym144 := z.DecBinary() - _ = yym144 + yyv144 := &x.StreamingConnectionIdleTimeout + yym145 := z.DecBinary() + _ = yym145 if false { - } else if z.HasExtensions() && z.DecExt(yyv143) { - } else if !yym144 && z.IsJSONHandle() { - z.DecJSONUnmarshal(yyv143) + } else if z.HasExtensions() && z.DecExt(yyv144) { + } else if !yym145 && z.IsJSONHandle() { + z.DecJSONUnmarshal(yyv144) } else { - z.DecFallback(yyv143, false) + z.DecFallback(yyv144, false) } } - yyj101++ - if yyhl101 { - yyb101 = yyj101 > l + yyj102++ + if yyhl102 { + yyb102 = yyj102 > l } else { - yyb101 = r.CheckBreak() + yyb102 = r.CheckBreak() } - if yyb101 { + if yyb102 { z.DecSendContainerState(codecSelfer_containerArrayEnd1234) return } @@ -4379,24 +4404,24 @@ func (x *KubeletConfiguration) codecDecodeSelfFromArray(l int, d *codec1978.Deco if r.TryDecodeAsNil() { x.NodeStatusUpdateFrequency = pkg1_unversioned.Duration{} } else { - yyv145 := &x.NodeStatusUpdateFrequency - yym146 := z.DecBinary() - _ = yym146 + yyv146 := &x.NodeStatusUpdateFrequency + yym147 := z.DecBinary() + _ = yym147 if false { - } else if z.HasExtensions() && z.DecExt(yyv145) { - } else if !yym146 && z.IsJSONHandle() { - z.DecJSONUnmarshal(yyv145) + } else if z.HasExtensions() && z.DecExt(yyv146) { + } else if !yym147 && z.IsJSONHandle() { + z.DecJSONUnmarshal(yyv146) } else { - z.DecFallback(yyv145, false) + z.DecFallback(yyv146, false) } } - yyj101++ - if yyhl101 { - yyb101 = yyj101 > l + yyj102++ + if yyhl102 { + yyb102 = yyj102 > l } else { - yyb101 = r.CheckBreak() + yyb102 = r.CheckBreak() } - if yyb101 { + if yyb102 { z.DecSendContainerState(codecSelfer_containerArrayEnd1234) return } @@ -4404,24 +4429,24 @@ func (x *KubeletConfiguration) codecDecodeSelfFromArray(l int, d *codec1978.Deco if r.TryDecodeAsNil() { x.ImageMinimumGCAge = pkg1_unversioned.Duration{} } else { - yyv147 := &x.ImageMinimumGCAge - yym148 := z.DecBinary() - _ = yym148 + yyv148 := &x.ImageMinimumGCAge + yym149 := z.DecBinary() + _ = yym149 if false { - } else if z.HasExtensions() && z.DecExt(yyv147) { - } else if !yym148 && z.IsJSONHandle() { - z.DecJSONUnmarshal(yyv147) + } else if z.HasExtensions() && z.DecExt(yyv148) { + } else if !yym149 && z.IsJSONHandle() { + z.DecJSONUnmarshal(yyv148) } else { - z.DecFallback(yyv147, false) + z.DecFallback(yyv148, false) } } - yyj101++ - if yyhl101 { - yyb101 = yyj101 > l + yyj102++ + if yyhl102 { + yyb102 = yyj102 > l } else { - yyb101 = r.CheckBreak() + yyb102 = r.CheckBreak() } - if yyb101 { + if yyb102 { z.DecSendContainerState(codecSelfer_containerArrayEnd1234) return } @@ -4431,13 +4456,13 @@ func (x *KubeletConfiguration) codecDecodeSelfFromArray(l int, d *codec1978.Deco } else { x.ImageGCHighThresholdPercent = int32(r.DecodeInt(32)) } - yyj101++ - if yyhl101 { - yyb101 = yyj101 > l + yyj102++ + if yyhl102 { + yyb102 = yyj102 > l } else { - yyb101 = r.CheckBreak() + yyb102 = r.CheckBreak() } - if yyb101 { + if yyb102 { z.DecSendContainerState(codecSelfer_containerArrayEnd1234) return } @@ -4447,13 +4472,13 @@ func (x *KubeletConfiguration) codecDecodeSelfFromArray(l int, d *codec1978.Deco } else { x.ImageGCLowThresholdPercent = int32(r.DecodeInt(32)) } - yyj101++ - if yyhl101 { - yyb101 = yyj101 > l + yyj102++ + if yyhl102 { + yyb102 = yyj102 > l } else { - yyb101 = r.CheckBreak() + yyb102 = r.CheckBreak() } - if yyb101 { + if yyb102 { z.DecSendContainerState(codecSelfer_containerArrayEnd1234) return } @@ -4463,13 +4488,13 @@ func (x *KubeletConfiguration) codecDecodeSelfFromArray(l int, d *codec1978.Deco } else { x.LowDiskSpaceThresholdMB = int32(r.DecodeInt(32)) } - yyj101++ - if yyhl101 { - yyb101 = yyj101 > l + yyj102++ + if yyhl102 { + yyb102 = yyj102 > l } else { - yyb101 = r.CheckBreak() + yyb102 = r.CheckBreak() } - if yyb101 { + if yyb102 { z.DecSendContainerState(codecSelfer_containerArrayEnd1234) return } @@ -4477,24 +4502,24 @@ func (x *KubeletConfiguration) codecDecodeSelfFromArray(l int, d *codec1978.Deco if r.TryDecodeAsNil() { x.VolumeStatsAggPeriod = pkg1_unversioned.Duration{} } else { - yyv152 := &x.VolumeStatsAggPeriod - yym153 := z.DecBinary() - _ = yym153 + yyv153 := &x.VolumeStatsAggPeriod + yym154 := z.DecBinary() + _ = yym154 if false { - } else if z.HasExtensions() && z.DecExt(yyv152) { - } else if !yym153 && z.IsJSONHandle() { - z.DecJSONUnmarshal(yyv152) + } else if z.HasExtensions() && z.DecExt(yyv153) { + } else if !yym154 && z.IsJSONHandle() { + z.DecJSONUnmarshal(yyv153) } else { - z.DecFallback(yyv152, false) + z.DecFallback(yyv153, false) } } - yyj101++ - if yyhl101 { - yyb101 = yyj101 > l + yyj102++ + if yyhl102 { + yyb102 = yyj102 > l } else { - yyb101 = r.CheckBreak() + yyb102 = r.CheckBreak() } - if yyb101 { + if yyb102 { z.DecSendContainerState(codecSelfer_containerArrayEnd1234) return } @@ -4504,13 +4529,13 @@ func (x *KubeletConfiguration) codecDecodeSelfFromArray(l int, d *codec1978.Deco } else { x.NetworkPluginName = string(r.DecodeString()) } - yyj101++ - if yyhl101 { - yyb101 = yyj101 > l + yyj102++ + if yyhl102 { + yyb102 = yyj102 > l } else { - yyb101 = r.CheckBreak() + yyb102 = r.CheckBreak() } - if yyb101 { + if yyb102 { z.DecSendContainerState(codecSelfer_containerArrayEnd1234) return } @@ -4520,13 +4545,13 @@ func (x *KubeletConfiguration) codecDecodeSelfFromArray(l int, d *codec1978.Deco } else { x.NetworkPluginDir = string(r.DecodeString()) } - yyj101++ - if yyhl101 { - yyb101 = yyj101 > l + yyj102++ + if yyhl102 { + yyb102 = yyj102 > l } else { - yyb101 = r.CheckBreak() + yyb102 = r.CheckBreak() } - if yyb101 { + if yyb102 { z.DecSendContainerState(codecSelfer_containerArrayEnd1234) return } @@ -4536,13 +4561,13 @@ func (x *KubeletConfiguration) codecDecodeSelfFromArray(l int, d *codec1978.Deco } else { x.VolumePluginDir = string(r.DecodeString()) } - yyj101++ - if yyhl101 { - yyb101 = yyj101 > l + yyj102++ + if yyhl102 { + yyb102 = yyj102 > l } else { - yyb101 = r.CheckBreak() + yyb102 = r.CheckBreak() } - if yyb101 { + if yyb102 { z.DecSendContainerState(codecSelfer_containerArrayEnd1234) return } @@ -4552,13 +4577,13 @@ func (x *KubeletConfiguration) codecDecodeSelfFromArray(l int, d *codec1978.Deco } else { x.CloudProvider = string(r.DecodeString()) } - yyj101++ - if yyhl101 { - yyb101 = yyj101 > l + yyj102++ + if yyhl102 { + yyb102 = yyj102 > l } else { - yyb101 = r.CheckBreak() + yyb102 = r.CheckBreak() } - if yyb101 { + if yyb102 { z.DecSendContainerState(codecSelfer_containerArrayEnd1234) return } @@ -4568,13 +4593,13 @@ func (x *KubeletConfiguration) codecDecodeSelfFromArray(l int, d *codec1978.Deco } else { x.CloudConfigFile = string(r.DecodeString()) } - yyj101++ - if yyhl101 { - yyb101 = yyj101 > l + yyj102++ + if yyhl102 { + yyb102 = yyj102 > l } else { - yyb101 = r.CheckBreak() + yyb102 = r.CheckBreak() } - if yyb101 { + if yyb102 { z.DecSendContainerState(codecSelfer_containerArrayEnd1234) return } @@ -4584,13 +4609,13 @@ func (x *KubeletConfiguration) codecDecodeSelfFromArray(l int, d *codec1978.Deco } else { x.KubeletCgroups = string(r.DecodeString()) } - yyj101++ - if yyhl101 { - yyb101 = yyj101 > l + yyj102++ + if yyhl102 { + yyb102 = yyj102 > l } else { - yyb101 = r.CheckBreak() + yyb102 = r.CheckBreak() } - if yyb101 { + if yyb102 { z.DecSendContainerState(codecSelfer_containerArrayEnd1234) return } @@ -4600,13 +4625,13 @@ func (x *KubeletConfiguration) codecDecodeSelfFromArray(l int, d *codec1978.Deco } else { x.RuntimeCgroups = string(r.DecodeString()) } - yyj101++ - if yyhl101 { - yyb101 = yyj101 > l + yyj102++ + if yyhl102 { + yyb102 = yyj102 > l } else { - yyb101 = r.CheckBreak() + yyb102 = r.CheckBreak() } - if yyb101 { + if yyb102 { z.DecSendContainerState(codecSelfer_containerArrayEnd1234) return } @@ -4616,13 +4641,13 @@ func (x *KubeletConfiguration) codecDecodeSelfFromArray(l int, d *codec1978.Deco } else { x.SystemCgroups = string(r.DecodeString()) } - yyj101++ - if yyhl101 { - yyb101 = yyj101 > l + yyj102++ + if yyhl102 { + yyb102 = yyj102 > l } else { - yyb101 = r.CheckBreak() + yyb102 = r.CheckBreak() } - if yyb101 { + if yyb102 { z.DecSendContainerState(codecSelfer_containerArrayEnd1234) return } @@ -4632,13 +4657,13 @@ func (x *KubeletConfiguration) codecDecodeSelfFromArray(l int, d *codec1978.Deco } else { x.CgroupRoot = string(r.DecodeString()) } - yyj101++ - if yyhl101 { - yyb101 = yyj101 > l + yyj102++ + if yyhl102 { + yyb102 = yyj102 > l } else { - yyb101 = r.CheckBreak() + yyb102 = r.CheckBreak() } - if yyb101 { + if yyb102 { z.DecSendContainerState(codecSelfer_containerArrayEnd1234) return } @@ -4648,13 +4673,13 @@ func (x *KubeletConfiguration) codecDecodeSelfFromArray(l int, d *codec1978.Deco } else { x.ContainerRuntime = string(r.DecodeString()) } - yyj101++ - if yyhl101 { - yyb101 = yyj101 > l + yyj102++ + if yyhl102 { + yyb102 = yyj102 > l } else { - yyb101 = r.CheckBreak() + yyb102 = r.CheckBreak() } - if yyb101 { + if yyb102 { z.DecSendContainerState(codecSelfer_containerArrayEnd1234) return } @@ -4664,13 +4689,13 @@ func (x *KubeletConfiguration) codecDecodeSelfFromArray(l int, d *codec1978.Deco } else { x.RktPath = string(r.DecodeString()) } - yyj101++ - if yyhl101 { - yyb101 = yyj101 > l + yyj102++ + if yyhl102 { + yyb102 = yyj102 > l } else { - yyb101 = r.CheckBreak() + yyb102 = r.CheckBreak() } - if yyb101 { + if yyb102 { z.DecSendContainerState(codecSelfer_containerArrayEnd1234) return } @@ -4680,13 +4705,13 @@ func (x *KubeletConfiguration) codecDecodeSelfFromArray(l int, d *codec1978.Deco } else { x.RktAPIEndpoint = string(r.DecodeString()) } - yyj101++ - if yyhl101 { - yyb101 = yyj101 > l + yyj102++ + if yyhl102 { + yyb102 = yyj102 > l } else { - yyb101 = r.CheckBreak() + yyb102 = r.CheckBreak() } - if yyb101 { + if yyb102 { z.DecSendContainerState(codecSelfer_containerArrayEnd1234) return } @@ -4696,13 +4721,13 @@ func (x *KubeletConfiguration) codecDecodeSelfFromArray(l int, d *codec1978.Deco } else { x.RktStage1Image = string(r.DecodeString()) } - yyj101++ - if yyhl101 { - yyb101 = yyj101 > l + yyj102++ + if yyhl102 { + yyb102 = yyj102 > l } else { - yyb101 = r.CheckBreak() + yyb102 = r.CheckBreak() } - if yyb101 { + if yyb102 { z.DecSendContainerState(codecSelfer_containerArrayEnd1234) return } @@ -4712,13 +4737,29 @@ func (x *KubeletConfiguration) codecDecodeSelfFromArray(l int, d *codec1978.Deco } else { x.LockFilePath = string(r.DecodeString()) } - yyj101++ - if yyhl101 { - yyb101 = yyj101 > l + yyj102++ + if yyhl102 { + yyb102 = yyj102 > l } else { - yyb101 = r.CheckBreak() + yyb102 = r.CheckBreak() } - if yyb101 { + if yyb102 { + z.DecSendContainerState(codecSelfer_containerArrayEnd1234) + return + } + z.DecSendContainerState(codecSelfer_containerArrayElem1234) + if r.TryDecodeAsNil() { + x.ExitOnLockContention = false + } else { + x.ExitOnLockContention = bool(r.DecodeBool()) + } + yyj102++ + if yyhl102 { + yyb102 = yyj102 > l + } else { + yyb102 = r.CheckBreak() + } + if yyb102 { z.DecSendContainerState(codecSelfer_containerArrayEnd1234) return } @@ -4728,13 +4769,13 @@ func (x *KubeletConfiguration) codecDecodeSelfFromArray(l int, d *codec1978.Deco } else { x.ConfigureCBR0 = bool(r.DecodeBool()) } - yyj101++ - if yyhl101 { - yyb101 = yyj101 > l + yyj102++ + if yyhl102 { + yyb102 = yyj102 > l } else { - yyb101 = r.CheckBreak() + yyb102 = r.CheckBreak() } - if yyb101 { + if yyb102 { z.DecSendContainerState(codecSelfer_containerArrayEnd1234) return } @@ -4744,13 +4785,13 @@ func (x *KubeletConfiguration) codecDecodeSelfFromArray(l int, d *codec1978.Deco } else { x.HairpinMode = string(r.DecodeString()) } - yyj101++ - if yyhl101 { - yyb101 = yyj101 > l + yyj102++ + if yyhl102 { + yyb102 = yyj102 > l } else { - yyb101 = r.CheckBreak() + yyb102 = r.CheckBreak() } - if yyb101 { + if yyb102 { z.DecSendContainerState(codecSelfer_containerArrayEnd1234) return } @@ -4760,13 +4801,13 @@ func (x *KubeletConfiguration) codecDecodeSelfFromArray(l int, d *codec1978.Deco } else { x.BabysitDaemons = bool(r.DecodeBool()) } - yyj101++ - if yyhl101 { - yyb101 = yyj101 > l + yyj102++ + if yyhl102 { + yyb102 = yyj102 > l } else { - yyb101 = r.CheckBreak() + yyb102 = r.CheckBreak() } - if yyb101 { + if yyb102 { z.DecSendContainerState(codecSelfer_containerArrayEnd1234) return } @@ -4776,13 +4817,13 @@ func (x *KubeletConfiguration) codecDecodeSelfFromArray(l int, d *codec1978.Deco } else { x.MaxPods = int32(r.DecodeInt(32)) } - yyj101++ - if yyhl101 { - yyb101 = yyj101 > l + yyj102++ + if yyhl102 { + yyb102 = yyj102 > l } else { - yyb101 = r.CheckBreak() + yyb102 = r.CheckBreak() } - if yyb101 { + if yyb102 { z.DecSendContainerState(codecSelfer_containerArrayEnd1234) return } @@ -4792,13 +4833,13 @@ func (x *KubeletConfiguration) codecDecodeSelfFromArray(l int, d *codec1978.Deco } else { x.NvidiaGPUs = int32(r.DecodeInt(32)) } - yyj101++ - if yyhl101 { - yyb101 = yyj101 > l + yyj102++ + if yyhl102 { + yyb102 = yyj102 > l } else { - yyb101 = r.CheckBreak() + yyb102 = r.CheckBreak() } - if yyb101 { + if yyb102 { z.DecSendContainerState(codecSelfer_containerArrayEnd1234) return } @@ -4808,13 +4849,13 @@ func (x *KubeletConfiguration) codecDecodeSelfFromArray(l int, d *codec1978.Deco } else { x.DockerExecHandlerName = string(r.DecodeString()) } - yyj101++ - if yyhl101 { - yyb101 = yyj101 > l + yyj102++ + if yyhl102 { + yyb102 = yyj102 > l } else { - yyb101 = r.CheckBreak() + yyb102 = r.CheckBreak() } - if yyb101 { + if yyb102 { z.DecSendContainerState(codecSelfer_containerArrayEnd1234) return } @@ -4824,13 +4865,13 @@ func (x *KubeletConfiguration) codecDecodeSelfFromArray(l int, d *codec1978.Deco } else { x.PodCIDR = string(r.DecodeString()) } - yyj101++ - if yyhl101 { - yyb101 = yyj101 > l + yyj102++ + if yyhl102 { + yyb102 = yyj102 > l } else { - yyb101 = r.CheckBreak() + yyb102 = r.CheckBreak() } - if yyb101 { + if yyb102 { z.DecSendContainerState(codecSelfer_containerArrayEnd1234) return } @@ -4840,13 +4881,13 @@ func (x *KubeletConfiguration) codecDecodeSelfFromArray(l int, d *codec1978.Deco } else { x.ResolverConfig = string(r.DecodeString()) } - yyj101++ - if yyhl101 { - yyb101 = yyj101 > l + yyj102++ + if yyhl102 { + yyb102 = yyj102 > l } else { - yyb101 = r.CheckBreak() + yyb102 = r.CheckBreak() } - if yyb101 { + if yyb102 { z.DecSendContainerState(codecSelfer_containerArrayEnd1234) return } @@ -4856,13 +4897,13 @@ func (x *KubeletConfiguration) codecDecodeSelfFromArray(l int, d *codec1978.Deco } else { x.CPUCFSQuota = bool(r.DecodeBool()) } - yyj101++ - if yyhl101 { - yyb101 = yyj101 > l + yyj102++ + if yyhl102 { + yyb102 = yyj102 > l } else { - yyb101 = r.CheckBreak() + yyb102 = r.CheckBreak() } - if yyb101 { + if yyb102 { z.DecSendContainerState(codecSelfer_containerArrayEnd1234) return } @@ -4872,13 +4913,13 @@ func (x *KubeletConfiguration) codecDecodeSelfFromArray(l int, d *codec1978.Deco } else { x.Containerized = bool(r.DecodeBool()) } - yyj101++ - if yyhl101 { - yyb101 = yyj101 > l + yyj102++ + if yyhl102 { + yyb102 = yyj102 > l } else { - yyb101 = r.CheckBreak() + yyb102 = r.CheckBreak() } - if yyb101 { + if yyb102 { z.DecSendContainerState(codecSelfer_containerArrayEnd1234) return } @@ -4888,13 +4929,13 @@ func (x *KubeletConfiguration) codecDecodeSelfFromArray(l int, d *codec1978.Deco } else { x.MaxOpenFiles = uint64(r.DecodeUint(64)) } - yyj101++ - if yyhl101 { - yyb101 = yyj101 > l + yyj102++ + if yyhl102 { + yyb102 = yyj102 > l } else { - yyb101 = r.CheckBreak() + yyb102 = r.CheckBreak() } - if yyb101 { + if yyb102 { z.DecSendContainerState(codecSelfer_containerArrayEnd1234) return } @@ -4904,13 +4945,13 @@ func (x *KubeletConfiguration) codecDecodeSelfFromArray(l int, d *codec1978.Deco } else { x.ReconcileCIDR = bool(r.DecodeBool()) } - yyj101++ - if yyhl101 { - yyb101 = yyj101 > l + yyj102++ + if yyhl102 { + yyb102 = yyj102 > l } else { - yyb101 = r.CheckBreak() + yyb102 = r.CheckBreak() } - if yyb101 { + if yyb102 { z.DecSendContainerState(codecSelfer_containerArrayEnd1234) return } @@ -4920,13 +4961,13 @@ func (x *KubeletConfiguration) codecDecodeSelfFromArray(l int, d *codec1978.Deco } else { x.RegisterSchedulable = bool(r.DecodeBool()) } - yyj101++ - if yyhl101 { - yyb101 = yyj101 > l + yyj102++ + if yyhl102 { + yyb102 = yyj102 > l } else { - yyb101 = r.CheckBreak() + yyb102 = r.CheckBreak() } - if yyb101 { + if yyb102 { z.DecSendContainerState(codecSelfer_containerArrayEnd1234) return } @@ -4936,13 +4977,13 @@ func (x *KubeletConfiguration) codecDecodeSelfFromArray(l int, d *codec1978.Deco } else { x.ContentType = string(r.DecodeString()) } - yyj101++ - if yyhl101 { - yyb101 = yyj101 > l + yyj102++ + if yyhl102 { + yyb102 = yyj102 > l } else { - yyb101 = r.CheckBreak() + yyb102 = r.CheckBreak() } - if yyb101 { + if yyb102 { z.DecSendContainerState(codecSelfer_containerArrayEnd1234) return } @@ -4952,13 +4993,13 @@ func (x *KubeletConfiguration) codecDecodeSelfFromArray(l int, d *codec1978.Deco } else { x.KubeAPIQPS = float32(r.DecodeFloat(true)) } - yyj101++ - if yyhl101 { - yyb101 = yyj101 > l + yyj102++ + if yyhl102 { + yyb102 = yyj102 > l } else { - yyb101 = r.CheckBreak() + yyb102 = r.CheckBreak() } - if yyb101 { + if yyb102 { z.DecSendContainerState(codecSelfer_containerArrayEnd1234) return } @@ -4968,13 +5009,13 @@ func (x *KubeletConfiguration) codecDecodeSelfFromArray(l int, d *codec1978.Deco } else { x.KubeAPIBurst = int32(r.DecodeInt(32)) } - yyj101++ - if yyhl101 { - yyb101 = yyj101 > l + yyj102++ + if yyhl102 { + yyb102 = yyj102 > l } else { - yyb101 = r.CheckBreak() + yyb102 = r.CheckBreak() } - if yyb101 { + if yyb102 { z.DecSendContainerState(codecSelfer_containerArrayEnd1234) return } @@ -4984,13 +5025,13 @@ func (x *KubeletConfiguration) codecDecodeSelfFromArray(l int, d *codec1978.Deco } else { x.SerializeImagePulls = bool(r.DecodeBool()) } - yyj101++ - if yyhl101 { - yyb101 = yyj101 > l + yyj102++ + if yyhl102 { + yyb102 = yyj102 > l } else { - yyb101 = r.CheckBreak() + yyb102 = r.CheckBreak() } - if yyb101 { + if yyb102 { z.DecSendContainerState(codecSelfer_containerArrayEnd1234) return } @@ -5000,13 +5041,13 @@ func (x *KubeletConfiguration) codecDecodeSelfFromArray(l int, d *codec1978.Deco } else { x.ExperimentalFlannelOverlay = bool(r.DecodeBool()) } - yyj101++ - if yyhl101 { - yyb101 = yyj101 > l + yyj102++ + if yyhl102 { + yyb102 = yyj102 > l } else { - yyb101 = r.CheckBreak() + yyb102 = r.CheckBreak() } - if yyb101 { + if yyb102 { z.DecSendContainerState(codecSelfer_containerArrayEnd1234) return } @@ -5014,24 +5055,24 @@ func (x *KubeletConfiguration) codecDecodeSelfFromArray(l int, d *codec1978.Deco if r.TryDecodeAsNil() { x.OutOfDiskTransitionFrequency = pkg1_unversioned.Duration{} } else { - yyv186 := &x.OutOfDiskTransitionFrequency - yym187 := z.DecBinary() - _ = yym187 + yyv188 := &x.OutOfDiskTransitionFrequency + yym189 := z.DecBinary() + _ = yym189 if false { - } else if z.HasExtensions() && z.DecExt(yyv186) { - } else if !yym187 && z.IsJSONHandle() { - z.DecJSONUnmarshal(yyv186) + } else if z.HasExtensions() && z.DecExt(yyv188) { + } else if !yym189 && z.IsJSONHandle() { + z.DecJSONUnmarshal(yyv188) } else { - z.DecFallback(yyv186, false) + z.DecFallback(yyv188, false) } } - yyj101++ - if yyhl101 { - yyb101 = yyj101 > l + yyj102++ + if yyhl102 { + yyb102 = yyj102 > l } else { - yyb101 = r.CheckBreak() + yyb102 = r.CheckBreak() } - if yyb101 { + if yyb102 { z.DecSendContainerState(codecSelfer_containerArrayEnd1234) return } @@ -5041,13 +5082,13 @@ func (x *KubeletConfiguration) codecDecodeSelfFromArray(l int, d *codec1978.Deco } else { x.NodeIP = string(r.DecodeString()) } - yyj101++ - if yyhl101 { - yyb101 = yyj101 > l + yyj102++ + if yyhl102 { + yyb102 = yyj102 > l } else { - yyb101 = r.CheckBreak() + yyb102 = r.CheckBreak() } - if yyb101 { + if yyb102 { z.DecSendContainerState(codecSelfer_containerArrayEnd1234) return } @@ -5055,21 +5096,21 @@ func (x *KubeletConfiguration) codecDecodeSelfFromArray(l int, d *codec1978.Deco if r.TryDecodeAsNil() { x.NodeLabels = nil } else { - yyv189 := &x.NodeLabels - yym190 := z.DecBinary() - _ = yym190 + yyv191 := &x.NodeLabels + yym192 := z.DecBinary() + _ = yym192 if false { } else { - z.F.DecMapStringStringX(yyv189, false, d) + z.F.DecMapStringStringX(yyv191, false, d) } } - yyj101++ - if yyhl101 { - yyb101 = yyj101 > l + yyj102++ + if yyhl102 { + yyb102 = yyj102 > l } else { - yyb101 = r.CheckBreak() + yyb102 = r.CheckBreak() } - if yyb101 { + if yyb102 { z.DecSendContainerState(codecSelfer_containerArrayEnd1234) return } @@ -5079,13 +5120,13 @@ func (x *KubeletConfiguration) codecDecodeSelfFromArray(l int, d *codec1978.Deco } else { x.NonMasqueradeCIDR = string(r.DecodeString()) } - yyj101++ - if yyhl101 { - yyb101 = yyj101 > l + yyj102++ + if yyhl102 { + yyb102 = yyj102 > l } else { - yyb101 = r.CheckBreak() + yyb102 = r.CheckBreak() } - if yyb101 { + if yyb102 { z.DecSendContainerState(codecSelfer_containerArrayEnd1234) return } @@ -5095,13 +5136,13 @@ func (x *KubeletConfiguration) codecDecodeSelfFromArray(l int, d *codec1978.Deco } else { x.EnableCustomMetrics = bool(r.DecodeBool()) } - yyj101++ - if yyhl101 { - yyb101 = yyj101 > l + yyj102++ + if yyhl102 { + yyb102 = yyj102 > l } else { - yyb101 = r.CheckBreak() + yyb102 = r.CheckBreak() } - if yyb101 { + if yyb102 { z.DecSendContainerState(codecSelfer_containerArrayEnd1234) return } @@ -5111,13 +5152,13 @@ func (x *KubeletConfiguration) codecDecodeSelfFromArray(l int, d *codec1978.Deco } else { x.EvictionHard = string(r.DecodeString()) } - yyj101++ - if yyhl101 { - yyb101 = yyj101 > l + yyj102++ + if yyhl102 { + yyb102 = yyj102 > l } else { - yyb101 = r.CheckBreak() + yyb102 = r.CheckBreak() } - if yyb101 { + if yyb102 { z.DecSendContainerState(codecSelfer_containerArrayEnd1234) return } @@ -5127,13 +5168,13 @@ func (x *KubeletConfiguration) codecDecodeSelfFromArray(l int, d *codec1978.Deco } else { x.EvictionSoft = string(r.DecodeString()) } - yyj101++ - if yyhl101 { - yyb101 = yyj101 > l + yyj102++ + if yyhl102 { + yyb102 = yyj102 > l } else { - yyb101 = r.CheckBreak() + yyb102 = r.CheckBreak() } - if yyb101 { + if yyb102 { z.DecSendContainerState(codecSelfer_containerArrayEnd1234) return } @@ -5143,13 +5184,13 @@ func (x *KubeletConfiguration) codecDecodeSelfFromArray(l int, d *codec1978.Deco } else { x.EvictionSoftGracePeriod = string(r.DecodeString()) } - yyj101++ - if yyhl101 { - yyb101 = yyj101 > l + yyj102++ + if yyhl102 { + yyb102 = yyj102 > l } else { - yyb101 = r.CheckBreak() + yyb102 = r.CheckBreak() } - if yyb101 { + if yyb102 { z.DecSendContainerState(codecSelfer_containerArrayEnd1234) return } @@ -5157,24 +5198,24 @@ func (x *KubeletConfiguration) codecDecodeSelfFromArray(l int, d *codec1978.Deco if r.TryDecodeAsNil() { x.EvictionPressureTransitionPeriod = pkg1_unversioned.Duration{} } else { - yyv196 := &x.EvictionPressureTransitionPeriod - yym197 := z.DecBinary() - _ = yym197 + yyv198 := &x.EvictionPressureTransitionPeriod + yym199 := z.DecBinary() + _ = yym199 if false { - } else if z.HasExtensions() && z.DecExt(yyv196) { - } else if !yym197 && z.IsJSONHandle() { - z.DecJSONUnmarshal(yyv196) + } else if z.HasExtensions() && z.DecExt(yyv198) { + } else if !yym199 && z.IsJSONHandle() { + z.DecJSONUnmarshal(yyv198) } else { - z.DecFallback(yyv196, false) + z.DecFallback(yyv198, false) } } - yyj101++ - if yyhl101 { - yyb101 = yyj101 > l + yyj102++ + if yyhl102 { + yyb102 = yyj102 > l } else { - yyb101 = r.CheckBreak() + yyb102 = r.CheckBreak() } - if yyb101 { + if yyb102 { z.DecSendContainerState(codecSelfer_containerArrayEnd1234) return } @@ -5185,17 +5226,17 @@ func (x *KubeletConfiguration) codecDecodeSelfFromArray(l int, d *codec1978.Deco x.EvictionMaxPodGracePeriod = int32(r.DecodeInt(32)) } for { - yyj101++ - if yyhl101 { - yyb101 = yyj101 > l + yyj102++ + if yyhl102 { + yyb102 = yyj102 > l } else { - yyb101 = r.CheckBreak() + yyb102 = r.CheckBreak() } - if yyb101 { + if yyb102 { break } z.DecSendContainerState(codecSelfer_containerArrayElem1234) - z.DecStructFieldNotFound(yyj101-1, "") + z.DecStructFieldNotFound(yyj102-1, "") } z.DecSendContainerState(codecSelfer_containerArrayEnd1234) } diff --git a/pkg/apis/componentconfig/types.go b/pkg/apis/componentconfig/types.go index 0b1e060de1..3130f2d4bb 100644 --- a/pkg/apis/componentconfig/types.go +++ b/pkg/apis/componentconfig/types.go @@ -273,6 +273,11 @@ type KubeletConfiguration struct { // It uses this file as a lock to synchronize with other kubelet processes // that may be running. LockFilePath string `json:"lockFilePath"` + // ExitOnLockContention is a flag that signifies to the kubelet that it is running + // in "bootstrap" mode. This requires that 'LockFilePath' has been set. + // This will cause the kubelet to listen to inotify events on the lock file, + // releasing it and exiting when another process tries to open that file. + ExitOnLockContention bool `json:"exitOnLockContention"` // configureCBR0 enables the kublet to configure cbr0 based on // Node.Spec.PodCIDR. ConfigureCBR0 bool `json:"configureCbr0"` diff --git a/pkg/kubelet/container/runtime.go b/pkg/kubelet/container/runtime.go index 81189cd888..00110af284 100644 --- a/pkg/kubelet/container/runtime.go +++ b/pkg/kubelet/container/runtime.go @@ -69,7 +69,7 @@ type Runtime interface { APIVersion() (Version, error) // Status returns error if the runtime is unhealthy; nil otherwise. Status() error - // GetPods returns a list containers group by pods. The boolean parameter + // GetPods returns a list of containers grouped by pods. The boolean parameter // specifies whether the runtime returns all containers including those already // exited and dead containers (used for garbage collection). GetPods(all bool) ([]*Pod, error)