- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 99 for sched (0.13 sec)
-
pkg/scheduler/eventhandlers_test.go
defer cancel() sched := &Scheduler{ Cache: cache.New(ctx, ttl), SchedulingQueue: queue.NewTestQueue(ctx, nil), logger: logger, } sched.addPodToCache(tt.oldObj) sched.updatePodInCache(tt.oldObj, tt.newObj) if tt.oldObj.(*v1.Pod).UID != tt.newObj.(*v1.Pod).UID { if pod, err := sched.Cache.GetPod(tt.oldObj.(*v1.Pod)); err == nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jan 10 14:38:54 UTC 2024 - 21.5K bytes - Viewed (0) -
cmd/kube-scheduler/app/testing/testserver.go
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Aug 24 10:35:59 UTC 2023 - 5.2K bytes - Viewed (0) -
src/runtime/testdata/testprogcgo/raceprof.go
// detector, because a call of the predeclared function copy was // turned into a call to runtime.slicecopy, which is not marked nosplit. /* #include <signal.h> #include <stdint.h> #include <pthread.h> #include <sched.h> struct cgoTracebackArg { uintptr_t context; uintptr_t sigContext; uintptr_t* buf; uintptr_t max; }; static int raceprofCount;
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Apr 24 18:13:14 UTC 2023 - 1.7K bytes - Viewed (0) -
src/runtime/testdata/testprogcgo/racesig.go
// call the C malloc function. /* #include <errno.h> #include <signal.h> #include <stdint.h> #include <stdio.h> #include <stdlib.h> #include <pthread.h> #include <sched.h> #include <unistd.h> #define ALLOCERS 100 #define SIGNALERS 10 static void* signalThread(void* p) { pthread_t* pt = (pthread_t*)(p); int i, j; for (i = 0; i < 100; i++) {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 12 01:46:05 UTC 2023 - 1.7K bytes - Viewed (0) -
src/cmd/trace/main.go
Go 1.7 does not require the binary argument. Supported profile types are: - net: network blocking profile - sync: synchronization blocking profile - syscall: syscall blocking profile - sched: scheduler latency profile Flags: -http=addr: HTTP service address (e.g., ':6060') -pprof=type: print a pprof-like profile instead -d=int: print debug info such as parsed events (1 for high-level, 2 for low-level)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 17 18:48:18 UTC 2024 - 10.4K bytes - Viewed (0) -
src/runtime/trace.go
// buffers before we snapshotted it to begin with. lock(&sched.lock) mToFlush := allm for mp := mToFlush; mp != nil; mp = mp.alllink { mp.trace.link = mp.alllink } for mp := sched.freem; mp != nil; mp = mp.freelink { mp.trace.link = mToFlush mToFlush = mp } unlock(&sched.lock) // Iterate over our snapshot, flushing every buffer until we're done. //
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 22 21:17:41 UTC 2024 - 37.1K bytes - Viewed (0) -
src/runtime/testdata/testprogcgo/needmdeadlock.go
package main // This is for issue #42207. // During a call to needm we could get a SIGCHLD signal // which would itself call needm, causing a deadlock. /* #include <signal.h> #include <pthread.h> #include <sched.h> #include <unistd.h> extern void GoNeedM(); #define SIGNALERS 10 static void* needmSignalThread(void* p) { pthread_t* pt = (pthread_t*)(p); int i; for (i = 0; i < 100; i++) {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Dec 13 18:45:54 UTC 2021 - 1.8K bytes - Viewed (0) -
src/runtime/mgcmark.go
// cached stacks around isn't a problem. func markrootFreeGStacks() { // Take list of dead Gs with stacks. lock(&sched.gFree.lock) list := sched.gFree.stack sched.gFree.stack = gList{} unlock(&sched.gFree.lock) if list.empty() { return } // Free stacks. q := gQueue{list.head, list.head} for gp := list.head.ptr(); gp != nil; gp = gp.schedlink.ptr() {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Apr 18 21:25:11 UTC 2024 - 52.5K bytes - Viewed (0) -
src/runtime/debugcall.go
// transition anymore. trace.GoSched() } casgstatus(gp, _Grunning, _Grunnable) if trace.ok() { traceRelease(trace) } dropg() lock(&sched.lock) globrunqput(gp) unlock(&sched.lock) trace = traceAcquire() casgstatus(callingG, _Gwaiting, _Grunnable) if trace.ok() { trace.GoUnpark(callingG, 0) traceRelease(trace) } execute(callingG, true)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Apr 05 20:50:21 UTC 2024 - 7.1K bytes - Viewed (0) -
src/runtime/runtime2.go
_defer *_defer // innermost defer m *m // current m; offset known to arm liblink sched gobuf syscallsp uintptr // if status==Gsyscall, syscallsp = sched.sp to use during gc syscallpc uintptr // if status==Gsyscall, syscallpc = sched.pc to use during gc syscallbp uintptr // if status==Gsyscall, syscallbp = sched.bp to use in fpTraceback stktopsp uintptr // expected sp at top of stack, to check in traceback
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 30 17:57:37 UTC 2024 - 47.9K bytes - Viewed (0)