Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 26 for Queued (0.15 sec)

  1. fess-crawler-opensearch/src/main/java/org/codelibs/fess/crawler/service/impl/OpenSearchUrlQueueService.java

        /**
         * QueueHolder holds the waiting and crawling queues.
         */
        protected static class QueueHolder {
            /**
             * Constructs a new QueueHolder.
             */
            public QueueHolder() {
                // Default constructor
            }
    
            /**
             * The queue for URLs waiting to be crawled.
             */
            protected Queue<OpenSearchUrlQueue> waitingQueue = new ConcurrentLinkedQueue<>();
    Registered: Sun Sep 21 03:50:09 UTC 2025
    - Last Modified: Thu Aug 07 02:55:08 UTC 2025
    - 17K bytes
    - Viewed (1)
  2. fess-crawler/src/main/java/org/codelibs/fess/crawler/service/impl/UrlQueueServiceImpl.java

     *   <li>Deleting URL queues associated with a session.</li>
     *   <li>Deleting all URL queues.</li>
     *   <li>Offering a list of URLs to the queue, ensuring duplicates are not added.</li>
     *   <li>Polling (retrieving and removing) a URL from the queue.</li>
     *   <li>Saving the session (currently a no-op).</li>
     *   <li>Checking if a URL has already been visited.</li>
     *   <li>Generating URL queues from a previous session's access results.</li>
    Registered: Sun Sep 21 03:50:09 UTC 2025
    - Last Modified: Sun Jul 06 02:13:03 UTC 2025
    - 9.3K bytes
    - Viewed (0)
  3. fess-crawler/src/main/java/org/codelibs/fess/crawler/service/UrlQueueService.java

        /**
         * Deletes all URL queues.
         */
        void deleteAll();
    
        /**
         * Offers all URL queues.
         *
         * @param sessionId The session ID.
         * @param newUrlQueueList The list of new URL queues.
         */
        void offerAll(String sessionId, List<QUEUE> newUrlQueueList);
    
        /**
         * Polls a URL queue.
         *
         * @param sessionId The session ID.
    Registered: Sun Sep 21 03:50:09 UTC 2025
    - Last Modified: Sun Jul 06 02:13:03 UTC 2025
    - 2.6K bytes
    - Viewed (0)
  4. fess-crawler/src/main/java/org/codelibs/fess/crawler/helper/MemoryDataHelper.java

            super();
        }
    
        /**
         * Clears all URL queues and session data.
         */
        public void clear() {
            urlQueueMap.clear();
            sessionMap.clear();
        }
    
        /**
         * Returns the URL queue for the specified session ID.
         * Creates a new queue if one doesn't exist.
         * @param sessionId the session ID
         * @return the URL queue for the session
         */
    Registered: Sun Sep 21 03:50:09 UTC 2025
    - Last Modified: Sun Jul 06 02:13:03 UTC 2025
    - 8.1K bytes
    - Viewed (0)
  5. fess-crawler-opensearch/src/main/java/org/codelibs/fess/crawler/util/OpenSearchCrawlerConfig.java

            this.filterIndex = filterIndex;
        }
    
        /**
         * Returns the number of queue shards.
         * @return The number of queue shards.
         */
        public int getQueueShards() {
            return queueShards;
        }
    
        /**
         * Sets the number of queue shards.
         * @param queueShards The number of queue shards.
         */
        public void setQueueShards(final int queueShards) {
    Registered: Sun Sep 21 03:50:09 UTC 2025
    - Last Modified: Sun Jul 06 02:13:03 UTC 2025
    - 5.4K bytes
    - Viewed (0)
  6. fess-crawler-opensearch/src/main/resources/mapping/queue.json

    Shinsuke Sugaya <******@****.***> 1730954650 +0900
    Registered: Sun Sep 21 03:50:09 UTC 2025
    - Last Modified: Thu Nov 07 04:44:10 UTC 2024
    - 457 bytes
    - Viewed (0)
  7. fess-crawler/src/main/java/org/codelibs/fess/crawler/CrawlerThread.java

            }
            log(logHelper, LogType.FINISHED_THREAD, crawlerContext);
        }
    
        /**
         * Adds sitemaps from robots.txt to the crawling queue.
         * @param urlQueue The URL queue to add sitemaps to.
         */
        protected void addSitemapsFromRobotsTxt(final UrlQueue<?> urlQueue) {
            final String[] sitemaps = crawlerContext.removeSitemaps();
            if (sitemaps != null) {
    Registered: Sun Sep 21 03:50:09 UTC 2025
    - Last Modified: Thu Aug 07 02:55:08 UTC 2025
    - 20.4K bytes
    - Viewed (0)
  8. fess-crawler/src/main/java/org/codelibs/fess/crawler/Crawler.java

     *   crawler.close();
     * </pre>
     */
    public class Crawler implements Runnable, AutoCloseable {
    
        private static final Logger logger = LogManager.getLogger(Crawler.class);
    
        /**
         * Service for managing URL queues during crawling.
         */
        @Resource
        protected UrlQueueService<UrlQueue<?>> urlQueueService;
    
        /**
         * Service for managing access result data.
         */
        @Resource
    Registered: Sun Sep 21 03:50:09 UTC 2025
    - Last Modified: Sun Jul 06 02:13:03 UTC 2025
    - 14K bytes
    - Viewed (0)
  9. fess-crawler/src/main/java/org/codelibs/fess/crawler/entity/UrlQueue.java

    /**
     * The UrlQueue interface represents a queue of URLs to be processed by a web crawler.
     * It provides methods to get and set various properties of a URL queue entry.
     *
     * @param <IDTYPE> the type of the identifier for the URL queue entry
     */
    public interface UrlQueue<IDTYPE> {
    
        /**
         * Retrieves the unique identifier of the URL queue.
         *
         * @return the unique identifier of type IDTYPE.
         */
    Registered: Sun Sep 21 03:50:09 UTC 2025
    - Last Modified: Sat Mar 15 06:52:00 UTC 2025
    - 4.3K bytes
    - Viewed (0)
  10. fess-crawler/src/main/java/org/codelibs/fess/crawler/util/CrawlingParameterUtil.java

            return URL_QUEUE_THREAD_LOCAL.get();
        }
    
        /**
         * Sets the URL queue for the current thread. If the provided URL queue is null,
         * the URL queue for the current thread is removed.
         *
         * @param urlQueue the URL queue to be set for the current thread, or null to remove the URL queue
         */
        public static void setUrlQueue(final UrlQueue<?> urlQueue) {
            if (urlQueue == null) {
    Registered: Sun Sep 21 03:50:09 UTC 2025
    - Last Modified: Sat Mar 15 06:52:00 UTC 2025
    - 6.4K bytes
    - Viewed (0)
Back to top