- Sort Score
- Num 10 results
- Language All
Results 91 - 100 of 304 for Reads (0.02 seconds)
-
cmd/erasure-metadata-utils.go
start := int(keyCrc % uint32(cardinality)) for i := 1; i <= cardinality; i++ { nums[i-1] = 1 + ((start + i) % cardinality) } return nums } // Reads all `xl.meta` metadata as a FileInfo slice. // Returns error slice indicating the failed metadata reads. func readAllFileInfo(ctx context.Context, disks []StorageAPI, origbucket string, bucket, object, versionID string, readData, healing bool) ([]FileInfo, []error) {
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 11.7K bytes - Click Count (0) -
android/guava-tests/test/com/google/common/collect/AbstractTableTest.java
import java.util.Map; import org.jspecify.annotations.NonNull; import org.jspecify.annotations.NullMarked; import org.jspecify.annotations.Nullable; /** * Test cases for a {@link Table} implementation supporting reads and writes. * * @author Jared Levy * @author Louis Wasserman */ @GwtCompatible @NullMarked public abstract class AbstractTableTest<C extends @Nullable Character> extends AbstractTableReadTest<C> {Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Tue Oct 28 16:03:47 GMT 2025 - 6K bytes - Click Count (0) -
guava/src/com/google/common/collect/HashMultimap.java
* views are modifiable. * * <p>This class is not threadsafe when any concurrent operations update the multimap. Concurrent * read operations will work correctly if the last write <i>happens-before</i> any reads. To allow * concurrent update operations, wrap your multimap with a call to {@link * Multimaps#synchronizedSetMultimap}. * * <p><b>Warning:</b> Do not modify either a key <i>or a value</i> of a {@code HashMultimap} in a
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Fri Dec 05 23:15:58 GMT 2025 - 5.8K bytes - Click Count (0) -
cmd/perf-tests.go
r.Close() if err == nil { response := time.Since(t) ttfb := time.Since(*fbr.t) // Only capture success criteria - do not // have to capture failed reads, truncated // reads etc. atomic.AddUint64(&totalBytesRead, uint64(n)) mu.Lock() downloadTimes = append(downloadTimes, response) downloadTTFB = append(downloadTTFB, ttfb) mu.Unlock() }
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 11.8K bytes - Click Count (0) -
android/guava-tests/test/com/google/common/util/concurrent/AbstractFutureCancellationCauseTest.java
// Load the "normal" copy of SettableFuture and related classes. SettableFuture<?> unused = SettableFuture.create(); // Hack to load AbstractFuture et. al. in a new classloader so that it re-reads the cancellation // cause system property. This allows us to run with both settings of the property in one jvm // without resorting to even crazier hacks to reset static final boolean fields.
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Mar 16 22:45:21 GMT 2026 - 6.3K bytes - Click Count (0) -
guava-tests/test/com/google/common/util/concurrent/AbstractFutureCancellationCauseTest.java
// Load the "normal" copy of SettableFuture and related classes. SettableFuture<?> unused = SettableFuture.create(); // Hack to load AbstractFuture et. al. in a new classloader so that it re-reads the cancellation // cause system property. This allows us to run with both settings of the property in one jvm // without resorting to even crazier hacks to reset static final boolean fields.
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Mar 16 22:45:21 GMT 2026 - 6.3K bytes - Click Count (0) -
doc/go_mem.html
"Path": "/ref/mem" }--> <style> p.rule { font-style: italic; } </style> <h2 id="introduction">Introduction</h2> <p> The Go memory model specifies the conditions under which reads of a variable in one goroutine can be guaranteed to observe values produced by writes to the same variable in a different goroutine. </p> <h3 id="advice">Advice</h3> <p>
Created: Tue Apr 07 11:13:11 GMT 2026 - Last Modified: Tue Aug 05 15:41:37 GMT 2025 - 26.6K bytes - Click Count (0) -
android/guava/src/com/google/common/collect/HashMultimap.java
* views are modifiable. * * <p>This class is not threadsafe when any concurrent operations update the multimap. Concurrent * read operations will work correctly if the last write <i>happens-before</i> any reads. To allow * concurrent update operations, wrap your multimap with a call to {@link * Multimaps#synchronizedSetMultimap}. * * <p><b>Warning:</b> Do not modify either a key <i>or a value</i> of a {@code HashMultimap} in a
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Fri Dec 05 23:15:58 GMT 2025 - 5.8K bytes - Click Count (0) -
src/test/java/jcifs/smb1/dcerpc/DcerpcMessageTest.java
* encode/decode operation. */ public class DcerpcMessageTest { /** * A trivial concrete subclass used for testing. It simply writes a * single small value in {@code encode_in} and reads it in * {@code decode_out}. */ private static class TestMessage extends DcerpcMessage { int decodedValue = 0; TestMessage() { /* nothing */ }Created: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Thu Aug 14 07:14:38 GMT 2025 - 7K bytes - Click Count (0) -
okhttp-tls/src/main/kotlin/okhttp3/tls/internal/der/BasicDerAdapter.kt
result = 31 * result + defaultValue.hashCode() result = 31 * result + (if (typeHint) 1 else 0) return result } override fun toString(): String = "$name [$tagClass/$tag]" /** Reads and writes values without knowledge of the enclosing tag, length, or defaults. */ interface Codec<T> { fun decode(reader: DerReader): T fun encode( writer: DerWriter, value: T, )
Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 4.4K bytes - Click Count (0)