- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 12 for lockMode (0.32 sec)
-
platforms/core-execution/persistent-cache/src/test/groovy/org/gradle/cache/internal/AbstractFileLockManagerTest.groovy
when: def lock = createLock(lockMode) then: lock.isLockFile(tmpDir.createFile(testFile.name + ".lock")) cleanup: lock?.close() where: lockMode << [Exclusive, Shared] } def "can lock a directory"() { when: def lock = createLock(lockMode, testDir) then:
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Apr 16 15:49:51 UTC 2024 - 13.6K bytes - Viewed (0) -
platforms/core-execution/persistent-cache/src/main/java/org/gradle/cache/internal/DefaultFileLockManager.java
*/ private LockState lock(LockMode lockMode) throws Throwable { LOGGER.debug("Waiting to acquire {} lock on {}.", lockMode.toString().toLowerCase(Locale.ROOT), displayName); // Lock the state region, with the requested mode FileLockOutcome lockOutcome = lockStateRegion(lockMode); if (!lockOutcome.isLockWasAcquired()) {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Apr 26 16:02:32 UTC 2024 - 22.3K bytes - Viewed (0) -
platforms/core-execution/persistent-cache/src/test/groovy/org/gradle/cache/internal/DefaultExclusiveCacheAccessCoordinatorTest.groovy
import java.util.function.Consumer import java.util.function.Supplier import static org.gradle.cache.FileLockManager.LockMode.Exclusive import static org.gradle.cache.FileLockManager.LockMode.None 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
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/test/groovy/org/gradle/cache/internal/LockOnDemandCrossProcessCacheAccessTest.groovy
def file = new TestFile("some-file.lock") def lockManager = Mock(FileLockManager) def cacheAccess = new LockOnDemandCrossProcessCacheAccess("<cache>", file, DefaultLockOptions.mode(FileLockManager.LockMode.Exclusive), lockManager, new ReentrantLock(), Stub(CacheInitializationAction), Stub(Consumer), Stub(Consumer)) def "close when lock has never been acquired"() { when: cacheAccess.close()
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/integTest/groovy/org/gradle/cache/internal/DefaultFileLockManagerContentionIntegrationTest.groovy
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Jun 11 09:51:15 UTC 2024 - 15.1K bytes - Viewed (0) -
subprojects/core/src/main/java/org/gradle/internal/service/scopes/ExecutionGradleServices.java
.createCrossVersionCacheBuilder("buildOutputCleanup") .withDisplayName("Build Output Cleanup Cache") .withInitialLockMode(FileLockManager.LockMode.OnDemand) .withProperties(Collections.singletonMap("gradle.version", GradleVersion.current().getVersion())) .open();
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon May 27 12:34:44 UTC 2024 - 11.7K bytes - Viewed (0) -
subprojects/core/src/main/java/org/gradle/process/internal/worker/child/WorkerProcessClassPathProvider.java
PersistentCache workerClassPathCache = cacheBuilderFactory .createCacheBuilder("workerMain") .withInitialLockMode(FileLockManager.LockMode.Exclusive) .withInitializer(new CacheInitializer()) .open(); try {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon Jun 10 14:28:48 UTC 2024 - 11.1K bytes - Viewed (0) -
platforms/core-execution/build-cache-example-client/src/main/java/org/gradle/caching/example/BuildCacheClientModule.java
import java.net.InetSocketAddress; import java.net.UnknownHostException; import java.nio.file.Files; import java.util.Collections; import java.util.function.Supplier; import static org.gradle.cache.FileLockManager.LockMode.OnDemand; import static org.gradle.internal.snapshot.CaseSensitivity.CASE_SENSITIVE; @SuppressWarnings("MethodMayBeStatic") class BuildCacheClientModule extends AbstractModule {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed Apr 17 07:11:58 UTC 2024 - 18.1K bytes - Viewed (0) -
platforms/jvm/toolchains-jvm-shared/src/main/java/org/gradle/jvm/toolchain/internal/install/DefaultJdkCacheDirectory.java
} public FileLock acquireWriteLock(File destinationFile, String operationName) { return lockManager.lock(destinationFile, DefaultLockOptions.mode(FileLockManager.LockMode.Exclusive), destinationFile.getName(), operationName); } public File getDownloadLocation() { return jdkDirectory; } private static String getNameWithoutExtension(File file) {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu May 23 23:47:49 UTC 2024 - 13.4K bytes - Viewed (0) -
platforms/core-execution/persistent-cache/src/main/java/org/gradle/cache/internal/DefaultCacheCoordinator.java
import java.util.concurrent.locks.Lock; import java.util.concurrent.locks.ReentrantLock; import java.util.function.Consumer; import java.util.function.Supplier; import static org.gradle.cache.FileLockManager.LockMode.Exclusive; @ThreadSafe public class DefaultCacheCoordinator implements CacheCreationCoordinator, ExclusiveCacheAccessCoordinator { private final static Logger LOG = LoggerFactory.getLogger(DefaultCacheCoordinator.class);
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed May 01 12:21:15 UTC 2024 - 20.5K bytes - Viewed (0)