- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 2,986 for held (0.35 sec)
-
platforms/core-execution/persistent-cache/src/main/java/org/gradle/cache/FileAccess.java
* @throws FileIntegrityViolationException If the integrity of the file cannot be guaranteed (i.e. {@link #writeFile(Runnable)} has never been called) * @throws InsufficientLockModeException If the held lock is not at least a shared lock (e.g. LockMode.NONE) */ <T> T readFile(Callable<? extends T> action) throws LockTimeoutException, FileIntegrityViolationException, InsufficientLockModeException; /**
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Apr 16 15:49:50 UTC 2024 - 3.6K bytes - Viewed (0) -
src/runtime/mklockrank.go
// the syntax. // // "a < b" means a must be acquired before b if both are held // (or, if b is held, a cannot be acquired). // // "NONE < a" means no locks may be held when a is acquired. // // If a lock is not given a rank, then it is assumed to be a leaf // lock, which means no other lock can be acquired while it is held. // Therefore, leaf locks do not need to be given an explicit rank. //
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 08 17:47:01 UTC 2024 - 9.1K bytes - Viewed (0) -
guava-tests/benchmark/com/google/common/cache/ChainBenchmark.java
for (int i = 0; i < length; i++) { Object key = new Object(); // TODO(b/145386688): This access should be guarded by 'this.segment', which is not currently // held chain = segment.newEntry(key, cache.hash(key), chain); if (i == 0) { head = chain; } } } @SuppressWarnings("GuardedBy") @Benchmark int time(int reps) { int dummy = 0; for (int i = 0; i < reps; i++) {
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Mon Apr 17 15:19:38 UTC 2023 - 2.1K bytes - Viewed (0) -
internal/dsync/dsync-server_test.go
defer l.mutex.Unlock() var locksHeld int64 if locksHeld, reply = l.lockMap[args.Resources[0]]; !reply { // No lock is held on the given name return false, fmt.Errorf("RUnlock attempted on an unlocked entity: %s", args.Resources[0]) } if reply = locksHeld != WriteLock; !reply { // A write-lock is held, cannot release a read lock return false, fmt.Errorf("RUnlock attempted on a write locked entity: %s", args.Resources[0]) }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Jan 23 16:46:37 UTC 2023 - 8.3K bytes - Viewed (0) -
platforms/core-execution/persistent-cache/src/main/java/org/gradle/cache/FileLockManager.java
import java.util.function.Consumer; @ServiceScope(Scope.Global.class) public interface FileLockManager { /** * Creates a lock for the given file with the given mode. Acquires a lock with the given mode, which is held until the lock is * released by calling {@link FileLock#close()}. This method blocks until the lock can be acquired. * * @param target The file to be locked. * @param options The lock options.
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Apr 16 15:49:51 UTC 2024 - 5.1K bytes - Viewed (0) -
src/runtime/mpagecache.go
} // flush empties out unallocated free pages in the given cache // into s. Then, it clears the cache, such that empty returns // true. // // p.mheapLock must be held. // // Must run on the system stack because p.mheapLock must be held. // //go:systemstack func (c *pageCache) flush(p *pageAlloc) { assertLockHeld(p.mheapLock) if c.empty() { return } ci := chunkIndex(c.base)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Apr 19 14:30:00 UTC 2023 - 5.6K bytes - Viewed (0) -
platforms/core-runtime/build-operations/src/main/java/org/gradle/internal/operations/notify/BuildOperationNotificationListener.java
* corresponding started event has returned. * * Implementations may retain the notification values beyond the method that passed them. * Started notifications maybe held until a corresponding finished notification, and slightly after. * Finished notifications maybe held for a short time after the return of the finished signal for * off thread processing. * * Implementations must not error from either signal.
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Oct 24 14:19:43 UTC 2023 - 1.7K bytes - Viewed (0) -
platforms/core-runtime/base-services/src/test/groovy/org/gradle/internal/work/DefaultWorkerLeaseServiceProjectLockTest.groovy
boolean lockIsHeld(final ResourceLock resourceLock) { MutableBoolean held = new MutableBoolean() coordinationService.withStateLock(new InternalTransformer<ResourceLockState.Disposition, ResourceLockState>() { @Override ResourceLockState.Disposition transform(ResourceLockState resourceLockState) { held.set(resourceLock.locked && resourceLock.isLockedByCurrentThread())
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Apr 05 16:29:26 UTC 2024 - 25.6K bytes - Viewed (0) -
pkg/util/async/bounded_frequency_runner.go
select { case bfr.retry <- struct{}{}: default: } } // assumes the lock is not held func (bfr *BoundedFrequencyRunner) stop() { bfr.mu.Lock() defer bfr.mu.Unlock() bfr.limiter.Stop() bfr.timer.Stop() } // assumes the lock is not held func (bfr *BoundedFrequencyRunner) doRetry() { bfr.mu.Lock() defer bfr.mu.Unlock() bfr.retryMu.Lock()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Nov 15 09:36:26 UTC 2022 - 9.4K bytes - Viewed (0) -
src/runtime/rwmutex.go
// // Semantic ranking is represented by acquiring readRank during read lock and // writeRank during write lock. // // wLock is held for the duration of a write lock, so it uses writeRank // directly, both for semantic and internal ranking. rLock is only held // temporarily inside the rlock/lock methods, so it uses readRankInternal to // represent internal ranking. Semantic ranking is represented by a separate
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Apr 22 14:29:04 UTC 2024 - 5K bytes - Viewed (0)