- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 41 for dequeue (0.02 sec)
-
.teamcity/src/main/kotlin/configurations/GitHubMergeQueueCheckPass.kt
) : BaseGradleBuildType(init = { id("${model.projectId}_GitHubMergeQueueCheckPass") uuid = "${DslContext.uuidPrefix}_${model.projectId}_GitHubMergeQueueCheckPass" name = "GitHub Merge Queue Check Pass" type = Type.COMPOSITE vcs { root(AbsoluteId(VersionedSettingsBranch.fromDslContext().vcsRootId())) checkoutMode = CheckoutMode.ON_AGENT }
Registered: Wed Sep 10 11:36:15 UTC 2025 - Last Modified: Wed Feb 12 09:12:03 UTC 2025 - 1.7K bytes - Viewed (0) -
fess-crawler/src/main/java/org/codelibs/fess/crawler/log/LogType.java
/** Indicates an access exception during crawling. */ CRAWLING_ACCESS_EXCEPTION, /** Indicates a general exception during crawling. */ CRAWLING_EXCEPTION, /** Indicates no URL is available in the queue. */ NO_URL_IN_QUEUE, /** Indicates the start of a crawler thread. */ START_THREAD, /** Indicates the finish of a crawler thread. */ FINISHED_THREAD,Registered: Sun Sep 21 03:50:09 UTC 2025 - Last Modified: Sun Jul 06 02:13:03 UTC 2025 - 2.4K bytes - Viewed (0) -
fess-crawler/src/main/java/org/codelibs/fess/crawler/interval/IntervalController.java
* <li>{@code PRE_PROCESSING} - Represents the pre-processing state.</li> * <li>{@code POST_PROCESSING} - Represents the post-processing state.</li> * <li>{@code NO_URL_IN_QUEUE} - Indicates that there are no URLs in the queue.</li> * <li>{@code WAIT_NEW_URL} - Indicates that the crawler is waiting for new URLs.</li> * </ul> */ public interface IntervalController { /** Constant representing the pre-processing state. */
Registered: Sun Sep 21 03:50:09 UTC 2025 - Last Modified: Sun Jul 06 02:13:03 UTC 2025 - 1.8K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/suggest/concurrent/Deferred.java
} private RESPONSE response = null; private Throwable error = null; private final Promise promise = new Promise(); private final Queue<Consumer<RESPONSE>> doneCallbacks = new LinkedBlockingQueue<>(); private final Queue<Consumer<Throwable>> errorCallbacks = new LinkedBlockingQueue<>(); private final CountDownLatch latch = new CountDownLatch(1); /**Registered: Fri Sep 19 09:08:11 UTC 2025 - Last Modified: Fri Jul 04 14:00:23 UTC 2025 - 7.8K bytes - Viewed (0) -
fess-crawler-opensearch/src/main/java/org/codelibs/fess/crawler/entity/OpenSearchUrlQueue.java
*/ public static final String WEIGHT = "weight"; /** * Converts this URL queue entry to XContent format for OpenSearch indexing. * * @param builder The XContentBuilder to write to. * @param params Additional parameters for the conversion. * @return The XContentBuilder with the URL queue data. * @throws IOException if the conversion fails. */ @OverrideRegistered: Sun Sep 21 03:50:09 UTC 2025 - Last Modified: Sun Jul 06 02:13:03 UTC 2025 - 3.1K bytes - Viewed (0) -
fess-crawler/src/main/java/org/codelibs/fess/crawler/interval/impl/DefaultIntervalController.java
* and when waiting for new URLs. * The delays are configurable via constructor parameters. * */ public class DefaultIntervalController extends AbstractIntervalController { /** Delay in milliseconds after processing a URL */ protected long delayMillisAfterProcessing = 0L; /** Delay in milliseconds when no URL is in the queue */Registered: Sun Sep 21 03:50:09 UTC 2025 - Last Modified: Sun Jul 06 02:13:03 UTC 2025 - 3.4K bytes - Viewed (0) -
fess-crawler/src/main/java/org/codelibs/fess/crawler/helper/impl/LogHelperImpl.java
* <li>Getting content</li> * <li>Handling redirects</li> * <li>Processing responses</li> * <li>Handling exceptions during crawling and child URL processing</li> * <li>Handling cases where no URL is in the queue</li> * <li>Handling cases where no response processor or rule is found</li> * <li>Handling system errors</li> * </ul> * * <p> * Each logging method checks the log level before logging the message.
Registered: Sun Sep 21 03:50:09 UTC 2025 - Last Modified: Sun Jul 06 02:13:03 UTC 2025 - 14K bytes - Viewed (0) -
fess-crawler/src/main/java/org/codelibs/fess/crawler/client/ftp/FtpClient.java
/** * The FTP client configuration. */ protected FTPClientConfig ftpClientConfig; /** * The queue of FTPClient instances. */ protected final Queue<FTPClient> ftpClientQueue = new ConcurrentLinkedQueue<>(); /** * The active external host. */ protected String activeExternalHost; /**Registered: Sun Sep 21 03:50:09 UTC 2025 - Last Modified: Sun Jul 06 02:13:03 UTC 2025 - 39.5K bytes - Viewed (0) -
.github/workflows/feedback.yml
jobs: feedback: permissions: issues: write pull-requests: write runs-on: ubuntu-latest steps: # Feedback loop: ask for something on PR/Issue and close if not provided or return to the queue on update. # https://github.com/gradle/issue-management-action/blob/main/src/feedback.tsRegistered: Wed Sep 10 11:36:15 UTC 2025 - Last Modified: Mon Jun 17 13:58:59 UTC 2024 - 482 bytes - Viewed (0) -
CODE_OF_CONDUCT.md
## Conflict Resolution Conflicts in an open source project can take many forms, from someone having a bad day and using harsh and hurtful language in the issue queue, to more serious instances such as sexist/racist statements or threats of violence, and everything in between. If the behavior is threatening or harassing, or for other reasons requires immediate escalation, please see below.
Registered: Tue Sep 09 12:39:10 UTC 2025 - Last Modified: Fri Feb 05 18:43:16 UTC 2021 - 5.2K bytes - Viewed (0)