Search Options

Results per page
Sort
Preferred Languages
Advance

Results 61 - 70 of 1,338 for reads (0.07 sec)

  1. src/bufio/bufio_test.go

    	buf := make([]byte, 1)
    	if _, err := b.Read(nil); err != nil {
    		t.Fatalf("1st nil Read = %v; want nil", err)
    	}
    	if _, err := b.Read(buf); err != errFake {
    		t.Fatalf("1st Read = %v; want errFake", err)
    	}
    	if _, err := b.Read(nil); err != nil {
    		t.Fatalf("2nd nil Read = %v; want nil", err)
    	}
    	if _, err := b.Read(buf); err != nil {
    		t.Fatalf("3rd Read with buffer = %v; want nil", err)
    	}
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Fri Nov 01 21:52:12 UTC 2024
    - 51.6K bytes
    - Viewed (0)
  2. doc/go_mem.html

        or a <i>synchronizing operation</i> such as an atomic data access,
    	a mutex operation, or a channel operation,</li>
    	<li>its location in the program,</li>
    	<li>the memory location or variable being accessed, and</li>
    	<li>the values read or written by the operation.</li>
    </ul>
    <p>
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Mon Mar 04 15:54:42 UTC 2024
    - 26.6K bytes
    - Viewed (0)
  3. guava/src/com/google/common/io/Files.java

       */
      public static byte[] toByteArray(File file) throws IOException {
        return asByteSource(file).read();
      }
    
      /**
       * Reads all characters from a file into a {@link String}, using the given character set.
       *
       * @param file the file to read from
       * @param charset the charset used to decode the input stream; see {@link StandardCharsets} for
       *     helpful predefined constants
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Mon Jul 22 19:03:12 UTC 2024
    - 33.1K bytes
    - Viewed (0)
  4. 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 Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Jul 17 15:43:14 UTC 2022
    - 5.8K bytes
    - Viewed (0)
  5. 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}.
     *
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Aug 02 10:02:49 UTC 2024
    - 6.1K bytes
    - Viewed (0)
  6. okhttp/src/main/kotlin/okhttp3/internal/http/HttpHeaders.kt

      var peek: String? = null
    
      while (true) {
        // Read a scheme name for this challenge if we don't have one already.
        if (peek == null) {
          skipCommasAndWhitespace()
          peek = readToken()
          if (peek == null) return
        }
    
        val schemeName = peek
    
        // Read a token68, a sequence of parameters, or nothing.
        val commaPrefixed = skipCommasAndWhitespace()
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 7.2K bytes
    - Viewed (0)
  7. cmd/untar.go

    	prefixAll  string
    }
    
    // disconnectReader will ensure that no reads can take place on
    // the upstream reader after close has been called.
    type disconnectReader struct {
    	r  io.Reader
    	mu sync.Mutex
    }
    
    func (d *disconnectReader) Read(p []byte) (n int, err error) {
    	d.mu.Lock()
    	defer d.mu.Unlock()
    	if d.r != nil {
    		return d.r.Read(p)
    	}
    	return 0, errors.New("reader closed")
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Sep 22 00:33:43 UTC 2024
    - 6K bytes
    - Viewed (2)
  8. 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 Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed May 15 00:11:04 UTC 2024
    - 2.9K bytes
    - Viewed (0)
  9. 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.
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Sep 06 17:04:31 UTC 2023
    - 6.1K bytes
    - Viewed (0)
  10. 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.
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Sep 06 17:04:31 UTC 2023
    - 6.1K bytes
    - Viewed (0)
Back to top