Search Options

Results per page
Sort
Preferred Languages
Advance

Results 211 - 220 of 393 for queues (0.18 sec)

  1. 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)
  2. docs/throttle/README.md

    MinIO server allows to throttle incoming requests:
    
    - limit the number of active requests allowed across the cluster
    - limit the wait duration for each request in the queue
    
    These values are enabled using server's configuration or environment variables.
    
    ## Examples
    
    ### Configuring connection limit
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 16 08:43:49 UTC 2024
    - 1.5K bytes
    - Viewed (1)
  3. mockwebserver/src/main/kotlin/mockwebserver3/QueueDispatcher.kt

          logger.info("served $requestLine")
          return MockResponse(code = HttpURLConnection.HTTP_NOT_FOUND)
        }
    
        if (failFastResponse != null && responseQueue.peek() == null) {
          // Fail fast if there's no response queued up.
          return failFastResponse!!
        }
    
        val result = responseQueue.take()
    
        // If take() returned because we're shutting down, then enqueue another dead letter so that any
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Sat Jun 14 16:09:26 UTC 2025
    - 2.9K bytes
    - Viewed (0)
  4. mockwebserver/src/main/kotlin/mockwebserver3/MockWebServer.kt

        // Cause acceptConnections() to break out.
        serverSocket.closeQuietly()
    
        // Await shutdown.
        for (queue in taskRunner.activeQueues()) {
          if (!queue.idleLatch().await(5, TimeUnit.SECONDS)) {
            throw AssertionError("Gave up waiting for queue to shut down")
          }
        }
        taskRunnerBackend.shutdown()
      }
    
      private fun serveConnection(
        connectionIndex: Int,
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Sat Aug 02 20:36:00 UTC 2025
    - 40.3K bytes
    - Viewed (0)
  5. fess-crawler-opensearch/src/main/resources/crawler_opensearch.xml

    		<arg>crawlerConfig</arg>
    	</component>
    
    	<component name="crawlerConfig" class="org.codelibs.fess.crawler.util.OpenSearchCrawlerConfig">
    		<property name="queueIndex">"fess_crawler.queue"</property>
    		<property name="queueShards">5</property>
    		<property name="queueReplicas">1</property>
    		<property name="dataIndex">"fess_crawler.data"</property>
    		<property name="dataShards">5</property>
    Registered: Sun Sep 21 03:50:09 UTC 2025
    - Last Modified: Thu Nov 07 04:44:10 UTC 2024
    - 2.2K bytes
    - Viewed (0)
  6. docs/es/docs/tutorial/dependencies/classes-as-dependencies.md

    Entonces, si tienes un objeto `something` (que podría _no_ ser una función) y puedes "llamarlo" (ejecutarlo) como:
    
    ```Python
    something()
    ```
    
    o
    
    ```Python
    something(some_argument, some_keyword_argument="foo")
    ```
    
    entonces es un "callable".
    
    ## Clases como dependencias
    
    Puedes notar que para crear una instance de una clase en Python, utilizas esa misma sintaxis.
    
    Por ejemplo:
    
    Registered: Sun Sep 07 07:19:17 UTC 2025
    - Last Modified: Mon Dec 30 18:26:57 UTC 2024
    - 6.9K bytes
    - Viewed (0)
  7. src/main/webapp/js/jquery-3.7.1.min.js

    &&t||t&&!v(t)&&t};return ce.fx.off?r.duration=0:"number"!=typeof r.duration&&(r.duration in ce.fx.speeds?r.duration=ce.fx.speeds[r.duration]:r.duration=ce.fx.speeds._default),null!=r.queue&&!0!==r.queue||(r.queue="fx"),r.old=r.complete,r.complete=function(){v(r.old)&&r.old.call(this),r.queue&&ce.dequeue(this,r.queue)},r},ce.fn.extend({fadeTo:function(e,t,n,r){return this.filter(ee).css("opacity",0).show().end().animate({opacity:t},e,n,r)},animate:function(t,e,n,r){var i=ce.isEmptyObject(t),o=ce....
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Sat Oct 26 01:07:52 UTC 2024
    - 85.5K bytes
    - Viewed (0)
  8. cmd/metrics-v3-audit.go

    	auditFailedMessagesMD = NewCounterMD(auditFailedMessages,
    		"Total number of messages that failed to send since start",
    		targetID)
    	auditTargetQueueLengthMD = NewGaugeMD(auditTargetQueueLength,
    		"Number of unsent messages in queue for target",
    		targetID)
    	auditTotalMessagesMD = NewCounterMD(auditTotalMessages,
    		"Total number of messages sent since start",
    		targetID)
    )
    
    // loadAuditMetrics - `MetricsLoaderFn` for audit
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri May 10 14:50:39 UTC 2024
    - 1.9K bytes
    - Viewed (0)
  9. docs/es/docs/tutorial/testing.md

    /// info | Información
    
    Ten en cuenta que el `TestClient` recibe datos que pueden ser convertidos a JSON, no modelos de Pydantic.
    
    Si tienes un modelo de Pydantic en tu prueba y quieres enviar sus datos a la aplicación durante las pruebas, puedes usar el `jsonable_encoder` descrito en [Codificador Compatible con JSON](encoder.md){.internal-link target=_blank}.
    
    ///
    
    ## Ejecútalo
    
    Registered: Sun Sep 07 07:19:17 UTC 2025
    - Last Modified: Mon Dec 30 18:26:57 UTC 2024
    - 6.9K bytes
    - Viewed (0)
  10. 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)
Back to top