- Sort Score
- Result 10 results
- Languages All
Results 1 - 7 of 7 for offerAll (0.08 sec)
-
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) -
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) -
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) -
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) -
fess-crawler/src/main/java/org/codelibs/fess/crawler/CrawlerThread.java
Registered: Sun Sep 21 03:50:09 UTC 2025 - Last Modified: Thu Aug 07 02:55:08 UTC 2025 - 20.4K bytes - Viewed (0) -
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) -
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)