- Sort Score
- Result 10 results
- Languages All
Results 1 - 3 of 3 for ContendedAction (0.27 sec)
-
platforms/core-execution/persistent-cache/src/test/groovy/org/gradle/cache/internal/LockOnDemandCrossProcessCacheAccessTest.groovy
def lock = Mock(FileLock) def signal = Mock(FileLockReleasedSignal) Consumer contendedAction given: 1 * lockManager.lock(file, _, _, _, _) >> { File target, LockOptions options, String targetDisplayName, String operationDisplayName, Consumer<FileLockReleasedSignal> whenContended -> contendedAction = whenContended return lock } cacheAccess.withFileLock(action)
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Apr 16 15:49:51 UTC 2024 - 21.8K bytes - Viewed (0) -
platforms/core-execution/persistent-cache/src/main/java/org/gradle/cache/internal/locklistener/DefaultFileLockContentionHandler.java
try { ContendedAction contendedAction = contendedActions.get(payload.getLockId()); if (contendedAction == null) { acceptConfirmationAsLockRequester(payload, packet.getPort()); } else { contendedAction.addRequester(packet.getSocketAddress());
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Apr 16 15:49:51 UTC 2024 - 12.4K bytes - Viewed (0) -
platforms/core-execution/persistent-cache/src/test/groovy/org/gradle/cache/internal/DefaultExclusiveCacheAccessCoordinatorTest.groovy
Consumer contendedAction when: access.open() access.useCache(action) then: 1 * lockManager.lock(lockFile, mode(Exclusive), "<display-name>", "", _) >> { File target, LockOptions options, String targetDisplayName, String operationDisplayName, Consumer<FileLockReleasedSignal> whenContended -> contendedAction = whenContended; return lock }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Apr 16 15:49:51 UTC 2024 - 24K bytes - Viewed (0)