Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 266 for wait (0.23 sec)

  1. docs/throttle/README.md

    ### Configuring connection (wait) deadline
    
    This value works in conjunction with max connection setting, setting this value allows for long waiting requests to quickly time out when there is no slot available to perform the request.
    
    Plain Text
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Sat Feb 12 00:51:25 GMT 2022
    - 2.4K bytes
    - Viewed (0)
  2. mockwebserver/src/main/kotlin/mockwebserver3/Dispatcher.kt

    import okhttp3.ExperimentalOkHttpApi
    
    /** Handler for mock server requests. */
    @ExperimentalOkHttpApi
    abstract class Dispatcher {
      /**
       * Returns a response to satisfy `request`. This method may block (for instance, to wait on
       * a CountdownLatch).
       */
      @Throws(InterruptedException::class)
      abstract fun dispatch(request: RecordedRequest): MockResponse
    
      /**
    Plain Text
    - Registered: Fri Apr 26 11:42:10 GMT 2024
    - Last Modified: Tue Jan 23 14:31:42 GMT 2024
    - 1.7K bytes
    - Viewed (0)
  3. common-protos/k8s.io/api/coordination/v1/generated.proto

    message LeaseSpec {
      // holderIdentity contains the identity of the holder of a current lease.
      // +optional
      optional string holderIdentity = 1;
    
      // leaseDurationSeconds is a duration that candidates for a lease need
      // to wait to force acquire it. This is measure against time of last
      // observed renewTime.
      // +optional
      optional int32 leaseDurationSeconds = 2;
    
      // acquireTime is a time when the current lease was acquired.
      // +optional
    Plain Text
    - Registered: Wed May 01 22:53:12 GMT 2024
    - Last Modified: Mon Mar 11 18:43:24 GMT 2024
    - 2.6K bytes
    - Viewed (0)
  4. okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Stream.kt

        }
      }
    
      /**
       * Like [Object.wait], but throws an [InterruptedIOException] when interrupted instead of the more
       * awkward [InterruptedException].
       */
      @Throws(InterruptedIOException::class)
      internal fun waitForIo() {
        try {
          condition.await()
        } catch (_: InterruptedException) {
    Plain Text
    - Registered: Fri Apr 26 11:42:10 GMT 2024
    - Last Modified: Sat Apr 20 17:03:43 GMT 2024
    - 23.2K bytes
    - Viewed (1)
  5. okhttp/src/test/java/okhttp3/ConnectionCoalescingTest.kt

              call: Call,
              inetSocketAddress: InetSocketAddress,
              proxy: Proxy,
            ) {
              try {
                // Wait for request2 to guarantee we make 2 separate connections to the server.
                latch1.await()
              } catch (e: InterruptedException) {
                throw AssertionError(e)
              }
            }
    
            override fun connectionAcquired(
    Plain Text
    - Registered: Fri Apr 26 11:42:10 GMT 2024
    - Last Modified: Sat Jan 20 10:30:28 GMT 2024
    - 18.7K bytes
    - Viewed (0)
  6. okhttp/src/main/kotlin/okhttp3/ConnectionPool.kt

         * Connections will still be closed if they idle beyond the keep-alive but will be replaced.
         */
        @JvmField val minimumConcurrentCalls: Int = 0,
        /** How long to wait to retry pre-emptive connection attempts that fail. */
        @JvmField val backoffDelayMillis: Long = 60 * 1000,
        /** How much jitter to introduce in connection retry backoff delays */
    Plain Text
    - Registered: Fri Apr 26 11:42:10 GMT 2024
    - Last Modified: Wed Apr 03 20:39:41 GMT 2024
    - 5.6K bytes
    - Viewed (0)
  7. docs/config/README.md

    ~ mc admin config set alias/ scanner
    KEY:
    scanner  manage namespace scanning for usage calculation, lifecycle, healing and more
    
    ARGS:
    delay     (float)     scanner delay multiplier, defaults to '10.0'
    max_wait  (duration)  maximum wait time between operations, defaults to '15s'
    cycle     (duration)  time duration between scanner cycles
    ```
    
    Plain Text
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Mon Sep 11 21:48:54 GMT 2023
    - 17.7K bytes
    - Viewed (0)
  8. helm/minio/templates/_helper_create_svcacct.txt

    # Special characters for example : ',",<,>,{,}
    MINIO_ACCESSKEY_SECRETKEY_TMP="/tmp/accessKey_and_secretKey_svcacct_tmp"
    
    # connectToMinio
    # Use a check-sleep-check loop to wait for MinIO service to be available
    connectToMinio() {
      SCHEME=$1
      ATTEMPTS=0 ; LIMIT=29 ; # Allow 30 attempts
      set -e ; # fail if we can't read the keys.
    Plain Text
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Thu Mar 28 23:20:50 GMT 2024
    - 3.4K bytes
    - Viewed (0)
  9. mockwebserver/src/main/kotlin/mockwebserver3/MockWebServer.kt

      /**
       * Awaits the next HTTP request (waiting up to the specified wait time if necessary), removes it,
       * and returns it. Callers should use this to verify the request was sent as intended within the
       * given time.
       *
       * @param timeout how long to wait before giving up, in units of [unit]
       * @param unit a [TimeUnit] determining how to interpret the [timeout] parameter
    Plain Text
    - Registered: Fri Apr 26 11:42:10 GMT 2024
    - Last Modified: Sun Mar 31 17:16:15 GMT 2024
    - 37.4K bytes
    - Viewed (0)
  10. helm/minio/templates/_helper_custom_command.txt

    MC_CONFIG_DIR="{{ .Values.configPathmc }}"
    MC="/usr/bin/mc --insecure --config-dir ${MC_CONFIG_DIR}"
    {{- else }}
    MC="/usr/bin/mc --insecure"
    {{- end }}
    
    # connectToMinio
    # Use a check-sleep-check loop to wait for MinIO service to be available
    connectToMinio() {
      SCHEME=$1
      ATTEMPTS=0 ; LIMIT=29 ; # Allow 30 attempts
      set -e ; # fail if we can't read the keys.
    Plain Text
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Sat Feb 19 20:34:14 GMT 2022
    - 1.4K bytes
    - Viewed (0)
Back to top