Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 29 for asynchronously (1.28 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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
         */
        @Execute
    Registered: Sat Dec 20 09:19:18 UTC 2025
    - Last Modified: Thu Aug 07 03:06:29 UTC 2025
    - 12.8K bytes
    - Viewed (0)
  9. src/main/java/org/codelibs/fess/rank/fusion/RankFusionProcessor.java

            }
            load();
        }
    
        /**
         * Updates the processor configuration by reloading available searchers.
         * This method executes the load operation asynchronously in a separate thread.
         */
        public void update() {
            CommonPoolUtil.execute(this::load);
        }
    
        /**
         * Loads the available searcher names from system properties.
    Registered: Sat Dec 20 09:19:18 UTC 2025
    - Last Modified: Fri Nov 28 16:29:12 UTC 2025
    - 27.5K bytes
    - Viewed (0)
  10. 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)
Back to top