mirror of
https://github.com/cozystack/cozystack.git
synced 2026-10-30 08:37:31 +09:00
The binder is the only writer of a device's placement, so budget and capacity checks that admission already ran cannot be raced past by two replicas or two webhook calls. Every event collapses into one pass over all GPU objects, which serializes the decisions without per-object locks, and devices are read past the cache so a unit booked in the last pass is never booked again from a stale view. A device that carries an unanswered bind request also queues a pass that only answers requests, so the webhook, which waits seconds, is not held behind moves, usage records and status of the whole cluster. The full pass moves held sets off nodes that cannot keep them, rebinds Lost sets before new orders, and binds new orders onto the fullest node with room. Finalizers and usage records run with the feature disabled too, so turning GPU off never hangs a namespace or class deletion. The devices one VM names move, go Lost and are rebound as a set. Every pass restores that invariant before it places anything, gathering a set left partly Lost, by a write that failed half way or by a VMI that ended next to held members, onto one node or sending all of it to Lost, so each later step only ever changes whole sets. A Lost device already counts against its tenant's budgets, so the pod of its still running VMI is not counted again under a raw GPU key; for node capacity it is, since the device itself holds no units. Signed-off-by: Aleksei Sviridkin <f@lex.la> Assisted-by: LLM
129 lines
5.1 KiB
Go
129 lines
5.1 KiB
Go
/*
|
|
Copyright 2026 The Cozystack Authors.
|
|
|
|
Licensed under the Apache License, Version 2.0 (the "License");
|
|
you may not use this file except in compliance with the License.
|
|
You may obtain a copy of the License at
|
|
|
|
http://www.apache.org/licenses/LICENSE-2.0
|
|
|
|
Unless required by applicable law or agreed to in writing, software
|
|
distributed under the License is distributed on an "AS IS" BASIS,
|
|
WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
|
See the License for the specific language governing permissions and
|
|
limitations under the License.
|
|
*/
|
|
|
|
// Package controller runs the GPU binder, the class and device lifecycle,
|
|
// usage records and metrics in cozystack-controller.
|
|
package controller
|
|
|
|
import (
|
|
"context"
|
|
"strings"
|
|
|
|
helmv2 "github.com/fluxcd/helm-controller/api/v2"
|
|
corev1 "k8s.io/api/core/v1"
|
|
"k8s.io/apimachinery/pkg/api/equality"
|
|
"k8s.io/apimachinery/pkg/apis/meta/v1/unstructured"
|
|
ctrl "sigs.k8s.io/controller-runtime"
|
|
"sigs.k8s.io/controller-runtime/pkg/builder"
|
|
"sigs.k8s.io/controller-runtime/pkg/client"
|
|
"sigs.k8s.io/controller-runtime/pkg/event"
|
|
"sigs.k8s.io/controller-runtime/pkg/handler"
|
|
"sigs.k8s.io/controller-runtime/pkg/manager"
|
|
"sigs.k8s.io/controller-runtime/pkg/predicate"
|
|
"sigs.k8s.io/controller-runtime/pkg/reconcile"
|
|
|
|
gpuv1alpha1 "github.com/cozystack/cozystack/api/gpu/v1alpha1"
|
|
cozyv1alpha1 "github.com/cozystack/cozystack/api/v1alpha1"
|
|
"github.com/cozystack/cozystack/internal/gpu"
|
|
"github.com/cozystack/cozystack/internal/gpu/model"
|
|
appsv1alpha1 "github.com/cozystack/cozystack/pkg/apis/apps/v1alpha1"
|
|
)
|
|
|
|
// Setup adds the GPU reconciler to mgr. Finalizers and usage records are
|
|
// always reconciled, so a disabled feature never hangs a deletion; with
|
|
// cfg.Enabled it also places devices and watches KubeVirt objects, which
|
|
// exist only where the feature is enabled.
|
|
func Setup(mgr manager.Manager, cfg gpu.Config) error {
|
|
r := &Reconciler{Client: mgr.GetClient(), Reader: mgr.GetAPIReader(), Cache: mgr.GetCache(), Config: cfg}
|
|
all := handler.EnqueueRequestsFromMapFunc(func(context.Context, client.Object) []reconcile.Request {
|
|
return []reconcile.Request{{NamespacedName: passKey}}
|
|
})
|
|
devices := handler.EnqueueRequestsFromMapFunc(func(_ context.Context, o client.Object) []reconcile.Request {
|
|
out := []reconcile.Request{{NamespacedName: passKey}}
|
|
if d, ok := o.(*gpuv1alpha1.GPUDevice); ok && d.Status.BindRequest != nil && d.Status.BindRequest.Result == "" {
|
|
out = append([]reconcile.Request{{NamespacedName: requestsKey}}, out...)
|
|
}
|
|
return out
|
|
})
|
|
b := ctrl.NewControllerManagedBy(mgr).
|
|
Named("gpu-binder").
|
|
Watches(&gpuv1alpha1.GPUClass{}, all).
|
|
Watches(&gpuv1alpha1.GPUDevice{}, devices).
|
|
Watches(&cozyv1alpha1.Workload{}, all, builder.WithPredicates(predicate.NewPredicateFuncs(func(o client.Object) bool {
|
|
return o.GetLabels()[workloadMonitorLabel] == gpu.UsageMonitorName
|
|
}))).
|
|
Watches(&cozyv1alpha1.WorkloadMonitor{}, all, builder.WithPredicates(predicate.NewPredicateFuncs(func(o client.Object) bool {
|
|
return o.GetName() == gpu.UsageMonitorName
|
|
})))
|
|
if cfg.Enabled {
|
|
vmi := &unstructured.Unstructured{}
|
|
vmi.SetGroupVersionKind(vmiGVK)
|
|
vm := &unstructured.Unstructured{}
|
|
vm.SetGroupVersionKind(vmGVK)
|
|
kv := &unstructured.Unstructured{}
|
|
kv.SetGroupVersionKind(kubeVirtGVK)
|
|
b = b.
|
|
Watches(&gpuv1alpha1.GPUNode{}, all).
|
|
Watches(&corev1.Node{}, all, builder.WithPredicates(nodePlacementChanged)).
|
|
Watches(&corev1.Namespace{}, all, builder.WithPredicates(predicate.LabelChangedPredicate{})).
|
|
Watches(&helmv2.HelmRelease{}, all, builder.WithPredicates(predicate.NewPredicateFuncs(func(o client.Object) bool {
|
|
return o.GetLabels()[appsv1alpha1.ApplicationKindLabel] == tenantKind
|
|
}))).
|
|
Watches(&corev1.Pod{}, all, builder.WithPredicates(predicate.NewPredicateFuncs(requestsExtendedResource))).
|
|
Watches(vmi, all).
|
|
Watches(vm, all).
|
|
Watches(kv, all)
|
|
}
|
|
return b.Complete(r)
|
|
}
|
|
|
|
// nodePlacementChanged drops node updates that cannot change placement,
|
|
// such as the kubelet's periodic status writes.
|
|
var nodePlacementChanged = predicate.Funcs{UpdateFunc: func(e event.UpdateEvent) bool {
|
|
o, ok1 := e.ObjectOld.(*corev1.Node)
|
|
n, ok2 := e.ObjectNew.(*corev1.Node)
|
|
if !ok1 || !ok2 {
|
|
return true
|
|
}
|
|
return o.Spec.Unschedulable != n.Spec.Unschedulable ||
|
|
!equality.Semantic.DeepEqual(o.Spec.Taints, n.Spec.Taints) ||
|
|
!equality.Semantic.DeepEqual(o.Labels, n.Labels) ||
|
|
!equality.Semantic.DeepEqual(o.Status.Allocatable, n.Status.Allocatable) ||
|
|
model.Ready(o) != model.Ready(n)
|
|
}}
|
|
|
|
// requestsExtendedResource keeps pod events that can change GPU usage
|
|
// without parsing the effective resource-name set on every pod event.
|
|
func requestsExtendedResource(o client.Object) bool {
|
|
p, ok := o.(*corev1.Pod)
|
|
if !ok {
|
|
return false
|
|
}
|
|
for _, cs := range [][]corev1.Container{p.Spec.Containers, p.Spec.InitContainers} {
|
|
for i := range cs {
|
|
for _, rl := range []corev1.ResourceList{cs[i].Resources.Limits, cs[i].Resources.Requests} {
|
|
for name := range rl {
|
|
// Every virt-launcher pod requests devices.kubevirt.io/kvm.
|
|
if strings.Contains(string(name), "/") && !strings.HasPrefix(string(name), "devices.kubevirt.io/") {
|
|
return true
|
|
}
|
|
}
|
|
}
|
|
}
|
|
}
|
|
return false
|
|
}
|