Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 983 for retake (0.15 sec)

  1. src/runtime/testdata/testprogcgo/pprof_callback.go

    //
    // This is a regression test for issue 50936.
    
    /*
    #include <unistd.h>
    
    void goCallbackPprof();
    
    static void callGo() {
    	// Spent >20us in C so this thread is eligible for sysmon to retake its
    	// P.
    	usleep(50);
    	goCallbackPprof();
    }
    */
    import "C"
    
    import (
    	"fmt"
    	"os"
    	"runtime"
    	"runtime/pprof"
    	"time"
    )
    
    func init() {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed Jun 08 15:44:05 UTC 2022
    - 1.8K bytes
    - Viewed (0)
  2. src/runtime/proc.go

    				startm(nil, false, false)
    			}
    		}
    		if scavenger.sysmonWake.Load() != 0 {
    			// Kick the scavenger awake if someone requested it.
    			scavenger.wake()
    		}
    		// retake P's blocked in syscalls
    		// and preempt long running G's
    		if retake(now) != 0 {
    			idle = 0
    		} else {
    			idle++
    		}
    		// check if we need to force a GC
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed May 29 17:58:53 UTC 2024
    - 207.5K bytes
    - Viewed (0)
  3. src/runtime/traceruntime.go

    	// context of just emitting this event alone. There are two cases. Either we're trying to steal
    	// the P just to get its attention (e.g. STW or sysmon retake) or we're trying to steal a P for
    	// ourselves specifically to keep running. The two contexts look different, but can be summarized
    	// fairly succinctly. In the former, we're a regular running goroutine and proc, if we have either.
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed May 22 22:31:00 UTC 2024
    - 25.7K bytes
    - Viewed (0)
  4. src/runtime/time.go

    			return
    		}
    	}
    }
    
    // take moves any timers from src into ts
    // and then clears the timer state from src,
    // because src is being destroyed.
    // The caller must not have locked either timers.
    // For now this is only called when the world is stopped.
    func (ts *timers) take(src *timers) {
    	ts.trace("take")
    	assertWorldStopped()
    	if len(src.heap) > 0 {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri Mar 29 14:36:24 UTC 2024
    - 37.5K bytes
    - Viewed (0)
  5. src/runtime/runtime2.go

    	// may be stolen by another M. This is similar to _Pidle but
    	// uses lightweight transitions and maintains M affinity.
    	//
    	// Leaving _Psyscall must be done with a CAS, either to steal
    	// or retake the P. Note that there's an ABA hazard: even if
    	// an M successfully CASes its original P back to _Prunning
    	// after a syscall, it must understand the P may have been
    	// used by another M in the interim.
    	_Psyscall
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu May 30 17:57:37 UTC 2024
    - 47.9K bytes
    - Viewed (0)
  6. src/runtime/mgcmark.go

    	// someone is calling forEachP.
    	//
    	// TODO(mknyszek): Consider always checking gp.preempt instead
    	// of having the preempt flag, and making an exception for certain
    	// mark workers in retake. That might be simpler than trying to
    	// enumerate all the reasons why we might want to preempt, even
    	// if we're supposed to be mostly non-preemptible.
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu Apr 18 21:25:11 UTC 2024
    - 52.5K bytes
    - Viewed (0)
  7. src/cmd/cgo/internal/test/test.go

    	// frequently resize its SyncClocks.
    	for i := 0; i < 100; i++ {
    		go func() {
    			for ctx.Err() == nil {
    				// Sleep in C for long enough that it is likely that the runtime
    				// will retake this goroutine's currently wired P.
    				C.usleep(1000 /* 1ms */)
    				runtime.Gosched() // avoid starvation (see #28701)
    			}
    		}()
    		go func() {
    			// Trigger lots of synchronization and memory reads/writes to
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon May 20 15:50:06 UTC 2024
    - 48.5K bytes
    - Viewed (0)
  8. test/rename.go

    Emmanuel Odeke <******@****.***> 1460323946 -0700
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon May 02 13:43:18 UTC 2016
    - 1.5K bytes
    - Viewed (0)
  9. src/cmd/internal/obj/s390x/rotate.go

    // 0xf0_00_00_00_00_00_00_0f | 60    | 3
    //
    // The Amount value represents the amount to rotate the
    // input left by. Note that this rotation is performed
    // before the masked region is used.
    type RotateParams struct {
    	Start  uint8 // big-endian start bit index [0..63]
    	End    uint8 // big-endian end bit index [0..63]
    	Amount uint8 // amount to rotate left
    }
    
    // NewRotateParams creates a set of parameters representing a
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon Dec 21 19:19:04 UTC 2020
    - 3.6K bytes
    - Viewed (0)
  10. test/codegen/rotate.go

    	return a
    }
    
    // Issue 18254: rotate after inlining
    func f32(x uint32) uint32 {
    	// amd64:"ROLL\t[$]7"
    	return rot32nc(x, 7)
    }
    
    func doubleRotate(x uint64) uint64 {
    	x = (x << 5) | (x >> 59)
    	// amd64:"ROLQ\t[$]15"
    	// arm64:"ROR\t[$]49"
    	x = (x << 10) | (x >> 54)
    	return x
    }
    
    // --------------------------------------- //
    //    Combined Rotate + Masking operations //
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu Mar 07 14:57:07 UTC 2024
    - 6K bytes
    - Viewed (0)
Back to top