Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 17 for sleeps (0.04 sec)

  1. android/guava-tests/test/com/google/common/io/testdata/alice_in_wonderland.txt

    like what I get" is the same thing as "I get what I like"!'
    
      `You might just as well say,' added the Dormouse, who seemed to
    be talking in his sleep, `that "I breathe when I sleep" is the
    same thing as "I sleep when I breathe"!'
    
      `It IS the same thing with you,' said the Hatter, and here the
    conversation dropped, and the party sat silent for a minute,
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Fri Apr 21 02:27:51 UTC 2017
    - 145.2K bytes
    - Viewed (0)
  2. docs/metrics/prometheus/grafana/bucket/minio-bucket.json

            "type": "prometheus",
            "uid": "${DS_PROMETHEUS}"
          },
          "fieldConfig": {
            "defaults": {
              "mappings": [],
              "thresholds": {
                "mode": "absolute",
                "steps": [
                  {
                    "color": "green",
                    "value": null
                  },
                  {
                    "color": "semi-dark-red",
                    "value": 80
                  }
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Mon Aug 04 01:46:49 UTC 2025
    - 101.9K bytes
    - Viewed (0)
  3. cmd/bucket-replication.go

    			<-ctx.Done()
    			return
    		}
    		duration := max(time.Duration(r.Float64()*float64(time.Minute)),
    			// Make sure to sleep at least a second to avoid high CPU ticks.
    			time.Second)
    		time.Sleep(duration)
    	}
    }
    
    // Loads bucket replication resync statuses into memory.
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 118K bytes
    - Viewed (0)
  4. okhttp/src/jvmTest/kotlin/okhttp3/CallTest.kt

        val request1ReceivedAt = System.currentTimeMillis()
        assertThat(server.takeRequest().headers["If-None-Match"]).isNull()
    
        // Hit that stored response. It's different, but Vary says it doesn't matter.
        Thread.sleep(10) // Make sure the timestamps are unique.
        val cacheHit =
          executeSynchronously(
            "/",
            "Accept-Language",
            "en-US",
            "Accept-Charset",
            "UTF-8",
          )
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Thu Jul 31 04:18:40 UTC 2025
    - 146.6K bytes
    - Viewed (0)
  5. guava/src/com/google/common/util/concurrent/ClosingFuture.java

     *
     * <h3>Derived steps</h3>
     *
     * A {@code ClosingFuture} step can be derived from one or more input {@code ClosingFuture} steps in
     * ways similar to {@link FluentFuture}s:
     *
     * <ul>
     *   <li>by transforming the value from a successful input step,
     *   <li>by catching the exception from a failed input step, or
     *   <li>by combining the results of several input steps.
     * </ul>
     *
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Wed Jul 23 15:26:56 UTC 2025
    - 98.1K bytes
    - Viewed (0)
  6. okhttp/src/jvmTest/kotlin/okhttp3/URLConnectionTest.kt

        assertThat(server.takeRequest().exchangeIndex).isEqualTo(0)
    
        // Give the server time to enact the socket policy if it's one that could happen after the
        // client has received the response.
        Thread.sleep(500)
        val response2 = getResponse(newRequest("/b"))
        response1.body
          .source()
          .timeout()
          .timeout(100, TimeUnit.MILLISECONDS)
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Sat Jun 21 20:36:35 UTC 2025
    - 133.2K bytes
    - Viewed (0)
  7. cmd/object-handlers.go

    		objInfo.ETag = origETag
    		enqueueTransitionImmediate(objInfo, lcEventSrc_s3CopyObject)
    		// Remove the transitioned object whose object version is being overwritten.
    		os.Sweep()
    	}
    }
    
    // PutObjectHandler - PUT Object
    // ----------
    // This implementation of the PUT operation adds an object to a bucket.
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Sun Sep 07 16:13:09 UTC 2025
    - 120.6K bytes
    - Viewed (0)
  8. okhttp/src/jvmTest/kotlin/okhttp3/CacheTest.kt

        assertThat(response1.header("Allow")).isNull()
        assertThat((response1.receivedResponseAtMillis - t0).toDouble()).isCloseTo(0.0, 250.0)
    
        // A conditional cache hit updates the cache.
        Thread.sleep(500) // Make sure t0 and t1 are distinct.
        val t1 = System.currentTimeMillis()
        val response2 = get(server.url("/a"))
        assertThat(response2.code).isEqualTo(HttpURLConnection.HTTP_OK)
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Sat Aug 16 09:39:51 UTC 2025
    - 113.6K bytes
    - Viewed (0)
  9. src/main/java/jcifs/smb/SmbFile.java

                if (isRetryableException(e) && shouldRetryConnection()) {
                    log.debug("Retrying tree connection after transient failure", e);
                    try {
                        Thread.sleep(100); // Brief delay before retry
                        this.treeHandle = this.treeConnection.connectWrapException(this.fileLocator);
                        if (this.fileLocator.getURL().getPath().contains("\\")) {
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 30 05:58:03 UTC 2025
    - 103.2K bytes
    - Viewed (0)
  10. src/main/java/org/codelibs/fess/opensearch/client/SearchEngineClient.java

                } else if (logger.isDebugEnabled()) {
                    logger.debug("[{}] Failed to access to Fesen ({})", i, SystemUtil.getSearchEngineHttpAddress(), cause);
                }
                ThreadUtil.sleep(1000L);
            }
            final String message =
                    "Fesen (" + SystemUtil.getSearchEngineHttpAddress() + ") is not available. Check the state of your Fesen cluster ("
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Sun Aug 31 08:19:00 UTC 2025
    - 121.9K bytes
    - Viewed (0)
Back to top