Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 36 for blockedOn (0.11 sec)

  1. android/guava/src/com/google/common/util/concurrent/InterruptibleTask.java

             * interrupting thread. In theory, interruptTask() should be very fast, but due to
             * InterruptibleChannel and JavaLangAccess.blockedOn(Thread, Interruptible), it isn't
             * predictable what work might be done. (e.g., close a file and flush buffers to disk). To
             * protect ourselves from this, we park ourselves and tell our interrupter that we did so.
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:05:33 UTC 2025
    - 10K bytes
    - Viewed (0)
  2. src/main/java/jcifs/util/AuthenticationRateLimiter.java

                recentAttempts.set(0);
                blocked.set(false);
                blockExpiry = null;
                windowStart = Instant.now();
            }
    
            void block(Duration duration) {
                blocked.set(true);
                blockExpiry = Instant.now().plus(duration);
            }
    
            boolean isBlocked() {
                return blocked.get();
            }
    
            int getRecentAttempts() {
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Sat Aug 30 05:58:03 UTC 2025
    - 15.1K bytes
    - Viewed (0)
  3. src/test/java/jcifs/util/AuthenticationRateLimiterTest.java

                assertTrue(rateLimiter.checkAttempt("user" + i, ip));
                rateLimiter.recordFailure("user" + i, ip);
            }
    
            // Should be blocked
            assertFalse(rateLimiter.checkAttempt("user6", ip), "IP should be blocked");
    
            // Manually unblock
            assertTrue(rateLimiter.unblockIp(ip), "Manual unblock should succeed");
    
            // Should be allowed again
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Sat Aug 30 05:58:03 UTC 2025
    - 15.8K bytes
    - Viewed (0)
  4. src/test/java/org/codelibs/core/io/FileUtilTest.java

            final Path baseDir = tempFolder.getRoot().toPath();
            final Path traversalPath = baseDir.resolve("../../../etc/passwd");
    
            assertFalse("Path traversal should be blocked", FileUtil.isPathSafe(traversalPath, baseDir));
        }
    
        /**
         * Test isPathSafe with File objects
         *
         * @throws Exception
         */
        @Test
    Registered: Sat Dec 20 08:55:33 UTC 2025
    - Last Modified: Sat Nov 22 11:21:59 UTC 2025
    - 10.3K bytes
    - Viewed (0)
  5. android/guava-tests/test/com/google/common/util/concurrent/GeneratedMonitorTest.java

      private static final long SMALL_TIMEOUT_MILLIS = 10;
    
      /** How long to wait when determining that a thread is blocked if we expect it to be blocked. */
      private static final long EXPECTED_HANG_DELAY_MILLIS = 75;
    
      /**
       * How long to wait when determining that a thread is blocked if we DON'T expect it to be blocked.
       */
      private static final long UNEXPECTED_HANG_DELAY_MILLIS = 10000;
    
      /**
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Thu Dec 11 21:00:51 UTC 2025
    - 27.1K bytes
    - Viewed (0)
  6. src/test/java/jcifs/util/PathValidatorTest.java

        @Test
        public void testClearBlacklist() throws Exception {
            validator.addToBlacklist("\\share\\blocked");
            validator.clearBlacklist();
    
            // Should allow previously blacklisted path
            String allowed = validator.validatePath("\\share\\blocked\\file.txt");
            assertEquals("\\share\\blocked\\file.txt", allowed);
        }
    
        @Test
        public void testClearWhitelist() throws Exception {
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Sat Aug 30 05:58:03 UTC 2025
    - 14.6K bytes
    - Viewed (0)
  7. android/guava-tests/test/com/google/common/util/concurrent/InterruptibleTaskTest.java

        // 1. the runner has been woken up
        // 2. the interrupter is stuck in the call the Thread.interrupt()
    
        // after some period of time the runner thread should become blocked on the task because it is
        // waiting for the slow interrupting thread to complete Thread.interrupt
        awaitBlockedOnInstanceOf(runner, InterruptibleTask.Blocker.class);
    
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Tue May 13 18:46:00 UTC 2025
    - 7.1K bytes
    - Viewed (0)
  8. src/main/java/org/codelibs/fess/app/web/admin/badword/EditForm.java

     * This form extends CreateForm to include fields necessary for updating existing bad word entries,
     * including tracking information for optimistic locking and audit trails.
     * Bad words are terms that should be filtered or blocked in search results.
     *
     */
    public class EditForm extends CreateForm {
    
        /**
         * Creates a new EditForm instance.
         */
        public EditForm() {
            super();
        }
    
        /**
    Registered: Sat Dec 20 09:19:18 UTC 2025
    - Last Modified: Thu Jul 17 08:28:31 UTC 2025
    - 2.2K bytes
    - Viewed (0)
  9. guava-tests/test/com/google/common/util/concurrent/SequentialExecutorTest.java

                }
                throw new RejectedExecutionException();
              }
            };
        SequentialExecutor executor = new SequentialExecutor(delegate);
        ExecutorService blocked = newCachedThreadPool();
        Future<?> first =
            blocked.submit(
                new Runnable() {
                  @Override
                  public void run() {
                    executor.execute(Runnables.doNothing());
                  }
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Fri Jul 11 18:52:30 UTC 2025
    - 11.4K bytes
    - Viewed (0)
  10. android/guava-tests/test/com/google/common/util/concurrent/SequentialExecutorTest.java

                }
                throw new RejectedExecutionException();
              }
            };
        SequentialExecutor executor = new SequentialExecutor(delegate);
        ExecutorService blocked = newCachedThreadPool();
        Future<?> first =
            blocked.submit(
                new Runnable() {
                  @Override
                  public void run() {
                    executor.execute(Runnables.doNothing());
                  }
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Fri Jul 11 18:52:30 UTC 2025
    - 11.4K bytes
    - Viewed (0)
Back to top