Search Options

Results per page
Sort
Preferred Languages
Advance

Results 41 - 50 of 360 for rlocked (2.17 sec)

  1. platforms/core-execution/persistent-cache/src/main/java/org/gradle/cache/CacheBuilder.java

         *     <li>Using {@link org.gradle.cache.FileLockManager.LockMode#Exclusive} will lock the cache on open() in the exclusive mode and keep it locked until {@link PersistentCache#close()} is called.</li>
         *     <li>Using {@link org.gradle.cache.FileLockManager.LockMode#Shared} will lock the cache on open() in the shared mode and keep it locked until {@link PersistentCache#close()} is called.</li>
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Tue Apr 16 15:49:51 UTC 2024
    - 3.1K bytes
    - Viewed (0)
  2. platforms/software/dependency-management/src/main/java/org/gradle/api/internal/artifacts/dsl/dependencies/DependencyLockingProvider.java

         */
        ListProperty<String> getIgnoredDependencies();
    
        /**
         * Confirms that the given lock is not locked.
         * This allows the lock state for the lock to be dropped if it existed before.
         *
         * @param lockId the ID of the lock to confirm is not locked
         */
        void confirmNotLocked(String lockId);
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Tue Mar 05 02:50:41 UTC 2024
    - 3.2K bytes
    - Viewed (0)
  3. src/runtime/sigqueue.go

    // variable. It can be in three states:
    // * sigReceiving means that signal_recv is blocked on sig.Note and there are
    //   no new pending signals.
    // * sigSending means that sig.mask *may* contain new pending signals,
    //   signal_recv can't be blocked in this state.
    // * sigIdle means that there are no new pending signals and signal_recv is not
    //   blocked.
    //
    // Transitions between states are done atomically with CAS.
    //
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon Mar 25 19:53:03 UTC 2024
    - 7.6K bytes
    - Viewed (0)
  4. platforms/software/dependency-management/src/integTest/groovy/org/gradle/integtests/resolve/api/ConfigurationRoleUsageIntegrationTest.groovy

        }
        // endregion Warnings
    
        private void assertUsageLockedFailure(String configurationName, String roleName = null) {
            String suffix = roleName ? "as it was locked upon creation to the role: '$roleName'." : "as it has been locked."
            failure.assertHasCause("Cannot change the allowed usage of configuration ':$configurationName', $suffix")
        }
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Wed Mar 27 01:42:49 UTC 2024
    - 27.5K bytes
    - Viewed (0)
  5. platforms/software/dependency-management/src/test/groovy/org/gradle/internal/locking/NoOpDependencyLockingProviderTest.groovy

    import static java.util.Collections.emptySet
    
    class NoOpDependencyLockingProviderTest extends Specification {
    
        @Subject
        def provider = NoOpDependencyLockingProvider.instance
    
        def 'does not find locked dependencies'() {
            when:
            def result = provider.loadLockState('conf', Describables.of("foo"))
    
            then:
            !result.mustValidateLockState()
        }
    
        def 'does nothing on persist'() {
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Tue Mar 05 02:50:41 UTC 2024
    - 1.3K bytes
    - Viewed (0)
  6. src/cmd/trace/goroutinegen.go

    	}
    	if from == trace.GoNotExist && to == trace.GoRunnable {
    		// Goroutine was created.
    		gs.created(ev.Time(), ev.Goroutine(), ev.Stack())
    	}
    	if from == trace.GoSyscall && to != trace.GoRunning {
    		// Exiting blocked syscall.
    		gs.syscallEnd(ev.Time(), true, ctx)
    		gs.blockedSyscallEnd(ev.Time(), ev.Stack(), ctx)
    	} else if from == trace.GoSyscall {
    		// Check if we're exiting a syscall in a non-blocking way.
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri May 17 18:48:18 UTC 2024
    - 4.6K bytes
    - Viewed (0)
  7. src/runtime/HACKING.md

    Some common patterns that mix atomic and non-atomic access are:
    
    * Read-mostly variables where updates are protected by a lock. Within
      the locked region, reads do not need to be atomic, but the write
      does. Outside the locked region, reads need to be atomic.
    
    * Reads that only happen during STW, where no writes can happen during
      STW, do not need to be atomic.
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon Mar 25 19:53:03 UTC 2024
    - 13.9K bytes
    - Viewed (0)
  8. src/net/net.go

    listed in /etc/resolv.conf, or it can use a cgo-based resolver that calls C
    library routines such as getaddrinfo and getnameinfo.
    
    On Unix the pure Go resolver is preferred over the cgo resolver, because a blocked DNS
    request consumes only a goroutine, while a blocked C call consumes an operating system thread.
    When cgo is available, the cgo-based resolver is used instead under a variety of
    conditions: on systems that do not let programs make direct DNS requests (OS X),
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed May 29 17:58:53 UTC 2024
    - 26.8K bytes
    - Viewed (0)
  9. pkg/kubelet/cm/dra/manager.go

    				}
    				pluginName := resourceHandle.DriverName
    				batches[pluginName] = append(batches[pluginName], claim)
    			}
    
    			return nil
    		})
    		if err != nil {
    			return fmt.Errorf("locked cache operation: %w", err)
    		}
    	}
    
    	// Call NodePrepareResources for all claims in each batch.
    	// If there is any error, processing gets aborted.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri May 03 13:23:29 UTC 2024
    - 19.4K bytes
    - Viewed (0)
  10. staging/src/k8s.io/apiserver/pkg/storage/cacher/cache_watcher_test.go

    	// May sure that the watch will not be blocked on Stop.
    	for i := 0; i < maxRetriesToProduceTheRaceCondition; i++ {
    		w = newCacheWatcher(0, filter, forget, storage.APIObjectVersioner{}, time.Now(), false, schema.GroupResource{Resource: "pods"}, "")
    		go w.Stop()
    		select {
    		case <-done:
    		case <-time.After(time.Second):
    			t.Fatal("stop is blocked when the timer is fired concurrently")
    		}
    	}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 09:20:10 UTC 2024
    - 22.9K bytes
    - Viewed (0)
Back to top