- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 29 for asynchronously (1.12 sec)
-
src/main/java/jcifs/internal/CommonServerMessageBlockRequest.java
* asynchronous handling, message chaining, cancellation, and timeout management. * * @author mbechler */ public interface CommonServerMessageBlockRequest extends CommonServerMessageBlock, Request { /** * Checks if the request will be handled asynchronously. * * @return request was handled asynchronously */ boolean isResponseAsync(); /**Registered: Sat Dec 20 13:44:44 UTC 2025 - Last Modified: Sat Aug 16 01:32:48 UTC 2025 - 2.4K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/opensearch/client/SearchEngineClient.java
} /** * Indexes a document asynchronously. * * @param request the index request * @return a future for the index response */ @Override public ActionFuture<IndexResponse> index(final IndexRequest request) { return client.index(request); } /** * Indexes a document asynchronously with a callback. *Registered: Sat Dec 20 09:19:18 UTC 2025 - Last Modified: Fri Nov 28 16:29:12 UTC 2025 - 122.4K bytes - Viewed (1) -
src/main/java/org/codelibs/fess/app/web/base/login/FessLoginAssist.java
return OptionalThing.empty(); } /** * Saves the login history for the given user. * This operation is performed asynchronously. * * @param user the user entity * @param userBean the user bean * @param option the login specified option */ @Override
Registered: Sat Dec 20 09:19:18 UTC 2025 - Last Modified: Thu Jul 17 08:28:31 UTC 2025 - 12.1K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/suggest/index/SuggestIndexer.java
} catch (final Exception e) { throw new SuggestIndexException("Failed to index from query_string.", e); } } /** * Indexes documents from a query log reader asynchronously. * @param queryLogReader The query log reader. * @param docPerReq The number of documents to process per request. * @param requestInterval The interval between requests.
Registered: Sat Dec 20 13:04:59 UTC 2025 - Last Modified: Mon Nov 24 03:40:05 UTC 2025 - 34.4K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/util/InputStreamThread.java
import org.apache.logging.log4j.Logger; /** * A thread that reads from an input stream line by line and maintains a buffer of recent lines. * This class provides functionality to read input stream data asynchronously, * optionally process each line with a callback function, and maintain a circular buffer * of recent lines for retrieval. */ public class InputStreamThread extends Thread { /** Logger instance for this class */Registered: Sat Dec 20 09:19:18 UTC 2025 - Last Modified: Thu Jul 17 08:28:31 UTC 2025 - 4.6K bytes - Viewed (0) -
fess-crawler/src/test/java/org/codelibs/fess/crawler/util/TemporaryFileInputStreamTest.java
TemporaryFileInputStream stream = new TemporaryFileInputStream(tempFile); stream.read(); // Read some data stream.close(); // Note: FileUtil.deleteInBackground() performs deletion asynchronously, // so we cannot reliably check if file is deleted immediately // This test just verifies that close() completes without error } public void test_emptyFile() throws Exception {Registered: Sat Dec 20 11:21:39 UTC 2025 - Last Modified: Sat Nov 22 13:28:22 UTC 2025 - 7.2K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/app/web/admin/backup/AdminBackupAction.java
} saveInfo(messages -> messages.addSuccessBulkProcessStarted(GLOBAL)); return redirect(getClass()); // no-op } /** * Import the file asynchronously. * @param fileName The file name. * @param tempFile The temporary file. */ protected void asyncImport(final String fileName, final File tempFile) { final int fileType;Registered: Sat Dec 20 09:19:18 UTC 2025 - Last Modified: Mon Nov 24 02:07:40 UTC 2025 - 32.1K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/app/web/api/admin/elevateword/ApiAdminElevatewordAction.java
} // PUT /api/admin/elevateword/upload /** * Uploads and imports elevate words from a CSV file. * Processes the file asynchronously and updates the suggest helper. * * @param body upload form containing the CSV file * @return JSON response with upload status */ @ExecuteRegistered: Sat Dec 20 09:19:18 UTC 2025 - Last Modified: Thu Aug 07 03:06:29 UTC 2025 - 12.8K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/rank/fusion/RankFusionProcessor.java
Registered: Sat Dec 20 09:19:18 UTC 2025 - Last Modified: Fri Nov 28 16:29:12 UTC 2025 - 27.5K bytes - Viewed (0) -
src/main/java/jcifs/audit/SecurityAuditLogger.java
// Add MDC context efficiently addMdcContext(entry.context); // Process asynchronously or synchronously based on configuration if (asyncLogging && !shutdown) { if (!logQueue.offer(entry)) { // Queue is full, log synchronously as fallback processLogEntry(entry); returnAuditEntry(entry); }Registered: Sat Dec 20 13:44:44 UTC 2025 - Last Modified: Sat Aug 30 05:58:03 UTC 2025 - 26.6K bytes - Viewed (0)