Improve kubelet logging around startup. This might help detect any lockup issues during startup.

This commit is contained in:
Vishnu Kannan 2015-04-08 20:57:19 +00:00
parent 7f4791c34b
commit 2b5cad6acf
4 changed files with 5 additions and 2 deletions

View File

@ -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) {

View File

@ -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)

View File

@ -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)),

View File

@ -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 {