Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 271 for preemption (0.23 sec)

  1. pkg/scheduler/framework/extender.go

    	// The possible changes made by extender may include:
    	//   1. Subset of given candidate nodes after preemption phase of extender.
    	//   2. A different set of victim pod for every given candidate node after preemption phase of extender.
    	ProcessPreemption(
    		pod *v1.Pod,
    		nodeNameToVictims map[string]*extenderv1.Victims,
    		nodeInfos NodeInfoLister,
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Feb 26 19:07:19 UTC 2024
    - 3.3K bytes
    - Viewed (0)
  2. pkg/scheduler/framework/plugins/defaultpreemption/default_preemption_test.go

    			},
    			wantResult: framework.NewPostFilterResultWithNominatedNode(""),
    			wantStatus: framework.NewStatus(framework.Unschedulable, "preemption: 0/1 nodes are available: 1 No preemption victims found for incoming pod."),
    		},
    		{
    			name: "preemption should respect filteredNodesStatuses",
    			pod:  st.MakePod().Name("p").UID("p").Namespace(v1.NamespaceDefault).Priority(highPriority).Obj(),
    			pods: []*v1.Pod{
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri May 31 15:52:16 UTC 2024
    - 82.8K bytes
    - Viewed (0)
  3. src/runtime/preempt_wasm.s

    // Code generated by mkpreempt.go; DO NOT EDIT.
    
    #include "go_asm.h"
    #include "textflag.h"
    
    TEXT ·asyncPreempt(SB),NOSPLIT|NOFRAME,$0-0
    	// No async preemption on wasm
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri May 21 21:52:38 UTC 2021
    - 176 bytes
    - Viewed (0)
  4. src/cmd/cgo/internal/testcarchive/testdata/main8.c

    // Copyright 2021 The Go Authors. All rights reserved.
    // Use of this source code is governed by a BSD-style
    // license that can be found in the LICENSE file.
    
    // Test preemption.
    
    #include <stdlib.h>
    
    #include "libgo8.h"
    
    int main() {
    	GoFunction8();
    
    	// That should have exited the program.
    	abort();
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri May 12 11:59:56 UTC 2023
    - 306 bytes
    - Viewed (0)
  5. src/runtime/debug_test.go

    	// caution to prevent #49370 from happening).
    	// TODO(mknyszek): This extra GC cycle is likely unnecessary
    	// because preemption (which may happen during the sweep phase)
    	// isn't much of an issue anymore thanks to asynchronous preemption.
    	// The biggest risk is having a write barrier in the debug call
    	// injection test code fire, because it runs in a signal handler
    	// and may not have a P.
    	//
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri Sep 08 15:08:04 UTC 2023
    - 8K bytes
    - Viewed (0)
  6. src/runtime/proc_test.go

    	<-done
    	<-done
    }
    
    // The function is used to test preemption at split stack checks.
    // Declaring a var avoids inlining at the call site.
    var preempt = func() int {
    	var a [128]int
    	sum := 0
    	for _, v := range a {
    		sum += v
    	}
    	return sum
    }
    
    func TestPreemption(t *testing.T) {
    	if runtime.GOARCH == "wasm" {
    		t.Skip("no preemption on wasm yet")
    	}
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed Jun 14 00:03:57 UTC 2023
    - 25.8K bytes
    - Viewed (0)
  7. src/runtime/lock_wasip1.go

    // Use of this source code is governed by a BSD-style
    // license that can be found in the LICENSE file.
    
    //go:build wasip1
    
    package runtime
    
    // wasm has no support for threads yet. There is no preemption.
    // See proposal: https://github.com/WebAssembly/threads
    // Waiting for a mutex or timeout is implemented as a busy loop
    // while allowing other goroutines to run.
    
    const (
    	mutex_unlocked = 0
    	mutex_locked   = 1
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue Nov 21 21:02:20 UTC 2023
    - 2K bytes
    - Viewed (0)
  8. src/runtime/testdata/testprog/preempt.go

    	"runtime/debug"
    	"sync/atomic"
    )
    
    func init() {
    	register("AsyncPreempt", AsyncPreempt)
    }
    
    func AsyncPreempt() {
    	// Run with just 1 GOMAXPROCS so the runtime is required to
    	// use scheduler preemption.
    	runtime.GOMAXPROCS(1)
    	// Disable GC so we have complete control of what we're testing.
    	debug.SetGCPercent(-1)
    	// Out of an abundance of caution, also make sure that there are
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue Dec 07 17:46:04 UTC 2021
    - 1.6K bytes
    - Viewed (0)
  9. src/runtime/mwbbuf.go

    //	p := buf.get2()
    //	p[0], p[1] = old, new
    //	... actual memory write ...
    //
    // The caller must ensure there are no preemption points during the
    // above sequence. There must be no preemption points while buf is in
    // use because it is a per-P resource. There must be no preemption
    // points between the buffer put and the write to memory because this
    // could allow a GC phase change, which could result in missed write
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon Mar 25 19:53:03 UTC 2024
    - 8.1K bytes
    - Viewed (0)
  10. src/runtime/signal_unix.go

    			ctxt.pushCall(abi.FuncPCABI0(asyncPreempt), newpc)
    		}
    	}
    
    	// Acknowledge the preemption.
    	gp.m.preemptGen.Add(1)
    	gp.m.signalPending.Store(0)
    
    	if GOOS == "darwin" || GOOS == "ios" {
    		pendingPreemptSignals.Add(-1)
    	}
    }
    
    const preemptMSupported = true
    
    // preemptM sends a preemption request to mp. This request may be
    // handled asynchronously and may be coalesced with other requests to
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri May 10 16:04:54 UTC 2024
    - 45K bytes
    - Viewed (0)
Back to top