Search Options

Results per page
Sort
Preferred Languages
Advance

Results 561 - 570 of 2,167 for Batch (0.01 sec)

  1. 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)
  2. 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)
  3. 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)
  4. src/main/java/org/codelibs/core/sql/ResultSetUtil.java

         *            結果セット
         */
        public static void close(final ResultSet resultSet) {
            if (resultSet == null) {
                return;
            }
            try {
                resultSet.close();
            } catch (final SQLException e) {
                logger.log(format("ECL0017", e.getMessage()), e);
            }
        }
    
        /**
         * 結果セットを次に進めます。
         *
         * @param resultSet
    Registered: Fri Nov 01 20:58:10 UTC 2024
    - Last Modified: Thu Mar 07 01:59:08 UTC 2024
    - 2.9K bytes
    - Viewed (0)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top