Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 5 of 5 for ContendedAction (0.23 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. testing/architecture-test/src/changes/archunit-store/internal-api-nullability.txt

    Class <org.gradle.cache.internal.locklistener.DefaultFileLockContentionHandler$ContendedAction> is not annotated (directly or via its package) with @org.gradle.api.NonNullApi in (DefaultFileLockContentionHandler.java:0)
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Tue Jun 11 09:51:15 UTC 2024
    - 967.9K bytes
    - Viewed (0)
Back to top