- Sort Score
- Result 10 results
- Languages All
Results 1 - 6 of 6 for maybePingOwner (0.24 sec)
-
platforms/core-execution/persistent-cache/src/test/groovy/org/gradle/cache/internal/locklistener/DefaultFileLockContentionHandlerTest.groovy
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Apr 16 15:49:49 UTC 2024 - 6.1K bytes - Viewed (0) -
platforms/core-execution/persistent-cache/src/main/java/org/gradle/cache/internal/locklistener/FileLockContentionHandler.java
* - The ping through the underlying socket failed * * @return true if the owner was pinged in this call */ boolean maybePingOwner(int port, long lockId, String displayName, long timeElapsed, @Nullable FileLockReleasedSignal signal);
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 18 01:28:02 UTC 2024 - 1.6K bytes - Viewed (0) -
subprojects/core/src/testFixtures/groovy/org/gradle/cache/internal/locklistener/NoOpFileLockContentionHandler.java
@Override public void stop(long lockId) {} @Override public int reservePort() { return -1; } @Override public boolean maybePingOwner(int port, long lockId, String displayName, long timeElapsed, FileLockReleasedSignal signal) { return false; }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Apr 16 15:49:51 UTC 2024 - 1.2K bytes - Viewed (0) -
platforms/core-execution/persistent-cache/src/test/groovy/org/gradle/cache/internal/DefaultFileLockManagerContentionTest.groovy
then: 1 * contentionHandler3.maybePingOwner(port1, _, _, _, _) >> { int port, long lockId, String displayName, long timeElapsed, FileLockReleasedSignal signal -> assert timeElapsed < 20 lock1.close() lock2 = createLock(Exclusive, file, manager2) Thread.sleep(50) return false }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Apr 16 15:49:51 UTC 2024 - 5.2K bytes - Viewed (0) -
platforms/core-execution/persistent-cache/src/main/java/org/gradle/cache/internal/locklistener/DefaultFileLockContentionHandler.java
* <p> * A Lock Requester will notice that a lock is held by a Lock Holder by failing to lock the lock file. * It then turns to this contention via {@link #maybePingOwner(int, long, String, long, FileLockReleasedSignal)}. * <p> * Both Lock Holder and Lock Requester listen on a socket using {@link FileLockCommunicator}. The messages they
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Apr 16 15:49:51 UTC 2024 - 12.4K bytes - Viewed (0) -
platforms/core-execution/persistent-cache/src/main/java/org/gradle/cache/internal/DefaultFileLockManager.java
* * If acquiring the lock for the state region fails, we read information region and get the port (if present) and we send a ping request to the owner * (see {@link FileLockContentionHandler#maybePingOwner(int, long, String, long, FileLockReleasedSignal)} how ping algorithm is done).
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Apr 26 16:02:32 UTC 2024 - 22.3K bytes - Viewed (0)