Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 10 for requiresInitialization (0.34 sec)

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

         */
        boolean requiresInitialization(FileLock fileLock);
    
        /**
         * Executes the action to initialize the cache. Called only if {@link #requiresInitialization(FileLock)} returns true, holding an exclusive lock.
         * The lock is not released between calling {@link #requiresInitialization(FileLock)} and this method.
         */
        void initialize(FileLock fileLock);
    
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Fri Sep 22 09:08:47 UTC 2023
    - 1.5K bytes
    - Viewed (0)
  2. platforms/core-execution/persistent-cache/src/test/groovy/org/gradle/cache/internal/FixedSharedModeCrossProcessCacheAccessTest.groovy

            then:
            1 * initAction.requiresInitialization(initialLock) >> true
            1 * initialLock.close()
    
            then:
            1 * lockManager.lock(file, {it.mode == FileLockManager.LockMode.Exclusive }, "<cache>") >> exclusiveLock
            1 * initAction.requiresInitialization(exclusiveLock) >> true
            1 * exclusiveLock.writeFile(_) >> { Runnable r -> r.run() }
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Tue Apr 16 15:49:51 UTC 2024
    - 5.5K bytes
    - Viewed (0)
  3. platforms/core-execution/persistent-cache/src/test/groovy/org/gradle/cache/internal/DefaultExclusiveCacheAccessCoordinatorTest.groovy

            1 * lockManager.lock(lockFile, mode(Shared), "<display-name>") >> lock
            1 * initializationAction.requiresInitialization(lock) >> true
            1 * lock.close()
    
            then:
            1 * lockManager.lock(lockFile, mode(Exclusive), "<display-name>") >> exclusiveLock
            1 * initializationAction.requiresInitialization(exclusiveLock) >> true
            1 * exclusiveLock.writeFile(_) >> { Runnable r -> r.run() }
    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/test/groovy/org/gradle/cache/internal/FixedExclusiveModeCrossProcessCacheAccessTest.groovy

            def lock = Mock(FileLock)
    
            when:
            cacheAccess.open()
    
            then:
            1 * lockManager.lock(file, _, _, "", _) >> lock
    
            then:
            1 * initAction.requiresInitialization(lock) >> false
    
            then:
            1 * onOpenAction.accept(lock)
            0 * _
        }
    
        def "acquires lock then initializes cache and runs handler action on open"() {
            def lock = Mock(FileLock)
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Tue Apr 16 15:49:51 UTC 2024
    - 3.3K bytes
    - Viewed (0)
  5. platforms/core-execution/persistent-cache/src/integTest/groovy/org/gradle/cache/internal/FixedSharedModeCrossProcessCacheAccessIntegrationTest.groovy

         * of failing, it should recheck if initialization was performed by calling {@link CacheInitializationAction#requiresInitialization(org.gradle.cache.FileLock)}
         * again. This is simulated here by an requiresInitialization() implementation that returns false after a number of calls to itself.
         */
        private simulateAnotherInitializationOfAlreadyInitializedWorkerClasspathCache() {
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Wed Jan 10 15:52:52 UTC 2024
    - 4.3K bytes
    - Viewed (0)
  6. platforms/core-execution/persistent-cache/src/main/java/org/gradle/cache/internal/FixedSharedModeCrossProcessCacheAccess.java

            }
            FileLock fileLock = lockManager.lock(lockTarget, lockOptions, cacheDisplayName);
            try {
                boolean rebuild = initializationAction.requiresInitialization(fileLock);
                if (rebuild) {
                    Exception latestException = null;
                    for (int tries = 0; rebuild && tries < 3; tries++) {
                        fileLock.close();
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Tue Apr 16 15:49:51 UTC 2024
    - 5.7K bytes
    - Viewed (0)
  7. platforms/core-execution/persistent-cache/src/main/java/org/gradle/cache/internal/FixedExclusiveModeCrossProcessCacheAccess.java

            }
            final FileLock fileLock = lockManager.lock(lockTarget, lockOptions, cacheDisplayName, "", unused -> {});
            try {
                boolean rebuild = initializationAction.requiresInitialization(fileLock);
                if (rebuild) {
                    fileLock.writeFile(() -> initializationAction.initialize(fileLock));
                }
                onOpenAction.accept(fileLock);
            } catch (Exception e) {
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Wed May 01 12:21:15 UTC 2024
    - 3.6K bytes
    - Viewed (0)
  8. platforms/core-execution/persistent-cache/src/test/groovy/org/gradle/cache/internal/LockOnDemandCrossProcessCacheAccessTest.groovy

                    return lock
            }
    
            then:
            1 * initAction.requiresInitialization(lock) >> true
            1 * lock.writeFile(_) >> { Runnable r -> r.run() }
            1 * initAction.initialize(lock)
    
            then:
            1 * action.get() >> { contendedAction.accept(signal) }
    
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Tue Apr 16 15:49:51 UTC 2024
    - 21.8K bytes
    - Viewed (0)
  9. platforms/core-execution/persistent-cache/src/main/java/org/gradle/cache/internal/DefaultPersistentDirectoryCache.java

        }
    
        public Properties getProperties() {
            return properties;
        }
    
        private class Initializer implements CacheInitializationAction {
            @Override
            public boolean requiresInitialization(FileLock lock) {
                if (!lock.getUnlockedCleanly()) {
                    if (lock.getState().canDetectChanges() && !lock.getState().isInInitialState()) {
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Thu May 09 19:20:15 UTC 2024
    - 5.1K bytes
    - Viewed (0)
  10. platforms/core-execution/persistent-cache/src/main/java/org/gradle/cache/internal/LockOnDemandCrossProcessCacheAccess.java

                    }
                    fileLock = lockManager.lock(lockTarget, lockOptions, cacheDisplayName, "", whenContended);
                    try {
                        if (initAction.requiresInitialization(fileLock)) {
                            fileLock.writeFile(() -> initAction.initialize(fileLock));
                        }
                        onOpen.accept(fileLock);
                    } catch (Exception e) {
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Tue Apr 16 15:49:51 UTC 2024
    - 6.7K bytes
    - Viewed (0)
Back to top