From 604e0ad328e213f73a33cd5f4ebb80bc795b26ae Mon Sep 17 00:00:00 2001
From: Federico Simoncelli <fsimonce@redhat.com>
Date: Mon, 30 Mar 2015 09:20:20 -0400
Subject: [PATCH 1/2] kubelet: move getNodeReference logic into a function

Signed-off-by: Federico Simoncelli <fsimonce@redhat.com>
---
 pkg/kubelet/kubelet.go | 15 +++++++++------
 1 file changed, 9 insertions(+), 6 deletions(-)

diff --git a/pkg/kubelet/kubelet.go b/pkg/kubelet/kubelet.go
index 3126bd4f558..1bcd1487da6 100644
--- a/pkg/kubelet/kubelet.go
+++ b/pkg/kubelet/kubelet.go
@@ -1996,19 +1996,22 @@ func (kl *Kubelet) PortForward(podFullName string, uid types.UID, port uint16, s
 	return kl.runner.PortForward(podInfraContainer.ID, port, stream)
 }
 
-// BirthCry sends an event that the kubelet has started up.
-func (kl *Kubelet) BirthCry() {
-	// Make an event that kubelet restarted.
-	// TODO: get the real minion object of ourself,
+func (kl *Kubelet) getNodeReference() *api.ObjectReference {
 	// and use the real minion name and UID.
 	// TODO: what is namespace for node?
-	ref := &api.ObjectReference{
+	return &api.ObjectReference{
 		Kind:      "Node",
 		Name:      kl.hostname,
 		UID:       types.UID(kl.hostname),
 		Namespace: "",
 	}
-	kl.recorder.Eventf(ref, "starting", "Starting kubelet.")
+}
+
+// BirthCry sends an event that the kubelet has started up.
+func (kl *Kubelet) BirthCry() {
+	// Make an event that kubelet restarted.
+	// TODO: get the real minion object of ourself,
+	kl.recorder.Eventf(kl.getNodeReference(), "starting", "Starting kubelet.")
 }
 
 func (kl *Kubelet) StreamingConnectionIdleTimeout() time.Duration {

From fe2d1f6762d19682edd89d0e4d739a2b5e385101 Mon Sep 17 00:00:00 2001
From: Federico Simoncelli <fsimonce@redhat.com>
Date: Fri, 27 Mar 2015 12:44:40 -0400
Subject: [PATCH 2/2] node: move the reboot detection logic to kubelet

Signed-off-by: Federico Simoncelli <fsimonce@redhat.com>
---
 pkg/cloudprovider/controller/nodecontroller.go | 10 ----------
 pkg/kubelet/kubelet.go                         |  9 ++++++++-
 2 files changed, 8 insertions(+), 11 deletions(-)

diff --git a/pkg/cloudprovider/controller/nodecontroller.go b/pkg/cloudprovider/controller/nodecontroller.go
index fcad935211d..02753143a02 100644
--- a/pkg/cloudprovider/controller/nodecontroller.go
+++ b/pkg/cloudprovider/controller/nodecontroller.go
@@ -294,16 +294,6 @@ func (nc *NodeController) populateNodeInfo(node *api.Node) error {
 	for key, value := range nodeInfo.Capacity {
 		node.Status.Capacity[key] = value
 	}
-	if node.Status.NodeInfo.BootID != "" &&
-		node.Status.NodeInfo.BootID != nodeInfo.NodeSystemInfo.BootID {
-		ref := &api.ObjectReference{
-			Kind:      "Minion",
-			Name:      node.Name,
-			UID:       node.UID,
-			Namespace: api.NamespaceDefault,
-		}
-		nc.recorder.Eventf(ref, "rebooted", "Node %s has been rebooted", node.Name)
-	}
 	node.Status.NodeInfo = nodeInfo.NodeSystemInfo
 	return nil
 }
diff --git a/pkg/kubelet/kubelet.go b/pkg/kubelet/kubelet.go
index 1bcd1487da6..a4d159f0002 100644
--- a/pkg/kubelet/kubelet.go
+++ b/pkg/kubelet/kubelet.go
@@ -1752,8 +1752,15 @@ func (kl *Kubelet) tryUpdateNodeStatus() error {
 	} else {
 		node.Status.NodeInfo.MachineID = info.MachineID
 		node.Status.NodeInfo.SystemUUID = info.SystemUUID
-		node.Status.NodeInfo.BootID = info.BootID
 		node.Status.Capacity = CapacityFromMachineInfo(info)
+		if node.Status.NodeInfo.BootID != "" &&
+			node.Status.NodeInfo.BootID != info.BootID {
+			// TODO: This requires a transaction, either both node status is updated
+			// and event is recorded or neither should happen, see issue #6055.
+			kl.recorder.Eventf(kl.getNodeReference(), "rebooted",
+				"Node %s has been rebooted, boot id: %s", kl.hostname, info.BootID)
+		}
+		node.Status.NodeInfo.BootID = info.BootID
 	}
 
 	currentTime := util.Now()