Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 7 of 7 for offerAll (0.08 sec)

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

            dataHelper.clearUrlQueueList();
        }
    
        /*
         * (non-Javadoc)
         *
         * @see org.codelibs.fess.crawler.service.UrlQueueService#offerAll(java.lang.String,
         * java.util.List)
         */
        @Override
        public void offerAll(final String sessionId, final List<UrlQueueImpl<Long>> newUrlQueueList) {
            final Queue<UrlQueueImpl<Long>> urlQueueList = dataHelper.getUrlQueueList(sessionId);
    Registered: Sun Sep 21 03:50:09 UTC 2025
    - Last Modified: Sun Jul 06 02:13:03 UTC 2025
    - 9.3K bytes
    - Viewed (0)
  2. fess-crawler/src/main/java/org/codelibs/fess/crawler/processor/impl/DefaultResponseProcessor.java

                    crawlerContext.decrementAndGetAccessCount();
                    final List<UrlQueue<?>> newUrlQueueList = new ArrayList<>();
                    newUrlQueueList.add(urlQueue);
                    urlQueueService.offerAll(crawlerContext.getSessionId(), newUrlQueueList);
                }
            } else if (logger.isDebugEnabled()) {
                logger.debug("Visited urlQueue: {}", urlQueue);
            }
        }
    
        /**
    Registered: Sun Sep 21 03:50:09 UTC 2025
    - Last Modified: Thu Aug 07 02:55:08 UTC 2025
    - 12.5K bytes
    - Viewed (0)
  3. guava/src/com/google/common/collect/TopKSelector.java

       * {@link Ordering#leastOf(Iterable, int)}, which provides a simpler API for that use case.
       */
      public void offerAll(Iterable<? extends T> elements) {
        offerAll(elements.iterator());
      }
    
      /**
       * Adds each member of {@code elements} as a candidate for the top {@code k} elements. This
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Sun Aug 31 13:15:26 UTC 2025
    - 11.4K bytes
    - Viewed (0)
  4. fess-crawler/src/main/java/org/codelibs/fess/crawler/service/UrlQueueService.java

         */
        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.
         * @return The URL queue.
         */
        QUEUE poll(String sessionId);
    
    Registered: Sun Sep 21 03:50:09 UTC 2025
    - Last Modified: Sun Jul 06 02:13:03 UTC 2025
    - 2.6K bytes
    - Viewed (0)
  5. fess-crawler/src/main/java/org/codelibs/fess/crawler/CrawlerThread.java

                        uq.setUrl(d.getUrl());
                        uq.setWeight(d.getWeight());
                        return uq;
                    })
                    .collect(Collectors.toList());
            urlQueueService.offerAll(crawlerContext.sessionId, childList);
        }
    
        /**
         * Stores a single child URL to the crawling queue.
         * @param childUrl The child URL to store.
         * @param parentUrl The parent URL.
    Registered: Sun Sep 21 03:50:09 UTC 2025
    - Last Modified: Thu Aug 07 02:55:08 UTC 2025
    - 20.4K bytes
    - Viewed (0)
  6. fess-crawler-opensearch/src/main/java/org/codelibs/fess/crawler/service/impl/OpenSearchUrlQueueService.java

         * Only URLs that don't already exist will be added.
         *
         * @param sessionId The session ID.
         * @param urlQueueList The list of URL queue entries to offer.
         */
        @Override
        public void offerAll(final String sessionId, final List<OpenSearchUrlQueue> urlQueueList) {
            if (logger.isDebugEnabled()) {
                logger.debug("Offering URL: Session ID: {}, UrlQueue: {}", sessionId, urlQueueList);
            }
    Registered: Sun Sep 21 03:50:09 UTC 2025
    - Last Modified: Thu Aug 07 02:55:08 UTC 2025
    - 17K bytes
    - Viewed (0)
  7. src/test/java/org/codelibs/fess/indexer/IndexUpdaterTest.java

                // Do nothing in test
            }
    
            @Override
            public void deleteAll() {
                // Do nothing in test
            }
    
            @Override
            public void offerAll(String sessionId, List<OpenSearchUrlQueue> list) {
                // Do nothing in test
            }
    
            @Override
            public OpenSearchUrlQueue poll(String sessionId) {
                return null;
            }
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Tue Aug 19 14:09:36 UTC 2025
    - 33K bytes
    - Viewed (0)
Back to top