Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 42 for suspendG (0.2 sec)

  1. src/runtime/mgcmark.go

    			}
    
    			// TODO: suspendG blocks (and spins) until gp
    			// stops, which may take a while for
    			// running goroutines. Consider doing this in
    			// two phases where the first is non-blocking:
    			// we scan the stacks we can and ask running
    			// goroutines to scan themselves; and the
    			// second blocks.
    			stopped := suspendG(gp)
    			if stopped.dead {
    				gp.gcscandone = true
    				return
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu Apr 18 21:25:11 UTC 2024
    - 52.5K bytes
    - Viewed (0)
  2. pkg/controller/cronjob/cronjob_controllerv2_test.go

    	}
    	for name, tc := range testCases {
    		name := name
    		tc := tc
    
    		t.Run(name, func(t *testing.T) {
    			cj := cronJob()
    			cj.Spec.ConcurrencyPolicy = tc.concurrencyPolicy
    			cj.Spec.Suspend = &tc.suspend
    			cj.Spec.Schedule = tc.schedule
    			cj.Spec.TimeZone = tc.timeZone
    			if tc.deadline != noDead {
    				cj.Spec.StartingDeadlineSeconds = &tc.deadline
    			}
    
    			var (
    				job *batchv1.Job
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 70.8K bytes
    - Viewed (0)
  3. pkg/controller/job/job_controller.go

    			// updates.
    			if job.Spec.Suspend != nil && *job.Spec.Suspend {
    				// Job can be in the suspended state only if it is NOT completed.
    				var isUpdated bool
    				job.Status.Conditions, isUpdated = ensureJobConditionStatus(job.Status.Conditions, batch.JobSuspended, v1.ConditionTrue, "JobSuspended", "Job suspended", jm.clock.Now())
    				if isUpdated {
    					suspendCondChanged = true
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Jun 10 23:56:37 UTC 2024
    - 77.6K bytes
    - Viewed (0)
  4. staging/src/k8s.io/api/testdata/v1.29.0/batch.v1beta1.CronJob.json

    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Dec 15 04:12:07 UTC 2023
    - 62.4K bytes
    - Viewed (0)
  5. staging/src/k8s.io/api/testdata/HEAD/batch.v1beta1.CronJob.json

    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed May 29 22:40:29 UTC 2024
    - 63.5K bytes
    - Viewed (0)
  6. staging/src/k8s.io/api/testdata/v1.29.0/batch.v1.CronJob.json

    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Dec 15 04:12:07 UTC 2023
    - 62.3K bytes
    - Viewed (0)
  7. staging/src/k8s.io/api/testdata/v1.30.0/batch.v1.CronJob.json

    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Apr 18 08:52:25 UTC 2024
    - 63.4K bytes
    - Viewed (0)
  8. staging/src/k8s.io/api/testdata/HEAD/batch.v1.CronJob.json

    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed May 29 22:40:29 UTC 2024
    - 63.5K bytes
    - Viewed (0)
  9. staging/src/k8s.io/api/testdata/v1.30.0/batch.v1beta1.CronJob.json

    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Apr 18 08:52:25 UTC 2024
    - 63.4K bytes
    - Viewed (0)
  10. cmd/erasure-object.go

    		if objects[i].VersionID == "" {
    			// MinIO extension to bucket version configuration
    			suspended := opts.VersionSuspended
    			versioned := opts.Versioned
    			if opts.PrefixEnabledFn != nil {
    				versioned = opts.PrefixEnabledFn(objects[i].ObjectName)
    			}
    			if versioned || suspended {
    				// Bucket is versioned and no version was explicitly
    				// mentioned for deletes, create a delete marker instead.
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Mon Jun 10 15:51:27 UTC 2024
    - 78.6K bytes
    - Viewed (0)
Back to top