} catch (final IOException e) { L57: throw new IORuntimeException(e); L58: } L59: }); L60: } catch (final Exception e) { L61: logger.warn("Failed to write a thread dump to {}", file, e); L62: } L63: } L64: L65: public static void processThreadDump(final Consumer<String> writer) { L66: for (final Map.Entry<Thread, StackTraceElement[]> entry : Thread.getAllStackTraces().entrySet()) { L67: writer.accept("Thread:...

-> { L76: try { L77: jobLogService.delete(entity); L78: saveInfo(messages -> messages.addSuccessCrudDeleteCrudTable(GLOBAL)); L79: } catch (final Exception e) { L80: logger.warn("Failed to process a request.", e); L81: throwValidationErrorApi(messages -> messages.addErrorsCrudFailedToDeleteCrudTable(GLOBAL, buildThrowableMessage(e))); L82: } L83: }).orElse(() -> { L84: throwValidationErrorApi(messages...

searchEngineClient.deleteByQuery(fessConfig.getIndexDocumentUpdateIndex(), query); L216: saveInfo(messages -> messages.addSuccessDeleteDocFromIndex(GLOBAL)); L217: } catch (final Exception e) { L218: logger.warn("Failed to process a request.", e); L219: throwValidationError(messages -> messages.addErrorsFailedToDeleteDocInAdmin(GLOBAL), this::asListHtml); L220: } L221: return asListHtml(); L222: } L223: L224: @Execute L225: @Secured({...

baos.write(bytes, 0, length); L62: } L63: length = bis.read(bytes); L64: } L65: return baos.toString(encoding); L66: } catch (final Exception e) { L67: throw new CurlException("Failed to access the content.", e); L68: } L69: } L70: L71: public InputStream getContentAsStream() throws IOException { L72: if (contentCache == null) { L73: if (contentException != null) { L74: throw new CurlException("The...

the License for the specific language L14: * governing permissions and limitations under the License. L15: */ L16:package org.codelibs.fess.ds; L17: L18:import java.io.File; L19:import java.io.InputStream; L20:import java.nio.file.FileSystem; L21:import java.nio.file.FileSystems; L22:import java.nio.file.Files; L23:import java.nio.file.Path; L24:import java.util.HashSet; L25:import java.util.LinkedHashMap; L26:import java.util.List; L27:import java.util.Locale; L28:import java.util.Map; L29:import java.util.Set;...

userBean, String.join(StringUtil.EMPTY, docIds)); L331: return true; L332: }); L333: } L334: L335: public boolean update(final String id, final String field, final Object value) { L336: return ComponentUtil.getSearchEngineClient().update(ComponentUtil.getFessConfig().getIndexDocumentUpdateIndex(), id, field, value); L337: } L338: L339: public boolean update(final String id, final Consumer<UpdateRequestBuilder> builderLambda) { L340: try { L341: final...

new String(InputStreamUtil.getBytes(is), charSet)); L415: putResultDataBody(dataMap, fessConfig.getIndexFieldHasCache(), Constants.TRUE); L416: } catch (final Exception e) { L417: logger.warn("Failed to write a cache: {}:{}", sessionId, responseData, e); L418: } L419: } else { L420: logger.debug("Content size is too large({} > {}): {}", responseData.getContentLength(), L421: fess...

(); L70: try { L71: userService.changePassword(username, form.newPassword); L72: saveInfo(messages -> messages.addSuccessChangedPassword(GLOBAL)); L73: } catch (final Exception e) { L74: logger.warn("Failed to change password for {}", username, e); L75: throwValidationError(messages -> messages.addErrorsFailedToChangePassword(GLOBAL), toIndexPage); L76: } L77: return redirect(getClass()); L78: } L79: L80: private void ...

list.remove(0); L75: } L76: } L77: } catch (final Exception e) { L78: running = false; L79: if (logger.isDebugEnabled()) { L80: logger.debug("Failed to process an input stream.", e); L81: } L82: } L83: } L84: } L85: L86: public String getOutput() { L87: final StringBuilder buf = new StringBuilder(100); L88: for (final String value : list) {...

labelSet.stream().map(s -> "\"" + s + "\"").collect(Collectors.joining(",")) + "}"); L62: return builder.setScript(script); L63: } L64: } catch (final Exception e) { L65: logger.warn("Failed to process {}", hit, e); L66: } L67: return null; L68: }); L69: resultBuf.append(count).append(" docs").append("\n"); L70: } catch (final Exception e) { L71: logger.error("Could...