- Sort Score
- Result 10 results
- Languages All
Results 61 - 70 of 233 for Reads (0.04 sec)
-
cmd/metrics-v3-system-network.go
"Total number of bytes sent to other peer nodes") internodeRecvBytesTotalMD = NewCounterMD(internodeRecvBytesTotal, "Total number of bytes received from other peer nodes") ) // loadNetworkInternodeMetrics - reads internode network metrics. // // This is a `MetricsLoaderFn`. func loadNetworkInternodeMetrics(ctx context.Context, m MetricValues, _ *metricsCache) error { connStats := globalConnStats.toServerConnStats()
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Sun Mar 10 09:15:15 UTC 2024 - 2.4K bytes - Viewed (0) -
guava/src/com/google/common/io/Files.java
* * @author Chris Nokleberg * @author Colin Decker * @since 1.0 */ @J2ktIncompatible @GwtIncompatible public final class Files { private Files() {} /** * Returns a buffered reader that reads from a file using the given character set. * * <p><b>{@link java.nio.file.Path} equivalent:</b> {@link * java.nio.file.Files#newBufferedReader(java.nio.file.Path, Charset)}. * * @param file the file to read from
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Tue May 13 17:27:14 UTC 2025 - 32.9K bytes - Viewed (0) -
cmd/erasure-encode.go
} writeErr := reduceWriteQuorumErrs(ctx, p.errs, objectOpIgnoredErrs, p.writeQuorum) return fmt.Errorf("%w (offline-disks=%d/%d)", writeErr, countErrs(p.errs, errDiskNotFound), len(p.writers)) } // Encode reads from the reader, erasure-encodes the data and writes to the writers. func (e *Erasure) Encode(ctx context.Context, src io.Reader, writers []io.Writer, buf []byte, quorum int) (total int64, err error) { writer := &multiWriter{
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Wed May 15 00:11:04 UTC 2024 - 2.9K bytes - Viewed (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 */ }
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Thu Aug 14 07:14:38 UTC 2025 - 7K bytes - Viewed (0) -
src/test/java/jcifs/internal/smb2/session/Smb2LogoffResponseTest.java
} } @Nested @DisplayName("readBytesWireFormat") class ReadBytesWireFormat { @ParameterizedTest @ValueSource(ints = { 0, 1, 5, 10 }) @DisplayName("Reads structure size 4 and returns 4 for various start indexes") void returnsFour_whenStructureSizeIsFour(int start) throws Exception { // Arrange: build a buffer that has the little-endian value 4 at 'start'
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Thu Aug 14 05:31:44 UTC 2025 - 4.7K bytes - Viewed (0) -
docs/bucket/versioning/DESIGN.md
} } } ] } ``` ### v1.3+ versions Version 1.3 introduces changes to help with [faster metadata reads and updates](https://blog.min.io/minio-versioning-metadata-deep-dive/) | Entry | Encoding | Content | ----------------|-----------------------------|----------------------------------------
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Sun Jul 17 15:43:14 UTC 2022 - 5.8K bytes - Viewed (0) -
src/bufio/bufio_test.go
} var bufreaders = []bufReader{ {"1", func(b *Reader) string { return reads(b, 1) }}, {"2", func(b *Reader) string { return reads(b, 2) }}, {"3", func(b *Reader) string { return reads(b, 3) }}, {"4", func(b *Reader) string { return reads(b, 4) }}, {"5", func(b *Reader) string { return reads(b, 5) }}, {"7", func(b *Reader) string { return reads(b, 7) }}, {"bytes", readBytes}, {"lines", readLines}, }
Registered: Tue Sep 09 11:13:09 UTC 2025 - Last Modified: Fri Feb 07 01:08:54 UTC 2025 - 51.6K bytes - Viewed (0) -
futures/failureaccess/pom.xml
<compilerArgs> <arg>-sourcepath</arg> <arg>${project.basedir}/src</arg> <arg>--add-reads=com.google.common=ALL-UNNAMED</arg> <!-- https://errorprone.info/docs/installation#maven --> <arg>-XDcompilePolicy=simple</arg> </compilerArgs>
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Wed Feb 12 18:13:11 UTC 2025 - 5.4K bytes - Viewed (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> {
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Sun Dec 22 03:38:46 UTC 2024 - 5.8K bytes - Viewed (0) -
src/test/java/jcifs/smb/SmbRandomAccessFileTest.java
assertThrows(SmbEndOfFileException.class, () -> raf.readFully(new byte[4])); } @Test @DisplayName("readFully(): reads across multiple partial reads") void readFully_readsAll() throws Exception { SmbRandomAccessFile raf = spy(newInstance("r", false, false, false)); AtomicInteger calls = new AtomicInteger(); doAnswer(inv -> {
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Thu Aug 14 05:31:44 UTC 2025 - 18.1K bytes - Viewed (0)