Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 161 - 170 of 207 for downTo (0.03 seconds)

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

  1. android/guava/src/com/google/common/util/concurrent/AbstractFutureState.java

                  if (remainingNanos < SPIN_THRESHOLD_NANOS) {
                    // Remove the waiter, one way or another we are done parking this thread.
                    removeWaiter(node);
                    break long_wait_loop; // jump down to the busy wait loop
                  }
                }
              }
              oldHead = waitersField; // re-read and loop.
            } while (oldHead != Waiter.TOMBSTONE);
          }
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Thu Aug 07 16:05:33 GMT 2025
    - 33.2K bytes
    - Click Count (0)
  2. src/main/java/org/codelibs/fess/ds/callback/FileListIndexUpdateCallbackImpl.java

                }
            }
            return true;
        }
    
        @Override
        public void commit() {
            try {
                if (logger.isDebugEnabled()) {
                    logger.debug("Shutting down thread executor.");
                }
                executor.shutdown();
                executor.awaitTermination(executorTerminationTimeout, TimeUnit.SECONDS);
            } catch (final InterruptedException e) {
    Created: Sat Dec 20 09:19:18 GMT 2025
    - Last Modified: Fri Nov 28 16:29:12 GMT 2025
    - 29.7K bytes
    - Click Count (3)
  3. android/guava-testlib/src/com/google/common/testing/NullPointerTester.java

        }
    
        /*
         * These methods "should" call checkNotNull. However, I'm wary of accidentally introducing
         * anything that might slow down execution on such a hot path. Given that the methods are only
         * package-private, I feel OK with just not testing them for NPE.
         *
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Mon Jul 14 14:44:08 GMT 2025
    - 24.9K bytes
    - Click Count (0)
  4. docs/resiliency/resiliency-tests.sh

    #!/usr/bin/env bash
    
    TESTS_RUN_STATUS=1
    
    function cleanup() {
    	echo "Cleaning up MinIO deployment"
    	docker compose -f "${DOCKER_COMPOSE_FILE}" down --volumes
    	for container in $(docker ps -q); do
    		echo Removing docker $container
    		docker rm -f $container >/dev/null 2>&1
    		docker wait $container
    	done
    }
    
    function cleanup_and_prune() {
    	cleanup
    	docker system prune --volumes --force
    	docker image prune --all --force
    }
    
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sat Dec 21 04:24:45 GMT 2024
    - 20.5K bytes
    - Click Count (0)
  5. android/guava/src/com/google/common/util/concurrent/ServiceManager.java

     *   }
     * }
     * }
     *
     * <p>This class uses the ServiceManager's methods to start all of its services, to respond to
     * service failure and to ensure that when the JVM is shutting down all the services are stopped.
     *
     * @author Luke Sandberg
     * @since 14.0
     */
    @J2ktIncompatible
    @GwtIncompatible
    public final class ServiceManager implements ServiceManagerBridge {
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Mon Sep 22 17:49:12 GMT 2025
    - 33.2K bytes
    - Click Count (1)
  6. guava/src/com/google/common/util/concurrent/ServiceManager.java

     *   }
     * }
     * }
     *
     * <p>This class uses the ServiceManager's methods to start all of its services, to respond to
     * service failure and to ensure that when the JVM is shutting down all the services are stopped.
     *
     * @author Luke Sandberg
     * @since 14.0
     */
    @J2ktIncompatible
    @GwtIncompatible
    public final class ServiceManager implements ServiceManagerBridge {
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Mon Sep 22 17:49:12 GMT 2025
    - 32.9K bytes
    - Click Count (0)
  7. guava/src/com/google/common/util/concurrent/AbstractFutureState.java

                  if (remainingNanos < SPIN_THRESHOLD_NANOS) {
                    // Remove the waiter, one way or another we are done parking this thread.
                    removeWaiter(node);
                    break long_wait_loop; // jump down to the busy wait loop
                  }
                }
              }
              oldHead = waitersField; // re-read and loop.
            } while (oldHead != Waiter.TOMBSTONE);
          }
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Thu Aug 07 16:05:33 GMT 2025
    - 34.8K bytes
    - Click Count (0)
  8. docs/en/docs/deployment/concepts.md

    If you have an API that does a comparable amount of computations every time and you have a lot of clients, then the **CPU utilization** will probably *also be stable* (instead of constantly going up and down quickly).
    
    ### Examples of Replication Tools and Strategies { #examples-of-replication-tools-and-strategies }
    
    Created: Sun Dec 28 07:19:09 GMT 2025
    - Last Modified: Sun Aug 31 09:15:41 GMT 2025
    - 18.6K bytes
    - Click Count (1)
  9. cmd/object-api-putobject_test.go

    	err = obj.MakeBucket(context.Background(), "unused-bucket", MakeBucketOptions{})
    	if err != nil {
    		// Failed to create newbucket, abort.
    		t.Fatalf("%s : %s", instanceType, err.Error())
    	}
    
    	// Take 4 disks down, one more we loose quorum on 16 disk node.
    	for _, disk := range disks[:4] {
    		os.RemoveAll(disk)
    	}
    
    	testCases := []struct {
    		bucketName    string
    		objName       string
    		inputData     []byte
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Thu Feb 22 06:26:06 GMT 2024
    - 25.8K bytes
    - Click Count (0)
  10. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/http2/Http2Connection.kt

        }
      }
    
      /**
       * Closes this connection. This cancels all open streams and unanswered pings. It closes the
       * underlying input and output streams and shuts down internal task queues.
       */
      override fun close() {
        close(ErrorCode.NO_ERROR, ErrorCode.CANCEL, null)
      }
    
      internal fun close(
        connectionCode: ErrorCode,
        streamCode: ErrorCode,
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Thu Jul 31 04:18:40 GMT 2025
    - 31.8K bytes
    - Click Count (0)
Back to Top