L34:import org.codelibs.fess.crawler.client.CrawlerClientFactory; L35:import org.codelibs.fess.crawler.entity.ResponseData; L36:import org.codelibs.fess.crawler.exception.CrawlingAccessException; L37:import org.codelibs.fess.es.client.SearchEngineClient; L38:import org.codelibs.fess.es.config.exentity.CrawlingConfig; L39:import org.codelibs.fess.exception.ThumbnailGenerationException; L40:import org.codelibs.fess.helper.CrawlingConfigHelper; L41:import org.codelibs.fess.helper.IndexingHelper; L42:import ...

() -> StringEscapeUtils.escapeJson(e.getValue().getHotThreads())); L57: return tempBuf.toString(); L58: }).collect(Collectors.joining(",")); L59: buf.append(hotThreads).append(','); L60: } catch (final Exception e) { L61: appendException(buf, e).append(','); L62: } L63: L64: appendTimestamp(buf); L65: buf.append('}'); L66: L67: if (logger.isInfoEnabled()) { L68: logger.info(buf.toString()); L69: }...

java.io.OutputStream; L21:import java.util.function.Function; L22: L23:import org.apache.logging.log4j.LogManager; L24:import org.apache.logging.log4j.Logger; L25:import org.codelibs.fess.es.client.SearchEngineClient; L26:import org.lastaflute.di.exception.IORuntimeException; L27:import org.opensearch.core.xcontent.MediaType; L28:import org.opensearch.core.xcontent.ToXContent; L29:import org.opensearch.core.xcontent.XContentBuilder; L30:import org.opensearch.core.xcontent.XContentHelper; L31:import...

StringUtil.EMPTY; L67: pathMapperFunc = pathMappingHelper.createPathMatcher(matcher, replacement); L68: } L69: try { L70: return pathMapperFunc.apply(input, matcher); L71: } catch (final Exception e) { L72: logger.warn("Failed to apply {} to {}.", regexPattern.pattern(), input, e); L73: } L74: } L75: return input; L76: } L77: L78: public boolean hasUAMathcer() { L79: return StringUtil.i...

L23:import org.codelibs.fess.unit.UnitFessTestCase; L24: L25:public class IntervalControlHelperTest extends UnitFessTestCase { L26: L27: private IntervalControlHelper intervalControlHelper; L28: L29: @Override L30: public void setUp() throws Exception { L31: super.setUp(); L32: intervalControlHelper = new IntervalControlHelper(); L33: } L34: L35: public void test_noRule() { L36: assertEquals(0, intervalControlHelper.getDelay()); L37: } L38: L39: public void test_0000()...

headerList = new ArrayList<>(); L171: } L172: headerList.add(new String[] { key, value }); L173: return this; L174: } L175: L176: public void connect(final Consumer<HttpURLConnection> actionListener, final Consumer<Exception> exceptionListener) { L177: final Runnable task = () -> { L178: if (paramList != null) { L179: char sp; L180: if (url.indexOf('?') == -1) { L181: sp = '?'; L182: }...

L183: engineObj.numberOfInFlightFetch = response.getNumberOfInFlightFetch(); L184: engineObj.status = response.getStatus().name().toLowerCase(Locale.ROOT); L185: } catch (final Exception e) { L186: engineObj.status = "red"; L187: engineObj.exception = e.getMessage(); L188: } L189: return engineObj; L190: } L191: L192: public static class FsObj { L193: public short percent; L194: public long used; L195: public...

try { L310: final byte[] buf = new byte[1024]; L311: while ((is.read(buf)) != -1) {} L312: } catch (final Exception ignored) {} finally { L313: try { L314: is.close(); L315: } catch (final Exception ignored) {} L316: } L317: } catch (final Exception ignored) {} L318: } L319: L320: protected void handleFileUploadException(final FileUploadException e) throws ServletException { L321: ...

temHelper.getHostname()); L71: postcard.setClustername(ping.getClusterName()); L72: postcard.setClusterstatus(ping.getClusterStatus()); L73: }); L74: } catch (final Exception e) { L75: logger.warn("Failed to send a test mail.", e); L76: } finally { L77: SMailCallbackContext.clearPreparedMessageHookOnThread(); L78: } L79: } L80: ...

ost; L21:import org.codelibs.fess.unit.UnitFessTestCase; L22: L23:public class DuplicateHostHelperTest extends UnitFessTestCase { L24: private DuplicateHostHelper duplicateHostHelper; L25: L26: @Override L27: public void setUp() throws Exception { L28: super.setUp(); L29: duplicateHostHelper = new DuplicateHostHelper(); L30: duplicateHostHelper.duplicateHostList = new ArrayList<DuplicateHost>(); L31: L32: DuplicateHost foo = new DuplicateHost(); L33: f...