- Sort Score
- Result 10 results
- Languages All
Results 1 - 9 of 9 for exit2 (0.04 sec)
-
pkg/scheduler/internal/queue/scheduling_queue.go
AssignedPodUpdated(logger klog.Logger, oldPod, newPod *v1.Pod) PendingPods() ([]*v1.Pod, string) PodsInActiveQ() []*v1.Pod // Close closes the SchedulingQueue so that the goroutine which is // waiting to pop items can exit gracefully. Close() // Run starts the goroutines managing the queue. Run(logger klog.Logger) } // NewSchedulingQueue initializes a priority queue as a new scheduling queue. func NewSchedulingQueue(
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 13:26:09 UTC 2024 - 61.4K bytes - Viewed (0) -
cmd/test-utils_test.go
globalConsoleSys = NewConsoleLogger(context.Background(), io.Discard) globalInternodeTransport = NewInternodeHTTPTransport(0)() initHelp() resetTestGlobals() globalIsCICD = true os.Exit(m.Run()) } // concurrency level for certain parallel tests. const testConcurrencyLevel = 10 const iso8601TimeFormat = "2006-01-02T15:04:05.000Z"
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Jun 10 15:50:49 UTC 2024 - 76.9K bytes - Viewed (0) -
configure.py
bazel_executable = which('bazel') if bazel_executable is None: bazel_executable = which('bazelisk') if bazel_executable is None: print('Cannot find bazel. Please install bazel/bazelisk.') sys.exit(1) stderr = open(os.devnull, 'wb') curr_version = run_shell([bazel_executable, '--version'], allow_non_zero=True, stderr=stderr)
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Mon Jun 10 04:32:44 UTC 2024 - 53.8K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/cacher/cacher.go
// We start with usable (write) locked. The below OnReplace function will // unlock it after a successful list. The below defer will then re-lock // it when this function exits (always due to disconnection), only if // we actually got a successful list. This cycle will repeat as needed. successfulList := false c.watchCache.SetOnReplace(func() { successfulList = true c.ready.set(true)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 10:12:02 UTC 2024 - 51.8K bytes - Viewed (0) -
cmd/iam.go
sys.iamRefreshInterval = iamRefreshInterval // Initialize IAM store sys.initStore(objAPI, etcdClient) sys.Unlock() retryCtx, cancel := context.WithCancel(ctx) // Indicate to our routine to exit cleanly upon return. defer cancel() r := rand.New(rand.NewSource(time.Now().UnixNano())) // Migrate storage format if needed. for { // Migrate IAM configuration, if necessary.
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu Jun 13 22:26:38 UTC 2024 - 71.9K bytes - Viewed (0) -
src/cmd/compile/internal/ssa/debug.go
// affects how the merge is done; the goal is to maximize sharing // and avoid allocation. everProcessed bool } // A liveSlot is a slot that's live in loc at entry/exit of a block. type liveSlot struct { VarLoc } func (ls *liveSlot) String() string { return fmt.Sprintf("0x%x.%d.%d", ls.Registers, ls.stackOffsetValue(), int32(ls.StackOffset)&1) }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Jun 10 19:44:43 UTC 2024 - 58.4K bytes - Viewed (0) -
CHANGELOG/CHANGELOG-1.31.md
- Pause: add a -v flag to the Windows variant of the pause binary, which prints the version of pause and exits. The Linux pause already has the flag. ([#125067](https://github.com/kubernetes/kubernetes/pull/125067), [@neolit123](https://github.com/neolit123)) [SIG Windows]
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 20:34:14 UTC 2024 - 60.3K bytes - Viewed (0) -
cmd/erasure-object.go
pr, pw := xioutil.WaitPipe() go func() { pw.CloseWithError(er.getObjectWithFileInfo(ctx, bucket, object, off, length, pw, fi, metaArr, onlineDisks)) }() // Cleanup function to cause the go routine above to exit, in // case of incomplete read. pipeCloser := func() { pr.CloseWithError(nil) } if !unlockOnDefer { return fn(pr, h, pipeCloser, nsUnlocker) } return fn(pr, h, pipeCloser) }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Jun 10 15:51:27 UTC 2024 - 78.6K bytes - Viewed (0) -
pkg/controller/job/job_controller.go
active, action, manageJobErr = jm.manageJob(ctx, &job, jobCtx) manageJobCalled = true } complete := false if job.Spec.Completions == nil { // This type of job is complete when any pod exits with success. // Each pod is capable of // determining whether or not the entire Job is done. Subsequent pods are // not expected to fail, but if they do, the failure is ignored. Once any
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Jun 10 23:56:37 UTC 2024 - 77.6K bytes - Viewed (0)