Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 21 for preemption (0.13 sec)

  1. src/sync/atomic/value.go

    	}
    	vp := (*efaceWords)(unsafe.Pointer(v))
    	vlp := (*efaceWords)(unsafe.Pointer(&val))
    	for {
    		typ := LoadPointer(&vp.typ)
    		if typ == nil {
    			// Attempt to start first store.
    			// Disable preemption so that other goroutines can use
    			// active spin wait to wait for completion.
    			runtime_procPin()
    			if !CompareAndSwapPointer(&vp.typ, nil, unsafe.Pointer(&firstStoreInProgress)) {
    				runtime_procUnpin()
    				continue
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon Feb 26 20:48:55 UTC 2024
    - 5.9K bytes
    - Viewed (0)
  2. src/runtime/debug.go

    func debug_modinfo() string {
    	return modinfo
    }
    
    // mayMoreStackPreempt is a maymorestack hook that forces a preemption
    // at every possible cooperative preemption point.
    //
    // This is valuable to apply to the runtime, which can be sensitive to
    // preemption points. To apply this to all preemption points in the
    // runtime and runtime-like code, use the following in bash or zsh:
    //
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Sat May 11 20:38:24 UTC 2024
    - 4.2K bytes
    - Viewed (0)
  3. src/internal/abi/symtab.go

    )
    
    // Special values for the PCDATA_UnsafePoint table.
    const (
    	UnsafePointSafe   = -1 // Safe for async preemption
    	UnsafePointUnsafe = -2 // Unsafe for async preemption
    
    	// UnsafePointRestart1(2) apply on a sequence of instructions, within
    	// which if an async preemption happens, we should back off the PC
    	// to the start of the sequence when resuming.
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri Feb 16 14:25:22 UTC 2024
    - 3.6K bytes
    - Viewed (0)
  4. 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)
  5. 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)
  6. src/internal/runtime/exithook/hooks.go

    // Package exithook provides limited support for on-exit cleanup.
    //
    // CAREFUL! The expectation is that Add should only be called
    // from a safe context (e.g. not an error/panic path or signal
    // handler, preemption enabled, allocation allowed, write barriers
    // allowed, etc), and that the exit function F will be invoked under
    // similar circumstances. That is the say, we are expecting that F
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri May 24 16:41:13 UTC 2024
    - 2.2K bytes
    - Viewed (0)
  7. manifests/charts/gateway/values.yaml

      # Configure this to a higher priority class in order to make sure your Istio gateway pods
      # will not be killed because of low priority class.
      # Refer to https://kubernetes.io/docs/concepts/configuration/pod-priority-preemption/#priorityclass
      # for more detail.
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Fri Jun 07 16:51:35 UTC 2024
    - 4.4K bytes
    - Viewed (0)
  8. src/sync/pool.go

    		}
    	}
    
    	// Mark the victim cache as empty for future gets don't bother
    	// with it.
    	atomic.StoreUintptr(&p.victimSize, 0)
    
    	return nil
    }
    
    // pin pins the current goroutine to P, disables preemption and
    // returns poolLocal pool for the P and the P's id.
    // Caller must call runtime_procUnpin() when done with the pool.
    func (p *Pool) pin() (*poolLocal, int) {
    	// Check whether p is nil to get a panic.
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri Jun 07 21:14:51 UTC 2024
    - 9.4K bytes
    - Viewed (1)
  9. src/runtime/lock_futex.go

    	}
    
    	gp := getg()
    	gp.m.mLockProfile.recordUnlock(l)
    	gp.m.locks--
    	if gp.m.locks < 0 {
    		throw("runtimeĀ·unlock: lock count")
    	}
    	if gp.m.locks == 0 && gp.preempt { // restore the preemption request in case we've cleared it in newstack
    		gp.stackguard0 = stackPreempt
    	}
    }
    
    // One-time notifications.
    func noteclear(n *note) {
    	n.key = 0
    }
    
    func notewakeup(n *note) {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu May 30 17:57:34 UTC 2024
    - 5.4K bytes
    - Viewed (0)
  10. src/runtime/testdata/testprog/lockosthread.go

    			for time.Now().Before(start) {
    			}
    
    			// Add work to the local runq to trigger early startm
    			// in handoffp.
    			go func() {}()
    
    			runtime.LockOSThread()
    			runtime.Gosched() // add a preemption point.
    			wg.Done()
    		}()
    	}
    
    	wg.Wait()
    	// If both LockOSThreads completed then we did not hit the race.
    	println("OK")
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu Mar 21 20:00:09 UTC 2024
    - 6.6K bytes
    - Viewed (0)
Back to top