github/kubernetes
1
0
Fork 0
mirror of https://github.com/k3s-io/kubernetes.git synced 2025-07-25 20:53:33 +00:00
Code Issues Projects Releases Wiki Activity

More scheduling debug in federated replica set

Browse Source
This commit is contained in:
Marcin Wielgus 2016-08-26 12:34:56 +02:00
parent ecf24101d3
commit 535a110603
1 changed files with 23 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

26
federation/pkg/federation-controller/replicaset/replicasetcontroller.go
View File

@ -17,8 +17,11 @@ limitations under the License.
package replicaset package replicaset
import ( import (
"bytes"
"encoding/json" "encoding/json"
"fmt"
"reflect" "reflect"
"sort"
"time" "time"
"github.com/golang/glog" "github.com/golang/glog"
@ -329,6 +332,23 @@ func (frsc *ReplicaSetController) schedule(frs *extensionsv1.ReplicaSet, cluster
for clusterName, replicas := range overflow { for clusterName, replicas := range overflow {
result[clusterName] += replicas result[clusterName] += replicas
} }
if glog.V(2) {
buf := bytes.NewBufferString(fmt.Sprintf("Schedule - ReplicaSet: %s/%s\n", frs.Namespace, frs.Name))
sort.Strings(clusterNames)
for _, clusterName := range clusterNames {
cur := current[clusterName]
target := scheduleResult[clusterName]
fmt.Fprintf(buf, "%s: current: %d target: %d", clusterName, cur, target)
if over, found := overflow[clusterName]; found {
fmt.Fprintf(buf, " overflow: %d", over)
}
if capacity, found := estimatedCapacity[clusterName]; found {
fmt.Fprintf(buf, " capacity: %d", capacity)
}
fmt.Fprintf(buf, "\n")
}
glog.V(2).Infof(buf.String())
}
return result return result
} }
@ -338,9 +358,9 @@ func (frsc *ReplicaSetController) reconcileReplicaSet(key string) error {
return nil return nil
} }
glog.Infof("Start reconcile replicaset %q", key) glog.V(1).Infof("Start reconcile replicaset %q", key)
startTime := time.Now() startTime := time.Now()
defer glog.Infof("Finished reconcile replicaset %q (%v)", key, time.Now().Sub(startTime)) defer glog.V(1).Infof("Finished reconcile replicaset %q (%v)", key, time.Now().Sub(startTime))
obj, exists, err := frsc.replicaSetStore.Store.GetByKey(key) obj, exists, err := frsc.replicaSetStore.Store.GetByKey(key)
if err != nil { if err != nil {
@ -382,7 +402,7 @@ func (frsc *ReplicaSetController) reconcileReplicaSet(key string) error {
scheduleResult := frsc.schedule(frs, clusters, current, estimatedCapacity) scheduleResult := frsc.schedule(frs, clusters, current, estimatedCapacity)
glog.Infof("Start syncing local replicaset %v", scheduleResult) glog.V(1).Infof("Start syncing local replicaset %s: %v", key, scheduleResult)
fedStatus := extensionsv1.ReplicaSetStatus{ObservedGeneration: frs.Generation} fedStatus := extensionsv1.ReplicaSetStatus{ObservedGeneration: frs.Generation}
for clusterName, replicas := range scheduleResult { for clusterName, replicas := range scheduleResult {