From 2b5cad6acf86a0bac367ae5f8b93eb60e92dc720 Mon Sep 17 00:00:00 2001
From: Vishnu Kannan <vishnuk@google.com>
Date: Wed, 8 Apr 2015 20:57:19 +0000
Subject: [PATCH] Improve kubelet logging around startup. This might help
 detect any lockup issues during startup.

---
 cmd/kubelet/app/server.go     | 1 +
 pkg/kubelet/kubelet.go        | 3 ++-
 pkg/kubelet/server.go         | 2 +-
 pkg/kubelet/status_manager.go | 1 +
 4 files changed, 5 insertions(+), 2 deletions(-)

diff --git a/cmd/kubelet/app/server.go b/cmd/kubelet/app/server.go
index ef03acc06e5..a08bdf37c22 100644
--- a/cmd/kubelet/app/server.go
+++ b/cmd/kubelet/app/server.go
@@ -425,6 +425,7 @@ func RunKubelet(kcfg *KubeletConfig, builder KubeletBuilder) {
 	} else {
 		startKubelet(k, podCfg, kcfg)
 	}
+	glog.Infof("Started kubelet")
 }
 
 func startKubelet(k KubeletBootstrap, podCfg *config.PodConfig, kc *KubeletConfig) {
diff --git a/pkg/kubelet/kubelet.go b/pkg/kubelet/kubelet.go
index 9de5e4af3d8..f57e539e391 100644
--- a/pkg/kubelet/kubelet.go
+++ b/pkg/kubelet/kubelet.go
@@ -561,7 +561,7 @@ func (kl *Kubelet) syncNodeStatus() {
 	if kl.kubeClient == nil {
 		return
 	}
-
+	glog.Infof("Starting node status updates")
 	for feq := initialNodeStatusUpdateFrequency; feq < kl.nodeStatusUpdateFrequency; feq += nodeStatusUpdateFrequencyInc {
 		select {
 		case <-time.After(feq):
@@ -1628,6 +1628,7 @@ func (kl *Kubelet) handleNotFittingPods(pods []api.Pod) {
 // no changes are seen to the configuration, will synchronize the last known desired
 // state every sync_frequency seconds. Never returns.
 func (kl *Kubelet) syncLoop(updates <-chan PodUpdate, handler SyncHandler) {
+	glog.Info("Starting kubelet main sync loop.")
 	for {
 		unsyncedPod := false
 		podSyncTypes := make(map[types.UID]metrics.SyncPodType)
diff --git a/pkg/kubelet/server.go b/pkg/kubelet/server.go
index a63a40c2873..08be664dcab 100644
--- a/pkg/kubelet/server.go
+++ b/pkg/kubelet/server.go
@@ -60,7 +60,7 @@ type TLSOptions struct {
 
 // ListenAndServeKubeletServer initializes a server to respond to HTTP network requests on the Kubelet.
 func ListenAndServeKubeletServer(host HostInterface, address net.IP, port uint, tlsOptions *TLSOptions, enableDebuggingHandlers bool) {
-	glog.V(1).Infof("Starting to listen on %s:%d", address, port)
+	glog.Infof("Starting to listen on %s:%d", address, port)
 	handler := NewServer(host, enableDebuggingHandlers)
 	s := &http.Server{
 		Addr:           net.JoinHostPort(address.String(), strconv.FormatUint(uint64(port), 10)),
diff --git a/pkg/kubelet/status_manager.go b/pkg/kubelet/status_manager.go
index 2d8f4449c6c..f5a80e89954 100644
--- a/pkg/kubelet/status_manager.go
+++ b/pkg/kubelet/status_manager.go
@@ -53,6 +53,7 @@ func newStatusManager(kubeClient client.Interface) *statusManager {
 
 func (s *statusManager) Start() {
 	// syncBatch blocks when no updates are available, we can run it in a tight loop.
+	glog.Info("Starting to sync pod status with apiserver")
 	go util.Forever(func() {
 		err := s.syncBatch()
 		if err != nil {