Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 63 for finalizer (0.25 sec)

  1. pkg/controller/job/job_controller.go

    	}
    	return string(batch.NonIndexedCompletion)
    }
    
    func appendJobCompletionFinalizerIfNotFound(finalizers []string) []string {
    	for _, fin := range finalizers {
    		if fin == batch.JobTrackingFinalizer {
    			return finalizers
    		}
    	}
    	return append(finalizers, batch.JobTrackingFinalizer)
    }
    
    func removeTrackingFinalizerPatch(pod *v1.Pod) []byte {
    	if !hasJobTrackingFinalizer(pod) {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Jun 10 23:56:37 UTC 2024
    - 77.6K bytes
    - Viewed (0)
  2. pkg/scheduler/framework/plugins/dynamicresources/dynamicresources.go

    			claim.Finalizers = append(claim.Finalizers, resourcev1alpha2.Finalizer)
    			if _, err := pl.clientset.ResourceV1alpha2().ResourceClaims(claim.Namespace).Update(ctx, claim, metav1.UpdateOptions{}); err != nil {
    				return nil, fmt.Errorf("add finalizer: %v", err)
    			}
    		}
    	}
    
    	// The claim might be stale, for example because the claim can get shared and some
    	// other goroutine has updated it in the meantime. We therefore cannot use
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu May 30 15:22:37 UTC 2024
    - 75.9K bytes
    - Viewed (0)
  3. src/runtime/pprof/pprof_test.go

    			})
    		}
    		wg.Wait()
    	})
    
    	// The finalizer goroutine should not show up in most profiles, since it's
    	// marked as a system goroutine when idle.
    	t.Run("finalizer not present", func(t *testing.T) {
    		var w strings.Builder
    		goroutineProf.WriteTo(&w, 1)
    		prof := w.String()
    		if includesFinalizer(prof) {
    			t.Errorf("profile includes finalizer (but finalizer should be marked as system):\n%s", prof)
    		}
    	})
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu May 23 18:42:28 UTC 2024
    - 68.8K bytes
    - Viewed (0)
  4. src/runtime/mgcmark.go

    //
    //go:nowritebarrier
    func markrootSpans(gcw *gcWork, shard int) {
    	// Objects with finalizers have two GC-related invariants:
    	//
    	// 1) Everything reachable from the object must be marked.
    	// This ensures that when we pass the object to its finalizer,
    	// everything the finalizer can reach will be retained.
    	//
    	// 2) Finalizer specials (which are not in the garbage
    	// collected heap) are roots. In practice, this means the fn
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu Apr 18 21:25:11 UTC 2024
    - 52.5K bytes
    - Viewed (0)
  5. src/runtime/mheap.go

    			// so it's retained for the finalizer.
    			if !span.spanclass.noscan() {
    				scanobject(base, gcw)
    			}
    			// Mark the finalizer itself, since the
    			// special isn't part of the GC'd heap.
    			scanblock(uintptr(unsafe.Pointer(&s.fn)), goarch.PtrSize, &oneptrmask[0], gcw, nil)
    			releasem(mp)
    		}
    		return true
    	}
    
    	// There was an old finalizer
    	lock(&mheap_.speciallock)
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed May 22 22:31:00 UTC 2024
    - 78K bytes
    - Viewed (0)
  6. src/runtime/mprof.go

    // goroutineProfileState will be "InProgress" and it will not be able to run
    // until the capture completes and the state moves to "Satisfied".
    //
    // Some goroutines (the finalizer goroutine, which at various times can be
    // either a "system" or a "user" goroutine, and the goroutine that is
    // coordinating the profile, any goroutines created during the profile) move
    // directly to the "Satisfied" state.
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu May 30 17:57:37 UTC 2024
    - 53.3K bytes
    - Viewed (0)
  7. pkg/controller/volume/persistentvolume/pv_controller.go

    		if err != nil {
    			return fmt.Errorf("persistent volume controller can't update finalizer: %v", err)
    		}
    		_, err = ctrl.storeVolumeUpdate(logger, volumeClone)
    		if err != nil {
    			return fmt.Errorf("persistent Volume Controller can't anneal migration finalizer: %v", err)
    		}
    		logger.V(2).Info("PV in-tree protection finalizer removed from volume", "volumeName", volume.Name)
    	}
    	return nil
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri May 10 08:42:31 UTC 2024
    - 89.2K bytes
    - Viewed (0)
  8. src/runtime/mgc.go

    // so they are empty. When a goroutine grabs a new span into mcache, it sweeps it.
    // When a goroutine explicitly frees an object or sets a finalizer, it ensures that
    // the span is swept (either by sweeping it, or by waiting for the concurrent sweep to finish).
    // The finalizer goroutine is kicked off only when all spans are swept.
    // When the next GC starts, it sweeps all not-yet-swept spans (if any).
    
    // GC rate.
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed May 29 16:25:21 UTC 2024
    - 62K bytes
    - Viewed (0)
  9. pkg/scheduler/framework/plugins/dynamicresources/dynamicresources_test.go

    			expectedErr: true,
    		},
    		"skip-adding-finalizer": {
    			pod:    podWithClaimName,
    			claims: []*resourcev1alpha2.ResourceClaim{pendingImmediateClaim},
    			oldObj: pendingImmediateClaim,
    			newObj: func() *resourcev1alpha2.ResourceClaim {
    				claim := pendingImmediateClaim.DeepCopy()
    				claim.Finalizers = append(claim.Finalizers, "foo")
    				return claim
    			}(),
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon May 27 07:57:10 UTC 2024
    - 61.9K bytes
    - Viewed (0)
  10. src/runtime/traceback.go

    // runtime.handleAsyncEvent (wasm only) and sometimes runtime.runfinq.
    //
    // If fixed is true, any goroutine that can vary between user and
    // system (that is, the finalizer goroutine) is considered a user
    // goroutine.
    func isSystemGoroutine(gp *g, fixed bool) bool {
    	// Keep this in sync with internal/trace.IsSystemGoroutine.
    	f := findfunc(gp.startpc)
    	if !f.valid() {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed May 29 16:25:21 UTC 2024
    - 55.1K bytes
    - Viewed (0)
Back to top