- Sort Score
- Result 10 results
- Languages All
Results 1 - 5 of 5 for ContendedAction (0.28 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) -
platforms/core-execution/persistent-cache/src/main/java/org/gradle/cache/internal/LockOnDemandCrossProcessCacheAccess.java
this.stateLock = stateLock; this.initAction = initAction; this.onOpen = onOpen; this.onClose = onClose; unlocker = new UnlockAction(); whenContended = new ContendedAction(); } @Override public void open() { // Don't need to do anything } @Override public void close() { stateLock.lock(); try {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Apr 16 15:49:51 UTC 2024 - 6.7K bytes - Viewed (0) -
testing/architecture-test/src/changes/archunit-store/internal-api-nullability.txt
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Jun 11 09:51:15 UTC 2024 - 967.9K bytes - Viewed (0)