Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for maybePingOwner (0.24 sec)

  1. platforms/core-execution/persistent-cache/src/test/groovy/org/gradle/cache/internal/locklistener/DefaultFileLockContentionHandlerTest.groovy

            when:
            int port = handler.reservePort()
            handler.start(10, { action1.set(true) })
            handler.start(11, { action2.set(true) })
    
            client.maybePingOwner(port, 10, "lock 1", 50000, null)
            client.maybePingOwner(port, 11, "lock 2", 50000, null)
    
            then:
            poll {
                assert action1.get() && action2.get()
            }
        }
    
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Tue Apr 16 15:49:49 UTC 2024
    - 6.1K bytes
    - Viewed (0)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
Back to top