Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 10 of 389 for Spread (0.06 seconds)

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

  1. docs/distributed/DESIGN.md

    - In this algorithm, we also make sure that we spread the drives out evenly. MinIO server expands ellipses passed as arguments. Here is a sample expansion to demonstrate the process.
    
    ```
    minio server http://host{1...2}/export{1...8}
    ```
    
    Expected expansion
    
    ```
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Wed Feb 26 09:25:50 GMT 2025
    - 8K bytes
    - Click Count (2)
  2. api/maven-api-xml/src/main/java/org/apache/maven/api/xml/XmlService.java

        @Nonnull
        public static XmlNode read(InputStream input, @Nullable InputLocationBuilder locationBuilder)
                throws XMLStreamException {
            return getService().doRead(input, locationBuilder);
        }
    
        /**
         * Reads an XML node from a reader.
         */
        @Nonnull
        public static XmlNode read(Reader reader) throws XMLStreamException {
            return read(reader, null);
        }
    
        /**
    Created: Sun Dec 28 03:35:09 GMT 2025
    - Last Modified: Thu Apr 03 13:33:59 GMT 2025
    - 9.2K bytes
    - Click Count (0)
  3. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/publicsuffix/BasePublicSuffixList.kt

        }
      }
    
      abstract val path: Any
    
      /**
       * Reads the public suffix list treating the operation as uninterruptible. We always want to read
       * the list otherwise we'll be left in a bad state. If the thread was interrupted prior to this
       * operation, it will be re-interrupted after the list is read.
       */
      private fun readTheListUninterruptibly() {
        var interrupted = false
        try {
          while (true) {
            try {
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Mon Jul 28 07:33:49 GMT 2025
    - 3.6K bytes
    - Click Count (0)
  4. android/guava-tests/benchmark/com/google/common/io/ByteSourceAsCharSourceReadBenchmark.java

              try (InputStreamReader reader = new InputStreamReader(byteSource.openStream(), cs)) {
                int nRead = 0;
                while (remaining > 0 && (nRead = reader.read(buffer, bufIndex, remaining)) != -1) {
                  bufIndex += nRead;
                  remaining -= nRead;
                }
                if (nRead == -1) {
                  // we reached EOF
                  return new String(buffer, 0, bufIndex);
                }
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Tue May 13 18:46:00 GMT 2025
    - 5.2K bytes
    - Click Count (0)
  5. android/guava-tests/test/com/google/common/util/concurrent/ThreadFactoryBuilderTest.java

              @Override
              public Thread newThread(Runnable r) {
                Thread thread = new Thread(r);
                thread.setName(THREAD_NAME);
                thread.setPriority(THREAD_PRIORITY);
                thread.setDaemon(THREAD_DAEMON);
                thread.setUncaughtExceptionHandler(UNCAUGHT_EXCEPTION_HANDLER);
                return thread;
              }
            };
    
        Thread thread =
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Thu Dec 11 20:07:52 GMT 2025
    - 7.6K bytes
    - Click Count (0)
  6. android/guava-tests/test/com/google/common/collect/SynchronizedTableTest.java

        @Override
        public String toString() {
          assertTrue(Thread.holdsLock(mutex));
          return delegate.toString();
        }
    
        @Override
        public boolean equals(@Nullable Object o) {
          assertTrue(Thread.holdsLock(mutex));
          return delegate.equals(o);
        }
    
        @Override
        public int hashCode() {
          assertTrue(Thread.holdsLock(mutex));
          return delegate.hashCode();
        }
    
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Wed Jul 16 17:42:14 GMT 2025
    - 4.7K bytes
    - Click Count (0)
  7. guava-tests/test/com/google/common/collect/SynchronizedDequeTest.java

        @Override
        public boolean offer(E o) {
          assertTrue(Thread.holdsLock(mutex));
          return delegate.offer(o);
        }
    
        @Override
        public @Nullable E poll() {
          assertTrue(Thread.holdsLock(mutex));
          return delegate.poll();
        }
    
        @Override
        public E remove() {
          assertTrue(Thread.holdsLock(mutex));
          return delegate.remove();
        }
    
        @Override
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Wed Jul 16 17:42:14 GMT 2025
    - 7.4K bytes
    - Click Count (0)
  8. guava-tests/test/com/google/common/util/concurrent/InterruptionUtil.java

          }
        }
    
        void stopInterrupting() {
          shouldStop = true;
        }
      }
    
      /** Interrupts the current thread after sleeping for the specified delay. */
      static void requestInterruptIn(long time, TimeUnit unit) {
        checkNotNull(unit);
        Thread interruptee = Thread.currentThread();
        new Thread(
                new Runnable() {
                  @Override
                  public void run() {
                    try {
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Sun Aug 10 19:54:19 GMT 2025
    - 4.5K bytes
    - Click Count (0)
  9. android/guava-tests/test/com/google/common/collect/SynchronizedQueueTest.java

        @Override
        public boolean offer(E o) {
          assertTrue(Thread.holdsLock(mutex));
          return delegate.offer(o);
        }
    
        @Override
        public @Nullable E poll() {
          assertTrue(Thread.holdsLock(mutex));
          return delegate.poll();
        }
    
        @Override
        public E remove() {
          assertTrue(Thread.holdsLock(mutex));
          return delegate.remove();
        }
    
        @Override
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Wed Jul 16 17:42:14 GMT 2025
    - 4.8K bytes
    - Click Count (0)
  10. src/main/java/org/codelibs/core/timer/TimeoutManager.java

            return instance;
        }
    
        /**
         * Starts the process.
         */
        public synchronized void start() {
            if (thread == null) {
                thread = new Thread(this, "CoreLib-TimeoutManager");
                thread.setDaemon(true);
                thread.start();
                if (logger.isDebugEnabled()) {
                    logger.debug("TimeoutManager started.");
                }
            }
        }
    
    Created: Sat Dec 20 08:55:33 GMT 2025
    - Last Modified: Sat May 10 01:32:17 GMT 2025
    - 7.8K bytes
    - Click Count (0)
Back to Top