Search Options

Results per page
Sort
Preferred Languages
Advance

Results 21 - 30 of 417 for timeouts (0.21 sec)

  1. internal/dsync/dsync-client_test.go

    		ReadBufferSize:        32 << 10, // 32KiB moving up from 4KiB default
    		IdleConnTimeout:       15 * time.Second,
    		ResponseHeaderTimeout: 15 * time.Minute, // Set conservative timeouts for MinIO internode.
    		TLSHandshakeTimeout:   15 * time.Second,
    		ExpectContinueTimeout: 15 * time.Second,
    		// Go net/http automatically unzip if content-type is
    		// gzip disable this feature, as we are always interested
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Jan 20 17:36:09 UTC 2022
    - 4.4K bytes
    - Viewed (0)
  2. okhttp/src/test/java/okhttp3/InterceptorTest.kt

        val call = client.newCall(request1)
        assertFailsWith<IllegalStateException> {
          call.execute()
        }.also { expected ->
          assertThat(expected.message)
            .isEqualTo("Timeouts can't be adjusted in a network interceptor")
        }
      }
    
      @Test
      fun networkInterceptorCannotChangeWriteTimeout() {
        addInterceptor(true) { chain: Interceptor.Chain ->
          chain.withWriteTimeout(
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sun Jan 14 10:20:09 UTC 2024
    - 27.8K bytes
    - Viewed (0)
  3. docs/recipes.md

            }
          }
        ```
    
    ### Timeouts ([.kt][ConfigureTimeoutsKotlin], [.java][ConfigureTimeoutsJava])
    
    Use timeouts to fail a call when its peer is unreachable. Network partitions can be due to client connectivity problems, server availability problems, or anything between. OkHttp supports connect, write, read, and full call timeouts.
    
    === ":material-language-kotlin: Kotlin"
        ```kotlin
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Fri Feb 18 08:52:22 UTC 2022
    - 40.2K bytes
    - Viewed (0)
  4. cmd/metrics-v3-system-drive.go

    	driveTimeoutErrorsMD = NewCounterMD(driveTimeoutErrorsTotal,
    		"Total timeout errors on a drive", allDriveLabels...)
    	driveIOErrorsMD = NewCounterMD(driveIOErrorsTotal,
    		"Total I/O errors on a drive", allDriveLabels...)
    	driveAvailabilityErrorsMD = NewCounterMD(driveAvailabilityErrorsTotal,
    		"Total availability errors (I/O errors, timeouts) on a drive",
    		allDriveLabels...)
    	driveWaitingIOMD = NewGaugeMD(driveWaitingIO,
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun May 12 17:23:50 UTC 2024
    - 7.9K bytes
    - Viewed (0)
  5. okhttp/src/main/kotlin/okhttp3/internal/http1/Http1ExchangeCodec.kt

      }
    
      /**
       * Sets the delegate of `timeout` to [Timeout.NONE] and resets its underlying timeout
       * to the default configuration. Use this to avoid unexpected sharing of timeouts between pooled
       * connections.
       */
      private fun detachTimeout(timeout: ForwardingTimeout) {
        val oldDelegate = timeout.delegate
        timeout.setDelegate(Timeout.NONE)
        oldDelegate.clearDeadline()
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 16.2K bytes
    - Viewed (0)
  6. mockwebserver/README.md

        .addHeader("Content-Type", "application/json; charset=utf-8")
        .addHeader("Cache-Control", "no-cache")
        .setBody("{}");
    ```
    
    MockResponse can be used to simulate a slow network. This is useful for
    testing timeouts and interactive testing.
    
    ```java
    response.throttleBody(1024, 1, TimeUnit.SECONDS);
    ```
    
    
    #### RecordedRequest
    
    Verify requests by their method, path, HTTP version, body, and headers.
    
    ```java
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sun Dec 17 15:34:10 UTC 2023
    - 5K bytes
    - Viewed (0)
  7. cmd/namespace-lock.go

    // Lock - block until write lock is taken or timeout has occurred.
    func (di *distLockInstance) GetLock(ctx context.Context, timeout *dynamicTimeout) (LockContext, error) {
    	lockSource := getSource(2)
    	start := UTCNow()
    
    	newCtx, cancel := context.WithCancel(ctx)
    	if !di.rwMutex.GetLock(newCtx, cancel, di.opsID, lockSource, dsync.Options{
    		Timeout:       timeout.Timeout(),
    		RetryInterval: timeout.RetryInterval(),
    	}) {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Sep 29 22:40:36 UTC 2024
    - 9.2K bytes
    - Viewed (0)
  8. docs/features/interceptors.md

     * Permitted to short-circuit and not call `Chain.proceed()`.
     * Permitted to retry and make multiple calls to `Chain.proceed()`.
     * Can adjust Call timeouts using withConnectTimeout, withReadTimeout, withWriteTimeout.
    
    **Network Interceptors**
    
     * Able to operate on intermediate responses like redirects and retries.
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sun Feb 06 02:19:09 UTC 2022
    - 8.1K bytes
    - Viewed (0)
  9. docs/changelogs/changelog_3x.md

     *  Fix: Don't leak a connection when a call is canceled immediately preceding the `onFailure()`
        callback.
    
     *  Fix: Apply call timeouts when connecting duplex calls, web sockets, and server-sent events.
        Once the streams are established no further timeout is enforced.
    
     *  Fix: Retain the `Route` when a connection is reused on a redirect or other follow-up. This was
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sun Feb 06 14:55:54 UTC 2022
    - 50.8K bytes
    - Viewed (0)
  10. okhttp/src/main/kotlin/okhttp3/internal/cache2/Relay.kt

            return bytesRead
          } finally {
            synchronized(this@Relay) {
              upstreamReader = null
              ******@****.***All()
            }
          }
        }
    
        override fun timeout(): Timeout = timeout
    
        @Throws(IOException::class)
        override fun close() {
          if (fileOperator == null) return // Already closed.
          fileOperator = null
    
          var fileToClose: RandomAccessFile? = null
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 11.8K bytes
    - Viewed (0)
Back to top