Search Options

Results per page
Sort
Preferred Languages
Advance

Results 51 - 60 of 360 for rlocked (4.3 sec)

  1. src/cmd/vendor/golang.org/x/sync/semaphore/semaphore.go

    		if next == nil {
    			break // No more waiters blocked.
    		}
    
    		w := next.Value.(waiter)
    		if s.size-s.cur < w.n {
    			// Not enough tokens for the next waiter.  We could keep going (to try to
    			// find a waiter with a smaller request), but under load that could cause
    			// starvation for large requests; instead, we leave all remaining waiters
    			// blocked.
    			//
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri May 03 02:38:00 UTC 2024
    - 4.3K bytes
    - Viewed (0)
  2. src/runtime/tracecpu.go

    	// we need to acquire it and read the generation.
    	locked := false
    	if mp.trace.seqlock.Load()%2 == 0 {
    		mp.trace.seqlock.Add(1)
    		locked = true
    	}
    	gen := trace.gen.Load()
    	if gen == 0 {
    		// Tracing is disabled, as it turns out. Release the seqlock if necessary
    		// and exit.
    		if locked {
    			mp.trace.seqlock.Add(1)
    		}
    		return
    	}
    
    	now := traceClockNow()
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon Apr 15 17:03:35 UTC 2024
    - 8.7K bytes
    - Viewed (0)
  3. src/runtime/netpoll.go

    	pd := pollcache.alloc()
    	lock(&pd.lock)
    	wg := pd.wg.Load()
    	if wg != pdNil && wg != pdReady {
    		throw("runtime: blocked write on free polldesc")
    	}
    	rg := pd.rg.Load()
    	if rg != pdNil && rg != pdReady {
    		throw("runtime: blocked read on free polldesc")
    	}
    	pd.fd = fd
    	if pd.fdseq.Load() == 0 {
    		// The value 0 is special in setEventErr, so don't use it.
    		pd.fdseq.Store(1)
    	}
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed May 15 19:57:43 UTC 2024
    - 20.7K bytes
    - Viewed (0)
  4. src/runtime/debug/garbage.go

    //
    // The limit controls the number of operating system threads, not the number
    // of goroutines. A Go program creates a new thread only when a goroutine
    // is ready to run but all the existing threads are blocked in system calls, cgo calls,
    // or are locked to other goroutines due to use of runtime.LockOSThread.
    //
    // SetMaxThreads is useful mainly for limiting the damage done by
    // programs that create an unbounded number of threads. The idea is
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu May 23 01:00:11 UTC 2024
    - 9.9K bytes
    - Viewed (0)
  5. testing/internal-integ-testing/src/main/groovy/org/gradle/test/fixtures/server/http/TrackingHttpHandler.java

         */
        WaitPrecondition getWaitPrecondition();
    
        /**
         * Releases any blocked requests, in preparation for shutdown.
         */
        void cancelBlockedRequests();
    
        /**
         * Asserts that this handler has been completed successfully.
         */
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Thu Apr 04 07:21:38 UTC 2024
    - 1.9K bytes
    - Viewed (0)
  6. src/crypto/rand/rand_plan9.go

    	seeded  sync.Once
    	seedErr error
    	key     [32]byte
    }
    
    func (r *reader) Read(b []byte) (n int, err error) {
    	r.seeded.Do(func() {
    		t := time.AfterFunc(time.Minute, func() {
    			println("crypto/rand: blocked for 60 seconds waiting to read random data from the kernel")
    		})
    		defer t.Stop()
    		entropy, err := os.Open(randomDevice)
    		if err != nil {
    			r.seedErr = err
    			return
    		}
    		defer entropy.Close()
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon May 13 18:57:38 UTC 2024
    - 1.8K bytes
    - Viewed (0)
  7. src/runtime/os_netbsd.go

    // baroque to remove a signal stack here only to add one in minit, but
    // it's a simple change that keeps NetBSD working like other OS's.
    // At this point all signals are blocked, so there is no race.
    //
    //go:nosplit
    func netbsdMstart0() {
    	st := stackt{ss_flags: _SS_DISABLE}
    	sigaltstack(&st, nil)
    	mstart0()
    }
    
    func osinit() {
    	ncpu = getncpu()
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon Mar 25 19:53:03 UTC 2024
    - 10.1K bytes
    - Viewed (0)
  8. src/runtime/traceruntime.go

    	tl.eventWriter(traceGoRunning, traceProcRunning).commit(traceEvGCMarkAssistEnd)
    }
    
    // GoCreate emits a GoCreate event.
    func (tl traceLocker) GoCreate(newg *g, pc uintptr, blocked bool) {
    	newg.trace.setStatusTraced(tl.gen)
    	ev := traceEvGoCreate
    	if blocked {
    		ev = traceEvGoCreateBlocked
    	}
    	tl.eventWriter(traceGoRunning, traceProcRunning).commit(ev, traceArg(newg.goid), tl.startPC(pc), tl.stack(2))
    }
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed May 22 22:31:00 UTC 2024
    - 25.7K bytes
    - Viewed (0)
  9. platforms/software/dependency-management/src/integTest/groovy/org/gradle/integtests/resolve/locking/AbstractLockingIntegrationTest.groovy

                    constraint("org:foo:$constraintVersion", "org:foo:1.0") {
                        byConstraint("dependency was locked to version '1.0'$extraReason")
                    }
                }
            }
    
            where:
            unique << [true, false]
        }
    
        def 'does not write-locks for not locked configuration'() {
            mavenRepo.module('org', 'foo', '1.0').publish()
    
            buildFile << """
    repositories {
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Tue Mar 05 02:50:41 UTC 2024
    - 19.2K bytes
    - Viewed (0)
  10. platforms/software/dependency-management/src/main/java/org/gradle/internal/locking/MissingLockStateException.java

        }
        public MissingLockStateException(DisplayName displayName) {
            super("Locking strict mode: " + displayName.getCapitalizedDisplayName() + " is locked but does not have lock state.");
        }
    
        @Override
        public List<String> getResolutions() {
            return RESOLUTIONS;
        }
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Tue Mar 05 02:50:41 UTC 2024
    - 1.7K bytes
    - Viewed (0)
Back to top