Search Options

Results per page
Sort
Preferred Languages
Advance

Results 271 - 280 of 326 for isDeep (0.09 sec)

  1. helm-releases/minio-2.0.0.tgz

    in the event of a failed command. {{- if .Values.configPathmc }} 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. ACCESS=$(cat /config/rootUser) ; SECRET=$(cat /config/rootPassword) ; set +e ;...
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 26 07:36:46 UTC 2021
    - 13.6K bytes
    - Viewed (0)
  2. okhttp/src/test/java/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 Nov 01 11:42:11 UTC 2024
    - Last Modified: Wed Apr 10 19:46:48 UTC 2024
    - 142.5K bytes
    - Viewed (0)
  3. android/guava-tests/test/com/google/common/util/concurrent/RateLimiterTest.java

      }
    
      /**
       * The stopwatch gathers events and presents them as strings. R0.6 means a delay of 0.6 seconds
       * caused by the (R)ateLimiter U1.0 means the (U)ser caused the stopwatch to sleep for a second.
       */
      static class FakeStopwatch extends SleepingStopwatch {
        long instant = 0L;
        final List<String> events = Lists.newArrayList();
    
        @Override
        public long readMicros() {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Mon Oct 21 14:28:19 UTC 2024
    - 21.8K bytes
    - Viewed (0)
  4. guava-tests/test/com/google/common/util/concurrent/RateLimiterTest.java

      }
    
      /**
       * The stopwatch gathers events and presents them as strings. R0.6 means a delay of 0.6 seconds
       * caused by the (R)ateLimiter U1.0 means the (U)ser caused the stopwatch to sleep for a second.
       */
      static class FakeStopwatch extends SleepingStopwatch {
        long instant = 0L;
        final List<String> events = Lists.newArrayList();
    
        @Override
        public long readMicros() {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Mon Oct 21 14:28:19 UTC 2024
    - 21.8K bytes
    - Viewed (0)
  5. okhttp/src/test/java/okhttp3/URLConnectionTest.kt

        assertThat(server.takeRequest().sequenceNumber).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)
        assertContent("This comes after a busted connection", response2)
    
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Jan 20 10:30:28 UTC 2024
    - 131.7K bytes
    - Viewed (0)
  6. src/main/java/org/codelibs/fess/exec/Crawler.java

                        String command;
                        while (true) {
                            try {
                                while (!reader.ready()) {
                                    ThreadUtil.sleep(1000L);
                                }
                                command = reader.readLine().trim();
                                if (logger.isDebugEnabled()) {
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Fri Oct 11 21:20:39 UTC 2024
    - 24K bytes
    - Viewed (0)
  7. cmd/signature-v4-utils_test.go

    	}
    
    	_, err = globalIAMSys.PolicyDBSet(ctx, ucreds.AccessKey, "consoleAdmin", regUser, false)
    	if err != nil {
    		t.Fatalf("unable to attach policy to credential, %s", err)
    	}
    
    	time.Sleep(4 * time.Second)
    
    	policies, err := globalIAMSys.PolicyDBGet(ucreds.AccessKey)
    	if err != nil {
    		t.Fatalf("unable to get policy to credential, %s", err)
    	}
    
    	if len(policies) == 0 {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Apr 05 21:26:41 UTC 2024
    - 14.3K bytes
    - Viewed (0)
  8. cmd/erasure-sets.go

    func (s *erasureSets) monitorAndConnectEndpoints(ctx context.Context, monitorInterval time.Duration) {
    	r := rand.New(rand.NewSource(time.Now().UnixNano()))
    
    	time.Sleep(time.Duration(r.Float64() * float64(time.Second)))
    
    	// Pre-emptively connect the disks if possible.
    	s.connectDisks(false)
    
    	monitor := time.NewTimer(monitorInterval)
    	defer monitor.Stop()
    
    	for {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 27 10:41:37 UTC 2024
    - 37K bytes
    - Viewed (0)
  9. misc/go_android_exec/main.go

    	// it to be ready. adb wait-for-device is not enough, we have to
    	// wait for sys.boot_completed.
    	if err := adb("wait-for-device", "exec-out", "while [[ -z $(getprop sys.boot_completed) ]]; do sleep 1; done;"); err != nil {
    		return 0, err
    	}
    
    	// Done once per make.bash.
    	if err := adbCopyGoroot(); err != nil {
    		return 0, err
    	}
    
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Mon Aug 21 17:46:57 UTC 2023
    - 15.3K bytes
    - Viewed (0)
  10. helm-releases/minio-3.5.0.tgz

    in the event of a failed command. {{- if .Values.configPathmc }} 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. ACCESS=$(cat /config/rootUser) ; SECRET=$(cat /config/rootPassword) ; set +e ;...
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Feb 02 00:16:41 UTC 2022
    - 15.2K bytes
    - Viewed (0)
Back to top