Search Options

Results per page
Sort
Preferred Languages
Advance

Results 21 - 30 of 41 for dequeue (0.02 sec)

  1. .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)
  2. 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)
  3. 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)
  4. 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)
  5. 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.
         */
        @Override
    Registered: Sun Sep 21 03:50:09 UTC 2025
    - Last Modified: Sun Jul 06 02:13:03 UTC 2025
    - 3.1K bytes
    - Viewed (0)
  6. 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)
  7. 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)
  8. 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)
  9. .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.ts
    Registered: Wed Sep 10 11:36:15 UTC 2025
    - Last Modified: Mon Jun 17 13:58:59 UTC 2024
    - 482 bytes
    - Viewed (0)
  10. 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)
Back to top