Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 34 for Fresh (0.03 sec)

  1. guava/src/com/google/common/util/concurrent/SmoothRateLimiter.java

       * acquire(10) request arriving. We serve the request partly from storedPermits, using all the
       * remaining 7.0 permits, and the remaining 3.0, we serve them by fresh permits produced by the
       * rate limiter.
       *
       * We already know how much time it takes to serve 3 fresh permits: if the rate is
       * "1 token per second", then this will take 3 seconds. But what does it mean to serve 7 stored
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Tue Apr 04 09:45:04 UTC 2023
    - 19.3K bytes
    - Viewed (0)
  2. okhttp/src/test/java/okhttp3/ConnectionCoalescingTest.kt

        assertThat(client.connectionPool.connectionCount()).isEqualTo(2)
        assertThat(server.takeRequest().sequenceNumber)
          .isEqualTo(0) // Fresh connection.
        assertThat(server.takeRequest().sequenceNumber)
          .isEqualTo(0) // Fresh connection.
      }
    
      /**
       * Check we would use an existing connection to a later DNS result instead of connecting to the
       * first DNS result for the first time.
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Jan 20 10:30:28 UTC 2024
    - 18.7K bytes
    - Viewed (0)
  3. okhttp-dnsoverhttps/src/test/java/okhttp3/dnsoverhttps/DnsOverHttpsTest.kt

          assertThat(ioe.cause!!).isInstanceOf<EOFException>()
        }
      }
    
      // TODO GET preferred order - with tests to confirm this
      // 1. successful fresh cached GET response
      // 2. unsuccessful (404, 500) fresh cached GET response
      // 3. successful network response
      // 4. successful stale cached GET response
      // 5. unsuccessful response
      @Test
      fun usesCache() {
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Wed Apr 10 19:46:48 UTC 2024
    - 11K bytes
    - Viewed (0)
  4. cmd/prepare-storage.go

    			return storageDisks, format, nil
    		}
    
    		tries++
    		switch {
    		case errors.Is(err, errNotFirstDisk):
    			// Fresh setup, wait for first server to be up.
    			logger.Info("Waiting for the first server to format the drives (elapsed %s)\n", getElapsedTime())
    		case errors.Is(err, errFirstDiskWait):
    			// Fresh setup, wait for other servers to come up.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jul 12 20:51:54 UTC 2024
    - 11.1K bytes
    - Viewed (1)
  5. cmd/format-erasure.go

    		Version string `json:"version"` // Version of 'xl' format.
    		Disk    string `json:"drive"`   // Disk field carries assigned disk uuid.
    		// JBOD field carries the input disk order generated the first
    		// time when fresh disks were supplied.
    		JBOD []string `json:"jbod"`
    	} `json:"xl"` // Erasure field holds xl format.
    }
    
    // Represents the V2 backend disk structure version
    // under `.minio.sys` and actual data namespace.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 23.2K bytes
    - Viewed (0)
  6. okhttp/src/main/kotlin/okhttp3/internal/connection/RealConnection.kt

      internal fun connectFailed(
        client: OkHttpClient,
        failedRoute: Route,
        failure: IOException,
      ) {
        // Tell the proxy selector when we fail to connect on a fresh connection.
        if (failedRoute.proxy.type() != Proxy.Type.DIRECT) {
          val address = failedRoute.address
          address.proxySelector.connectFailed(
            address.url.toUri(),
            failedRoute.proxy.address(),
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Apr 20 17:03:43 UTC 2024
    - 15.4K bytes
    - Viewed (0)
  7. okhttp/src/main/kotlin/okhttp3/CacheControl.kt

          this.maxStaleSeconds = maxStaleSecondsLong.commonClampToInt()
        }
    
        /**
         * Sets the minimum number of seconds that a response will continue to be fresh for. If the
         * response will be stale when [minFresh] have elapsed, the cached response will not be used and
         * a network request will be made.
         *
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Apr 15 13:41:01 UTC 2024
    - 10K bytes
    - Viewed (0)
  8. okhttp/src/main/kotlin/okhttp3/internal/cache/CacheStrategy.kt

              .headers(conditionalRequestHeaders.build())
              .build()
          return CacheStrategy(conditionalRequest, cacheResponse)
        }
    
        /**
         * Returns the number of milliseconds that the response was fresh for, starting from the served
         * date.
         */
        private fun computeFreshnessLifetime(): Long {
          val responseCaching = cacheResponse!!.cacheControl
          if (responseCaching.maxAgeSeconds != -1) {
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Apr 15 13:24:48 UTC 2024
    - 12K bytes
    - Viewed (0)
  9. cmd/storage-datatypes.go

    	Data []byte `msg:"d,allownil"` // optionally carries object data
    
    	NumVersions      int       `msg:"nv"`
    	SuccessorModTime time.Time `msg:"smt"`
    
    	Fresh bool `msg:"fr"` // indicates this is a first time call to write FileInfo.
    
    	// Position of this version or object in a multi-object delete call,
    	// no other caller must set this value other than multi-object delete call.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 22 15:30:50 UTC 2024
    - 17.3K bytes
    - Viewed (0)
  10. android-test/src/androidTest/java/okhttp/android/test/OkHttpTest.kt

          val clientCertificates =
            HandshakeCertificates.Builder()
              .addPlatformTrustedCertificates()
              .addInsecureHost(server.hostName)
              .build()
    
          // Need fresh client to reset sslSocketFactoryOrNull
          client =
            OkHttpClient.Builder()
              .eventListenerFactory(
                clientTestRule.wrap(
                  object : EventListener() {
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Jan 20 10:30:28 UTC 2024
    - 27K bytes
    - Viewed (0)
Back to top