Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 10 of 41 for blockedOn (0.1 seconds)

  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.
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Thu Aug 07 16:05:33 GMT 2025
    - 10K bytes
    - Click Count (0)
  2. impl/maven-core/src/main/java/org/apache/maven/artifact/repository/MavenArtifactRepository.java

                this.mirroredRepositories = Collections.emptyList();
            }
        }
    
        @Override
        public boolean isBlocked() {
            return blocked;
        }
    
        @Override
        public void setBlocked(boolean blocked) {
            this.blocked = blocked;
        }
    Created: Sun Dec 28 03:35:09 GMT 2025
    - Last Modified: Fri Jun 06 14:28:57 GMT 2025
    - 12.1K bytes
    - Click Count (0)
  3. 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() {
    Created: Sat Dec 20 13:44:44 GMT 2025
    - Last Modified: Sat Aug 30 05:58:03 GMT 2025
    - 15.1K bytes
    - Click Count (0)
  4. 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
    Created: Sat Dec 20 13:44:44 GMT 2025
    - Last Modified: Sat Aug 30 05:58:03 GMT 2025
    - 15.8K bytes
    - Click Count (0)
  5. 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
    Created: Sat Dec 20 08:55:33 GMT 2025
    - Last Modified: Sat Nov 22 11:21:59 GMT 2025
    - 10.3K bytes
    - Click Count (0)
  6. 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;
    
      /**
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Thu Dec 11 21:00:51 GMT 2025
    - 27.1K bytes
    - Click Count (0)
  7. 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 {
    Created: Sat Dec 20 13:44:44 GMT 2025
    - Last Modified: Sat Aug 30 05:58:03 GMT 2025
    - 14.6K bytes
    - Click Count (0)
  8. 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());
                  }
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Fri Jul 11 18:52:30 GMT 2025
    - 11.4K bytes
    - Click Count (0)
  9. 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());
                  }
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Fri Jul 11 18:52:30 GMT 2025
    - 11.4K bytes
    - Click Count (0)
  10. impl/maven-core/src/main/java/org/apache/maven/lifecycle/internal/MojoExecutor.java

                            + "in this parallel build, those kind of mojos require exclusive access to "
                            + "reactor to prevent race conditions. This mojo execution will be blocked "
                            + "until the aggregator mojo is done.";
                    warn(msg);
                    acquiredAggregatorLock.lock();
                }
                if (!acquiredProjectLock.tryLock()) {
    Created: Sun Dec 28 03:35:09 GMT 2025
    - Last Modified: Thu Jun 12 14:55:55 GMT 2025
    - 21K bytes
    - Click Count (0)
Back to Top