mirror of
https://github.com/cozystack/cozystack.git
synced 2026-10-28 15:47:33 +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
289 lines
9.5 KiB
Go
289 lines
9.5 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
|
|
|
|
import (
|
|
"context"
|
|
"fmt"
|
|
"time"
|
|
|
|
apierrors "k8s.io/apimachinery/pkg/api/errors"
|
|
"k8s.io/apimachinery/pkg/api/meta"
|
|
metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
|
|
"k8s.io/apimachinery/pkg/apis/meta/v1/unstructured"
|
|
"k8s.io/apimachinery/pkg/runtime"
|
|
"k8s.io/apimachinery/pkg/types"
|
|
"sigs.k8s.io/controller-runtime/pkg/client"
|
|
"sigs.k8s.io/controller-runtime/pkg/controller/controllerutil"
|
|
"sigs.k8s.io/controller-runtime/pkg/log"
|
|
|
|
gpuv1alpha1 "github.com/cozystack/cozystack/api/gpu/v1alpha1"
|
|
"github.com/cozystack/cozystack/internal/gpu"
|
|
"github.com/cozystack/cozystack/internal/gpu/model"
|
|
)
|
|
|
|
func (r *Reconciler) ensureFinalizers(ctx context.Context, w *world) []error {
|
|
var errs []error
|
|
for _, c := range w.classes {
|
|
if c.DeletionTimestamp.IsZero() && controllerutil.AddFinalizer(c, gpu.FinalizerClass) {
|
|
errs = append(errs, r.Client.Update(ctx, c))
|
|
}
|
|
}
|
|
for _, d := range w.devices {
|
|
if d.DeletionTimestamp.IsZero() && controllerutil.AddFinalizer(d, gpu.FinalizerDevice) {
|
|
errs = append(errs, r.Client.Update(ctx, d))
|
|
}
|
|
}
|
|
return errs
|
|
}
|
|
|
|
func vmiOwner(d *gpuv1alpha1.GPUDevice) types.UID {
|
|
for _, ref := range d.OwnerReferences {
|
|
if ref.Kind == vmiGVK.Kind && ref.APIVersion == vmiGVK.GroupVersion().String() {
|
|
return ref.UID
|
|
}
|
|
}
|
|
return ""
|
|
}
|
|
|
|
// attachedVMI returns the VMI a device's attachment names, or nil when it
|
|
// does not exist. A template device owned by an earlier VMI of the same
|
|
// name does not belong to the current one.
|
|
func (w *world) attachedVMI(d *gpuv1alpha1.GPUDevice) *vmi {
|
|
if d.Status.AttachedTo == nil {
|
|
return nil
|
|
}
|
|
v := w.vmis[key(d.Namespace, d.Status.AttachedTo.VMI)]
|
|
if v == nil {
|
|
return nil
|
|
}
|
|
if owner := vmiOwner(d); owner != "" && owner != v.UID {
|
|
return nil
|
|
}
|
|
return v
|
|
}
|
|
|
|
// attachments moves devices into and out of Attached as their VMIs come
|
|
// and go, sets a VMI as the owner of its template devices, and clears
|
|
// attachments whose VMI never appeared.
|
|
func (r *Reconciler) attachments(ctx context.Context, w *world) []error {
|
|
var errs []error
|
|
seen := map[string]bool{}
|
|
for _, d := range w.devices {
|
|
if d.Status.AttachedTo == nil {
|
|
// The webhook crashed between creating and attaching it; its VMI
|
|
// cannot be told from its name, which may be hashed.
|
|
if isTemplate(d) && d.DeletionTimestamp.IsZero() && w.now.Sub(d.CreationTimestamp.Time) >= r.Config.AttachmentGrace {
|
|
errs = append(errs, r.deleteDevice(ctx, d))
|
|
}
|
|
continue
|
|
}
|
|
v := w.attachedVMI(d)
|
|
phase := d.Status.Phase
|
|
switch {
|
|
case v != nil && !v.final():
|
|
errs = append(errs, r.attachLive(ctx, w, d, v))
|
|
case v != nil, phase == gpuv1alpha1.GPUDeviceAttached, phase == gpuv1alpha1.GPUDeviceLost, vmiOwner(d) != "":
|
|
errs = append(errs, r.detach(ctx, w, d))
|
|
default:
|
|
k := d.Namespace + "/" + d.Name + "/" + d.Status.AttachedTo.VMI
|
|
seen[k] = true
|
|
if w.now.Sub(r.attachedAt(w, k, d)) >= r.Config.AttachmentGrace {
|
|
errs = append(errs, r.detach(ctx, w, d))
|
|
}
|
|
}
|
|
}
|
|
r.mu.Lock()
|
|
for k := range r.attachedSince {
|
|
if !seen[k] {
|
|
delete(r.attachedSince, k)
|
|
}
|
|
}
|
|
r.mu.Unlock()
|
|
return errs
|
|
}
|
|
|
|
// attachedAt is when an attachment whose VMI has not appeared was made: its
|
|
// bind request's time, or when this controller first saw it.
|
|
func (r *Reconciler) attachedAt(w *world, k string, d *gpuv1alpha1.GPUDevice) time.Time {
|
|
if req := d.Status.BindRequest; req != nil && req.VMI == d.Status.AttachedTo.VMI {
|
|
return req.RequestedAt.Time
|
|
}
|
|
r.mu.Lock()
|
|
defer r.mu.Unlock()
|
|
since, ok := r.attachedSince[k]
|
|
if !ok {
|
|
since = w.now
|
|
r.attachedSince[k] = since
|
|
}
|
|
return since
|
|
}
|
|
|
|
func (r *Reconciler) attachLive(ctx context.Context, w *world, d *gpuv1alpha1.GPUDevice, v *vmi) error {
|
|
if isTemplate(d) && vmiOwner(d) == "" && d.DeletionTimestamp.IsZero() {
|
|
// Not a controller reference and no blockOwnerDeletion: the device's
|
|
// own finalizer, not the garbage collector, decides when it goes.
|
|
d.OwnerReferences = append(d.OwnerReferences, metav1.OwnerReference{
|
|
APIVersion: vmiGVK.GroupVersion().String(),
|
|
Kind: vmiGVK.Kind,
|
|
Name: v.Name,
|
|
UID: v.UID,
|
|
})
|
|
if err := r.Client.Update(ctx, d); err != nil {
|
|
return err
|
|
}
|
|
}
|
|
switch d.Status.Phase {
|
|
case gpuv1alpha1.GPUDeviceBound:
|
|
case gpuv1alpha1.GPUDeviceLost:
|
|
// The node came back while the VMI still runs.
|
|
if n := w.nodes[d.Status.NodeName]; n == nil || !model.Ready(n) || w.lost[n.Name].covers(w.resourceName(d.Spec.ClassName)) {
|
|
return nil
|
|
}
|
|
default:
|
|
return nil
|
|
}
|
|
d.Status.Phase = gpuv1alpha1.GPUDeviceAttached
|
|
return r.updateStatus(ctx, w, d)
|
|
}
|
|
|
|
// detach ends an attachment whose VMI is final, removed, or never appeared.
|
|
// A template device lives only with its VMI, so it is deleted instead.
|
|
func (r *Reconciler) detach(ctx context.Context, w *world, d *gpuv1alpha1.GPUDevice) error {
|
|
if isTemplate(d) {
|
|
if !d.DeletionTimestamp.IsZero() {
|
|
return nil
|
|
}
|
|
return r.deleteDevice(ctx, d)
|
|
}
|
|
d.Status.AttachedTo = nil
|
|
d.Status.BindRequest = nil
|
|
if d.Status.Phase == gpuv1alpha1.GPUDeviceAttached {
|
|
d.Status.Phase = gpuv1alpha1.GPUDeviceBound
|
|
}
|
|
return r.updateStatus(ctx, w, d)
|
|
}
|
|
|
|
func (r *Reconciler) deleteDevice(ctx context.Context, d *gpuv1alpha1.GPUDevice) error {
|
|
log.FromContext(ctx).Info("deleting template GPUDevice", "namespace", d.Namespace, "name", d.Name)
|
|
return client.IgnoreNotFound(r.Client.Delete(ctx, d))
|
|
}
|
|
|
|
// usedByVMI reports whether a VMI that can still hold the device's GPUs
|
|
// uses it. With the feature disabled no VMI cache exists, so the VMI is
|
|
// read directly; a cluster without KubeVirt has none.
|
|
func (r *Reconciler) usedByVMI(ctx context.Context, w *world, d *gpuv1alpha1.GPUDevice) (bool, error) {
|
|
if d.Status.AttachedTo == nil {
|
|
return false, nil
|
|
}
|
|
if r.Config.Enabled {
|
|
v := w.attachedVMI(d)
|
|
if v == nil && d.Status.Phase != gpuv1alpha1.GPUDeviceAttached && d.Status.Phase != gpuv1alpha1.GPUDeviceLost &&
|
|
vmiOwner(d) == "" {
|
|
// A fresh attachment whose VMI the cache has not shown yet, as
|
|
// attachments() treats it: the VMI may be starting with the GPU.
|
|
k := d.Namespace + "/" + d.Name + "/" + d.Status.AttachedTo.VMI
|
|
return w.now.Sub(r.attachedAt(w, k, d)) < r.Config.AttachmentGrace, nil
|
|
}
|
|
return v != nil && !v.final(), nil
|
|
}
|
|
u := &unstructured.Unstructured{}
|
|
u.SetGroupVersionKind(vmiGVK)
|
|
err := r.Reader.Get(ctx, key(d.Namespace, d.Status.AttachedTo.VMI), u)
|
|
switch {
|
|
case apierrors.IsNotFound(err), meta.IsNoMatchError(err), runtime.IsNotRegisteredError(err):
|
|
return false, nil
|
|
case err != nil:
|
|
return false, err
|
|
}
|
|
v := vmiFrom(u)
|
|
if owner := vmiOwner(d); owner != "" && owner != v.UID {
|
|
return false, nil
|
|
}
|
|
return !v.final(), nil
|
|
}
|
|
|
|
// releaseDeleted lets a deleted device go once no VMI uses it, and a
|
|
// deleted class once no device of it holds or owes GPUs.
|
|
func (r *Reconciler) releaseDeleted(ctx context.Context, w *world) []error {
|
|
var errs []error
|
|
for _, d := range w.devices {
|
|
if d.DeletionTimestamp.IsZero() || !controllerutil.ContainsFinalizer(d, gpu.FinalizerDevice) {
|
|
continue
|
|
}
|
|
used, err := r.usedByVMI(ctx, w, d)
|
|
if err != nil || used {
|
|
errs = append(errs, err)
|
|
continue
|
|
}
|
|
if err := r.deleteRecord(ctx, d); err != nil {
|
|
errs = append(errs, err)
|
|
continue
|
|
}
|
|
controllerutil.RemoveFinalizer(d, gpu.FinalizerDevice)
|
|
if err := client.IgnoreNotFound(r.Client.Update(ctx, d)); err != nil {
|
|
// The device stays, so its class must too.
|
|
controllerutil.AddFinalizer(d, gpu.FinalizerDevice)
|
|
errs = append(errs, err)
|
|
}
|
|
}
|
|
for _, c := range w.classes {
|
|
if c.DeletionTimestamp.IsZero() || !controllerutil.ContainsFinalizer(c, gpu.FinalizerClass) {
|
|
continue
|
|
}
|
|
held := false
|
|
for _, d := range w.devices {
|
|
if d.Spec.ClassName == c.Name && model.CountsAgainstBudget(d.Status.Phase) && !released(d) {
|
|
held = true
|
|
break
|
|
}
|
|
}
|
|
if held {
|
|
continue
|
|
}
|
|
controllerutil.RemoveFinalizer(c, gpu.FinalizerClass)
|
|
errs = append(errs, client.IgnoreNotFound(r.Client.Update(ctx, c)))
|
|
}
|
|
return errs
|
|
}
|
|
|
|
// released reports a device whose finalizer this pass has removed.
|
|
func released(d *gpuv1alpha1.GPUDevice) bool {
|
|
return !d.DeletionTimestamp.IsZero() && !controllerutil.ContainsFinalizer(d, gpu.FinalizerDevice)
|
|
}
|
|
|
|
// deleteVMI deletes the unscheduled VMI of a device that cannot stay on its
|
|
// node, so the device becomes unattached and can move. What the VM does
|
|
// next follows its runStrategy.
|
|
func (r *Reconciler) deleteVMI(ctx context.Context, v *vmi, why string) error {
|
|
log.FromContext(ctx).Info("deleting unscheduled VMI", "namespace", v.Namespace, "name", v.Name, "reason", why)
|
|
u := &unstructured.Unstructured{}
|
|
u.SetGroupVersionKind(vmiGVK)
|
|
u.SetNamespace(v.Namespace)
|
|
u.SetName(v.Name)
|
|
// The VMI is read from the cache; the version precondition keeps one
|
|
// scheduled since then from being deleted on that stale view.
|
|
err := r.Client.Delete(ctx, u, client.Preconditions{UID: &v.UID, ResourceVersion: &v.ResourceVersion})
|
|
if apierrors.IsNotFound(err) || apierrors.IsConflict(err) {
|
|
return nil
|
|
}
|
|
if err != nil {
|
|
return fmt.Errorf("delete VMI %s/%s: %w", v.Namespace, v.Name, err)
|
|
}
|
|
return nil
|
|
}
|