- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 58 for sched (0.12 sec)
-
src/runtime/proc.go
// otherwise our help is not required if sched.nmspinning.Load()+sched.npidle.Load() == 0 && sched.nmspinning.CompareAndSwap(0, 1) { // TODO: fast atomic sched.needspinning.Store(0) startm(pp, true, false) return } lock(&sched.lock) if sched.gcwaiting.Load() { pp.status = _Pgcstop pp.gcStopTime = nanotime() sched.stopwait-- if sched.stopwait == 0 { notewakeup(&sched.stopnote) }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 29 17:58:53 UTC 2024 - 207.5K bytes - Viewed (0) -
pkg/scheduler/schedule_one.go
if status.IsRejected() { defer sched.SchedulingQueue.MoveAllToActiveOrBackoffQueue(logger, internalqueue.AssignedPodDelete, assumedPod, nil, func(pod *v1.Pod) bool { return assumedPod.UID != pod.UID }) } else { sched.SchedulingQueue.MoveAllToActiveOrBackoffQueue(logger, internalqueue.AssignedPodDelete, assumedPod, nil, nil) } } sched.FailureHandler(ctx, fwk, podInfo, status, clearNominatedNode, start)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Jun 06 13:28:08 UTC 2024 - 43.4K bytes - Viewed (0) -
src/time/tick_test.go
case <-stop: } close(done1) }() go func() { select { case <-C: done <- true case <-stop: } close(done2) }() Sleep(sched) notDone(done) tim.Reset(sched / 2) Sleep(sched) waitDone(done) tim.Stop() close(stop) waitDone(done1) waitDone(done2) if isTicker { // extra send might have sent done again // (handled by buffering done above).
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Jun 11 17:10:37 UTC 2024 - 14.7K bytes - Viewed (0) -
cmd/kube-scheduler/app/server.go
go func() { stopCh := server.SetupSignalHandler() <-stopCh cancel() }() cc, sched, err := Setup(ctx, opts, registryOptions...) if err != nil { return err } // add feature enablement metrics utilfeature.DefaultMutableFeatureGate.AddMetrics() return Run(ctx, cc, sched) } // Run executes the scheduler based on the given configuration. It only returns on error or when context is done.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon May 27 19:11:24 UTC 2024 - 14.3K bytes - Viewed (0) -
src/runtime/stack.go
"\tmorebuf={pc:", hex(morebuf.pc), " sp:", hex(morebuf.sp), " lr:", hex(morebuf.lr), "}\n", "\tsched={pc:", hex(gp.sched.pc), " sp:", hex(gp.sched.sp), " lr:", hex(gp.sched.lr), " ctxt:", gp.sched.ctxt, "}\n") } if sp < gp.stack.lo { print("runtime: gp=", gp, ", goid=", gp.goid, ", gp->status=", hex(readgstatus(gp)), "\n ")
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 22 22:31:00 UTC 2024 - 41.1K bytes - Viewed (0) -
pkg/scheduler/scheduler.go
registeredHandlers []cache.ResourceEventHandlerRegistration } func (sched *Scheduler) applyDefaultHandlers() { sched.SchedulePod = sched.schedulePod sched.FailureHandler = sched.handleSchedulingFailure } type schedulerOptions struct { componentConfigVersion string kubeConfig *restclient.Config
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:20:55 UTC 2024 - 20.8K bytes - Viewed (0) -
src/runtime/debug.go
// This call will go away when the scheduler improves. func GOMAXPROCS(n int) int { if GOARCH == "wasm" && n > 1 { n = 1 // WebAssembly has no threads yet, so only one CPU is possible. } lock(&sched.lock) ret := int(gomaxprocs) unlock(&sched.lock) if n <= 0 || n == ret { return ret } stw := stopTheWorldGC(stwGOMAXPROCS) // newprocs will be processed by startTheWorld newprocs = int32(n) startTheWorldGC(stw)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Sat May 11 20:38:24 UTC 2024 - 4.2K bytes - Viewed (0) -
src/runtime/asm_loong64.s
MOVV R7, 24(R3) JAL runtime·cgocallbackg(SB) // Restore g->sched (== m->curg->sched) from saved values. MOVV 0(R3), R4 MOVV R4, (g_sched+gobuf_pc)(g) MOVV $(24+8)(R3), R13 // must match frame size MOVV R13, (g_sched+gobuf_sp)(g) // Switch back to m->g0's stack and restore m->g0->sched.sp. // (Unlike m->curg, the g0 goroutine never uses sched.pc, // so we do not have to restore it.) MOVV g_m(g), R12
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon May 13 15:04:25 UTC 2024 - 26.5K bytes - Viewed (0) -
src/runtime/asm_mipsx.s
MOVW R7, 12(R29) JAL runtime·cgocallbackg(SB) // Restore g->sched (== m->curg->sched) from saved values. MOVW 0(R29), R4 MOVW R4, (g_sched+gobuf_pc)(g) MOVW $(12+4)(R29), R2 // must match frame size MOVW R2, (g_sched+gobuf_sp)(g) // Switch back to m->g0's stack and restore m->g0->sched.sp. // (Unlike m->curg, the g0 goroutine never uses sched.pc, // so we do not have to restore it.) MOVW g_m(g), R3
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon May 06 11:46:29 UTC 2024 - 26.3K bytes - Viewed (0) -
src/runtime/metrics.go
sched.timeToRun.write(out) }, }, "/sched/pauses/stopping/gc:seconds": { compute: func(_ *statAggregate, out *metricValue) { sched.stwStoppingTimeGC.write(out) }, }, "/sched/pauses/stopping/other:seconds": { compute: func(_ *statAggregate, out *metricValue) { sched.stwStoppingTimeOther.write(out) }, }, "/sched/pauses/total/gc:seconds": {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Apr 08 21:03:13 UTC 2024 - 26K bytes - Viewed (0)