- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 1,165 for readFn (0.3 sec)
-
cmd/metacache-stream_test.go
} want = want[:0] entries, err = r.readN(0, false, true, false, "") if err != nil { t.Fatal(err, entries.len()) } if entries.len() != len(want) { t.Fatal("unexpected length:", entries.len(), "want:", len(want)) } // Reload. r = loadMetacacheSample(t) defer r.Close() entries, err = r.readN(0, false, true, false, "") if err != nil { t.Fatal(err, entries.len()) }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Sep 19 18:05:16 UTC 2022 - 15K bytes - Viewed (0) -
cmd/metacache-stream.go
}} // metacacheReader allows reading a cache stream. type metacacheReader struct { mr *msgp.Reader current metaCacheEntry err error // stateful error closer func() creator func() error } // newMetacacheReader creates a new cache reader. // Nothing will be read from the stream yet. func newMetacacheReader(r io.Reader) *metacacheReader { dec := s2DecPool.Get().(*s2.Reader)
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu Apr 04 12:04:40 UTC 2024 - 19.5K bytes - Viewed (0) -
tensorflow/c/experimental/filesystem/plugins/gcs/gcs_filesystem.cc
return; } TF_RandomAccessFile reader; NewRandomAccessFile(filesystem, path, &reader, status); if (TF_GetCode(status) != TF_OK) return; char* buffer = static_cast<char*>(plugin_memory_allocate(metadata->size())); int64_t read = tf_random_access_file::Read(&reader, 0, metadata->size(), buffer, status); tf_random_access_file::Cleanup(&reader); if (TF_GetCode(status) != TF_OK) return;
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Wed Aug 23 06:55:53 UTC 2023 - 46.9K bytes - Viewed (0) -
cmd/metacache-set.go
} } o.debugln("forwarded to ", o.Prefix, "marker:", o.Marker, "sep:", o.Separator) // Filter if !o.Recursive { entries.o = make(metaCacheEntries, 0, o.Limit) pastPrefix := false err := r.readFn(func(entry metaCacheEntry) bool { if o.Prefix != "" && !strings.HasPrefix(entry.name, o.Prefix) { // We are past the prefix, don't continue. pastPrefix = true return false }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri Jun 07 22:18:44 UTC 2024 - 30.4K bytes - Viewed (0) -
src/net/http/h2_bundle.go
p.readFn() // e.g. copy trailers p.readFn = nil // not sticky like p.err } p.b = nil return 0, p.err } p.c.Wait() } } var ( http2errClosedPipeWrite = errors.New("write on closed buffer") http2errUninitializedPipeWrite = errors.New("write on uninitialized buffer") ) // Write copies bytes from p into the buffer and wakes a reader.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Jun 04 16:19:04 UTC 2024 - 364.1K bytes - Viewed (0) -
internal/etag/reader.go
src: r, md5: NewUUIDHash(forceMD5), checksum: etag, } } return &Reader{ src: r, md5: md5.New(), checksum: etag, } } // Read reads up to len(p) bytes from the underlying // io.Reader as specified by the io.Reader interface. func (r *Reader) Read(p []byte) (int, error) { n, err := r.src.Read(p) r.readN += int64(n) r.md5.Write(p[:n])
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu Jan 18 07:03:17 UTC 2024 - 4.8K bytes - Viewed (0) -
src/internal/trace/raw/reader.go
"fmt" "io" "internal/trace/event" "internal/trace/version" ) // Reader parses trace bytes with only very basic validation // into an event stream. type Reader struct { r *bufio.Reader v version.Version specs []event.Spec } // NewReader creates a new reader for the trace wire format. func NewReader(r io.Reader) (*Reader, error) { br := bufio.NewReader(r) v, err := version.ReadHeader(br)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 17 18:48:18 UTC 2024 - 2.2K bytes - Viewed (0) -
src/compress/lzw/reader.go
} var errClosed = errors.New("lzw: reader/writer is closed") // Close closes the [Reader] and returns an error for any future read operation. // It does not close the underlying [io.Reader]. func (r *Reader) Close() error { r.err = errClosed // in case any Reads come along return nil } // Reset clears the [Reader]'s state and allows it to be reused again // as a new [Reader].
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Oct 12 14:39:39 UTC 2023 - 8K bytes - Viewed (0) -
src/debug/elf/reader.go
return r.error } // readSeekerFromReader converts an io.Reader into an io.ReadSeeker. // In general Seek may not be efficient, but it is optimized for // common cases such as seeking to the end to find the length of the // data. type readSeekerFromReader struct { reset func() (io.Reader, error) r io.Reader size int64 offset int64 } func (r *readSeekerFromReader) start() { x, err := r.reset()
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Sep 07 19:06:17 UTC 2023 - 2.1K bytes - Viewed (0) -
src/io/io.go
// ReadAt blocks until either all the data is available or an error occurs. // In this respect ReadAt is different from Read. // // If the n = len(p) bytes returned by ReadAt are at the end of the // input source, ReadAt may return either err == EOF or err == nil. // // If ReadAt is reading from an input source with a seek offset, // ReadAt should not affect nor be affected by the underlying
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Apr 15 17:34:10 UTC 2024 - 21.6K bytes - Viewed (0)