Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 25 for lockMode (0.14 sec)

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

            try {
                return lock.readFile(action);
            } finally {
                lock.close();
            }
        }
    
        @Override
        public void updateFile(Runnable action) throws LockTimeoutException, FileIntegrityViolationException {
            FileLock lock = manager.lock(targetFile, mode(FileLockManager.LockMode.Exclusive), displayName);
            try {
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Tue Apr 16 15:49:50 UTC 2024
    - 2.3K bytes
    - Viewed (0)
  2. platforms/core-execution/persistent-cache/src/test/groovy/org/gradle/cache/internal/DefaultFileLockManagerContentionTest.groovy

                signal.trigger()
            }
    
            where:
            lockMode << [Exclusive, Shared]
        }
    
        def "cannot acquire lock with mode #lockMode while another lock manager in same process is holding shared lock"() {
            given:
            def file = tmpDir.file("lock-file.bin")
            createLock(Shared, file)
    
            when:
            createLock(lockMode, file, manager2)
    
            then:
            thrown(LockTimeoutException)
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Tue Apr 16 15:49:51 UTC 2024
    - 5.2K bytes
    - Viewed (0)
  3. platforms/core-execution/persistent-cache/src/test/groovy/org/gradle/cache/internal/FixedSharedModeCrossProcessCacheAccessTest.groovy

        def initAction = Mock(CacheInitializationAction)
        def onOpenAction = Mock(Consumer)
        def onCloseAction = Mock(Consumer)
        def lockOptions = DefaultLockOptions.mode(FileLockManager.LockMode.Shared)
        def cacheAccess = new FixedSharedModeCrossProcessCacheAccess("<cache>", file, lockOptions, lockManager, initAction, onOpenAction, onCloseAction)
    
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Tue Apr 16 15:49:51 UTC 2024
    - 5.5K bytes
    - Viewed (0)
  4. platforms/core-execution/persistent-cache/src/test/groovy/org/gradle/cache/internal/DefaultPersistentDirectoryCacheTest.groovy

            expect:
            emptyDir.assertDoesNotExist()
    
            when:
            def cache = new DefaultPersistentDirectoryCache(emptyDir, "<display-name>", properties, mode(FileLockManager.LockMode.Shared), initializationAction, cacheCleanup, lockManager, Mock(ExecutorFactory), buildOperationRunner)
            try {
                cache.open()
            } finally {
                cache.close()
            }
    
            then:
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Tue May 14 16:40:49 UTC 2024
    - 9.3K bytes
    - Viewed (0)
  5. platforms/core-execution/persistent-cache/src/main/java/org/gradle/cache/CacheBuilder.java

         * </p>
         * <ul>
         *     <li>Using {@link org.gradle.cache.FileLockManager.LockMode#Exclusive} will lock the cache on open() in the exclusive mode and keep it locked until {@link PersistentCache#close()} is called.</li>
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Tue Apr 16 15:49:51 UTC 2024
    - 3.1K bytes
    - Viewed (0)
  6. platforms/core-execution/persistent-cache/src/main/java/org/gradle/cache/internal/DefaultCacheBuilder.java

        private Consumer<? super PersistentCache> initializer;
        private CacheCleanupStrategy cacheCleanupStrategy = CacheCleanupStrategy.NO_CLEANUP;
        private LockOptions lockOptions = mode(FileLockManager.LockMode.Shared);
        private String displayName;
    
        public DefaultCacheBuilder(CacheFactory factory, File baseDir) {
            this.factory = factory;
            this.baseDir = baseDir;
        }
    
        @Override
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Thu May 09 19:10:33 UTC 2024
    - 2.6K bytes
    - Viewed (0)
  7. platforms/core-execution/persistent-cache/src/test/groovy/org/gradle/cache/internal/OnDemandFileAccessTest.groovy

     */
    package org.gradle.cache.internal
    
    import org.gradle.cache.FileAccess
    import org.gradle.cache.FileLock
    import org.gradle.cache.FileLockManager
    import org.gradle.cache.FileLockManager.LockMode
    import org.gradle.test.fixtures.file.TestNameTestDirectoryProvider
    import org.junit.Rule
    import spock.lang.Specification
    
    import java.util.function.Supplier
    
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Tue Apr 16 15:49:50 UTC 2024
    - 3.3K bytes
    - Viewed (0)
  8. platforms/core-execution/persistent-cache/src/main/java/org/gradle/cache/FileLockManager.java

        /**
         * These modes can be used either with {@link FileLockManager} or when creating {@link PersistentCache} via {@link CacheBuilder#withInitialLockMode(LockMode)}
         */
        enum LockMode {
    
            /**
             * On demand, single writer, no readers (on demand exclusive mode).
             * <br><br>
             *
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Tue Apr 16 15:49:51 UTC 2024
    - 5.1K bytes
    - Viewed (0)
  9. platforms/core-execution/persistent-cache/src/test/groovy/org/gradle/cache/internal/DefaultCacheBuilderTest.groovy

    import spock.lang.Specification
    
    import java.util.function.Consumer
    
    import static org.gradle.cache.CacheCleanupStrategy.NO_CLEANUP
    import static org.gradle.cache.FileLockManager.LockMode.OnDemand
    import static org.gradle.cache.FileLockManager.LockMode.Shared
    import static org.gradle.cache.internal.filelock.DefaultLockOptions.mode
    
    class DefaultCacheBuilderTest extends Specification {
        @Rule
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Tue May 14 16:40:49 UTC 2024
    - 2.9K bytes
    - Viewed (0)
  10. platforms/core-execution/persistent-cache/src/main/java/org/gradle/cache/FileAccess.java

         * @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)
Back to top