mirror of https://github.com/k3s-io/k3s
Removed unnecessarly empty line.
parent
b9bb440bd6
commit
cc26fe6ee9
|
@ -1797,7 +1797,6 @@ func (kl *Kubelet) syncLoopIteration(configCh <-chan kubetypes.PodUpdate, handle
|
||||||
// takes place only after kubelet calls the update handler to process
|
// takes place only after kubelet calls the update handler to process
|
||||||
// the update to ensure the internal pod cache is up-to-date.
|
// the update to ensure the internal pod cache is up-to-date.
|
||||||
kl.sourcesReady.AddSource(u.Source)
|
kl.sourcesReady.AddSource(u.Source)
|
||||||
|
|
||||||
case e := <-plegCh:
|
case e := <-plegCh:
|
||||||
if isSyncPodWorthy(e) {
|
if isSyncPodWorthy(e) {
|
||||||
// PLEG event for a pod; sync it.
|
// PLEG event for a pod; sync it.
|
||||||
|
|
|
@ -565,7 +565,6 @@ func (kl *Kubelet) setNodeStatusVersionInfo(node *v1.Node) {
|
||||||
// TODO: kube-proxy might be different version from kubelet in the future
|
// TODO: kube-proxy might be different version from kubelet in the future
|
||||||
node.Status.NodeInfo.KubeProxyVersion = version.Get().String()
|
node.Status.NodeInfo.KubeProxyVersion = version.Get().String()
|
||||||
}
|
}
|
||||||
|
|
||||||
}
|
}
|
||||||
|
|
||||||
// Set daemonEndpoints for the node.
|
// Set daemonEndpoints for the node.
|
||||||
|
|
|
@ -174,7 +174,6 @@ func TestAddTwoFireEarly(t *testing.T) {
|
||||||
if !reflect.DeepEqual(item, third) {
|
if !reflect.DeepEqual(item, third) {
|
||||||
t.Errorf("expected %v, got %v", third, item)
|
t.Errorf("expected %v, got %v", third, item)
|
||||||
}
|
}
|
||||||
|
|
||||||
}
|
}
|
||||||
|
|
||||||
func TestCopyShifting(t *testing.T) {
|
func TestCopyShifting(t *testing.T) {
|
||||||
|
|
Loading…
Reference in New Issue