Search Options

Results per page
Sort
Preferred Languages
Advance

Results 51 - 60 of 343 for sleep (0.41 sec)

  1. cmd/metacache-set.go

    					o.objectPath(0), "", ReadOptions{})
    				if err != nil {
    					time.Sleep(retryDelay250)
    					retries++
    					continue
    				}
    				break
    			}
    		}
    		retryWait := func() {
    			retries++
    			if retries == 1 {
    				time.Sleep(retryDelay)
    			} else {
    				time.Sleep(retryDelay250)
    			}
    		}
    		// Load first part metadata...
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Fri Apr 26 19:52:52 GMT 2024
    - 30.4K bytes
    - Viewed (0)
  2. helm/minio/templates/_helper_create_user.txt

    # Special characters for example : ',",<,>,{,}
    MINIO_ACCESSKEY_SECRETKEY_TMP="/tmp/accessKey_and_secretKey_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: Tue Dec 12 23:43:32 GMT 2023
    - 3.2K bytes
    - Viewed (0)
  3. android/guava-tests/test/com/google/common/util/concurrent/AbstractScheduledServiceTest.java

        assertEquals(1, service.numIterations.get());
        service.stopAsync();
        service.secondBarrier.await();
        service.awaitTerminated();
        // Sleep for a while just to ensure that our task wasn't called again.
        Thread.sleep(UNIT.toMillis(3 * DELAY));
        assertEquals(1, service.numIterations.get());
      }
    
      public void testCustomScheduler_deadlock() throws InterruptedException, BrokenBarrierException {
    Java
    - Registered: Fri May 03 12:43:13 GMT 2024
    - Last Modified: Wed Sep 06 17:04:31 GMT 2023
    - 22.5K bytes
    - Viewed (0)
  4. istioctl/pkg/writer/envoy/configdump/testdata/endpoint/emptyfilter_output.yaml

          healthStatus: HEALTHY
          loadBalancingWeight: 1
          metadata:
            filterMetadata:
              envoy.transport_socket_match:
                tlsMode: istio
              istio:
                workload: sleep;default;sleep;latest;Kubernetes
        loadBalancingWeight: 1
        locality: {}
      policy:
        overprovisioningFactor: 140
    - clusterName: xds-grpc
      endpoints:
      - lbEndpoints:
        - endpoint:
            address:
    Others
    - Registered: Wed May 01 22:53:12 GMT 2024
    - Last Modified: Tue Jul 12 02:25:59 GMT 2022
    - 17.1K bytes
    - Viewed (0)
  5. docs/config/README.md

    default adapts to the system speed and pauses up to '250ms' per object when the system has `max_io` number of concurrent requests. It is possible to adjust the `max_sleep` and `max_io` values thereby increasing the healing speed. The delays between each operation of the healer can be adjusted by the `mc admin config set alias/ heal max_sleep=1s` and maximum concurrent requests allowed before we start slowing things down can be configured with `mc admin config set alias/ heal max_io=30` . By default the...
    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)
  6. docs/bucket/replication/delete-replication.sh

    export MINIO_ROOT_USER="minioadmin"
    export MINIO_ROOT_PASSWORD="minioadmin"
    
    ./minio server --address ":9001" /tmp/xl/1/{1...4}/ 2>&1 >/tmp/dc1.log &
    ./minio server --address ":9002" /tmp/xl/2/{1...4}/ 2>&1 >/tmp/dc2.log &
    
    sleep 3
    
    export MC_HOST_myminio1=http://minioadmin:minioadmin@localhost:9001
    export MC_HOST_myminio2=http://minioadmin:minioadmin@localhost:9002
    
    ./mc mb myminio1/testbucket/
    ./mc version enable myminio1/testbucket/
    Shell Script
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Mon Mar 04 18:05:56 GMT 2024
    - 2.9K bytes
    - Viewed (0)
  7. android/guava-tests/test/com/google/common/util/concurrent/InterruptionUtil.java

          this.everyMillis = everyMillis;
          this.interruptee = interruptee;
        }
    
        @Override
        public void run() {
          while (true) {
            try {
              Thread.sleep(everyMillis);
            } catch (InterruptedException e) {
              // ok. just stop sleeping.
            }
            if (shouldStop) {
              break;
            }
            interruptee.interrupt();
          }
        }
    
    Java
    - Registered: Fri May 03 12:43:13 GMT 2024
    - Last Modified: Mon Dec 04 17:37:03 GMT 2017
    - 4.4K bytes
    - Viewed (0)
  8. okhttp/src/test/java/okhttp3/WholeOperationTimeoutTest.kt

          Request.Builder()
            .url(server.url("/"))
            .build()
        val call = client.newCall(request)
        call.timeout().timeout(250, TimeUnit.MILLISECONDS)
        val response = call.execute()
        Thread.sleep(500)
        assertFailsWith<IOException> {
          response.body.source().readUtf8()
        }.also { expected ->
          assertThat(expected.message).isEqualTo("timeout")
          assertThat(call.isCanceled()).isTrue()
        }
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Mon Jan 08 01:13:22 GMT 2024
    - 10.5K bytes
    - Viewed (0)
  9. src/test/java/org/codelibs/fess/it/CrawlTestBase.java

                    return;
                }
                ThreadUtil.sleep(1000L);
            }
            fail("could not start job.");
        }
    
        protected static void waitJob(final String namePrefix) {
            Boolean isRunning = false;
            int count = 0;
    
            while (count < 300 && !isRunning) { // Wait until the crawler starts
                ThreadUtil.sleep(500);
                count++;
    Java
    - Registered: Mon Apr 29 08:04:11 GMT 2024
    - Last Modified: Thu Feb 22 01:37:57 GMT 2024
    - 9.9K bytes
    - Viewed (0)
  10. mockwebserver/src/main/kotlin/mockwebserver3/internal/duplex/MockStreamHandler.kt

          responseSent.countDown()
        }
      }
    
      fun exhaustResponse() =
        apply {
          actions += { stream -> stream.responseBody.close() }
        }
    
      fun sleep(
        duration: Long,
        unit: TimeUnit,
      ) = apply {
        actions += { Thread.sleep(unit.toMillis(duration)) }
      }
    
      override fun handle(stream: Stream) {
        val task = serviceStreamTask(stream)
        results.add(task)
        task.run()
      }
    
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Mon Jan 08 01:13:22 GMT 2024
    - 3.2K bytes
    - Viewed (0)
Back to top