() -> downloadpage(form.dictId)); L223: verifyTokenKeep(() -> downloadpage(form.dictId)); L224: return protwordsService.getProtwordsFile(form.dictId) L225: .map(file -> asStream(new File(file.getPath()).getName()).contentTypeOctetStream().stream(out -> { L226: file.writeOut(out); L227: })).orElseGet(() -> { L228: throwValidationError(messages -> messages.addErrorsFailedToDownloadProtwordsFile(GLOBAL), L229: ...

L188: propFile.deleteOnExit(); L189: } catch (final Exception e) { L190: logger.warn("Failed to create system properties file.", e); L191: } L192: } L193: L194: int totalCount = 0; L195: int count = 1; L196: final ExecutorService executorService = Executors.newFixedThreadPool(options.numOfThreads); L197: try { L198: while (count != 0) { L199: count = ComponentUtil.getThumbnailManager().gen...

final BulkItemResponse resp = items[i]; L90: if (resp.isFailed() && resp.getFailure() != null) { L91: final Map<String, Object> req = docList.get(i); L92: final Failure failure = resp.getFailure(); L93: logger.debug("Failed Request: {}\n=>{}", req, failure.getMessage()); L94: } L95: ...

StringUtil.isNotBlank(excludedPaths)) { L172: try { L173: list.add(new LabelTypePattern(labelType.getValue(), includedPaths, excludedPaths)); L174: } catch (final Exception e) { L175: logger.warn("Failed to create a matching pattern of a label: {}, includedPaths:{}, excludedPaths:{}", L176: labelType.getValue(), includedPaths, excludedPaths, e); L177: } L178: } L179: } L180: labelTypePatternList...

(encrypted && cipher != null) { L237: try { L238: rolesStr = cipher.decryptoText(rolesStr); L239: } catch (final Exception e) { L240: if (logger.isDebugEnabled()) { L241: logger.debug("Failed to decrypt {}", rolesStr, e); L242: } L243: return; L244: } L245: } L246: L247: if (logger.isDebugEnabled()) { L248: logger.debug("role: original: {}, decrypto: {}", value, rolesStr);...

getSchedulerItem(namePrefix); L68: assertTrue(scheduler.containsKey("running")); L69: isRunning = (Boolean) scheduler.get("running"); L70: } L71: if (300 <= count) { L72: logger.info("Time out: Failed to start crawler)"); L73: fail(); // Time Out L74: } L75: L76: logger.info("Crawler is running"); L77: count = 0; L78: isRunning = true; L79: while (count < 300 && isRunning) { // Wait until the crawler terminates L80: ...

} else { L152: logger.warn("Failed to parse {}", mapping); L153: } L154: } else { L155: logger.warn("Unknown mapping type: {}={}", key, mapping); L156: } L157: } catch (final Exception e) { L158: logger.warn("Failed to parse {}", values[0], e); L159: } L160: ...

resultList.stream().map(f -> { L209: try { L210: return f.get(); L211: } catch (InterruptedException | ExecutionException e) { L212: if (logger.isDebugEnabled()) { L213: logger.debug("Failed to process a search result.", e); L214: } L215: return SearchResult.create().build(); L216: } L217: }).toArray(n -> new SearchResult[n]); L218: L219: final String scoreField = fessConfig.getR...

and limitations under the License. L15: */ L16:package org.codelibs.fess.helper; L17: L18:import java.io.IOException; L19:import java.nio.file.attribute.AclFileAttributeView; L20:import java.nio.file.attribute.GroupPrincipal; L21:import java.nio.file.attribute.PosixFileAttributeView; L22:import java.nio.file.attribute.PosixFileAttributes; L23:import java.nio.file.attribute.UserPrincipal; L24:import java.util.ArrayList; L25:import java.util.List; L26:import java.util.Locale; L27:import java.util.Map;...

L78: final String configType = configId.substring(0, 1); L79: if (ConfigType.WEB.getTypePrefix().equals(configType)) { L80: return ConfigType.WEB; L81: } L82: if (ConfigType.FILE.getTypePrefix().equals(configType)) { L83: return ConfigType.FILE; L84: } L85: if (ConfigType.DATA.getTypePrefix().equals(configType)) { L86: return ConfigType.DATA; L87: } L88: return null; L89: } L90: L91: protected String getId(final...