Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 6 of 6 for offerAll (0.06 seconds)

  1. 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);
            }
    Created: Sun Apr 12 03:50:13 GMT 2026
    - Last Modified: Thu Nov 20 08:40:57 GMT 2025
    - 16.9K bytes
    - Click Count (1)
  2. 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;
            }
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Fri Mar 13 23:01:26 GMT 2026
    - 33.6K bytes
    - Click Count (0)
  3. fess-crawler-opensearch/src/test/java/org/codelibs/fess/crawler/service/impl/OpenSearchUrlQueueServiceTest.java

                urlQueue.setSessionId(sessionId);
                urlQueue.setUrl("http://www.example.com/page" + i);
                urlQueueList.add(urlQueue);
            }
    
            urlQueueService.offerAll(sessionId, urlQueueList);
    
            // Poll all items
            int count = 0;
            while (true) {
                final OpenSearchUrlQueue polled = urlQueueService.poll(sessionId);
                if (polled == null) {
    Created: Sun Apr 12 03:50:13 GMT 2026
    - Last Modified: Wed Jan 14 23:48:16 GMT 2026
    - 14.5K bytes
    - Click Count (0)
  4. 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.
    Created: Sun Apr 12 03:50:13 GMT 2026
    - Last Modified: Wed Dec 31 09:07:38 GMT 2025
    - 20.3K bytes
    - Click Count (0)
  5. android/guava/src/com/google/common/collect/Ordering.java

            list.subList(k, list.size()).clear();
          }
          list.trimToSize();
          return unmodifiableList(list);
        } else {
          TopKSelector<E> selector = TopKSelector.least(k, this);
          selector.offerAll(iterator);
          return selector.topK();
        }
      }
    
      /**
       * Returns the {@code k} greatest elements of the given iterable according to this ordering, in
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Feb 23 19:19:10 GMT 2026
    - 39.4K bytes
    - Click Count (0)
  6. guava/src/com/google/common/collect/Ordering.java

            list.subList(k, list.size()).clear();
          }
          list.trimToSize();
          return unmodifiableList(list);
        } else {
          TopKSelector<E> selector = TopKSelector.least(k, this);
          selector.offerAll(iterator);
          return selector.topK();
        }
      }
    
      /**
       * Returns the {@code k} greatest elements of the given iterable according to this ordering, in
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Feb 23 19:19:10 GMT 2026
    - 39.4K bytes
    - Click Count (0)
Back to Top