Search Options

Results per page
Sort
Preferred Languages
Advance

Results 131 - 140 of 1,889 for Watch (0.02 sec)

  1. src/test/java/org/codelibs/fess/validation/CustomSizeTest.java

            final CustomSize annotation = field.getAnnotation(CustomSize.class);
    
            assertNotNull("Annotation should be present on field", annotation);
            assertEquals("minKey should match", "test.min", annotation.minKey());
            assertEquals("maxKey should match", "test.max", annotation.maxKey());
            assertEquals("message should be default", "{jakarta.validation.constraints.Size.message}", annotation.message());
        }
    
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Tue Aug 19 14:09:36 UTC 2025
    - 17.2K bytes
    - Viewed (0)
  2. guava-testlib/src/com/google/common/testing/GcFinalization.java

        do {
          System.runFinalization();
          if (latch.getCount() == 0) {
            return;
          }
          System.gc();
          try {
            if (latch.await(1L, SECONDS)) {
              return;
            }
          } catch (InterruptedException ie) {
            throw new RuntimeException("Unexpected interrupt while waiting for latch", ie);
          }
        } while (System.nanoTime() - deadline < 0);
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Mon Mar 17 20:26:29 UTC 2025
    - 11.5K bytes
    - Viewed (0)
  3. compat/maven-compat/src/main/java/org/apache/maven/artifact/resolver/DefaultArtifactResolver.java

                        executor.execute(new ResolveTask(
                                classLoader, latch, artifact, session, node.getRemoteRepositories(), result));
                    } else {
                        latch.countDown();
                    }
                }
                try {
                    latch.await();
                } catch (InterruptedException e) {
                    result.addErrorArtifactException(
    Registered: Sun Sep 07 03:35:12 UTC 2025
    - Last Modified: Fri Jun 06 14:28:57 UTC 2025
    - 25K bytes
    - Viewed (0)
  4. src/main/java/org/codelibs/fess/helper/ProcessHelper.java

                    } catch (final Exception e) {
                        logger.warn("Could not close a process error stream.", e);
                    } finally {
                        latch.countDown();
                    }
                }, "ProcessCloser-error-" + sessionId).start();
                new Thread(() -> {
                    try {
                        CloseableUtil.closeQuietly(process.getOutputStream());
                    } catch (final Exception e) {
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Thu Jul 17 08:28:31 UTC 2025
    - 9.8K bytes
    - Viewed (0)
  5. compat/maven-compat/src/main/java/org/apache/maven/repository/DefaultMirrorSelector.java

         * <li>{@code *,!repo1} = everything except {@code repo1}.</li>
         * </ul>
         *
         * @param originalRepository to compare for a match.
         * @param pattern used for match.
         * @return true if the repository is a match to this pattern.
         */
        static boolean matchPattern(ArtifactRepository originalRepository, String pattern) {
            boolean result = false;
    Registered: Sun Sep 07 03:35:12 UTC 2025
    - Last Modified: Fri Jun 06 14:28:57 UTC 2025
    - 8K bytes
    - Viewed (0)
  6. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/tls/OkHostnameVerifier.kt

        }
    
        // Optimization: check whether hostname is too short to match the pattern. hostName must be at
        // least as long as the pattern because asterisk must match the whole left-most label and
        // hostname starts with a non-empty label. Thus, asterisk has to match one or more characters.
        if (hostname.length < pattern.length) {
          return false // Hostname too short to match the pattern.
        }
    
        if ("*." == pattern) {
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Wed Mar 19 19:25:20 UTC 2025
    - 7.6K bytes
    - Viewed (0)
  7. src/main/java/org/codelibs/fess/exec/SuggestCreator.java

                    exitCode.set(1);
                    latch.countDown();
                });
    
                try {
                    latch.await();
                } catch (final InterruptedException ignore) {
                    if (logger.isDebugEnabled()) {
                        logger.debug("Interrupted.", ignore);
                    }
                    exitCode.set(1);
                }
            }
    
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Thu Aug 07 03:06:29 UTC 2025
    - 11K bytes
    - Viewed (0)
  8. okhttp/src/jvmTest/kotlin/okhttp3/WholeOperationTimeoutTest.kt

            ) {
              exceptionRef.set(e)
              latch.countDown()
            }
    
            @Throws(IOException::class)
            override fun onResponse(
              call: Call,
              response: Response,
            ) {
              response.close()
              latch.countDown()
            }
          },
        )
        latch.await()
        assertThat(call.isCanceled()).isTrue()
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Wed Jun 18 12:28:21 UTC 2025
    - 10.6K bytes
    - Viewed (0)
  9. guava-tests/test/com/google/common/util/concurrent/ListenableFutureTester.java

      private final CountDownLatch latch;
    
      public ListenableFutureTester(ListenableFuture<?> future) {
        this.exec = newCachedThreadPool();
        this.future = checkNotNull(future);
        this.latch = new CountDownLatch(1);
      }
    
      public void setUp() {
        future.addListener(
            new Runnable() {
              @Override
              public void run() {
                latch.countDown();
              }
            },
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Fri Jul 11 18:52:30 UTC 2025
    - 3.3K bytes
    - Viewed (0)
  10. okhttp/src/androidMain/kotlin/okhttp3/internal/platform/android/ConscryptSocketAdapter.kt

              Conscrypt.isAvailable() && atLeastVersion(2, 1, 0) -> true
              else -> false
            }
          } catch (e: NoClassDefFoundError) {
            false
          } catch (e: ClassNotFoundException) {
            false
          }
    
        fun atLeastVersion(
          major: Int,
          minor: Int = 0,
          patch: Int = 0,
        ): Boolean {
          val conscryptVersion = Conscrypt.version() ?: return false
    
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Wed Mar 19 19:25:20 UTC 2025
    - 3K bytes
    - Viewed (0)
Back to top