- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 433 for readArg (0.13 sec)
-
src/compress/bzip2/bit_reader.go
"io" ) // bitReader wraps an io.Reader and provides the ability to read values, // bit-by-bit, from it. Its Read* methods don't return the usual error // because the error handling was verbose. Instead, any error is kept and can // be checked afterwards. type bitReader struct { r io.ByteReader n uint64 bits uint err error } // newBitReader returns a new bitReader reading from r. If r is not
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Oct 13 23:20:03 UTC 2023 - 2K bytes - Viewed (0) -
src/io/ioutil/ioutil.go
// sorted by filename. If an error occurs reading the directory, // ReadDir returns no directory entries along with the error. // // Deprecated: As of Go 1.16, [os.ReadDir] is a more efficient and correct choice: // it returns a list of [fs.DirEntry] instead of [fs.FileInfo], // and it returns partial results in the case of an error // midway through reading a directory. //
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 01:00:11 UTC 2024 - 3.2K bytes - Viewed (0) -
src/runtime/rwmutex_test.go
func HammerRWMutex(gomaxprocs, numReaders, num_iterations int) { GOMAXPROCS(gomaxprocs) // Number of active readers + 10000 * number of active writers. var activity int32 var rwm RWMutex rwm.Init() cdone := make(chan bool) go writer(&rwm, num_iterations, &activity, cdone) var i int for i = 0; i < numReaders/2; i++ { go reader(&rwm, num_iterations, &activity, cdone) } go writer(&rwm, num_iterations, &activity, cdone)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Dec 15 22:00:45 UTC 2023 - 4.2K bytes - Viewed (0) -
src/cmd/vendor/golang.org/x/sync/semaphore/semaphore.go
// Consider a semaphore used as a read-write lock, with N tokens, N // readers, and one writer. Each reader can Acquire(1) to obtain a read // lock. The writer can Acquire(N) to obtain a write lock, excluding all // of the readers. If we allow the readers to jump ahead in the queue, // the writer will starve — there is always one token available for every // reader. break } s.cur += w.n s.waiters.Remove(next)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 03 02:38:00 UTC 2024 - 4.3K bytes - Viewed (0) -
src/cmd/vendor/golang.org/x/text/unicode/norm/readwriter.go
r.lastBoundary = lastBoundary(&r.rb.f, r.outbuf) if r.lastBoundary == -1 { r.lastBoundary = 0 } } } } // Reader returns a new reader that implements Read // by reading data from r and returning f(data). func (f Form) Reader(r io.Reader) io.Reader { const chunk = 4000 buf := make([]byte, chunk) rr := &normReader{rb: reorderBuffer{}, r: r, inbuf: buf} rr.rb.init(f, buf) return rr
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Jan 24 13:01:26 UTC 2024 - 2.9K bytes - Viewed (0) -
src/net/http/internal/chunked_test.go
} } func TestChunkEndReadError(t *testing.T) { readErr := fmt.Errorf("chunk end read error") r := NewChunkedReader(io.MultiReader(strings.NewReader("4\r\nabcd"), iotest.ErrReader(readErr))) if _, err := io.ReadAll(r); err != readErr { t.Errorf("expected %v, got %v", readErr, err) } } func TestChunkReaderTooMuchOverhead(t *testing.T) {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Jan 04 20:45:19 UTC 2024 - 8K bytes - Viewed (0) -
src/internal/trace/batch.go
gen, err := binary.ReadUvarint(r) if err != nil { return batch{}, gen, fmt.Errorf("error reading batch gen: %w", err) } m, err := binary.ReadUvarint(r) if err != nil { return batch{}, gen, fmt.Errorf("error reading batch M ID: %w", err) } ts, err := binary.ReadUvarint(r) if err != nil { return batch{}, gen, fmt.Errorf("error reading batch timestamp: %w", err) } // Read in the size of the batch to follow.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 17 18:48:18 UTC 2024 - 2.9K bytes - Viewed (0) -
platforms/software/resources/src/main/java/org/gradle/internal/resource/TextResource.java
*/ boolean getHasEmptyContent() throws ResourceException; /** * Returns an *unbuffered* reader over the content of this resource. * * <p>Note that this method, or reading from the provided reader, may be expensive when {@link #isContentCached()} returns false, depending on the implementation. *
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Oct 12 19:38:08 UTC 2023 - 4.5K bytes - Viewed (0) -
platforms/native/platform-native/src/main/java/org/gradle/nativeplatform/toolchain/internal/swift/metadata/SwiftcMetadataProvider.java
} @Override protected SwiftcMetadata parseCompilerOutput(String stdout, String stderr, File swiftc, List<File> path) { BufferedReader reader = new BufferedReader(new StringReader(stdout)); try { String line; while ((line = reader.readLine()) != null) { if (line.contains("Swift version")) { String[] tokens = line.split(" ");
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Nov 16 20:20:03 UTC 2023 - 3.5K bytes - Viewed (0) -
platforms/core-execution/build-cache-spi/src/main/java/org/gradle/caching/BuildCacheEntryReader.java
* * @param input input stream that contains the build cache entry * @throws IOException when an I/O error occurs when reading the cache entry from the given input stream */ void readFrom(InputStream input) throws IOException;
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon Feb 05 16:09:36 UTC 2024 - 1.2K bytes - Viewed (0)