- Sort Score
- Num 10 results
- Language All
Results 1 - 10 of 419 for Spread (0.04 seconds)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
src/main/java/jcifs/smb1/smb1/TestLocking.java
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) -
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)