Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 5 of 5 for offerAll (0.03 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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