- Sort Score
- Result 10 results
- Languages All
Results 561 - 570 of 2,167 for Batch (0.01 sec)
-
fess-crawler-opensearch/src/main/java/org/codelibs/fess/crawler/service/impl/AbstractCrawlerService.java
return builder; } catch (final IOException e) { throw new OpenSearchAccessException("Failed to convert " + target + " to JSON.", e); } } protected RefreshResponse refresh() { try { return getClient().get(c -> c.admin().indices().prepareRefresh(index).execute()); } catch (final Exception e) {
Registered: Sun Nov 10 03:50:12 UTC 2024 - Last Modified: Thu Nov 07 04:44:10 UTC 2024 - 23.6K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/ws/WebSocketHttpTest.kt
// Stall in onOpen to prevent pongs from being sent. val latch = CountDownLatch(1) webServer.enqueue( MockResponse.Builder() .webSocketUpgrade( object : WebSocketListener() { override fun onOpen( webSocket: WebSocket, response: Response, ) { try { latch.await() // The server can't respond to pings!
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Sun Mar 31 17:16:15 UTC 2024 - 35.2K bytes - Viewed (0) -
src/test/java/org/codelibs/fess/suggest/settings/BadWordSettingsTest.java
assertTrue(true); } catch (IllegalArgumentException e) { fail(); } try { settings.badword().add(""); fail(); } catch (IllegalArgumentException e) { assertTrue(true); } try { settings.badword().add("aaaa bbb"); fail(); } catch (IllegalArgumentException e) {
Registered: Fri Nov 08 09:08:12 UTC 2024 - Last Modified: Thu Feb 22 01:36:54 UTC 2024 - 4.4K bytes - Viewed (0) -
src/main/java/org/codelibs/core/sql/ResultSetUtil.java
Registered: Fri Nov 01 20:58:10 UTC 2024 - Last Modified: Thu Mar 07 01:59:08 UTC 2024 - 2.9K bytes - Viewed (0) -
buildscripts/multipart-quorum-test.sh
exit 1 fi trap 'catch $LINENO' ERR function purge() { rm -rf "$1" } # shellcheck disable=SC2120 catch() { if [ $# -ne 0 ]; then echo "error on line $1" fi echo "Cleaning up instances of MinIO" pkill minio || true pkill -9 minio || true purge "$WORK_DIR" if [ $# -ne 0 ]; then exit $# fi } catch function start_minio_10drive() {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Sep 06 10:51:23 UTC 2024 - 2.9K bytes - Viewed (0) -
fess-crawler/src/main/java/org/codelibs/fess/crawler/extractor/impl/ZipExtractor.java
buf.append('\n'); } catch (final Exception e) { if (logger.isDebugEnabled()) { logger.debug("Exception in an internal extractor.", e); } } } } } } catch (final MaxLengthExceededException e) { throw e;
Registered: Sun Nov 10 03:50:12 UTC 2024 - Last Modified: Thu Feb 22 01:47:32 UTC 2024 - 4.1K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/concurrent/TaskQueue.kt
taskRunner.kickCoordinator(this) } return newTask.latch } } private class AwaitIdleTask : Task("$okHttpName awaitIdle", cancelable = false) { val latch = CountDownLatch(1) override fun runOnce(): Long { latch.countDown() return -1L } }
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 7.5K bytes - Viewed (0) -
compat/maven-settings-builder/src/main/java/org/apache/maven/settings/io/DefaultSettingsReader.java
InputSource source = new InputSource(input.toString()); return new Settings(new SettingsStaxReader().read(in, isStrict(options), source)); } catch (XMLStreamException e) { throw new SettingsParseException( e.getMessage(), e.getLocation().getLineNumber(), e.getLocation().getColumnNumber(),
Registered: Sun Nov 03 03:35:11 UTC 2024 - Last Modified: Fri Oct 25 12:31:46 UTC 2024 - 3.6K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/app/web/api/admin/scheduler/ApiAdminSchedulerAction.java
messages.addErrorsFailedToStartJob(GLOBAL, entity.getName()); }); } try { entity.start(); } catch (final Exception e) { throwValidationErrorApi(messages -> { messages.addErrorsFailedToStartJob(GLOBAL, entity.getName()); }); } }).orElse(() -> {
Registered: Thu Oct 31 13:40:30 UTC 2024 - Last Modified: Thu Feb 22 01:53:18 UTC 2024 - 7.6K bytes - Viewed (0) -
guava-testlib/src/com/google/common/collect/testing/testers/ListToArrayTester.java
Object[] actual = getList().toArray(); assertArrayEquals("toArray() order should match list", createOrderedArray(), actual); } @CollectionSize.Require(absent = ZERO) public void testToArray_tooSmall() { Object[] actual = getList().toArray(new Object[0]); assertArrayEquals("toArray(tooSmall) order should match list", createOrderedArray(), actual); } public void testToArray_largeEnough() {
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Sat Oct 19 00:05:46 UTC 2024 - 2.2K bytes - Viewed (0)