- Sort Score
- Result 10 results
- Languages All
Results 1 - 7 of 7 for FileLockPacketType (0.34 sec)
-
platforms/core-execution/persistent-cache/src/main/java/org/gradle/cache/internal/locklistener/FileLockPacketType.java
*/ package org.gradle.cache.internal.locklistener; /** * Packet type for communication about file locks. * * <p>For backward compatibility, enum constants must not be removed. */ public enum FileLockPacketType { UNKNOWN, UNLOCK_REQUEST, UNLOCK_REQUEST_CONFIRMATION, LOCK_RELEASE_CONFIRMATION
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 09:08:47 UTC 2023 - 929 bytes - Viewed (0) -
platforms/core-execution/persistent-cache/src/main/java/org/gradle/cache/internal/locklistener/FileLockPacketPayload.java
import static org.gradle.cache.internal.locklistener.FileLockPacketType.UNKNOWN; public class FileLockPacketPayload { public static final int MAX_BYTES = 1 + 8 + 1; // protocolVersion + lockId + type private static final byte PROTOCOL_VERSION = 1; private static final ImmutableList<FileLockPacketType> TYPES = ImmutableList.copyOf(FileLockPacketType.values()); private final long lockId;
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 09:08:47 UTC 2023 - 3.3K bytes - Viewed (0) -
platforms/core-execution/persistent-cache/src/test/groovy/org/gradle/cache/internal/locklistener/FileLockPacketPayloadTest.groovy
*/ package org.gradle.cache.internal.locklistener import spock.lang.Specification import static org.gradle.cache.internal.locklistener.FileLockPacketType.LOCK_RELEASE_CONFIRMATION import static org.gradle.cache.internal.locklistener.FileLockPacketType.UNKNOWN class FileLockPacketPayloadTest extends Specification { def "encodes lock id and type"() { when:
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 09:08:47 UTC 2023 - 2K bytes - Viewed (0) -
platforms/core-execution/persistent-cache/src/main/java/org/gradle/cache/internal/locklistener/FileLockCommunicator.java
import java.net.SocketException; import java.util.Set; import static org.gradle.cache.internal.locklistener.FileLockPacketType.LOCK_RELEASE_CONFIRMATION; import static org.gradle.cache.internal.locklistener.FileLockPacketType.UNLOCK_REQUEST; import static org.gradle.cache.internal.locklistener.FileLockPacketType.UNLOCK_REQUEST_CONFIRMATION; import static org.gradle.internal.UncheckedException.throwAsUncheckedException;
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Apr 16 15:49:49 UTC 2024 - 5.9K bytes - Viewed (0) -
platforms/core-execution/persistent-cache/src/test/groovy/org/gradle/cache/internal/locklistener/FileLockCommunicatorTest.groovy
when: communicator.pingOwner(communicator.getPort(), 155, "lock") then: poll { assert receivedPayload.lockId == 155 assert receivedPayload.type == FileLockPacketType.UNLOCK_REQUEST } } def "can receive lock id despite missing type"() { FileLockPacketPayload receivedPayload start { def packet = communicator.receive()
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Apr 16 15:49:49 UTC 2024 - 3.7K bytes - Viewed (0) -
platforms/core-execution/persistent-cache/src/main/java/org/gradle/cache/internal/locklistener/DefaultFileLockContentionHandler.java
import java.util.Map; import java.util.Set; import java.util.concurrent.locks.Lock; import java.util.concurrent.locks.ReentrantLock; import java.util.function.Consumer; import static org.gradle.cache.internal.locklistener.FileLockPacketType.LOCK_RELEASE_CONFIRMATION; /** * The contention handler is responsible for negotiating the transfer of a lock from one process to another.
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Apr 16 15:49:51 UTC 2024 - 12.4K 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)