Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 61 - 70 of 383 for Sleeps (0.04 seconds)

The search processing time has exceeded the limit. The displayed results may be partial.

  1. okhttp/src/jvmTest/kotlin/okhttp3/internal/http/CancelTest.kt

          it is ResponseFailed
    
      private fun sleep(delayMillis: Int) {
        try {
          Thread.sleep(delayMillis.toLong())
        } catch (e: InterruptedException) {
          Thread.currentThread().interrupt()
        }
      }
    
      private fun cancelLater(
        call: Call,
        delayMillis: Int,
      ): CountDownLatch {
        val latch = CountDownLatch(1)
        Thread {
          sleep(delayMillis)
          if (cancelMode == CANCEL) {
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Tue Nov 04 19:13:52 GMT 2025
    - 9.4K bytes
    - Click Count (0)
  2. docs/distributed/decom.sh

    	count=$((count + 1))
    	if [ ${count} -eq 120 ]; then
    		./mc cat /tmp/expanded_*.log
    	fi
    	sleep 1
    done
    
    kill $pid_1
    kill $pid_2
    
    sleep 5
    
    (minio server --address ":9001" http://localhost:9001/tmp/xl/{11...30}/disk{0...3} 2>&1 >/tmp/removed.log) &
    pid=$!
    
    sleep 5
    export MC_HOST_myminio="http://minioadmin:minioadmin@localhost:9001/"
    
    ./mc ready myminio
    
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Mon May 27 19:17:46 GMT 2024
    - 6.4K bytes
    - Click Count (0)
  3. scripts/playwright/header_param_models/image01.py

    )
    try:
        for _ in range(3):
            try:
                response = httpx.get("http://localhost:8000/docs")
            except httpx.ConnectError:
                time.sleep(1)
                break
        with sync_playwright() as playwright:
            run(playwright)
    finally:
    Created: Sun Apr 05 07:19:11 GMT 2026
    - Last Modified: Tue Sep 17 18:54:10 GMT 2024
    - 1.1K bytes
    - Click Count (0)
  4. scripts/playwright/request_form_models/image01.py

    )
    try:
        for _ in range(3):
            try:
                response = httpx.get("http://localhost:8000/docs")
            except httpx.ConnectError:
                time.sleep(1)
                break
        with sync_playwright() as playwright:
            run(playwright)
    finally:
    Created: Sun Apr 05 07:19:11 GMT 2026
    - Last Modified: Fri Sep 13 09:14:46 GMT 2024
    - 1.1K bytes
    - Click Count (0)
  5. 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 {
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 16 22:45:21 GMT 2026
    - 22.8K bytes
    - Click Count (0)
  6. 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 {
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 16 22:45:21 GMT 2026
    - 22.8K bytes
    - Click Count (0)
  7. buildscripts/heal-inconsistent-versions.sh

    		# remove mc source.
    		purge "${MC_BUILD_DIR}"
    	fi
    
    	"${MINIO[@]}" --address ":$start_port" "${WORK_DIR}/disk{1...4}" >"${WORK_DIR}/server1.log" 2>&1 &
    	pid=$!
    	disown $pid
    	sleep 5
    
    	if ! ps -p ${pid} 1>&2 >/dev/null; then
    		echo "server1 log:"
    		cat "${WORK_DIR}/server1.log"
    		echo "FAILED"
    		purge "$WORK_DIR"
    		exit 1
    	fi
    
    	"${PWD}/mc" mb --with-versioning minio/bucket
    
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri May 26 05:07:25 GMT 2023
    - 1.9K bytes
    - Click Count (0)
  8. android/guava/src/com/google/common/util/concurrent/Uninterruptibles.java

            Thread.currentThread().interrupt();
          }
        }
      }
    
      // TODO(user): Support Sleeper somehow (wrapper or interface method)?
      /**
       * Invokes {@code unit.}{@link TimeUnit#sleep(long) sleep(sleepFor)} uninterruptibly.
       *
       * @since 33.4.0 (but since 28.0 in the JRE flavor)
       */
      @J2ktIncompatible
      @GwtIncompatible // concurrency
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Thu Jan 29 23:24:32 GMT 2026
    - 22.5K bytes
    - Click Count (0)
  9. compat/maven-compat/src/main/java/org/apache/maven/artifact/repository/metadata/DefaultRepositoryMetadataManager.java

                            if (file.exists()) {
                                if (!file.delete()) {
                                    // sleep for 10ms just in case this is windows holding a file lock
                                    try {
                                        Thread.sleep(10);
                                    } catch (InterruptedException ie) {
                                        // ignore
                                    }
    Created: Sun Apr 05 03:35:12 GMT 2026
    - Last Modified: Fri Jun 06 14:28:57 GMT 2025
    - 18.9K bytes
    - Click Count (0)
  10. .github/workflows/run-mint.sh

    ## change working directory
    cd .github/workflows/mint
    
    ## always pull latest
    docker pull docker.io/minio/mint:edge
    
    docker-compose -f minio-${MODE}.yaml up -d
    sleep 1m
    
    docker system prune -f || true
    docker volume prune -f || true
    docker volume rm $(docker volume ls -q -f dangling=true) || true
    
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Mon Jan 20 14:49:07 GMT 2025
    - 1.9K bytes
    - Click Count (0)
Back to Top