Search Options

Results per page
Sort
Preferred Languages
Advance

Results 31 - 40 of 501 for rlocked (0.32 sec)

  1. src/cmd/trace/gstate.go

    // and orthogonal to syscallEnd; both must be called if the syscall blocked. This sets up an instant
    // to emit a flow event from, indicating explicitly that this goroutine was unblocked by the system.
    func (gs *gState[R]) blockedSyscallEnd(ts trace.Time, stack trace.Stack, ctx *traceContext) {
    	name := "exit blocked syscall"
    	gs.setStartCause(ts, name, trace.SyscallP, stack)
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri May 17 18:48:18 UTC 2024
    - 11.9K bytes
    - Viewed (0)
  2. src/cmd/trace/jsontrace_test.go

    	return parts[1]
    }
    
    // filterBlocked returns an event filter that returns true if the event's
    // "blocked" argument is equal to blocked.
    func filterBlocked(blocked string) eventFilterFn {
    	return func(e *format.Event, _ *format.Data) bool {
    		m, ok := e.Arg.(map[string]any)
    		if !ok {
    			return false
    		}
    		return m["blocked"] == blocked
    	}
    }
    
    // filterStackRootFunc returns an event filter that returns true if the function
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri May 17 18:48:18 UTC 2024
    - 7.8K bytes
    - Viewed (0)
  3. platforms/extensibility/plugin-use/src/main/java/org/gradle/plugin/management/internal/DefaultPluginResolutionStrategy.java

        private final Map<PluginId, String> pluginVersions = new HashMap<>();
        private boolean locked;
    
        public DefaultPluginResolutionStrategy(ListenerManager listenerManager) {
            listenerManager.addListener(new InternalBuildAdapter(){
                @Override
                public void projectsLoaded(Gradle gradle) {
                    locked = true;
                }
            });
        }
    
        @Override
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Mon Dec 11 13:37:56 UTC 2023
    - 2.7K bytes
    - Viewed (0)
  4. platforms/core-runtime/base-services/src/test/groovy/org/gradle/internal/resources/DefaultResourceLockCoordinationServiceTest.groovy

                }
            }
    
            when:
            beforeState.eachWithIndex { boolean locked, int i -> lock[i].lockedState = locked }
            coordinationService.withStateLock(outerAction)
    
            then:
            afterState.eachWithIndex { boolean locked, int i -> assert lock[i].lockedState == locked }
    
            where:
            beforeState                  | afterState
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Thu Apr 11 17:16:10 UTC 2024
    - 15.4K bytes
    - Viewed (0)
  5. src/runtime/debugcall.go

    		// Transfer locked-ness to the new goroutine.
    		// Save lock state to restore later.
    		mp := gp.m
    		if mp != gp.lockedm.ptr() {
    			throw("inconsistent lockedm")
    		}
    		// Save the external lock count and clear it so
    		// that it can't be unlocked from the debug call.
    		// Note: we already locked internally to the thread,
    		// so if we were locked before we're still locked now.
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri Apr 05 20:50:21 UTC 2024
    - 7.1K bytes
    - Viewed (0)
  6. internal/dsync/drwmutex.go

    			g := Granted{index: index}
    			if c == nil {
    				log("dsync: nil locker\n")
    				ch <- g
    				return
    			}
    
    			var locked bool
    			var err error
    			if isReadLock {
    				if locked, err = c.RLock(netLockCtx, args); err != nil {
    					log("dsync: Unable to call RLock failed with %s for %#v at %s\n", err, args, c)
    				}
    			} else {
    				if locked, err = c.Lock(netLockCtx, args); err != nil {
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 19.7K bytes
    - Viewed (0)
  7. platforms/software/dependency-management/src/integTest/groovy/org/gradle/integtests/resolve/locking/MixedDependencyLockingIntegrationTest.groovy

        def lockfileFixture = new LockfileFixture(testDirectory: testDirectory)
    
        def setup() {
            settingsFile << "rootProject.name = 'mixedDepLock'"
        }
    
        def 'can resolve locked and unlocked configurations'() {
            mavenRepo.module('org', 'foo', '1.0').publish()
            mavenRepo.module('org', 'foo', '1.1').publish()
    
            buildFile << """
    repositories {
        maven {
            name 'repo'
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Tue Oct 10 21:10:11 UTC 2023
    - 4.2K bytes
    - Viewed (0)
  8. platforms/software/dependency-management/src/integTest/groovy/org/gradle/integtests/resolve/locking/DependencyLockingStrictModeIntegrationTest.groovy

            fails 'dependencies', '--update-locks', 'org:foo'
    
            then:
            failureHasCause("Locking strict mode: Configuration ':lockedConf' is locked but does not have lock state.")
            lockfileFixture.expectLockStateMissing('unlockedConf')
        }
    
        def 'ignores not locked configurations'() {
            mavenRepo.module('org', 'foo', '1.0').publish()
    
            buildFile << """
    dependencyLocking {
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Tue Mar 05 02:50:41 UTC 2024
    - 3K bytes
    - Viewed (0)
  9. src/internal/trace/testdata/testprog/wait-on-pipe.go

    // Copyright 2023 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.
    
    // Tests a goroutine sitting blocked in a syscall for
    // an entire generation. This is a regression test for
    // #65196.
    
    //go:build ignore
    
    package main
    
    import (
    	"log"
    	"os"
    	"runtime/trace"
    	"syscall"
    	"time"
    )
    
    func main() {
    	// Create a pipe to block on.
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri May 17 18:48:18 UTC 2024
    - 1.6K bytes
    - Viewed (0)
  10. src/cmd/trace/procgen.go

    	if from == trace.GoNotExist && to == trace.GoRunnable {
    		// Goroutine was created.
    		gs.created(ev.Time(), ev.Proc(), ev.Stack())
    	}
    	if from == trace.GoSyscall && to != trace.GoRunning {
    		// Goroutine exited a blocked syscall.
    		gs.blockedSyscallEnd(ev.Time(), ev.Stack(), ctx)
    	}
    
    	// Handle syscalls.
    	if to == trace.GoSyscall && ev.Proc() != trace.NoProc {
    		start := ev.Time()
    		if from == trace.GoUndetermined {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri May 17 18:48:18 UTC 2024
    - 6.1K bytes
    - Viewed (0)
Back to top