- Sort Score
- Num 10 results
- Language All
Results 41 - 50 of 299 for _process (0.14 seconds)
-
build-logic/cleanup/src/main/java/gradlebuild/cleanup/services/KillLeakingJavaProcesses.java
try { Process process = new ProcessBuilder().command(args).start(); CountDownLatch latch = new CountDownLatch(2); ByteArrayOutputStream stdout = connectStream(process.getInputStream(), latch); ByteArrayOutputStream stderr = connectStream(process.getErrorStream(), latch); process.waitFor(1, TimeUnit.MINUTES);Created: Wed Apr 01 11:36:16 GMT 2026 - Last Modified: Tue Sep 23 13:49:45 GMT 2025 - 12K bytes - Click Count (0) -
src/main/java/org/codelibs/fess/job/PythonJob.java
it.start(); final Process currentProcess = jobProcess.getProcess(); currentProcess.waitFor(); it.join(5000); final int exitValue = currentProcess.exitValue(); if (logger.isInfoEnabled()) { logger.info("Python: Exit Code={} - Process Output:\n{}", exitValue, it.getOutput()); }
Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Thu Jul 17 08:28:31 GMT 2025 - 8.2K bytes - Click Count (0) -
build-logic-commons/basics/src/main/kotlin/gradlebuild/basics/kotlindsl/kotlin-dsl-upstream-candidates.kt
// This file contains members that we should consider to pull upstream // and make available to all Kotlin DSL users package gradlebuild.basics.kotlindsl import org.gradle.process.ExecOperations import java.io.ByteArrayOutputStream import java.io.File /** * `dir / "sub"` is the same as `dir.resolve("sub")`. * * @see [File.resolve] */ operator fun File.div(child: String): File = resolve(child)
Created: Wed Apr 01 11:36:16 GMT 2026 - Last Modified: Mon May 19 11:33:57 GMT 2025 - 965 bytes - Click Count (0) -
src/test/java/org/codelibs/fess/helper/ActivityHelperTest.java
assertEquals( "{\"@timestamp\":\"2022-01-01T00:00:00.000Z\",\"log.level\":\"INFO\",\"ecs.version\":\"1.2.0\",\"service.name\":\"fess\",\"event.dataset\":\"app\",\"process.thread.name\":\"main\",\"log.logger\":\"org.codelibs.fess.helper.ActivityHelperTest$1\",\"labels.action\":\"LOGIN\",\"labels.user\":\"-\",\"labels.permissions\":\"-\"}", localLogMsg.get());
Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Thu Mar 26 11:45:43 GMT 2026 - 24.3K bytes - Click Count (0) -
src/test/java/org/codelibs/fess/util/ComponentUtilTest.java
List<String> results = new ArrayList<>(); Runnable process = () -> results.add("executed"); ComponentUtil.processAfterContainerInit(process); assertEquals(0, results.size()); } @Test public void test_processAfterContainerInit_notAvailable() { List<String> results = new ArrayList<>(); Runnable process = () -> results.add("executed");
Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Fri Mar 13 23:01:26 GMT 2026 - 7.7K bytes - Click Count (0) -
src/test/java/org/codelibs/fess/score/ScoreUpdaterTest.java
this.returnValue = returnValue; } @Override public long process() { return returnValue; } } // Test class that throws exception private static class ExceptionScoreBooster extends ScoreBooster { @Override public long process() { throw new RuntimeException("Test exception"); } }Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Wed Jan 14 14:29:07 GMT 2026 - 10.5K bytes - Click Count (0) -
src/main/java/org/codelibs/fess/thumbnail/impl/BaseThumbnailGenerator.java
* @param id The document ID. * @param consumer The consumer function to process response data. * @return True if processing was successful, false otherwise. */ protected boolean process(final String id, final Predicate<ResponseData> consumer) { return process(id, (configId, url) -> { final CrawlingConfigHelper crawlingConfigHelper = ComponentUtil.getCrawlingConfigHelper();Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Fri Nov 28 16:29:12 GMT 2025 - 13.4K bytes - Click Count (0) -
src/main/java/org/codelibs/fess/ds/callback/IndexUpdateCallbackImpl.java
Map<String, Object> target = dataMap; for (final Ingester ingester : ingestFactory.getIngesters()) { try { target = ingester.process(target, paramMap); } catch (final Exception e) { logger.warn("[{}] Failed to process ingester", ingester.getClass().getSimpleName(), e); } } return target; } /**
Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Fri Nov 28 16:29:12 GMT 2025 - 10.5K bytes - Click Count (0) -
src/main/java/org/codelibs/fess/storage/S3StorageClient.java
requestBuilder.prefix(normalizedPrefix); } final ListObjectsV2Response response = s3Client.listObjectsV2(requestBuilder.build()); // Process common prefixes (directories) for (final CommonPrefix commonPrefix : response.commonPrefixes()) { final String dirName = getName(commonPrefix.prefix());
Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Sat Dec 13 02:21:17 GMT 2025 - 10.9K bytes - Click Count (0) -
src/packaging/common/packaging.properties
# Default values for min/max heap memory allocated to fess java process packaging.fess.heap.min=256m packaging.fess.heap.max=1g # Specifies the maximum file descriptor number packaging.os.max.open.files=65535 # Maximum number of VMA (Virtual Memory Areas) a process can own packaging.os.max.map.count=262144 # Simple marker to check that properties are correctly overridden
Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Thu Dec 10 01:24:02 GMT 2015 - 797 bytes - Click Count (0)