- Sort Score
- Num 10 results
- Language All
Results 1491 - 1500 of 2,682 for latch (0.04 seconds)
-
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) -
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 clientCreated: Fri Apr 17 09:08:13 GMT 2026 - Last Modified: Sun Feb 01 12:48:24 GMT 2026 - 9.7K bytes - Click Count (0) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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)