Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 14 for guard (0.01 sec)

  1. android/guava-tests/test/com/google/common/util/concurrent/GeneratedMonitorTest.java

        // (b) Waiting for the single guard to become satisfied.
        // (c) Occupying the monitor and awaiting the tearDownLatch.
        //
        // Except for (c), every thread should occupy the monitor very briefly, and every thread leaves
        // the monitor with the guard satisfied. Therefore as soon as tearDownLatch is triggered, we
        // should be able to enter the monitor, and then we set the guard to satisfied for the benefit
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Thu Dec 11 21:00:51 UTC 2025
    - 27.1K bytes
    - Viewed (0)
  2. android/guava-tests/test/com/google/common/util/concurrent/SupplementalMonitorTest.java

        Monitor monitor2 = new Monitor();
        FlagGuard guard = new FlagGuard(monitor2);
        assertThrows(IllegalMonitorStateException.class, () -> monitor1.getWaitQueueLength(guard));
      }
    
      public void testHasWaitersWithWrongMonitorThrowsIMSE() {
        Monitor monitor1 = new Monitor();
        Monitor monitor2 = new Monitor();
        FlagGuard guard = new FlagGuard(monitor2);
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Tue Oct 28 16:03:47 UTC 2025
    - 5K bytes
    - Viewed (0)
  3. guava-tests/test/com/google/common/util/concurrent/SupplementalMonitorTest.java

        Monitor monitor2 = new Monitor();
        FlagGuard guard = new FlagGuard(monitor2);
        assertThrows(IllegalMonitorStateException.class, () -> monitor1.getWaitQueueLength(guard));
      }
    
      public void testHasWaitersWithWrongMonitorThrowsIMSE() {
        Monitor monitor1 = new Monitor();
        Monitor monitor2 = new Monitor();
        FlagGuard guard = new FlagGuard(monitor2);
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Tue Oct 28 16:03:47 UTC 2025
    - 5K bytes
    - Viewed (0)
  4. src/test/java/jcifs/smb/WinErrorTest.java

            assertEquals(WinError.WINERR_CODES.length, WinError.WINERR_MESSAGES.length, "Codes/messages length mismatch");
    
            // Exact content check to guard against accidental reordering or drift
            assertArrayEquals(
                    new int[] { WinError.ERROR_SUCCESS, WinError.ERROR_ACCESS_DENIED, WinError.ERROR_REQ_NOT_ACCEP, WinError.ERROR_BAD_PIPE,
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Thu Aug 14 05:31:44 UTC 2025
    - 8.4K bytes
    - Viewed (0)
  5. guava/src/com/google/common/util/concurrent/ServiceManager.java

         * which it is guaranteed that it can never become healthy.
         */
        final Monitor.Guard awaitHealthGuard = new AwaitHealthGuard();
    
        @WeakOuter
        final class AwaitHealthGuard extends Monitor.Guard {
          AwaitHealthGuard() {
            super(ServiceManagerState.this.monitor);
          }
    
          @Override
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Mon Sep 22 17:49:12 UTC 2025
    - 32.9K bytes
    - Viewed (0)
  6. android/guava/src/com/google/common/util/concurrent/ServiceManager.java

         * which it is guaranteed that it can never become healthy.
         */
        final Monitor.Guard awaitHealthGuard = new AwaitHealthGuard();
    
        @WeakOuter
        final class AwaitHealthGuard extends Monitor.Guard {
          AwaitHealthGuard() {
            super(ServiceManagerState.this.monitor);
          }
    
          @Override
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Mon Sep 22 17:49:12 UTC 2025
    - 33.2K bytes
    - Viewed (1)
  7. src/test/java/jcifs/EncodableTest.java

        void encodeCopiesAndReportsSize(byte[] src, int off, int len, int dstIndex) {
            Encodable enc = new ByteEncodable(src, off, len);
    
            // Destination has guard space to verify non-overwritten regions.
            byte[] dst = new byte[dstIndex + len + 5];
            Arrays.fill(dst, (byte) 0x55);
    
            // Act
            int written = enc.encode(dst, dstIndex);
    
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Thu Aug 14 05:31:44 UTC 2025
    - 4.6K bytes
    - Viewed (0)
  8. android/guava/src/com/google/common/collect/MinMaxPriorityQueue.java

            queue[0] = x;
            return 0;
          }
          int parentIndex = getParentIndex(index);
          E parentElement = elementData(parentIndex);
          if (parentIndex != 0) {
            /*
             * This is a guard for the case of the childless aunt node. Since the end of the array is
             * actually the middle of the heap, a smaller childless aunt node can become a child of x
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Mon Sep 22 18:35:44 UTC 2025
    - 33.9K bytes
    - Viewed (0)
  9. src/main/java/org/codelibs/fess/rank/fusion/RankFusionProcessor.java

            final FessConfig fessConfig = ComponentUtil.getFessConfig();
            final int rankConstant = fessConfig.getRankFusionRankConstantAsInteger();
            // Guard against division by zero (should not happen due to caller checks, but defensive)
            if (searchers.length == 0) {
                logger.warn("searchWithMultipleSearchers called with empty searcher array");
    Registered: Sat Dec 20 09:19:18 UTC 2025
    - Last Modified: Fri Nov 28 16:29:12 UTC 2025
    - 27.5K bytes
    - Viewed (0)
  10. android/guava/src/com/google/common/io/Files.java

       *
       * <p>Copying is not an atomic operation - in the case of an I/O error, power loss, process
       * termination, or other problems, {@code to} may not be a complete copy of {@code from}. If you
       * need to guard against those conditions, you should employ other file-level synchronization.
       *
       * <p><b>Warning:</b> If {@code to} represents an existing file, that file will be overwritten
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Thu Sep 25 20:24:13 UTC 2025
    - 32.8K bytes
    - Viewed (0)
Back to top