Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1491 - 1500 of 2,682 for latch (0.04 seconds)

  1. src/test/java/jcifs/internal/fscc/FileBasicInfoTest.java

            // Create a new FileBasicInfo and decode to verify encoding
            FileBasicInfo decoded = new FileBasicInfo();
            decoded.decode(buffer, startIndex, 36); // decode only reads 36 bytes
    
            // Verify the values match after round-trip
            assertEquals(TEST_CREATE_TIME, decoded.getCreateTime());
            assertEquals(TEST_LAST_ACCESS_TIME, decoded.getLastAccessTime());
            assertEquals(TEST_LAST_WRITE_TIME, decoded.getLastWriteTime());
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Thu Aug 14 05:31:44 GMT 2025
    - 11.5K bytes
    - Click Count (0)
  2. src/main/java/org/codelibs/fess/suggest/util/ScrollOperationHelper.java

                }
            } finally {
                SuggestUtil.deleteScrollContext(client, scrollId);
            }
        }
    
        /**
         * Performs a scroll-based search with a batch callback for processing hits.
         * This is useful when you need to process hits in batches (e.g., for bulk writes).
         *
         * @param client The OpenSearch client
    Created: Fri Apr 17 09:08:13 GMT 2026
    - Last Modified: Sun Feb 01 12:48:24 GMT 2026
    - 9.7K bytes
    - Click Count (0)
  3. apache-maven/src/assembly/maven/bin/mvnenc.cmd

    @REM Apache Maven Encrypt Script
    @REM
    @REM Environment Variable Prerequisites
    @REM
    @REM   JAVA_HOME           (Optional) Points to a Java installation.
    @REM   MAVEN_BATCH_ECHO    (Optional) Set to 'on' to enable the echoing of the batch commands.
    @REM   MAVEN_BATCH_PAUSE   (Optional) set to 'on' to wait for a key stroke before ending.
    @REM   MAVEN_OPTS          (Optional) Java runtime options used when Maven is executed.
    Created: Sun Apr 05 03:35:12 GMT 2026
    - Last Modified: Fri Oct 18 11:01:21 GMT 2024
    - 1.7K bytes
    - Click Count (0)
  4. okhttp-testing-support/src/main/kotlin/okhttp3/OkHttpClientTestRule.kt

        try {
          ensureAllConnectionsReleased()
          releaseClient()
        } catch (ae: AssertionError) {
          result += ae
        }
    
        try {
          if (taskQueuesWereIdle) {
            ensureAllTaskQueuesIdle()
          }
        } catch (ae: AssertionError) {
          result += ae
        }
    
        if (result != null) throw result
      }
    
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Tue Nov 04 19:13:52 GMT 2025
    - 10.8K bytes
    - Click Count (0)
  5. okhttp-logging-interceptor/src/test/java/okhttp3/logging/LoggingEventListenerTest.kt

            .eventListenerFactory(loggingEventListenerFactory)
            .build()
        try {
          client.newCall(request().build()).execute()
          fail<Any>()
        } catch (expected: UnknownHostException) {
        }
        logRecorder
          .assertLogMatch(Regex("""callStart: Request\{method=GET, url=$url\}"""))
          .assertLogMatch(Regex("""proxySelectStart: $url"""))
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Fri Jun 20 11:46:46 GMT 2025
    - 10.2K bytes
    - Click Count (0)
  6. android/guava/src/com/google/common/collect/RegularContiguousSet.java

        if (object == null) {
          return false;
        }
        try {
          @SuppressWarnings("unchecked") // The worst case is usually CCE, which we catch.
          C c = (C) object;
          return range.contains(c);
        } catch (ClassCastException e) {
          return false;
        }
      }
    
      @Override
      public boolean containsAll(Collection<?> targets) {
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Thu Aug 07 16:05:33 GMT 2025
    - 8.3K bytes
    - Click Count (0)
  7. android/guava/src/com/google/common/util/concurrent/ExecutionList.java

      private static void executeListener(Runnable runnable, Executor executor) {
        try {
          executor.execute(runnable);
        } catch (Exception e) { // sneaky checked exception
          // Log it and keep going -- bad runnable and/or executor. Don't punish the other runnables if
          // we're given a bad one. We only catch Exception because we want Errors to propagate up.
          log.get()
              .log(
                  Level.SEVERE,
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Tue Feb 10 11:51:21 GMT 2026
    - 6.9K bytes
    - Click Count (0)
  8. fess-crawler-opensearch/src/main/java/org/codelibs/fess/crawler/service/impl/OpenSearchUrlFilterService.java

         */
        @Override
        public List<Pattern> getIncludeUrlPatternList(final String sessionId) {
            try {
                return includeFilterCache.get(sessionId);
            } catch (final ExecutionException e) {
                throw new CrawlerSystemException(e);
            }
        }
    
        /**
         * Gets the list of exclude URL patterns for the specified session.
         *
    Created: Sun Apr 12 03:50:13 GMT 2026
    - Last Modified: Thu Nov 20 08:40:57 GMT 2025
    - 9K bytes
    - Click Count (0)
  9. src/main/java/org/codelibs/fess/mylasta/direction/sponsor/FessUserLocaleProcessProvider.java

            if (StringUtil.isNotBlank(name)) {
                try {
                    return requestManager.getParameter(name).filter(StringUtil::isNotBlank).map(LocaleUtils::toLocale);
                } catch (final Exception e) {
                    logger.debug("Failed to parse locale: name={}", name, e);
                }
            }
            return OptionalObject.empty();
        }
    
        @Override
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Fri Nov 28 16:29:12 GMT 2025
    - 2.9K bytes
    - Click Count (0)
  10. src/main/java/org/codelibs/core/collection/ArrayIterator.java

            return index < items.length;
        }
    
        @Override
        public T next() {
            try {
                final T o = items[index];
                index++;
                return o;
            } catch (final IndexOutOfBoundsException e) {
                throw new NoSuchElementException("index=" + index);
            }
        }
    
        @Override
        public void remove() {
    Created: Fri Apr 03 20:58:12 GMT 2026
    - Last Modified: Thu Jun 19 09:12:22 GMT 2025
    - 2.5K bytes
    - Click Count (0)
Back to Top