Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 10 of 419 for Spread (0.04 seconds)

  1. docs/distributed/README.md

    - **Each object is written to a single EC set, and therefore is spread over no more than 16 drives.**
    - **All the nodes running distributed MinIO setup are recommended to be homogeneous, i.e. same operating system, same number of drives and same network interconnects.**
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Tue Aug 12 18:20:36 GMT 2025
    - 8.9K bytes
    - Click Count (0)
  2. 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)
  3. 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)
  4. android/guava-tests/benchmark/com/google/common/util/concurrent/AbstractFutureFootprintBenchmark.java

      @Footprint(exclude = {Runnable.class, Executor.class, Thread.class, Exception.class})
      public Object measureSize() {
        for (Thread thread : blockedThreads) {
          thread.interrupt();
        }
        blockedThreads.clear();
        Facade<Object> f = impl.newFacade();
        for (int i = 0; i < numThreads; i++) {
          Thread thread =
              new Thread() {
                @Override
                public void run() {
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Tue May 13 18:46:00 GMT 2025
    - 3K bytes
    - Click Count (0)
  5. 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)
  6. 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)
  7. src/test/java/jcifs/tests/persistent/HandleInfoTest.java

                    null);
    
            assertFalse(durableInfo.isExpired());
    
            // Wait for expiration
            try {
                Thread.sleep(150);
            } catch (InterruptedException e) {
                Thread.currentThread().interrupt();
            }
    
            assertTrue(durableInfo.isExpired());
    
            // Test persistent handle (never expires)
    Created: Sat Dec 20 13:44:44 GMT 2025
    - Last Modified: Thu Aug 21 04:51:33 GMT 2025
    - 4.6K bytes
    - Click Count (0)
  8. 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)
  9. src/main/java/jcifs/smb1/smb1/TestLocking.java

                } else {
                    t.url = args[ai];
                }
            }
    
            final Thread[] threads = new Thread[t.numThreads];
            int ti;
    
            for (ti = 0; ti < t.numThreads; ti++) {
                threads[ti] = new Thread(t);
                logger.info(threads[ti].getName());
                threads[ti].start();
            }
    
    Created: Sat Dec 20 13:44:44 GMT 2025
    - Last Modified: Sat Aug 30 05:58:03 GMT 2025
    - 4.2K bytes
    - Click Count (0)
  10. 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)
Back to Top