- Sort Score
- Num 10 results
- Language All
Results 41 - 50 of 86 for joina (0.01 seconds)
-
src/main/java/org/codelibs/fess/api/chat/ChatApiManager.java
Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Thu Mar 26 06:06:55 GMT 2026 - 25.8K bytes - Click Count (0) -
src/test/java/org/codelibs/fess/job/SuggestJobTest.java
this.output = output; } @Override public void start() { // Mock implementation } // Custom join method to avoid overriding final Thread.join() public void waitForCompletion(long millis) { // Mock implementation } @Override public String getOutput() { return output;Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Fri Mar 13 23:01:26 GMT 2026 - 31.6K bytes - Click Count (0) -
src/main/java/org/codelibs/fess/job/SuggestJob.java
final InputStreamThread it = jobProcess.getInputStreamThread(); it.start(); final Process currentProcess = jobProcess.getProcess(); currentProcess.waitFor(); it.join(5000); final int exitValue = currentProcess.exitValue(); if (logger.isInfoEnabled()) {
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/util/IpAddressUtil.java
currentLength = 0; } } // If longest sequence is only 1 zero, don't compress if (longestLength <= 1) { return String.join(":", normalized); } // Build compressed address final StringBuilder result = new StringBuilder(); boolean inCompression = false; for (int i = 0; i < 8; i++) {Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Thu Nov 06 08:31:03 GMT 2025 - 9.4K bytes - Click Count (0) -
src/main/java/org/codelibs/fess/job/PythonJob.java
final InputStreamThread it = jobProcess.getInputStreamThread(); 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) -
src/main/java/org/codelibs/fess/job/GenerateThumbnailJob.java
final InputStreamThread it = jobProcess.getInputStreamThread(); it.start(); final Process currentProcess = jobProcess.getProcess(); currentProcess.waitFor(); it.join(5000); final int exitValue = currentProcess.exitValue(); if (logger.isInfoEnabled()) {
Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Fri Nov 28 16:29:12 GMT 2025 - 11.7K bytes - Click Count (0) -
src/test/java/org/codelibs/fess/mylasta/direction/FessPropTest.java
} private void assertArrays(final String[] expected, final String[] actual) { Arrays.sort(expected); Arrays.sort(actual); assertEquals(String.join(",", expected), String.join(",", actual)); } @Test public void test_getEntraIdPermissionFields_withNewKey() { final Map<String, String> systemPropMap = new HashMap<>(); FessProp.propMap.clear();Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Fri Mar 13 23:01:26 GMT 2026 - 25.4K bytes - Click Count (0) -
src/main/java/org/codelibs/fess/util/ResourceUtil.java
final Path confPath = getConfPath(names); if (Files.exists(confPath)) { return confPath; } return org.codelibs.core.io.ResourceUtil.getResourceAsFile(String.join("/", names)).toPath(); } /** * Gets the path to compiled classes directory. * * @param names the path components to append to the classes directory
Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Thu Jul 17 08:28:31 GMT 2025 - 14.1K bytes - Click Count (0) -
src/test/java/org/codelibs/fess/mylasta/direction/sponsor/FessCurtainFinallyHookTest.java
// Start all threads for (Thread thread : threads) { thread.start(); } // Wait for all threads to complete for (Thread thread : threads) { thread.join(5000); // 5 second timeout } // Verify no errors occurred during concurrent execution assertFalse(hasError.get()); }Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Fri Mar 13 23:01:26 GMT 2026 - 8.7K bytes - Click Count (0) -
src/test/java/org/codelibs/fess/ds/callback/IndexUpdateCallbackImplTest.java
} }); threads.add(thread); thread.start(); } // Wait for all threads for (Thread thread : threads) { thread.join(); } // Verify all documents were processed assertEquals(threadCount * docsPerThread, successCount.get()); assertEquals(threadCount * docsPerThread, indexUpdateCallback.getDocumentSize());Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Fri Mar 13 23:01:26 GMT 2026 - 24.7K bytes - Click Count (0)